Trees | Index | Help |
---|
Package flumotion :: Package component :: Module feedcomponent :: Class MultiInputParseLaunchComponent |
|
object
--+ |GObject
--+ |object
--+ | | |InitMixin
--+ |Loggable
--+ |BaseComponent
--+ |FeedComponent
--+ |ParseLaunchComponent
--+ | MultiInputParseLaunchComponent
Method Summary | |
---|---|
Return a gst-parse description of the muxer, which must be named 'muxer' | |
Method that must be implemented by subclasses to produce the gstparse string for the component's pipeline. | |
Return a parse-launch description of a queue, if this component wants an input queue on this eater, or None if not | |
After this function returns, the stream lock for this eater must have been released. | |
Inherited from ParseLaunchComponent | |
Method that can be implemented by subclasses if they wish to interact with the pipeline after it has been created and set on the component. | |
gst.Pipeline
|
Subclasses have to implement this method. |
Tell the component to start. | |
| |
| |
| |
Expand the given pipeline string representation by substituting blocks between '@' with a filled-in template. | |
Subclasses can override me. | |
Expand the given string to a full element name for an eater or feeder. | |
Expand each @..@ block to use the full element name for eater or feeder. | |
Inherited from FeedComponent | |
| |
| |
| |
Sets up component. | |
BaseComponent vmethod for stopping. | |
Inform of a timestamp discontinuity for the given eater. | |
The eater for the given feedId is now active and producing data. | |
The eater for the given feedId is no longer active By default, the component will go hungry. | |
Inform of a timestamp discontinuity for the given eater. | |
Tell the component to eat the given feedId from the given fd. | |
Notify the manager that an effect property has changed to a new value. | |
| |
Return the list of feeder names this component eats from. | |
Get an element out of the pipeline. | |
Gets a property of an element in the GStreamer pipeline. | |
Return the list of feedeNames for feeds this component has. | |
Return the list of feedId's of feeders this component has. | |
| |
A subclass should do as little as possible in its init method. | |
twisted.internet.defer.Deferred
|
Make the component eat from the feeds it depends on and start producing feeds itself. |
| |
| |
| |
Tell the component to provide a master clock on the given port. | |
Called (as a signal callback) when the FD is no longer in use by multifdsink. | |
Sets a property on an element in the GStreamer pipeline. | |
| |
| |
| |
| |
Periodically scheduled buffer probe, that ensures that we're currently actually having dataflow through our eater elements. | |
Check that buffers are being received by the eater. | |
An event probe used to consume unwanted duplicate newsegment events. | |
An event probe used to consume unwanted EOS events on eaters. | |
| |
| |
| |
Inherited from BaseComponent | |
Subclasses should not override __init__ at all. | |
Add a message to the component. | |
Call a remote method on all admin client views on this component. | |
Subclasses can implement me to run any checks before the component performs setup. | |
| |
Fix properties that have been renamed from a previous version, and add a warning for them. | |
int |
Gets the mood on the component. |
| |
| |
| |
Set the given mood on the component if it's different from the current one. | |
Set the shutdown hook for this component (replacing any previous hook). | |
Sets up the component with the given config. | |
| |
Tell the component to start. | |
Tell the component to stop. | |
| |
| |
Inherited from Loggable | |
Log a debug message. | |
dict |
Log a message at the given level, with the possibility of going higher up in the stack. |
Log an error. | |
Log an informational message. | |
Log a log message. | |
Overridable log function. | |
Overridable object name function. | |
Log a warning. | |
Log a warning about a Failure. | |
Inherited from GObject | |
x.__cmp__(y) <==> cmp(x,y) | |
| |
x.__hash__() <==> hash(x) | |
T.__new__(S, ...) -> a new object with type S, a subtype of T | |
x.__repr__() <==> repr(x) | |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
Inherited from object | |
x.__delattr__('name') <==> del x.name | |
x.__getattribute__('name') <==> x.name | |
helper for pickle | |
helper for pickle | |
x.__setattr__('name', value) <==> x.name = value | |
x.__str__() <==> str(x) |
Instance Variable Summary | |
---|---|
Inherited from BaseComponent | |
BaseComponentMedium |
medium : the component's medium |
string | name : the name of the component |
Class Variable Summary | |
---|---|
int |
QUEUE_SIZE_BUFFERS = 16 |
Inherited from ParseLaunchComponent | |
str |
DELIMITER = '@'
|
Inherited from FeedComponent | |
GType |
__gtype__ = <GType flumotion+component+feedcomponent010+...
|
float |
BUFFER_CHECK_FREQUENCY = 12.5 |
int |
BUFFER_PROBE_ADD_FREQUENCY = 5 |
float |
BUFFER_TIME_THRESHOLD = 12.5 |
bool |
checkOffset : whether to check continuity of offsets for eaters |
bool |
checkTimestamp : whether to check continuity of timestamps for eaters |
str |
DEPAY_TMPL = 'gdpdepay name=%(name)s-depay'
|
str |
FDSRC_TMPL = 'fdsrc name=%(name)s'
|
str |
FEEDER_TMPL = 'gdppay ! multifdsink sync=false name=%(na...
|
str |
logCategory : Implementors can provide a category to log their messages under. |
int |
_reconnectInterval = 3 |
Inherited from Loggable | |
Implements |
__implemented__ = <implementedBy flumotion.common.log.Lo...
|
ClassProvides |
__providedBy__ = <zope.interface.declarations.ClassProvi...
|
ClassProvides |
__provides__ = <zope.interface.declarations.ClassProvide...
|
Inherited from GObject | |
str |
__gdoc__ = 'Object GObject\n\nSignals from GObject:\n n...
|
getset_descriptor |
__grefcount__ = <attribute '__grefcount__' of 'gobject.G...
|
GProps |
props = <gobject.GProps object at 0x2aaab8cc8550>
|
Method Details |
---|
get_muxer_string(self, properties)Return a gst-parse description of the muxer, which must be named 'muxer' |
get_pipeline_string(self, properties)Method that must be implemented by subclasses to produce the gstparse string for the component's pipeline. Subclasses should not chain up; this method raises a NotImplemented error. Returns: a new pipeline string representation.
|
get_queue_string(self, eaterName)Return a parse-launch description of a queue, if this component wants an input queue on this eater, or None if not
|
unblock_eater(self, feedId)After this function returns, the stream lock for this eater must have been released. If your component needs to do something here, override this method.
|
Class Variable Details |
---|
QUEUE_SIZE_BUFFERS
|
Trees | Index | Help |
---|
Generated by Epydoc 2.1 on Sat Apr 14 13:16:50 2007 | http://epydoc.sf.net |