From 66471a9cb0a0461672ea1cfcea638a8c021542f5 Mon Sep 17 00:00:00 2001 From: MaZderMind Date: Sun, 14 Sep 2014 15:49:25 +0200 Subject: use an external failsrc for the failover shmsrc --- voctocore/lib/pipeline.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'voctocore/lib/pipeline.py') diff --git a/voctocore/lib/pipeline.py b/voctocore/lib/pipeline.py index 35ecf2a..529aeca 100644 --- a/voctocore/lib/pipeline.py +++ b/voctocore/lib/pipeline.py @@ -12,6 +12,7 @@ from lib.videomix import VideoMix # from lib.audiomix import AudioMix from lib.distributor import TimesTwoDistributor from lib.shmsrc import FailsafeShmSrc +from lib.failvideosrc import FailVideoSrc class Pipeline(Gst.Pipeline): """mixing, streaming and encoding pipeline constuction and control""" @@ -45,11 +46,11 @@ class Pipeline(Gst.Pipeline): self.videonames = Config.getlist('sources', 'video') self.audionames = Config.getlist('sources', 'video') - for name in self.videonames: + for idx, name in enumerate(self.videonames): socket = os.path.join(socketpath, 'v-'+name) self.log.info('Creating video-source "%s" at socket-path %s', name, socket) - sourcebin = FailsafeShmSrc(socket) + sourcebin = FailsafeShmSrc(socket, FailVideoSrc(idx, name)) self.add(sourcebin) distributor = TimesTwoDistributor() -- cgit v1.2.3