@@ -27,12 +27,12 @@ class UDPReceiver(Thread, StatisticsClientThread):
...
@@ -27,12 +27,12 @@ class UDPReceiver(Thread, StatisticsClientThread):
try:
try:
self.host=self.options['udp_host']
self.host=self.options['udp_host']
exceptException:
exceptKeyError:
raise
raise
try:
try:
self.port=self.options['udp_port']
self.port=self.options['udp_port']
exceptException:
exceptKeyError:
raise
raise
self.poll_timeout=self.options['poll_timeout']
self.poll_timeout=self.options['poll_timeout']
...
@@ -123,6 +123,3 @@ class UDPReceiver(Thread, StatisticsClientThread):
...
@@ -123,6 +123,3 @@ class UDPReceiver(Thread, StatisticsClientThread):
ifself.is_alive():
ifself.is_alive():
# there is nothing we can do except wait (stall) longer, which could be indefinitely.
# there is nothing we can do except wait (stall) longer, which could be indefinitely.
logger.error(f"UDP thread for {self.host}:{self.port} did not shut down after {self.DISCONNECT_TIMEOUT} seconds, just leaving it dangling. Please attach a debugger to thread ID {self.ident}.")
logger.error(f"UDP thread for {self.host}:{self.port} did not shut down after {self.DISCONNECT_TIMEOUT} seconds, just leaving it dangling. Please attach a debugger to thread ID {self.ident}.")