This commit is contained in:
ZettaScript 2024-02-03 18:57:23 +01:00
commit 2863035228
3 changed files with 70 additions and 2 deletions

View file

@ -4,6 +4,8 @@ from threading import Thread, Lock
class Sock:
def __init__(self):
self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
self.queue = []
self.queue_lock = Lock()
self.sock_thread = None
@ -17,7 +19,7 @@ class Sock:
self.sock_thread = SockThread(self, address, length)
self.sock_thread.start()
def poll(self):
def get(self):
if len(self.queue) == 0:
return []
with self.queue_lock: