Hinzufügen und Entfernen von Audioquellen zu/von GStreamer-Pipeline unterwegs

Question

Ich schrieb ein kleines Python-Skript, das ein Adder-Plugin verwendet, um zwei Quellströme zusammen zu mischen.

Nach dem Start des Programms hören Sie einen 1 kHz-Ton, der vom -Plugin erzeugt wird. Wenn Sie die Eingabetaste drücken, wird ein weiterer 500 Hz Testton an die Adder angeschlossen, so dass Sie sie zusammen hören. (Übrigens, ich verstehe nicht wirklich, warum sollte ich die Pipeline wieder spielen Zustand hier, um die Mischung zu hören. Gibt es eine Möglichkeit, ich kann neue Quellen anschließen, ohne die Pipeline neu starten?)

Wann Du drückst noch einmal Enter, der 1kHz-Ton sollte aus dem Mix genommen werden und der 500Hz-Ton sollte weiterspielen, stattdessen höre ich nichts mehr. Ich bekomme eine pulse pulsesink.c:528:gst_pulsering_stream_underflow_cb:<pulseaudio_output> Got underflow in der Debug-Ausgabe als letzte Zeile. Ich weiß nicht wirklich, was ich als nächstes versuchen soll.

Hier ist der vollständige Quellcode:

#!/usr/bin/python 
# On-the-go source removal doesn't work this way with GStreamer. Why? 

import gobject; 
gobject.threads_init() 
import gst; 

if __name__ == "__main__": 
    pipe = gst.Pipeline("mypipe") 

    adder = gst.element_factory_make("adder","audiomixer") 
    pipe.add(adder) 

    buzzer = gst.element_factory_make("audiotestsrc","buzzer") 
    buzzer.set_property("freq",1000) 
    pipe.add(buzzer) 

    pulse = gst.element_factory_make("pulsesink", "pulseaudio_output") 
    pipe.add(pulse) 

    buzzer.link(adder) 
    adder.link(pulse) 
    pipe.set_state(gst.STATE_PLAYING) 

    raw_input("1kHz test sound. Press <ENTER> to continue.") 

    buzzer2=gst.element_factory_make("audiotestsrc","buzzer2") 
    buzzer2.set_property("freq",500) 

    pipe.add(buzzer2) 
    buzzer2.link(adder) 
    pipe.set_state(gst.STATE_PLAYING) 

    raw_input("1kHz + 500Hz test sound playing simoultenously. Press <ENTER> to continue.") 

    buzzer.unlink(adder) 
    pipe.set_state(gst.STATE_PLAYING) 

    raw_input("Only 500Hz test sound. Press <ENTER> to stop.") 

Answer 1

ich die Lösung auf meinem eigenen gefunden habe. Ich musste Request-Pads mit Adder verwenden und die pad blocking-Fähigkeit von GStreamer verwenden.

Hier ist der Arbeits Quellcode mit einigen Beschreibungen:

#!/usr/bin/python 

import gobject; 
gobject.threads_init() 
import gst; 

if __name__ == "__main__": 
    # First create our pipeline 
    pipe = gst.Pipeline("mypipe") 

    # Create a software mixer with "Adder" 
    adder = gst.element_factory_make("adder","audiomixer") 
    pipe.add(adder) 

    # Gather a request sink pad on the mixer 
    sinkpad1=adder.get_request_pad("sink%d") 

    # Create the first buzzer.. 
    buzzer1 = gst.element_factory_make("audiotestsrc","buzzer1") 
    buzzer1.set_property("freq",1000) 
    pipe.add(buzzer1) 
    # .. and connect it's source pad to the previously gathered request pad 
    buzzersrc1=buzzer1.get_pad("src") 
    buzzersrc1.link(sinkpad1) 

    # Add some output 
    output = gst.element_factory_make("autoaudiosink", "audio_out") 
    pipe.add(output) 
    adder.link(output) 

    # Start the playback 
    pipe.set_state(gst.STATE_PLAYING) 

    raw_input("1kHz test sound. Press <ENTER> to continue.") 

    # Get an another request sink pad on the mixer 
    sinkpad2=adder.get_request_pad("sink%d") 

    # Create an another buzzer and connect it the same way 
    buzzer2 = gst.element_factory_make("audiotestsrc","buzzer2") 
    buzzer2.set_property("freq",500) 
    pipe.add(buzzer2) 

    buzzersrc2=buzzer2.get_pad("src") 
    buzzersrc2.link(sinkpad2) 

    # Start the second buzzer (other ways streaming stops because of starvation) 
    buzzer2.set_state(gst.STATE_PLAYING) 

    raw_input("1kHz + 500Hz test sound playing simoultenously. Press <ENTER> to continue.") 

    # Before removing a source, we must use pad blocking to prevent state changes 
    buzzersrc1.set_blocked(True) 
    # Stop the first buzzer 
    buzzer1.set_state(gst.STATE_NULL) 
    # Unlink from the mixer 
    buzzersrc1.unlink(sinkpad2) 
    # Release the mixers first sink pad 
    adder.release_request_pad(sinkpad1) 
    # Because here none of the Adder's sink pads block, streaming continues 

    raw_input("Only 500Hz test sound. Press <ENTER> to stop.")