diff --git a/src/client/connector.rs b/src/client/connector.rs index 5d66d66d6..b97cfc711 100644 --- a/src/client/connector.rs +++ b/src/client/connector.rs @@ -46,6 +46,8 @@ pub struct ClientConnectorStats { pub errors: usize, /// Number of connection timeouts pub timeouts: usize, + /// Number of released connections + pub released: usize, } #[derive(Debug)] @@ -904,6 +906,7 @@ impl Handler for ClientConnector { impl StreamHandler for ClientConnector { fn handle(&mut self, msg: AcquiredConnOperation, ctx: &mut Context) { let now = Instant::now(); + self.stats.released += 1; // check if we have queued up waiters let waiter = {