From 87e3df8455bdf5c176ecc275858c3dd7a9cb0e6c Mon Sep 17 00:00:00 2001 From: Gabriel Pettier Date: Sun, 22 Sep 2019 17:11:19 +0200 Subject: [PATCH] don't catch either error for now --- oscpy/server.py | 7 +++---- tests/test_server.py | 4 ++-- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/oscpy/server.py b/oscpy/server.py index ac72b39..7186d14 100644 --- a/oscpy/server.py +++ b/oscpy/server.py @@ -19,6 +19,8 @@ from oscpy.client import send_bundle, send_message from oscpy.stats import Stats +UDP_MAX_SIZE = 65535 + def ServerClass(cls): """Decorate classes with for methods implementing OSC endpoints. @@ -332,10 +334,7 @@ def _listen(self): continue for sender_socket in read: - try: - data, sender = sender_socket.recvfrom(65535) - except ConnectionResetError: - continue + data, sender = sender_socket.recvfrom(UDP_MAX_SIZE) for address, tags, values, offset in read_packet( data, drop_late=drop_late, encoding=self.encoding, diff --git a/tests/test_server.py b/tests/test_server.py index 6ccdfaf..fae5d54 100644 --- a/tests/test_server.py +++ b/tests/test_server.py @@ -937,8 +937,8 @@ def test_close_receiving(): port = osc.getaddress()[1] def send_messages(): - for i in range(5000): - send_message(b'/flood', [b't' * 60000], 'localhost', port, safer=True) + for i in range(500): + send_message(b'/flood', [b't' * 60000], 'localhost', port) thread = Thread(target=send_messages) thread.start()