From b77fc78dde60baee9a9cc11714b7e8991804af37 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bj=C3=B6rn=20Freise?= Date: Tue, 23 Apr 2019 11:40:33 +0200 Subject: [PATCH] Speed up unittests, only wait 1 second instead of 10 seconds in listen() --- cache_test.py | 4 +- coapthon/forward_proxy/coap.py | 6 -- coapthon/reverse_proxy/coap.py | 6 -- coverage_test.py | 118 +++++++++++++++----------------- coverage_testIPv6.py | 2 +- coverage_test_advanced.py | 2 +- coverage_test_multicast.py | 2 +- coverage_test_multicast_ipv6.py | 2 +- coverage_test_proxy.py | 4 +- coverage_test_reverse_proxy.py | 4 +- plugtest.py | 2 +- 11 files changed, 66 insertions(+), 86 deletions(-) diff --git a/cache_test.py b/cache_test.py index 42d8cf5..92c82d6 100644 --- a/cache_test.py +++ b/cache_test.py @@ -24,10 +24,10 @@ class Tests(unittest.TestCase): self.current_mid = random.randint(1, 1000) self.server_mid = random.randint(1000, 2000) self.server = CoAPServer("127.0.0.1", 5684) - self.server_thread = threading.Thread(target=self.server.listen, args=(10,)) + self.server_thread = threading.Thread(target=self.server.listen, args=(1,)) self.server_thread.start() self.proxy = CoAPForwardProxy("127.0.0.1", 5683, cache=True) - self.proxy_thread = threading.Thread(target=self.proxy.listen, args=(10,)) + self.proxy_thread = threading.Thread(target=self.proxy.listen, args=(1,)) self.proxy_thread.start() self.queue = Queue() diff --git a/coapthon/forward_proxy/coap.py b/coapthon/forward_proxy/coap.py index 922405f..977d2fa 100644 --- a/coapthon/forward_proxy/coap.py +++ b/coapthon/forward_proxy/coap.py @@ -92,9 +92,6 @@ class CoAP(object): mreq = struct.pack("4sl", socket.inet_aton(defines.ALL_COAP_NODES), socket.INADDR_ANY) self._socket.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq) - self._unicast_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) - self._unicast_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) - self._unicast_socket.bind(self.server_address) else: # Bugfix for Python 3.6 for Windows ... missing IPPROTO_IPV6 constant if not hasattr(socket, 'IPPROTO_IPV6'): @@ -111,9 +108,6 @@ class CoAP(object): group_bin = socket.inet_pton(socket.AF_INET6, addrinfo_multicast[4][0]) mreq = group_bin + struct.pack('@I', 0) self._socket.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_JOIN_GROUP, mreq) - self._unicast_socket = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM) - self._unicast_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) - self._unicast_socket.bind(self.server_address) else: if addrinfo[0] == socket.AF_INET: # IPv4 self._socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) diff --git a/coapthon/reverse_proxy/coap.py b/coapthon/reverse_proxy/coap.py index 0d7cd47..ed05686 100644 --- a/coapthon/reverse_proxy/coap.py +++ b/coapthon/reverse_proxy/coap.py @@ -100,9 +100,6 @@ class CoAP(object): mreq = struct.pack("4sl", socket.inet_aton(defines.ALL_COAP_NODES), socket.INADDR_ANY) self._socket.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq) - self._unicast_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) - self._unicast_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) - self._unicast_socket.bind(self.server_address) else: # Bugfix for Python 3.6 for Windows ... missing IPPROTO_IPV6 constant if not hasattr(socket, 'IPPROTO_IPV6'): @@ -119,9 +116,6 @@ class CoAP(object): group_bin = socket.inet_pton(socket.AF_INET6, addrinfo_multicast[4][0]) mreq = group_bin + struct.pack('@I', 0) self._socket.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_JOIN_GROUP, mreq) - self._unicast_socket = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM) - self._unicast_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) - self._unicast_socket.bind(self.server_address) else: if addrinfo[0] == socket.AF_INET: # IPv4 self._socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) diff --git a/coverage_test.py b/coverage_test.py index e61a2af..36e7323 100644 --- a/coverage_test.py +++ b/coverage_test.py @@ -15,6 +15,48 @@ from coapthon.serializer import Serializer __author__ = 'Giacomo Tanganelli' __version__ = "2.0" +PAYLOAD = "Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut " \ + "labore et dolore magna aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et " \ + "ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum " \ + "dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore " \ + "magna aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. " \ + "Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit " \ + "amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna " \ + "aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita " \ + "kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. " \ + "Duis autem vel eum iriure dolor in hendrerit in vulputate velit esse molestie consequat, vel illum dolore " \ + "eu feugiat nulla facilisis at vero eros et accumsan et iusto odio dignissim qui blandit praesent luptatum " \ + "zzril delenit augue duis dolore te feugait nulla facilisi. Lorem ipsum dolor sit amet, consectetuer " \ + "adipiscing elit, sed diam nonummy nibh euismod tincidunt ut laoreet dolore magna aliquam erat volutpat. " \ + "Ut wisi enim ad minim veniam, quis nostrud exerci tation ullamcorper suscipit lobortis nisl ut aliquip " \ + "ex ea commodo consequat. Duis autem vel eum iriure dolor in hendrerit in vulputate velit esse molestie " \ + "consequat, vel illum dolore eu feugiat nulla facilisis at vero eros et accumsan et iusto odio dignissim " \ + "qui blandit praesent luptatum zzril delenit augue duis dolore te feugait nulla facilisi. " \ + "Nam liber tempor cum soluta nobis eleifend option congue nihil imperdiet doming id quod mazim placerat " \ + "facer possim assum. Lorem ipsum dolor sit amet, consectetuer adipiscing elit, sed diam nonummy nibh " \ + "euismod tincidunt ut laoreet dolore magna aliquam erat volutpat. Ut wisi enim ad minim veniam, quis " \ + "nostrud exerci tation ullamcorper suscipit lobortis nisl ut aliquip ex ea commodo consequat. " \ + "Duis autem vel eum iriure dolor in hendrerit in vulputate velit esse molestie consequat, vel illum dolore " \ + "eu feugiat nulla facilisis. " \ + "At vero eos et accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata " \ + "sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam " \ + "nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam erat, sed diam voluptua. At vero eos et " \ + "accusam et justo duo dolores et ea rebum. Stet clita kasd gubergren, no sea takimata sanctus est Lorem " \ + "ipsum dolor sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, At accusam aliquyam diam " \ + "diam dolore dolores duo eirmod eos erat, et nonumy sed tempor et et invidunt justo labore Stet clita ea " \ + "et gubergren, kasd magna no rebum. sanctus sea sed takimata ut vero voluptua. est Lorem ipsum dolor " \ + "sit amet. Lorem ipsum dolor sit amet, consetetur sadipscing elitr, sed diam nonumy eirmod tempor " \ + "invidunt ut labore et dolore magna aliquyam erat. " \ + "Consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna " \ + "aliquyam erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita " \ + "kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, " \ + "consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam " \ + "erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita kasd " \ + "gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet. Lorem ipsum dolor sit amet, " \ + "consetetur sadipscing elitr, sed diam nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam " \ + "erat, sed diam voluptua. At vero eos et accusam et justo duo dolores et ea rebum. Stet clita kasd " \ + "gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet." + class Tests(unittest.TestCase): @@ -23,7 +65,7 @@ class Tests(unittest.TestCase): self.current_mid = random.randint(1, 1000) self.server_mid = random.randint(1000, 2000) self.server = CoAPServer("127.0.0.1", 5683) - self.server_thread = threading.Thread(target=self.server.listen, args=(10,)) + self.server_thread = threading.Thread(target=self.server.listen, args=(1,)) self.server_thread.start() self.queue = Queue() @@ -407,18 +449,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras sollicitudin fermentum ornare. " \ - "Cras accumsan tellus quis dui lacinia eleifend. Proin ultrices rutrum orci vitae luctus. " \ - "Nullam malesuada pretium elit, at aliquam odio vehicula in. Etiam nec maximus elit. " \ - "Etiam at erat ac ex ornare feugiat. Curabitur sed malesuada orci, id aliquet nunc. Phasellus " \ - "nec leo luctus, blandit lorem sit amet, interdum metus. Duis efficitur volutpat magna, ac " \ - "ultricies nibh aliquet sit amet. Etiam tempor egestas augue in hendrerit. Nunc eget augue " \ - "ultricies, dignissim lacus et, vulputate dolor. Nulla eros odio, fringilla vel massa ut, " \ - "facilisis cursus quam. Fusce faucibus lobortis congue. Fusce consectetur porta neque, id " \ - "sollicitudin velit maximus eu. Sed pharetra leo quam, vel finibus turpis cursus ac. " \ - "Aenean ac nisi massa. Cras commodo arcu nec ante tristique ullamcorper. Quisque eu hendrerit" \ - " urna. Cras fringilla eros ut nunc maximus, non porta nisl mollis. Aliquam in rutrum massa." \ - " Praesent tristique turpis dui, at ultri" + req.payload = PAYLOAD req.block1 = (1, 1, 1024) expected = Response() @@ -437,18 +468,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Cras sollicitudin fermentum ornare. " \ - "Cras accumsan tellus quis dui lacinia eleifend. Proin ultrices rutrum orci vitae luctus. " \ - "Nullam malesuada pretium elit, at aliquam odio vehicula in. Etiam nec maximus elit. " \ - "Etiam at erat ac ex ornare feugiat. Curabitur sed malesuada orci, id aliquet nunc. Phasellus " \ - "nec leo luctus, blandit lorem sit amet, interdum metus. Duis efficitur volutpat magna, ac " \ - "ultricies nibh aliquet sit amet. Etiam tempor egestas augue in hendrerit. Nunc eget augue " \ - "ultricies, dignissim lacus et, vulputate dolor. Nulla eros odio, fringilla vel massa ut, " \ - "facilisis cursus quam. Fusce faucibus lobortis congue. Fusce consectetur porta neque, id " \ - "sollicitudin velit maximus eu. Sed pharetra leo quam, vel finibus turpis cursus ac. " \ - "Aenean ac nisi massa. Cras commodo arcu nec ante tristique ullamcorper. Quisque eu hendrerit" \ - " urna. Cras fringilla eros ut nunc maximus, non porta nisl mollis. Aliquam in rutrum massa." \ - " Praesent tristique turpis dui, at ultri" + req.payload = PAYLOAD req.block1 = (0, 1, 1024) expected = Response() @@ -468,10 +488,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "a imperdiet nisl. Quisque a iaculis libero, id tempus lacus. Aenean convallis est non justo " \ - "consectetur, a hendrerit enim consequat. In accumsan ante a egestas luctus. Etiam quis neque " \ - "nec eros vestibulum faucibus. Nunc viverra ipsum lectus, vel scelerisque dui dictum a. Ut orci " \ - "enim, ultrices a ultrices nec, pharetra in quam. Donec accumsan sit amet eros eget fermentum." + req.payload = PAYLOAD req.block1 = (1, 1, 64) expected = Response() @@ -491,10 +508,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "a imperdiet nisl. Quisque a iaculis libero, id tempus lacus. Aenean convallis est non justo " \ - "consectetur, a hendrerit enim consequat. In accumsan ante a egestas luctus. Etiam quis neque " \ - "nec eros vestibulum faucibus. Nunc viverra ipsum lectus, vel scelerisque dui dictum a. Ut orci " \ - "enim, ultrices a ultrices nec, pharetra in quam. Donec accumsan sit amet eros eget fermentum." + req.payload = PAYLOAD req.block1 = (3, 1, 64) expected = Response() @@ -513,10 +527,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "a imperdiet nisl. Quisque a iaculis libero, id tempus lacus. Aenean convallis est non justo " \ - "consectetur, a hendrerit enim consequat. In accumsan ante a egestas luctus. Etiam quis neque " \ - "nec eros vestibulum faucibus. Nunc viverra ipsum lectus, vel scelerisque dui dictum a. Ut orci " \ - "enim, ultrices a ultrices nec, pharetra in quam. Donec accumsan sit amet eros eget fermentum." + req.payload = PAYLOAD req.block1 = (2, 0, 64) expected = Response() @@ -737,7 +748,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "Lorem ipsum dolo" + req.payload = PAYLOAD req.block1 = (0, 1, 16) expected = Response() @@ -757,7 +768,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "r sit amet, consectetur adipisci" + req.payload = PAYLOAD req.block1 = (1, 1, 32) expected = Response() @@ -777,7 +788,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "ng elit. Sed ut ultrices ligula. Pellentesque purus augue, cursu" + req.payload = PAYLOAD req.block1 = (2, 1, 64) expected = Response() @@ -797,8 +808,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "s ultricies est in, vehicula congue metus. Vestibulum vel justo lacinia, porttitor quam vitae, " \ - "feugiat sapien. Quisque finibus, " + req.payload = PAYLOAD req.block1 = (3, 1, 128) expected = Response() @@ -818,9 +828,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "nisi vitae rhoncus malesuada, augue mauris dapibus tellus, sit amet venenatis libero" \ - " libero sed lorem. In pharetra turpis sed eros porta mollis. Quisque dictum dolor nisl," \ - " imperdiet tincidunt augue malesuada vitae. Donec non felis urna. Suspendisse at hend" + req.payload = PAYLOAD req.block1 = (4, 1, 256) expected = Response() @@ -840,12 +848,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "rerit ex, quis aliquet ante. Vivamus ultrices dolor at elit tincidunt, eget fringilla " \ - "ligula vestibulum. In molestie sagittis nibh, ut efficitur tellus faucibus non. Maecenas " \ - "posuere elementum faucibus. Morbi nisi diam, molestie non feugiat et, elementum eget magna." \ - " Donec vel sem facilisis quam viverra ultrices nec eu lacus. Sed molestie nisi id ultrices " \ - "interdum. Curabitur pharetra sed tellus in dignissim. Duis placerat aliquam metus, volutpat " \ - "elementum augue aliquam a. Nunc sed dolor at orci maximus portt" + req.payload = PAYLOAD req.block1 = (5, 1, 512) expected = Response() @@ -865,18 +868,7 @@ class Tests(unittest.TestCase): req.type = defines.Types["CON"] req._mid = self.current_mid req.destination = self.server_address - req.payload = "itor ac sit amet eros. Mauris et nisi in tortor pharetra rhoncus sit amet hendrerit metus. " \ - "Integer laoreet placerat cursus. Nam a nulla ex. Donec laoreet sagittis libero quis " \ - "imperdiet. Vivamus facilisis turpis nec rhoncus venenatis. Duis pulvinar tellus vel quam " \ - "maximus imperdiet. Mauris eget nibh orci. Duis ut cursus nibh. Nulla sed commodo elit. " \ - "Suspendisse ac eros lacinia, mattis turpis at, porttitor justo. Vivamus molestie " \ - "tincidunt libero. Etiam porttitor lacus odio, at lobortis tortor scelerisque nec. " \ - "Nullam non ante vel nisi ultrices consectetur. Maecenas massa felis, tempor eget " \ - "malesuada eget, pretium eu sapien. Vivamus dapibus ante erat, non faucibus orci sodales " \ - "sit amet. Cras magna felis, sodales eget magna sed, eleifend rutrum ligula. Vivamus interdum " \ - "enim enim, eu facilisis tortor dignissim quis. Ut metus nulla, mattis non lorem et, " \ - "elementum ultrices orci. Quisque eleifend, arcu vitae ullamcorper pulvinar, ipsum ex " \ - "sodales arcu, eget consectetur mauris metus ac tortor. Donec id sem felis. Maur" + req.payload = PAYLOAD req.block1 = (6, 0, 1024) expected = Response() diff --git a/coverage_testIPv6.py b/coverage_testIPv6.py index cdbc876..d0a1381 100644 --- a/coverage_testIPv6.py +++ b/coverage_testIPv6.py @@ -20,7 +20,7 @@ class Tests(unittest.TestCase): self.current_mid = random.randint(1, 1000) self.server_mid = random.randint(1000, 2000) self.server = CoAPServer("::1", 5683) - self.server_thread = threading.Thread(target=self.server.listen, args=(10,)) + self.server_thread = threading.Thread(target=self.server.listen, args=(1,)) self.server_thread.start() self.queue = Queue() diff --git a/coverage_test_advanced.py b/coverage_test_advanced.py index 31b4657..e576b3c 100644 --- a/coverage_test_advanced.py +++ b/coverage_test_advanced.py @@ -18,7 +18,7 @@ class Tests(unittest.TestCase): self.current_mid = random.randint(1, 1000) self.server_mid = random.randint(1000, 2000) self.server = CoAPServer("127.0.0.1", 5683) - self.server_thread = threading.Thread(target=self.server.listen, args=(10,)) + self.server_thread = threading.Thread(target=self.server.listen, args=(1,)) self.server_thread.start() self.queue = Queue() diff --git a/coverage_test_multicast.py b/coverage_test_multicast.py index 994f521..812221a 100644 --- a/coverage_test_multicast.py +++ b/coverage_test_multicast.py @@ -21,7 +21,7 @@ class Tests(unittest.TestCase): self.current_mid = random.randint(1, 1000) self.server_mid = random.randint(1000, 2000) self.server = CoAPServer("0.0.0.0", 5683, multicast=True) - self.server_thread = threading.Thread(target=self.server.listen, args=(10,)) + self.server_thread = threading.Thread(target=self.server.listen, args=(1,)) self.server_thread.start() self.queue = Queue() diff --git a/coverage_test_multicast_ipv6.py b/coverage_test_multicast_ipv6.py index ba6a87d..da427d2 100644 --- a/coverage_test_multicast_ipv6.py +++ b/coverage_test_multicast_ipv6.py @@ -21,7 +21,7 @@ class Tests(unittest.TestCase): self.current_mid = random.randint(1, 1000) self.server_mid = random.randint(1000, 2000) self.server = CoAPServer("::1", 5683, multicast=True) - self.server_thread = threading.Thread(target=self.server.listen, args=(10,)) + self.server_thread = threading.Thread(target=self.server.listen, args=(1,)) self.server_thread.start() self.queue = Queue() diff --git a/coverage_test_proxy.py b/coverage_test_proxy.py index eb7c838..e40f007 100644 --- a/coverage_test_proxy.py +++ b/coverage_test_proxy.py @@ -23,10 +23,10 @@ class Tests(unittest.TestCase): self.current_mid = random.randint(1, 1000) self.server_mid = random.randint(1000, 2000) self.server = CoAPServer("127.0.0.1", 5684) - self.server_thread = threading.Thread(target=self.server.listen, args=(10,)) + self.server_thread = threading.Thread(target=self.server.listen, args=(1,)) self.server_thread.start() self.proxy = CoAPForwardProxy("127.0.0.1", 5683) - self.proxy_thread = threading.Thread(target=self.proxy.listen, args=(10,)) + self.proxy_thread = threading.Thread(target=self.proxy.listen, args=(1,)) self.proxy_thread.start() self.queue = Queue() diff --git a/coverage_test_reverse_proxy.py b/coverage_test_reverse_proxy.py index 293a212..6aabdd1 100644 --- a/coverage_test_reverse_proxy.py +++ b/coverage_test_reverse_proxy.py @@ -25,10 +25,10 @@ class Tests(unittest.TestCase): self.current_mid = random.randint(1, 1000) self.server_mid = random.randint(1000, 2000) self.server = CoAPServer("127.0.0.1", 5684) - self.server_thread = threading.Thread(target=self.server.listen, args=(10,)) + self.server_thread = threading.Thread(target=self.server.listen, args=(1,)) self.server_thread.start() self.proxy = CoAPReverseProxy("127.0.0.1", 5683, "reverse_proxy_mapping.xml") - self.proxy_thread = threading.Thread(target=self.proxy.listen, args=(10,)) + self.proxy_thread = threading.Thread(target=self.proxy.listen, args=(1,)) self.proxy_thread.start() self.queue = Queue() diff --git a/plugtest.py b/plugtest.py index b7146b0..a970d39 100644 --- a/plugtest.py +++ b/plugtest.py @@ -23,7 +23,7 @@ class Tests(unittest.TestCase): self.current_mid = random.randint(1, 1000) self.server_mid = random.randint(1000, 2000) self.server = CoAPServerPlugTest("127.0.0.1", 5683, starting_mid=self.server_mid) - self.server_thread = threading.Thread(target=self.server.listen, args=(10,)) + self.server_thread = threading.Thread(target=self.server.listen, args=(1,)) self.server_thread.start() self.queue = Queue()