* gstreamer.py:

Add getPipeline() method.
	  Base class implementation uses getPipelineDesc().
This commit is contained in:
Thomas Vander Stichele
2011-08-05 19:11:00 +00:00
parent 55c4bddfcf
commit 7ae0f41457
2 changed files with 15 additions and 6 deletions

6
morituri/extern/task/ChangeLog vendored Normal file
View File

@@ -0,0 +1,6 @@
2011-08-05 Thomas Vander Stichele <thomas at apestaart dot org>
* gstreamer.py:
Add getPipeline() method.
Base class implementation uses getPipelineDesc().

View File

@@ -54,10 +54,8 @@ class GstPipelineTask(task.Task):
self.gst = gst
task.Task.start(self, runner)
desc = self.getPipelineDesc()
self.debug('creating pipeline %r', desc)
self.pipeline = self.gst.parse_launch(desc)
self.getPipeline()
self._bus = self.pipeline.get_bus()
self.gst.debug('got bus %r' % self._bus)
@@ -117,8 +115,13 @@ class GstPipelineTask(task.Task):
self.stopped()
task.Task.stop(self)
### subclass optional implementations
def getPipeline(self):
desc = self.getPipelineDesc()
self.debug('creating pipeline %r', desc)
self.pipeline = self.gst.parse_launch(desc)
### subclass required implementations
def getPipelineDesc(self):
"""
subclasses should implement this to provide a pipeline description.
@@ -127,10 +130,10 @@ class GstPipelineTask(task.Task):
"""
raise NotImplementedError
### subclass optional implementations
def parsed(self):
"""
Called after parsing the pipeline but before setting it to paused.
Called after parsing/getting the pipeline but before setting it to
paused.
"""
pass