@@ -312,26 +312,26 @@ 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
328
329
- // The 'con' connection may not yet be freed, so the total connection
330
- // count still account for it and with_new_connection() may temporarily
331
- // break the limit. That's OK, the 'con' will be closed really soon
332
- co_await with_new_connection (coroutine::lambda ([this , &req, &handle, as, expected] (connection& con) -> future<> {
333
- co_await do_make_request (con, req, handle, as, expected);
334
- }), as);
329
+ // The 'con' connection may not yet be freed, so the total connection
330
+ // count still account for it and with_new_connection() may temporarily
331
+ // break the limit. That's OK, the 'con' will be closed really soon
332
+ co_await with_new_connection (coroutine::lambda ([this , &req, &handle, as, expected] (connection& con) -> future<> {
333
+ co_await do_make_request (con, req, handle, as, expected);
334
+ }), as);
335
335
}
336
336
337
337
future<> client::do_make_request (connection& con, request& req, reply_handler& handle, abort_source* as, std::optional<reply::status_type> expected) {
0 commit comments