mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2025-04-26 05:06:17 +00:00
Pipeline, Thread, Bin generate RuntimeError exceptions
Original commit message from CVS: Pipeline, Thread, Bin generate RuntimeError exceptions
This commit is contained in:
parent
d13b976ed2
commit
6cd99af3e2
8 changed files with 0 additions and 22 deletions
|
@ -57,7 +57,6 @@ class BPS(object):
|
||||||
|
|
||||||
def build_pipeline(self, buffers):
|
def build_pipeline(self, buffers):
|
||||||
pipeline = Pipeline('pipeline')
|
pipeline = Pipeline('pipeline')
|
||||||
assert pipeline
|
|
||||||
|
|
||||||
src = self.fakesrc(buffers)
|
src = self.fakesrc(buffers)
|
||||||
pipeline.add(src)
|
pipeline.add(src)
|
||||||
|
|
|
@ -106,7 +106,6 @@ class DVDPlayer(object):
|
||||||
def build_video_thread(self):
|
def build_video_thread(self):
|
||||||
# ***** pre-construct the video thread *****
|
# ***** pre-construct the video thread *****
|
||||||
self.v_thread = Thread('v_thread')
|
self.v_thread = Thread('v_thread')
|
||||||
assert self.v_thread
|
|
||||||
|
|
||||||
self.v_queue = Element('queue','v_queue')
|
self.v_queue = Element('queue','v_queue')
|
||||||
|
|
||||||
|
@ -151,7 +150,6 @@ class DVDPlayer(object):
|
||||||
def build_audio_thread(self):
|
def build_audio_thread(self):
|
||||||
# ***** pre-construct the audio thread *****
|
# ***** pre-construct the audio thread *****
|
||||||
self.a_thread = Thread('a_thread')
|
self.a_thread = Thread('a_thread')
|
||||||
assert self.a_thread
|
|
||||||
|
|
||||||
self.a_queue = Element('queue','a_queue')
|
self.a_queue = Element('queue','a_queue')
|
||||||
|
|
||||||
|
@ -171,7 +169,6 @@ class DVDPlayer(object):
|
||||||
def build(self):
|
def build(self):
|
||||||
# ***** construct the main pipeline *****
|
# ***** construct the main pipeline *****
|
||||||
self.pipeline = Pipeline('pipeline')
|
self.pipeline = Pipeline('pipeline')
|
||||||
assert self.pipeline
|
|
||||||
|
|
||||||
self.src = Element('dvdreadsrc','src');
|
self.src = Element('dvdreadsrc','src');
|
||||||
|
|
||||||
|
|
|
@ -31,7 +31,6 @@ def main():
|
||||||
# create a new bin to hold the elements
|
# create a new bin to hold the elements
|
||||||
#gst_debug_set_categories(-1)
|
#gst_debug_set_categories(-1)
|
||||||
bin = Pipeline('pipeline')
|
bin = Pipeline('pipeline')
|
||||||
assert bin
|
|
||||||
|
|
||||||
src = Element('fakesrc', 'src')
|
src = Element('fakesrc', 'src')
|
||||||
src.connect('handoff', handoff)
|
src.connect('handoff', handoff)
|
||||||
|
|
|
@ -93,7 +93,6 @@ def simple(argv):
|
||||||
gst_schedulerfactory_set_default_name (argv[1])
|
gst_schedulerfactory_set_default_name (argv[1])
|
||||||
|
|
||||||
pipeline = Pipeline('pipeline')
|
pipeline = Pipeline('pipeline')
|
||||||
assert pipeline
|
|
||||||
|
|
||||||
src = fakesrc()
|
src = fakesrc()
|
||||||
pipeline.add(src)
|
pipeline.add(src)
|
||||||
|
@ -114,13 +113,10 @@ def queue(argv):
|
||||||
gst_schedulerfactory_set_default_name (argv[1])
|
gst_schedulerfactory_set_default_name (argv[1])
|
||||||
|
|
||||||
pipeline = Pipeline('pipeline')
|
pipeline = Pipeline('pipeline')
|
||||||
assert pipeline
|
|
||||||
|
|
||||||
src_thr = Thread('src_thread')
|
src_thr = Thread('src_thread')
|
||||||
assert src_thr
|
|
||||||
|
|
||||||
src = fakesrc()
|
src = fakesrc()
|
||||||
assert src
|
|
||||||
src_thr.add(src)
|
src_thr.add(src)
|
||||||
|
|
||||||
src_q = Element('queue','src_q')
|
src_q = Element('queue','src_q')
|
||||||
|
@ -136,10 +132,8 @@ def queue(argv):
|
||||||
last.get_pad('src').link(sink_q.get_pad('sink'))
|
last.get_pad('src').link(sink_q.get_pad('sink'))
|
||||||
|
|
||||||
sink_thr = Thread('sink_thread')
|
sink_thr = Thread('sink_thread')
|
||||||
assert sink_thr
|
|
||||||
|
|
||||||
sink = fakesink()
|
sink = fakesink()
|
||||||
assert sink
|
|
||||||
|
|
||||||
sink_thr.add(sink)
|
sink_thr.add(sink)
|
||||||
|
|
||||||
|
|
|
@ -57,7 +57,6 @@ class BPS(object):
|
||||||
|
|
||||||
def build_pipeline(self, buffers):
|
def build_pipeline(self, buffers):
|
||||||
pipeline = Pipeline('pipeline')
|
pipeline = Pipeline('pipeline')
|
||||||
assert pipeline
|
|
||||||
|
|
||||||
src = self.fakesrc(buffers)
|
src = self.fakesrc(buffers)
|
||||||
pipeline.add(src)
|
pipeline.add(src)
|
||||||
|
|
|
@ -106,7 +106,6 @@ class DVDPlayer(object):
|
||||||
def build_video_thread(self):
|
def build_video_thread(self):
|
||||||
# ***** pre-construct the video thread *****
|
# ***** pre-construct the video thread *****
|
||||||
self.v_thread = Thread('v_thread')
|
self.v_thread = Thread('v_thread')
|
||||||
assert self.v_thread
|
|
||||||
|
|
||||||
self.v_queue = Element('queue','v_queue')
|
self.v_queue = Element('queue','v_queue')
|
||||||
|
|
||||||
|
@ -151,7 +150,6 @@ class DVDPlayer(object):
|
||||||
def build_audio_thread(self):
|
def build_audio_thread(self):
|
||||||
# ***** pre-construct the audio thread *****
|
# ***** pre-construct the audio thread *****
|
||||||
self.a_thread = Thread('a_thread')
|
self.a_thread = Thread('a_thread')
|
||||||
assert self.a_thread
|
|
||||||
|
|
||||||
self.a_queue = Element('queue','a_queue')
|
self.a_queue = Element('queue','a_queue')
|
||||||
|
|
||||||
|
@ -171,7 +169,6 @@ class DVDPlayer(object):
|
||||||
def build(self):
|
def build(self):
|
||||||
# ***** construct the main pipeline *****
|
# ***** construct the main pipeline *****
|
||||||
self.pipeline = Pipeline('pipeline')
|
self.pipeline = Pipeline('pipeline')
|
||||||
assert self.pipeline
|
|
||||||
|
|
||||||
self.src = Element('dvdreadsrc','src');
|
self.src = Element('dvdreadsrc','src');
|
||||||
|
|
||||||
|
|
|
@ -31,7 +31,6 @@ def main():
|
||||||
# create a new bin to hold the elements
|
# create a new bin to hold the elements
|
||||||
#gst_debug_set_categories(-1)
|
#gst_debug_set_categories(-1)
|
||||||
bin = Pipeline('pipeline')
|
bin = Pipeline('pipeline')
|
||||||
assert bin
|
|
||||||
|
|
||||||
src = Element('fakesrc', 'src')
|
src = Element('fakesrc', 'src')
|
||||||
src.connect('handoff', handoff)
|
src.connect('handoff', handoff)
|
||||||
|
|
|
@ -93,7 +93,6 @@ def simple(argv):
|
||||||
gst_schedulerfactory_set_default_name (argv[1])
|
gst_schedulerfactory_set_default_name (argv[1])
|
||||||
|
|
||||||
pipeline = Pipeline('pipeline')
|
pipeline = Pipeline('pipeline')
|
||||||
assert pipeline
|
|
||||||
|
|
||||||
src = fakesrc()
|
src = fakesrc()
|
||||||
pipeline.add(src)
|
pipeline.add(src)
|
||||||
|
@ -114,13 +113,10 @@ def queue(argv):
|
||||||
gst_schedulerfactory_set_default_name (argv[1])
|
gst_schedulerfactory_set_default_name (argv[1])
|
||||||
|
|
||||||
pipeline = Pipeline('pipeline')
|
pipeline = Pipeline('pipeline')
|
||||||
assert pipeline
|
|
||||||
|
|
||||||
src_thr = Thread('src_thread')
|
src_thr = Thread('src_thread')
|
||||||
assert src_thr
|
|
||||||
|
|
||||||
src = fakesrc()
|
src = fakesrc()
|
||||||
assert src
|
|
||||||
src_thr.add(src)
|
src_thr.add(src)
|
||||||
|
|
||||||
src_q = Element('queue','src_q')
|
src_q = Element('queue','src_q')
|
||||||
|
@ -136,10 +132,8 @@ def queue(argv):
|
||||||
last.get_pad('src').link(sink_q.get_pad('sink'))
|
last.get_pad('src').link(sink_q.get_pad('sink'))
|
||||||
|
|
||||||
sink_thr = Thread('sink_thread')
|
sink_thr = Thread('sink_thread')
|
||||||
assert sink_thr
|
|
||||||
|
|
||||||
sink = fakesink()
|
sink = fakesink()
|
||||||
assert sink
|
|
||||||
|
|
||||||
sink_thr.add(sink)
|
sink_thr.add(sink)
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue