From b4ffc6e2f001a2bd12371975cacb7c526d9e7f08 Mon Sep 17 00:00:00 2001 From: Jakob Ketterl Date: Sun, 22 Sep 2019 12:56:35 +0200 Subject: [PATCH] replace os pipe with multiprocessing (seems to work better) --- owrx/websocket.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/owrx/websocket.py b/owrx/websocket.py index 321330c..dad40cd 100644 --- a/owrx/websocket.py +++ b/owrx/websocket.py @@ -1,7 +1,7 @@ import base64 import hashlib import json -import os +from multiprocessing import Pipe import select import threading @@ -19,7 +19,7 @@ class WebSocketConnection(object): self.handler = handler self.handler.connection.setblocking(0) self.messageHandler = messageHandler - (self.interruptPipeRecv, self.interruptPipeSend) = os.pipe() + (self.interruptPipeRecv, self.interruptPipeSend) = Pipe(duplex=False) self.open = True self.sendLock = threading.Lock() my_headers = self.handler.headers.items() @@ -118,7 +118,7 @@ class WebSocketConnection(object): self.close() def interrupt(self): - os.write(self.interruptPipeSend, bytes(0x00)) + self.interruptPipeSend.send(bytes(0x00)) def read_loop(self): self.open = True