summaryrefslogtreecommitdiff
path: root/voctocore/lib/audiomix.py
diff options
context:
space:
mode:
Diffstat (limited to 'voctocore/lib/audiomix.py')
-rw-r--r--voctocore/lib/audiomix.py35
1 files changed, 33 insertions, 2 deletions
diff --git a/voctocore/lib/audiomix.py b/voctocore/lib/audiomix.py
index 24c34a9..e307527 100644
--- a/voctocore/lib/audiomix.py
+++ b/voctocore/lib/audiomix.py
@@ -18,15 +18,46 @@ class AudioMix(object):
def __init__(self):
self.caps = Config.get('mix', 'audiocaps')
+ self.names = Config.getlist('mix', 'sources')
+ self.log.info('Configuring Mixer for %u Sources', len(self.names))
+
pipeline = """
- interaudiosrc channel=audio_cam1_mixer !
+ audiomixer name=mix !
{caps} !
- queue !
interaudiosink channel=audio_mix
""".format(
caps=self.caps
)
+ for idx, name in enumerate(self.names):
+ pipeline += """
+ interaudiosrc channel=audio_{name}_mixer !
+ {caps} !
+ mix.
+ """.format(
+ name=name,
+ caps=self.caps
+ )
+
self.log.debug('Creating Mixing-Pipeline:\n%s', pipeline)
self.mixingPipeline = Gst.parse_launch(pipeline)
+
+ self.log.debug('Initializing Mixer-State')
+ self.updateMixerState()
+
+ self.log.debug('Launching Mixing-Pipeline')
self.mixingPipeline.set_state(Gst.State.PLAYING)
+
+ def updateMixerState(self):
+ self.log.info('Updating Mixer-State')
+
+ for idx, name in enumerate(self.names):
+ volume = int(idx == self.selectedSource)
+
+ self.log.debug('Setting Mixerpad %u to volume=%0.2f', idx, volume)
+ mixerpad = self.mixingPipeline.get_by_name('mix').get_static_pad('sink_%u' % idx)
+ mixerpad.set_property('volume', volume)
+
+ def setAudioSource(self, source):
+ self.selectedSource = source
+ self.updateMixerState()