Agent: Call pipe.start(), not run()

run() blocks, start() starts the run method on a different thread.
This commit is contained in:
Mike Salvatore 2022-09-12 16:31:03 -04:00
parent 9002c47d56
commit fe954bb659
1 changed files with 1 additions and 1 deletions

View File

@ -37,7 +37,7 @@ class TCPPipeSpawner:
pipe = SocketsPipe(source, dest, self._handle_pipe_closed) pipe = SocketsPipe(source, dest, self._handle_pipe_closed)
with self._lock: with self._lock:
self._pipes.add(pipe) self._pipes.add(pipe)
pipe.run() pipe.start()
def has_open_pipes(self) -> bool: def has_open_pipes(self) -> bool:
"""Return whether or not the TCPPipeSpawner has any open pipes.""" """Return whether or not the TCPPipeSpawner has any open pipes."""