diff --git a/mixnode/src/node/mod.rs b/mixnode/src/node/mod.rs index 20b7133408..6a1cde30d4 100644 --- a/mixnode/src/node/mod.rs +++ b/mixnode/src/node/mod.rs @@ -87,11 +87,14 @@ impl MixNode { fn start_packet_forwarder(&mut self) -> mpsc::UnboundedSender<(SocketAddr, Vec)> { info!("Starting packet forwarder..."); - packet_forwarding::PacketForwarder::new( - self.config.get_packet_forwarding_initial_backoff(), - self.config.get_packet_forwarding_maximum_backoff(), - ) - .start(self.runtime.handle()) + self.runtime + .enter(|| { + packet_forwarding::PacketForwarder::new( + self.config.get_packet_forwarding_initial_backoff(), + self.config.get_packet_forwarding_maximum_backoff(), + ) + }) + .start(self.runtime.handle()) } pub fn run(&mut self) {