Connection closed before response was received

Package

dio

Version

5.4.2+1

Operating-System

Android, iOS

Adapter

Default Dio

Output of `flutter doctor -v`

[✓] Flutter (Channel stable, 3.19.4, on macOS 14.4.1 23E224 darwin-arm64, locale en-EG)
[✓] Android toolchain - develop for Android devices (Android SDK version 34.0.0)
[✓] Xcode - develop for iOS and macOS (Xcode 15.3)
[✓] Chrome - develop for the web
[✓] Android Studio (version 2023.2)
[✓] VS Code (version 1.87.2)
[✓] Connected device (3 available)            
    ! Error: Browsing on the local area network for Me. Ensure the device is unlocked and attached with a cable or associated with the same
      local area network as this Mac.
      The device must be opted into Developer Mode to connect wirelessly. (code -27)
    ! Error: Browsing on the local area network for Mohamed’s Iphone (2). Ensure the device is unlocked and attached with a cable or
      associated with the same local area network as this Mac.
      The device must be opted into Developer Mode to connect wirelessly. (code -27)
    ! Error: Browsing on the local area network for ‏iPhone ‏Fadwa. Ensure the device is unlocked and attached with a cable or associated
      with the same local area network as this Mac.
      The device must be opted into Developer Mode to connect wirelessly. (code -27)
    ! Error: Browsing on the local area network for H. Sayed. Ensure the device is unlocked and attached with a cable or associated with the
      same local area network as this Mac.
      The device must be opted into Developer Mode to connect wirelessly. (code -27)
[✓] Network resources

• No issues found!

Dart Version

3.3.2

Steps to Reproduce

Run with any version of Dio above 5.4.0.
try to send more requests in a short period of time.

Expected Result

When using Dio version 5.4.0, the connection is not closed and the response succeeds.

Actual Result

flutter: The following exception was thrown getBOKRechargeRequestStatusProvider:
flutter: AppException.serverException(type: ServerExceptionType.unknown, message: HttpException: Connection closed before response was received, uri = https://api.bravo-sudan.com/bravo/api/v1/bok/getRechargeRequests, code: null)
flutter:
#0 DioMixin.fetch (package:dio/src/dio_mixin.dart:509:7)

#1 MainApiFacade._errorHandler (package:bravo/core/infrastructure/network/main_api/api_callers/main_api_facade.dart:66:14)

#2 TransactionRemoteDataSource.getBOKRechargeRequestStatus (package:bravo/features/transaction/infrastructure/data_sourse/transaction_remote_remote_data_source.dart:48:20)

#3 TransactionHistoryRepository.getBOKRechargeRequestStatus (package:bravo/features/transaction/infrastructure/repository/transaction_history_repository.dart:43:20)

If this is version specific, could you run git bisect to find out which commit breaks the functionality?

I have recently upgraded Dio from version 5.4.0 to 5.4.2+1. However, I believe the issue began with version 5.4.1.

Running bisect will help to determine which exact commit breaks the behavior.

I am contemplating running a bisect to pinpoint the problematic commit. However, I want to clarify that my recent commit solely consisted of upgrading the version to 5.4.2+1. Additionally, I have already tested version 5.4.1, as I suspect the issue originated there, and encountered the same problem.

I understand your statement clearly, IMO. I'm asking you to do the bisect because you have a reproducible example and can debug the issue easily. Besides, simply switching between versions might not be helpful since every version includes a bunch of commits.

I've completed running git bisect to identify the commit that introduced the issue in the Dio package. After testing multiple commits, I've found that the first bad bisect commit is "Fix streamed response cancellation and progress (#2068)".

845e06f

I've completed running git bisect to identify the commit that introduced the issue in the Dio package. After testing multiple commits, I've found that the first bad bisect commit is "Fix streamed response cancellation and progress (#2068)".

845e06f

Thanks for the bisect! Now could you split a minimal reproducible example so we can take a deeper investigation with your case?

@kuhnroyal

cc @kuhnroyal to check the implementation as the code owner

What is the recommandation to avoid this issue ?

This was changed in 5.4.1, you might be able to lock the dio version to 5.4.0.

The issue occurs when you have two requests with different CancelTokens, and when the first request is completed, the second request starts executing. At that moment, if you cancel the CancelToken of the first request somewhere in the code (for example, in Bloc dispose), then the second request gets canceled before it is received, even if it had a different cancelToken from the first request, causing the entire DIO connection to close.

For example

List<CancelToken> cancelTokens = [CancelToken(), CancelToken()]
RequestData request1 = await Repo.request1(cancelTokens.first); // done
RequestData request2 = Repo.request2(cancelTokens.last);  // no await
microtask({
    cancelTokens.first.cancel();  // parallel cancel first cancelToken
});

While request2 is still being execute, a cancelation occurs on the first CancelToken in parallel in code, which will drop request2. that cancelation should not influence second request.

Fixes I found so far:

You can use lower Dio version (I rollbacked to 5.3.3, did not checked later versions yet).
Open new Dio connection for each request.
Initialize DIO with (BaseOptions(persistenConnection: false)). I think this option is the same meaning as new dio client for new request.

@wratheus

@wratheus Can you reproduce this in a test case? Also not sure if this is the same issue.

This seems to work:

    test('cancel one request', () {
      final dio = Dio()..options.baseUrl = 'https://httpbun.com';
      final token = CancelToken();

      expectLater(
        dio.get(
          '/drip?delay=0&duration=2&numbytes=10',
          cancelToken: token,
        ),
        throwsDioException(DioExceptionType.cancel),
      );
      expectLater(
        dio.get(
          '/drip?delay=0&duration=2&numbytes=10',
          cancelToken: CancelToken(),
        ),
        completes,
      );

      Future.delayed(const Duration(seconds: 1), () {
        token.cancel('cancelled');
      });
    });

This case fails.

dio/dio_test/lib/src/test/cancellation_tests.dart

Lines 117 to 143 in 537832e

    
           test( 
        
             'not closing sockets with requests that have same hosts', 
        
             () async { 
        
               final token = CancelToken(); 
        
               final completer = Completer<Response?>(); 
        
               // Complete the first request with the cancel token. 
        
               await dio.get('/get', cancelToken: token); 
        
               // Request the second without any cancel token, but with the same host. 
        
               dio.get('/drip?duration=3').then( 
        
                 (res) { 
        
                   completer.complete(res); 
        
                   return res; 
        
                 }, 
        
                 onError: (e) { 
        
                   completer.complete(null); 
        
                   return Response(requestOptions: (e as DioException).requestOptions); 
        
                 }, 
        
               ); 
        
               // Simulate connection established. 
        
               await Future.delayed(const Duration(seconds: 1)); 
        
               token.cancel(); 
        
               final response = await completer.future; 
        
               // Response should be obtained without exceptions. 
        
               expect(response, isNotNull); 
        
             }, 
        
             testOn: '!browser', 
        
           );

There is no difference if there is cancelToken in second request or no. Same with post requests. That's the problem I was talking about. Issue does not occurs at 5.3.3 version

import 'dart:async';

import 'package:dio/dio.dart';
import 'package:flutter_test/flutter_test.dart';

  void main() {
    Dio dio = Dio();
    test(
      'not closing sockets with requests that have same hosts',
          () async {
        final token = CancelToken();
        const String baseUrl = 'https://httpbun.com';

        final completer = Completer<Response?>();
        // Complete the first request with the cancel token.
        await dio.get('$baseUrl/get', cancelToken: token);
        // Request the second without any cancel token, but with the same host.
        dio.get('$baseUrl/drip?duration=3', cancelToken: CancelToken()).then(
              (res) {
            completer.complete(res);
            return res;
          },
          onError: (e, t) {
                print(e);
                print(t);
            completer.complete(null);
            return Response(requestOptions: (e as DioException).requestOptions);
          },
        );
        // Simulate connection established.
        await Future.delayed(const Duration(seconds: 1));
        token.cancel();
        final response = await completer.future;
        // Response should be obtained without exceptions.
        expect(response, isNotNull);
      },
      testOn: '!browser',
    );
  }

🔥 Do not detaches sockets / terminates client stream (#2173)

5.4.0

Is there a big difference between 5.4.0 and 5.4.2+1? I also reproduced this problem on 5.4.2+1. If I lock 5.4.0, does my user need to make API level adjustments?

The fix is included in v5.4.3 and shall not require interface updates.

🔥 Do not detaches sockets / terminates client stream (cfug#2173)

Navigation Menu

Repository navigation

Connection closed before response was received #2170

Package

Version

Operating-System

Adapter

Output of `flutter doctor -v`

Dart Version

Steps to Reproduce

Expected Result

Actual Result

6 remaining items

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

	test(
	'not closing sockets with requests that have same hosts',
	() async {
	final token = CancelToken();
	final completer = Completer<Response?>();
	// Complete the first request with the cancel token.
	await dio.get('/get', cancelToken: token);
	// Request the second without any cancel token, but with the same host.
	dio.get('/drip?duration=3').then(
	(res) {
	completer.complete(res);
	return res;
	},
	onError: (e) {
	completer.complete(null);
	return Response(requestOptions: (e as DioException).requestOptions);
	},
	);
	// Simulate connection established.
	await Future.delayed(const Duration(seconds: 1));
	token.cancel();
	final response = await completer.future;
	// Response should be obtained without exceptions.
	expect(response, isNotNull);
	},
	testOn: '!browser',
	);

Connection closed before response was received #2170

Description

Package

Version

Operating-System

Adapter

Output of flutter doctor -v

Dart Version

Steps to Reproduce

Expected Result

Actual Result

Activity

AlexV525 commented on Mar 28, 2024

Abouassi98 commented on Mar 28, 2024

AlexV525 commented on Mar 28, 2024

Abouassi98 commented on Mar 28, 2024

AlexV525 commented on Mar 28, 2024

Abouassi98 commented on Mar 28, 2024

AlexV525 commented on Mar 29, 2024

AlexV525 commented on Mar 29, 2024

6 remaining items

EArminjon commented on Apr 5, 2024

kuhnroyal commented on Apr 5, 2024

devguusta commented on Apr 8, 2024

wratheus commented on Apr 10, 2024

kuhnroyal commented on Apr 10, 2024

AlexV525 commented on Apr 11, 2024

wratheus commented on Apr 11, 2024

chesongsong commented on Jun 24, 2024

AlexV525 commented on Jun 24, 2024

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions

Output of `flutter doctor -v`