Entering runtime context when creating mix traffic controller

2020-03-20 12:23:04 +00:00
parent eae2fe675d
commit 3a4bdc861a
1 changed files with 9 additions and 6 deletions
@@ -212,12 +212,15 @@ impl NymClient {
    // controller for sending sphinx packets to mixnet (either real traffic or cover traffic)
    fn start_mix_traffic_controller(&mut self, mix_rx: MixMessageReceiver) {
        info!("Starting mix trafic controller...");
-        MixTrafficController::new(
-            self.config.get_packet_forwarding_initial_backoff(),
-            self.config.get_packet_forwarding_maximum_backoff(),
-            mix_rx,
-        )
-        .start(self.runtime.handle());
+        self.runtime
+            .enter(|| {
+                MixTrafficController::new(
+                    self.config.get_packet_forwarding_initial_backoff(),
+                    self.config.get_packet_forwarding_maximum_backoff(),
+                    mix_rx,
+                )
+            })
+            .start(self.runtime.handle());
    }

    fn start_socket_listener<T: 'static + NymTopology>(