stop thread loop using Event from threading

Author: dariusstefan

opensips/event/datagram.py

@@ -41,9 +41,12 @@ def create(self):
         else:
             self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
             self.sock.bind(self.sock_name)
+        self.sock.setblocking(False)
 
     def handle(self, callback, stop):
-        while not stop:
-            data = self.sock.recv(1024)
-            callback(data)
-
+        while not stop.is_set():
+            try:
+                data = self.sock.recv(1024)
+                callback(data)
+            except BlockingIOError:
+                pass

opensips/event/subscriber.py

@@ -20,7 +20,7 @@
 from ..mi import MI
 from .datagram import Datagram
 from .stream import Stream
-from threading import Thread
+from threading import Thread, Event
 
 class EventInterface():
     def __init__(self, mi: MI, type: str, **kwargs):
@@ -43,13 +43,14 @@ def subscribe(self, event: str, callback, expire=3600):
                 raise Exception("Failed to subscribe to event")
 
             self.socket.create()
-            self.thread_stop = False
+            self.thread_stop = Event()
+            self.thread_stop.clear()
             self.thread = Thread(target=self.socket.handle, args=(callback, self.thread_stop))
             self.thread.start()
 
         except Exception as e:
             raise e
 
     def stop(self):
-        self.thread_stop = True
+        self.thread_stop.set()
         self.thread.join()