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