Entering runtime context when creating packet forwarder

2020-03-19 11:32:44 +00:00
parent 6254169151
commit 776a857779
1 changed files with 8 additions and 5 deletions
@@ -87,11 +87,14 @@ impl MixNode {

    fn start_packet_forwarder(&mut self) -> mpsc::UnboundedSender<(SocketAddr, Vec<u8>)> {
        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) {