Trees | Index | Help |
---|
Package flumotion :: Package component :: Module feedcomponent010 :: Class FeedComponent |
|
object
--+ |GObject
--+ |object
--+ | | |InitMixin
--+ |Loggable
--+ |BaseComponent
--+ | FeedComponent
ParseLaunchComponent
Method Summary | |
---|---|
addEffect(self,
effect)
| |
bus_watch_func(self,
bus,
message)
| |
cleanup(self)
| |
gst.Pipeline
|
Subclasses have to implement this method. |
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. | |
get_pipeline(self)
| |
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. |
parseEaterConfig(self,
eater_config)
| |
parseFeederConfig(self,
feeder_config)
| |
pipeline_stop(self)
| |
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. | |
set_master_clock(self,
ip,
port,
base_time)
| |
Subclasses can override me. | |
setup_pipeline(self)
| |
After this function returns, the stream lock for this eater must have been released. | |
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. | |
BaseComponent vmethod for starting up. | |
| |
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 | |
---|---|
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 |
classobj |
componentMediumClass = flumotion.component.feedcomponent.FeedComponentMedium |
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. |
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 0x41c28d0c>
|
Method Details |
---|
create_pipeline(self)Subclasses have to implement this method.
|
do_setup(self)Sets up component. |
do_stop(self)BaseComponent vmethod for stopping. The component should do any cleanup it needs, but must not set the component's mood to sleeping.
|
eaterOffsetDiscont(self, feedId, prevOffsetEnd, curOffset)Inform of a timestamp discontinuity for the given eater. |
eaterSetActive(self, feedId)The eater for the given feedId is now active and producing data. By default, the component will go happy if all eaters are active. |
eaterSetInactive(self, feedId)The eater for the given feedId is no longer active By default, the component will go hungry. |
eaterTimestampDiscont(self, feedId, prevTs, prevDuration, curTs)Inform of a timestamp discontinuity for the given eater. |
eatFromFD(self, feedId, fd)Tell the component to eat the given feedId from the given fd. The component takes over the ownership of the fd, closing it when no longer eating.
|
effectPropertyChanged(self, effectName, propertyName, value)Notify the manager that an effect property has changed to a new value. Admin clients will receive it as a propertyChanged message for effectName:propertyName. |
feedToFD(self, feedName, fd, cleanup, eaterId=None)
|
get_eater_names(self)Return the list of feeder names this component eats from.
|
get_element(self, element_name)Get an element out of the pipeline. If it is possible that the component has not yet been set up, the caller needs to check if self.pipeline is actually set. |
get_element_property(self, element_name, property)Gets a property of an element in the GStreamer pipeline. |
get_feed_names(self)Return the list of feedeNames for feeds this component has.
|
get_feeder_names(self)Return the list of feedId's of feeders this component has.
|
init(self)A subclass should do as little as possible in its init method. In particular, it should not try to access resources. Failures during init are marshalled back to the manager through the worker's remote_create method, since there is no component state proxied to the manager yet at the time of init.
|
link(self)Make the component eat from the feeds it depends on and start producing feeds itself.
|
provide_master_clock(self, port)Tell the component to provide a master clock on the given port.
|
removeClientCallback(self, sink, fd)Called (as a signal callback) when the FD is no longer in use by multifdsink. This will call the registered callable on the fd. Called from GStreamer threads. |
set_element_property(self, element_name, property, value)Sets a property on an element in the GStreamer pipeline. |
set_pipeline(self, pipeline)Subclasses can override me. They should chain up first. |
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 |
---|
__gtype__
|
BUFFER_CHECK_FREQUENCY
|
BUFFER_PROBE_ADD_FREQUENCY
|
BUFFER_TIME_THRESHOLD
|
checkOffsetwhether to check continuity of offsets for eaters
|
checkTimestampwhether to check continuity of timestamps for eaters
|
DEPAY_TMPL
|
FDSRC_TMPL
|
FEEDER_TMPL
|
logCategoryImplementors can provide a category to log their messages under.
|
Trees | Index | Help |
---|
Generated by Epydoc 2.1 on Fri Apr 6 10:10:23 2007 | http://epydoc.sf.net |