diff --git a/src/write_stage.rs b/src/write_stage.rs index 129056b078..866fe9a547 100644 --- a/src/write_stage.rs +++ b/src/write_stage.rs @@ -75,7 +75,10 @@ impl WriteStage { match e { Error::RecvTimeoutError(RecvTimeoutError::Disconnected) => break, Error::RecvTimeoutError(RecvTimeoutError::Timeout) => (), - _ => error!("{:?}", e), + _ => { + inc_new_counter!("write_stage-error", 1); + error!("{:?}", e); + } } }; }