@@ -312,29 +312,29 @@ future<> client::do_make_request(request req, reply_handler handle, abort_source
312
312
co_await do_make_request (con, req, handle, as, expected);
313
313
}), as);
314
314
} catch (const std::system_error& ex) {
315
- if (as && as->abort_requested ()) {
316
- std::rethrow_exception (as->abort_requested_exception_ptr ());
317
- }
315
+ if (as && as->abort_requested ()) {
316
+ std::rethrow_exception (as->abort_requested_exception_ptr ());
317
+ }
318
318
319
- if (!_retry) {
320
- throw ;
321
- }
319
+ if (!_retry) {
320
+ throw ;
321
+ }
322
322
323
- auto code = ex.code ().value ();
324
- if ((code != EPIPE) && (code != ECONNABORTED)) {
325
- throw ;
326
- }
323
+ auto code = ex.code ().value ();
324
+ if ((code != EPIPE) && (code != ECONNABORTED)) {
325
+ throw ;
326
+ }
327
327
328
- retry_with_new = true ;
328
+ retry_with_new = true ;
329
329
}
330
330
331
331
if (retry_with_new) {
332
- // The 'con' connection may not yet be freed, so the total connection
333
- // count still account for it and with_new_connection() may temporarily
334
- // break the limit. That's OK, the 'con' will be closed really soon
335
- co_await with_new_connection (coroutine::lambda ([this , &req, &handle, as, expected] (connection& con) -> future<> {
336
- co_await do_make_request (con, req, handle, as, expected);
337
- }), as);
332
+ // The 'con' connection may not yet be freed, so the total connection
333
+ // count still account for it and with_new_connection() may temporarily
334
+ // break the limit. That's OK, the 'con' will be closed really soon
335
+ co_await with_new_connection (coroutine::lambda ([this , &req, &handle, as, expected] (connection& con) -> future<> {
336
+ co_await do_make_request (con, req, handle, as, expected);
337
+ }), as);
338
338
}
339
339
}
340
340
0 commit comments