From edd071739f089b4f974096b47f34b0cc9cebfae4 Mon Sep 17 00:00:00 2001 From: Koushik Dutta Date: Sun, 21 May 2023 22:48:06 -0700 Subject: [PATCH] python-codecs: dont feed preroll into queue --- plugins/python-codecs/package-lock.json | 4 ++-- plugins/python-codecs/package.json | 2 +- plugins/python-codecs/src/gst_generator.py | 7 +++---- 3 files changed, 6 insertions(+), 7 deletions(-) diff --git a/plugins/python-codecs/package-lock.json b/plugins/python-codecs/package-lock.json index b41ff7542..5708bc5ec 100644 --- a/plugins/python-codecs/package-lock.json +++ b/plugins/python-codecs/package-lock.json @@ -1,12 +1,12 @@ { "name": "@scrypted/python-codecs", - "version": "0.1.57", + "version": "0.1.58", "lockfileVersion": 3, "requires": true, "packages": { "": { "name": "@scrypted/python-codecs", - "version": "0.1.57", + "version": "0.1.58", "devDependencies": { "@scrypted/sdk": "file:../../sdk" } diff --git a/plugins/python-codecs/package.json b/plugins/python-codecs/package.json index adefb9669..768a6e20d 100644 --- a/plugins/python-codecs/package.json +++ b/plugins/python-codecs/package.json @@ -1,6 +1,6 @@ { "name": "@scrypted/python-codecs", - "version": "0.1.57", + "version": "0.1.58", "description": "Python Codecs for Scrypted", "keywords": [ "scrypted", diff --git a/plugins/python-codecs/src/gst_generator.py b/plugins/python-codecs/src/gst_generator.py index ad95ec8e5..99b500b78 100644 --- a/plugins/python-codecs/src/gst_generator.py +++ b/plugins/python-codecs/src/gst_generator.py @@ -76,10 +76,10 @@ async def createPipelineIterator(pipeline: str): finish() - def on_new_sample(sink, preroll): + def on_new_sample(sink): nonlocal hasFinished - sample = sink.emit('pull-preroll' if preroll else 'pull-sample') + sample = sink.emit('pull-sample') if hasFinished: return Gst.FlowReturn.OK @@ -91,8 +91,7 @@ async def createPipelineIterator(pipeline: str): pass return Gst.FlowReturn.OK - appsink.connect('new-preroll', on_new_sample, True) - appsink.connect('new-sample', on_new_sample, False) + appsink.connect('new-sample', on_new_sample) gst.set_state(Gst.State.PLAYING) return gst, gen