aboutsummaryrefslogtreecommitdiff
path: root/voctocore
diff options
context:
space:
mode:
Diffstat (limited to 'voctocore')
-rwxr-xr-xvoctocore/experiments/sync-videomix.py31
1 files changed, 23 insertions, 8 deletions
diff --git a/voctocore/experiments/sync-videomix.py b/voctocore/experiments/sync-videomix.py
index 1e17a2e..ce8eb1e 100755
--- a/voctocore/experiments/sync-videomix.py
+++ b/voctocore/experiments/sync-videomix.py
@@ -40,8 +40,22 @@ class Example:
)
self.pipeline = Gst.parse_launch(pipeline)
- sig = self.pipeline.get_by_name('sig')
- sig.connect('handoff', self.handoff)
+
+ # with sync=False changes to videomixer & scaler are performed
+ # from the main thread. In the frame-images it becomes clear, that
+ # sometimes not all changes are applied before a frame is pushed
+ # through the mixer, and so there are "half modified" frames where
+ # some pieces are missing, the zorder or the size of one video is
+ # incorrect
+ # with sync=True all changes are made from the streaming-thread
+ # that drives the videomixer and the following elements, so they
+ # are always completed before the mixer processes the next frame
+ sync = True
+ if sync:
+ sig = self.pipeline.get_by_name('sig')
+ sig.connect('handoff', self.reconfigure)
+ else:
+ GLib.timeout_add(1/25 * 1000, self.reconfigure, 0, 0)
self.pad0 = self.pipeline.get_by_name('mix').get_static_pad('sink_0')
self.pad1 = self.pipeline.get_by_name('mix').get_static_pad('sink_1')
@@ -51,8 +65,8 @@ class Example:
self.state = False
- def handoff(self, object, buffer):
-
+ def reconfigure(self, object, buffer):
+ print("reconfigure!")
if self.state:
padA = self.pad0
padB = self.pad1
@@ -68,15 +82,16 @@ class Example:
padA.set_property('ypos', 10)
padA.set_property('alpha', 1.0)
padA.set_property('zorder', 1)
- capsA.set_property('caps', Gst.Caps.from_string('video/x-raw,width=400,height=225'))
+ capsA.set_property('caps', Gst.Caps.from_string('video/x-raw,width=320,height=180'))
- padB.set_property('xpos', 390)
- padB.set_property('ypos', 215)
+ padB.set_property('xpos', 310)
+ padB.set_property('ypos', 170)
padB.set_property('alpha', 1.0)
padB.set_property('zorder', 2)
- capsB.set_property('caps', Gst.Caps.from_string('video/x-raw,width=400,height=225'))
+ capsB.set_property('caps', Gst.Caps.from_string('video/x-raw,width=480,height=270'))
self.state = not self.state
+ return True
def run(self):
self.pipeline.set_state(Gst.State.PLAYING)