From db85e13657cb5bdf2439bae9327150e70385d337 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sat, 15 Dec 2018 02:20:19 -0500 Subject: [PATCH] Use a fifo lock for IPC --- tractor/_ipc.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tractor/_ipc.py b/tractor/_ipc.py index 52b1ca5..f7bebbe 100644 --- a/tractor/_ipc.py +++ b/tractor/_ipc.py @@ -20,7 +20,7 @@ class StreamQueue: self._agen = self._iter_packets() self._laddr = self.stream.socket.getsockname()[:2] self._raddr = self.stream.socket.getpeername()[:2] - self._send_lock = trio.Lock() + self._send_lock = trio.StrictFIFOLock() async def _iter_packets(self) -> typing.AsyncGenerator[dict, None]: """Yield packets from the underlying stream.