birbnetes/iot-platform-raspberry
birbnetes/iot-platform-raspberry
4
0
Fork 0
Code Pull Requests Releases Wiki Activity

Added queue tracking

Browse Source
This commit is contained in:
Pünkösd Marcell 2021-11-18 18:15:03 +01:00
parent 497009da7e
commit e3d4fdcdae
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
birbnetes_iot_platform_raspberry/record_stuff.py
View File

@ -88,6 +88,9 @@ class SlicedRecorder(Thread):
except Empty: except Empty:
return None return None
def get_queue_length(self) -> int:
return self._output_queue.qsize()
def stop(self): def stop(self):
self._active = False self._active = False
@ -104,6 +107,10 @@ class BirbnetesIoTPlatformRecordDriver:
def get_recording(cls, blocking: bool = False) -> Optional[str]: def get_recording(cls, blocking: bool = False) -> Optional[str]:
return cls.sliced_recorder.get_recording(blocking) return cls.sliced_recorder.get_recording(blocking)
@classmethod
def get_queue_length(cls) -> int:
return cls.sliced_recorder.get_queue_length()
@classmethod @classmethod
def cleanup(cls): def cleanup(cls):
cls.sliced_recorder.stop() cls.sliced_recorder.stop()