python-codecs: fix zygote pop usage. implement firstFrameOnly pipelin…

…e blocking.
koush · Jul 28, 2023 · 220c010 · 220c010
1 parent 02238f9
commit 220c010
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 5 deletions.
diff --git a/plugins/python-codecs/src/gstreamer.py b/plugins/python-codecs/src/gstreamer.py
@@ -366,16 +366,20 @@ def setDecoderClearDefault(value: str):
     if fps:
         videorate = f"! videorate max-rate={fps}"
 
+    queue = "! queue leaky=downstream max-size-buffers=0"
+    if options and options.get('firstFrameOnly'):
+        queue = ""
+
     if postProcessPipeline == "VAAPI":
         pipeline += (
-            f" ! {decoder} {videorate} ! queue leaky=downstream max-size-buffers=0"
+            f" ! {decoder} {videorate} {queue}"
         )
     elif postProcessPipeline == "OpenGL (GPU memory)":
-        pipeline += f" ! {decoder} {videorate} ! queue leaky=downstream max-size-buffers=0 ! glupload"
+        pipeline += f" ! {decoder} {videorate} {queue} ! glupload"
     elif postProcessPipeline == "OpenGL (system memory)":
-        pipeline += f" ! {decoder} {videorate} ! queue leaky=downstream max-size-buffers=0 ! video/x-raw ! glupload"
+        pipeline += f" ! {decoder} {videorate} {queue} ! video/x-raw ! glupload"
     else:
-        pipeline += f" ! {decoder} ! video/x-raw {videorate} ! queue leaky=downstream max-size-buffers=0"
+        pipeline += f" ! {decoder} ! video/x-raw {videorate} {queue}"
         # disable the gstreamer post process because videocrop spams the log
         postProcessPipeline = "Default"
         # postProcessPipeline = None

diff --git a/plugins/python-codecs/src/zygote.py b/plugins/python-codecs/src/zygote.py
@@ -9,7 +9,7 @@ def createZygote():
 
     def next():
         while True:
-            cur = queue.pop()
+            cur = queue.pop(0)
             queue.append(scrypted_sdk.fork())
             yield cur