jacob.eva/Sideband_CE
1
0
Fork 0
mirror of https://github.com/liberatedsystems/Sideband_CE.git synced 2024-09-03 04:13:27 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

Updated view example

Browse Source
This commit is contained in:
Mark Qvist 2024-03-27 18:37:13 +01:00
parent 48908842c6
commit 6700b7f8b7
1 changed files with 16 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
docs/example_plugins/view.py
View File

@ -158,7 +158,7 @@ class CameraSource(ViewSource):
self.camera_ready = False
class StreamSource(ViewSource):
DEFAULT_IDLE_TIMEOUT = 5
DEFAULT_IDLE_TIMEOUT = 10
def __init__(self, url=None):
self.url = url
@ -180,19 +180,18 @@ class StreamSource(ViewSource):
try:
while max(self.last_update, self.started)+self.idle_timeout > time.time():
ret, frame = self.stream.read()
self.stream_ready = True
if not ret:
self.stream_ready = False
break
else:
self.stream_ready = True
if not self.frame_queue.empty():
if self.frame_queue.qsize() > 1:
try:
self.frame_queue.get_nowait()
except queue.Empty:
pass
if not self.frame_queue.empty():
if self.frame_queue.qsize() > 1:
try:
self.frame_queue.get_nowait()
except queue.Empty:
pass
self.frame_queue.put(frame)
self.frame_queue.put(frame)
RNS.log(str(self)+" idled", RNS.LOG_DEBUG)
@ -206,6 +205,9 @@ class StreamSource(ViewSource):
self.start_reading()
while not self.stream_ready:
time.sleep(0.2)
if self.stream == None:
self.source_data = None
return
frame = self.frame_queue.get()
retval, buffer = cv2.imencode(".png", frame)