v/Lego-Boost-Python-Library
1
0
Fork 0
mirror of https://github.com/undera/pylgbst.git synced 2020-11-18 19:37:26 -08:00
Code Issues Releases Wiki Activity

Drop port data in case handler is too slow

Browse Source
This commit is contained in:
Andrey Pohilko 2018-01-28 08:39:26 +03:00
parent 56657c05fa
commit 83be117966
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pylgbst/peripherals.py
View File

@ -27,7 +27,7 @@ class Peripheral(object):
self._working = False self._working = False
self._subscribers = set() self._subscribers = set()
self._port_subscription_mode = None self._port_subscription_mode = None
self._incoming_port_data = queue.Queue() self._incoming_port_data = queue.Queue(1) # limit 1 means we drop data if we can't handle it fast enough
thr = Thread(target=self._queue_reader) thr = Thread(target=self._queue_reader)
thr.setDaemon(True) thr.setDaemon(True)
thr.setName("Port data queue: %s" % self) thr.setName("Port data queue: %s" % self)
@ -83,7 +83,10 @@ class Peripheral(object):
subscriber(*args, **kwargs) subscriber(*args, **kwargs)
def queue_port_data(self, data): def queue_port_data(self, data):
self._incoming_port_data.put(data) try:
self._incoming_port_data.put_nowait(data)
except queue.Full:
logging.debug("Dropped port data: %s", data)
def handle_port_data(self, data): def handle_port_data(self, data):
log.warning("Unhandled device notification for %s: %s", self, str2hex(data[4:])) log.warning("Unhandled device notification for %s: %s", self, str2hex(data[4:]))