From 3a4bdc861ac99b5a767012abfacfe256cab8d28f Mon Sep 17 00:00:00 2001 From: jstuczyn Date: Fri, 20 Mar 2020 12:23:04 +0000 Subject: [PATCH] Entering runtime context when creating mix traffic controller --- nym-client/src/client/mod.rs | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/nym-client/src/client/mod.rs b/nym-client/src/client/mod.rs index 2dc70e8357..6446aed6f5 100644 --- a/nym-client/src/client/mod.rs +++ b/nym-client/src/client/mod.rs @@ -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(