Unsaturate dial negotiation queue (#6711)

* Unsaturate dial-negotiation count
This commit is contained in:
Age Manning
2024-12-18 07:10:53 +11:00
committed by GitHub
parent 1de498340c
commit 1315c94adb

View File

@@ -964,6 +964,9 @@ where
request_info: (Id, RequestType<E>),
error: StreamUpgradeError<RPCError>,
) {
// This dialing is now considered failed
self.dial_negotiated -= 1;
let (id, req) = request_info;
// map the error
@@ -989,9 +992,6 @@ where
StreamUpgradeError::Apply(other) => other,
};
// This dialing is now considered failed
self.dial_negotiated -= 1;
self.outbound_io_error_retries = 0;
self.events_out
.push(HandlerEvent::Err(HandlerErr::Outbound {