aboutsummaryrefslogtreecommitdiff
path: root/voctocore/lib/pipeline.py
diff options
context:
space:
mode:
Diffstat (limited to 'voctocore/lib/pipeline.py')
-rw-r--r--voctocore/lib/pipeline.py21
1 files changed, 15 insertions, 6 deletions
diff --git a/voctocore/lib/pipeline.py b/voctocore/lib/pipeline.py
index 5687573..fb9b846 100644
--- a/voctocore/lib/pipeline.py
+++ b/voctocore/lib/pipeline.py
@@ -18,12 +18,21 @@ class Pipeline(object):
vsources = []
vmirrors = []
vpreviews = []
+ vmixer = None
+ vmixerout = None
def __init__(self):
+ self.initVideo()
+
+ def initVideo(self):
caps = Config.get('mix', 'videocaps')
self.log.info('Video-Caps configured to: %s', caps)
- for idx, name in enumerate(Config.getlist('sources', 'video')):
+ names = Config.getlist('sources', 'video')
+ if len(names) < 1:
+ raise RuntimeException("At least one Video-Source must be configured!")
+
+ for idx, name in enumerate(names):
port = 10000 + idx
self.log.info('Creating Video-Source %s at tcp-port %u', name, port)
@@ -37,9 +46,9 @@ class Pipeline(object):
mirror = VideoRawOutput('video_%s_mirror' % name, port, caps)
self.vmirrors.append(mirror)
- # self.log.debug('Creating Video-Mixer')
- # self.videomixer = VideoMix()
+ self.log.debug('Creating Video-Mixer')
+ self.videomixer = VideoMix()
- # port = 11000
- # self.log.debug('Creating Video-Mixer-Output at tcp-port %u', port)
- # mirror = VideoRawOutput('video_mix', port, caps)
+ port = 11000
+ self.log.debug('Creating Video-Mixer-Output at tcp-port %u', port)
+ self.vmixerout = VideoRawOutput('video_mix', port, caps)