From 776a857779171a40389655402ed4e90f8bd6bce2 Mon Sep 17 00:00:00 2001 From: jstuczyn Date: Thu, 19 Mar 2020 11:32:44 +0000 Subject: [PATCH] Entering runtime context when creating packet forwarder --- mixnode/src/node/mod.rs | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) 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) {