diff options
| author | MaZderMind <peter@mazdermind.de> | 2014-09-14 15:49:25 +0200 |
|---|---|---|
| committer | MaZderMind <peter@mazdermind.de> | 2014-09-14 15:49:25 +0200 |
| commit | 66471a9cb0a0461672ea1cfcea638a8c021542f5 (patch) | |
| tree | 523e8c0d344c253a40d5bed03c4f1f742b18ced0 /voctocore/lib/pipeline.py | |
| parent | 638f52635b788a4c43b232cc6d59be11ec6dab52 (diff) | |
use an external failsrc for the failover shmsrc
Diffstat (limited to 'voctocore/lib/pipeline.py')
| -rw-r--r-- | voctocore/lib/pipeline.py | 5 |
1 files changed, 3 insertions, 2 deletions
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() |