diff --git a/easytier/src/peers/peer_manager.rs b/easytier/src/peers/peer_manager.rs index e081995a..f85beaef 100644 --- a/easytier/src/peers/peer_manager.rs +++ b/easytier/src/peers/peer_manager.rs @@ -1718,6 +1718,7 @@ impl PeerManager { Ok(()) } + #[cfg_attr(feature = "hotpath", hotpath::measure(impl_type = "PeerManager"))] pub async fn send_msg_by_ip( &self, mut msg: ZCPacket, diff --git a/easytier/src/tunnel/mpsc.rs b/easytier/src/tunnel/mpsc.rs index 32c2dcfa..e131d66b 100644 --- a/easytier/src/tunnel/mpsc.rs +++ b/easytier/src/tunnel/mpsc.rs @@ -19,6 +19,7 @@ use futures::SinkExt; pub struct MpscTunnelSender(Sender); impl MpscTunnelSender { + #[cfg_attr(feature = "hotpath", hotpath::measure(impl_type = "MpscTunnelSender"))] pub async fn send(&self, item: ZCPacket) -> Result<(), TunnelError> { match self.0.try_send(item) { Ok(()) => Ok(()),