gstreamer - パイプラインを再起動せずに gstreamer パイプラインで現在再生中のファイルを変更するには?

Question

何らかの理由で、この問題に対する有効な解決策をオンラインで見つけるのに苦労しました.

現在、ソースは filesrc 要素です。現在の非解決策は、パイプラインの状態を READY に変更し、location プロパティを変更して、パイプラインの状態を PLAYING に設定することです (以下の change_song メソッドを参照してください)。

これにより、次のエラーが発生します。

CHANGING SONG TO music2.mp3
('ERROR:', 'filesource', ':', 'Internal data stream error.')
('debugging info:', 'gstbasesrc.c(2950): gst_base_src_loop (): /GstPipeline:pipeline0/GstFileSrc:filesource:\nstreaming stopped, reason not-linked (-1)')

最初の曲の再生が聞こえますが、PLAYING 状態に再び入ろうとすると、パイプラインがクラッシュします。これは私たちのコードです:

import gi
import time
import threading
gi.require_version('Gst', '1.0')
from gi.repository import Gst, GObject, GLib
class Server:
    def __init__(self):
        self.pipeline = None
        bus = None
        message = None

        # initialize GStreamer
        Gst.init(None)

        # build the pipeline
        self.pipeline = Gst.parse_launch('filesrc name=filesource ! queue name=queueelement ! decodebin ! audioconvert ! audioresample ! opusenc ! rtpopuspay ! udpsink port=40401 host=224.1.1.1')
        self.filesrc = self.pipeline.get_by_name("filesource")        
        self.filesrc.set_property("location", "music.mp3")
        self.queue = self.pipeline.get_by_name("queueelement")

    def hang(self):
        # wait until EOS or error
        bus = self.pipeline.get_bus()
        msg = bus.timed_pop_filtered(Gst.CLOCK_TIME_NONE, Gst.MessageType.ERROR | Gst.MessageType.EOS)

        if msg:
            t = msg.type
            if t == Gst.MessageType.ERROR:
                err, dbg = msg.parse_error()
                print("ERROR:", msg.src.get_name(), ":", err.message)
                if dbg:
                    print("debugging info:", dbg)
            elif t == Gst.MessageType.EOS:
                print("End-Of-Stream reached")
            else:
                # this should not happen. we only asked for ERROR and EOS
                print("ERROR: Unexpected message received.")

        # free resources
        self.pipeline.set_state(Gst.State.NULL)

    def start(self):
        # start playing
        self.pipeline.set_state(Gst.State.PLAYING)

        t = threading.Thread(target=self.hang)
        t.start()

    def change_song(self, song_name):
        print("CHANGING SONG TO " + song_name)
        self.pipeline.set_state(Gst.State.READY)
        self.filesrc.set_property("location", song_name)
        self.pipeline.set_state(Gst.State.PLAYING)

s = Server()
s.start()
time.sleep(5)
s.change_song("music2.mp3")

また、次のことも試しました。

def change_song(self, song_name):
    print("CHANGING SONG TO " + song_name)
    self.pipeline.set_state(Gst.State.READY)
    self.filesrc.unlink(queue)
    self.filesrc.set_property("location", song_name)
    self.filesrc.link(queue)
    self.pipeline.set_state(Gst.State.PLAYING)

しかし、これは同じエラーを出します。