summaryrefslogtreecommitdiff
path: root/voctocore/experiments
diff options
context:
space:
mode:
Diffstat (limited to 'voctocore/experiments')
-rwxr-xr-xvoctocore/experiments/failovertest.py14
1 files changed, 10 insertions, 4 deletions
diff --git a/voctocore/experiments/failovertest.py b/voctocore/experiments/failovertest.py
index 47b4341..deb665b 100755
--- a/voctocore/experiments/failovertest.py
+++ b/voctocore/experiments/failovertest.py
@@ -22,14 +22,20 @@ class Example:
self.bus.connect('message::eos', self.on_eos)
self.bus.connect('message::error', self.on_error)
+ self.addTest('/tmp/v-cam2')
+ self.addTest('/tmp/v-cam1')
+
+ def addTest(self, socket):
self.mixdisplay = VideomixerWithDisplay()
- self.grabbersrc = ShmSrc('/tmp/grabber-v', Gst.Caps.from_string('video/x-raw,width=1280,height=720,framerate=25/1,format=RGBx'))
+ self.videoconvert = Gst.ElementFactory.make('videoconvert', None)
+ self.grabbersrc = ShmSrc(socket, Gst.Caps.from_string('video/x-raw,width=1280,height=720,framerate=25/1,format=RGBx'))
# Add elements to pipeline
- self.pipeline.add(self.mixdisplay)
self.pipeline.add(self.grabbersrc)
-
- self.grabbersrc.link(self.mixdisplay)
+ self.pipeline.add(self.videoconvert)
+ self.pipeline.add(self.mixdisplay)
+ self.grabbersrc.link(self.videoconvert)
+ self.videoconvert.link(self.mixdisplay)
def run(self):
self.pipeline.set_state(Gst.State.PAUSED)