Loading crates/tor-chanmgr/src/lib.rs +1 −1 Original line number Diff line number Diff line Loading @@ -322,7 +322,7 @@ impl<R: Runtime> ChanMgr<R> { let result = self.mgr.handle_incoming(src, stream).await; #[cfg(feature = "metrics")] self.mgr.metrics.increment_inbound_channels_build(&result); self.mgr.metrics.increment_inbound_channels_built(&result); result } Loading crates/tor-chanmgr/src/mgr.rs +3 −1 Original line number Diff line number Diff line Loading @@ -210,6 +210,7 @@ pub(crate) struct ChanMgrMetrics { #[cfg(feature = "metrics")] impl ChanMgrMetrics { /// Create a new instance of [`ChanMgrMetrics`]. pub(crate) fn new() -> Self { ChanMgrMetrics { inbound_channels_built_success: metrics::counter!( Loading Loading @@ -334,7 +335,8 @@ impl ChanMgrMetrics { } } pub(crate) fn increment_inbound_channels_build<R>(&self, result: &Result<R>) { /// Increment the correct inbound_channels_built counter for the given result. pub(crate) fn increment_inbound_channels_built<R>(&self, result: &Result<R>) { match result { Ok(_) => self.inbound_channels_built_success.increment(1), Err(Error::UnusableTarget(_)) => self Loading Loading
crates/tor-chanmgr/src/lib.rs +1 −1 Original line number Diff line number Diff line Loading @@ -322,7 +322,7 @@ impl<R: Runtime> ChanMgr<R> { let result = self.mgr.handle_incoming(src, stream).await; #[cfg(feature = "metrics")] self.mgr.metrics.increment_inbound_channels_build(&result); self.mgr.metrics.increment_inbound_channels_built(&result); result } Loading
crates/tor-chanmgr/src/mgr.rs +3 −1 Original line number Diff line number Diff line Loading @@ -210,6 +210,7 @@ pub(crate) struct ChanMgrMetrics { #[cfg(feature = "metrics")] impl ChanMgrMetrics { /// Create a new instance of [`ChanMgrMetrics`]. pub(crate) fn new() -> Self { ChanMgrMetrics { inbound_channels_built_success: metrics::counter!( Loading Loading @@ -334,7 +335,8 @@ impl ChanMgrMetrics { } } pub(crate) fn increment_inbound_channels_build<R>(&self, result: &Result<R>) { /// Increment the correct inbound_channels_built counter for the given result. pub(crate) fn increment_inbound_channels_built<R>(&self, result: &Result<R>) { match result { Ok(_) => self.inbound_channels_built_success.increment(1), Err(Error::UnusableTarget(_)) => self Loading