From fe954bb659430cfb1ac549fc89305dcbcbb8863b Mon Sep 17 00:00:00 2001 From: Mike Salvatore Date: Mon, 12 Sep 2022 16:31:03 -0400 Subject: [PATCH] Agent: Call pipe.start(), not run() run() blocks, start() starts the run method on a different thread. --- monkey/infection_monkey/network/relay/tcp_pipe_spawner.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/monkey/infection_monkey/network/relay/tcp_pipe_spawner.py b/monkey/infection_monkey/network/relay/tcp_pipe_spawner.py index e4c48b77f..dab5721b8 100644 --- a/monkey/infection_monkey/network/relay/tcp_pipe_spawner.py +++ b/monkey/infection_monkey/network/relay/tcp_pipe_spawner.py @@ -37,7 +37,7 @@ class TCPPipeSpawner: pipe = SocketsPipe(source, dest, self._handle_pipe_closed) with self._lock: self._pipes.add(pipe) - pipe.run() + pipe.start() def has_open_pipes(self) -> bool: """Return whether or not the TCPPipeSpawner has any open pipes."""