Package flumotion :: Package component :: Module feedcomponent :: Class ParseLaunchComponent
[show private | hide private]
[frames | no frames]

Type ParseLaunchComponent

object --+            
         |            
   GObject --+        
             |        
object --+   |        
         |   |        
 InitMixin --+        
             |        
  Loggable --+        
             |        
 BaseComponent --+    
                 |    
     FeedComponent --+
                     |
                    ParseLaunchComponent


A component using gst-launch syntax
Method Summary
  configure_pipeline(self, pipeline, properties)
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 create_pipeline(self)
Subclasses have to implement this method.
  do_start(self, eatersData, feedersData, clocking)
Tell the component to start, linking itself to other components.
  get_pipeline_string(self, properties)
Method that must be implemented by subclasses to produce the gstparse string for the component's pipeline.
  parse_pipeline(self, pipeline)
  parse_tmpl(self, pipeline, names, template, format)
Expand the given pipeline string representation by substituting blocks between '@' with a filled-in template.
  set_pipeline(self, pipeline)
Subclasses can override me.
    Inherited from FeedComponent
  addEffect(self, effect)
  bus_watch_func(self, bus, message)
  cleanup(self)
  do_setup(self)
Subclasses can implement me to set up the component before it is started.
  do_stop(self)
BaseComponent vmethod for stopping.
  effectPropertyChanged(self, effectName, propertyName, value)
Notify the manager that an effect property has changed to a new value.
  get_eater_names(self)
Return the list of feeder names this component eats from.
  get_element(self, element_name)
  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 feeder names this component has.
  get_feeder_names(self)
Return the list of feeder names this component has.
  get_pipeline(self)
  init(self)
A subclass should do as little as possible in its init method.
  link(self, eatersData, feedersData)
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)
  provide_master_clock(self, port)
Tell the component to provide a master clock on the given port.
  really_link(self, res)
  really_provide_master_clock(self)
  restart(self)
  set_element_property(self, element_name, property, value)
Sets a property on an element in the GStreamer pipeline.
  set_master_clock(self, ip, port, base_time)
  setup_pipeline(self)
    Inherited from BaseComponent
  __init__(self)
Subclasses should not override __init__ at all.
  addMessage(self, message)
Add a message to the component.
  adminCallRemote(self, methodName, *args, **kwargs)
Call a remote method on all admin client views on this component.
  do_check(self)
Subclasses can implement me to run any checks before the component performs setup.
  emit(self, name, *args)
  getName(self)
  getWorkerName(self)
  setMedium(self, medium)
  setMood(self, mood)
Set the given mood on the component if it's different from the current one.
  setup(self, config)
Sets up the component with the given config.
  setWorkerName(self, workerName)
  start(self, *args, **kwargs)
Tell the component to start.
  startHeartbeat(self)
Start sending heartbeats.
  stop(self)
Tell the component to stop.
  stopHeartbeat(self)
Stop sending heartbeats.
    Inherited from Loggable
  debug(self, *args)
Log a debug message.
  error(self, *args)
Log an error.
  info(self, *args)
Log an informational message.
  log(self, *args)
Log a log message.
  logFunction(self, message)
Overridable log function.
  logObjectName(self)
Overridable object name function.
  warning(self, *args)
Log a warning.
  warningFailure(self, failure)
Log a warning about a Failure.
    Inherited from GObject
  __cmp__(x, y)
x.__cmp__(y) <==> cmp(x,y)
  __gobject_init__(...)
  __hash__(x)
x.__hash__() <==> hash(x)
  __new__(T, S, ...)
T.__new__(S, ...) -> a new object with type S, a subtype of T
  __repr__(x)
x.__repr__() <==> repr(x)
  chain(...)
  connect(...)
  connect_after(...)
  connect_object(...)
  connect_object_after(...)
  disconnect(...)
  emit_stop_by_name(...)
  freeze_notify(...)
  get_data(...)
  get_property(...)
  handler_block(...)
  handler_disconnect(...)
  handler_is_connected(...)
  handler_unblock(...)
  notify(...)
  set_data(...)
  set_property(...)
  stop_emission(...)
  thaw_notify(...)
    Inherited from object
  __delattr__(...)
x.__delattr__('name') <==> del x.name
  __getattribute__(...)
x.__getattribute__('name') <==> x.name
  __reduce__(...)
helper for pickle
  __reduce_ex__(...)
helper for pickle
  __setattr__(...)
x.__setattr__('name', value) <==> x.name = value
  __str__(x)
x.__str__() <==> str(x)

Instance Variable Summary
    Inherited from BaseComponent
string name: the name of the component

Class Variable Summary
str DELIMITER = '@'
    Inherited from FeedComponent
GType __gtype__ = <GType flumotion+component+feedcomponent010+...
str EATER_TMPL = 'tcpclientsrc name=%(name)s'
str FEEDER_TMPL = 'tcpserversink sync=false name=%(name)s bu...
str logCategory: Implementors can provide a category to log their messages under.
    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 0xf600a8ec>

Method Details

configure_pipeline(self, pipeline, properties)

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.

This could include attaching signals and bus handlers.

create_pipeline(self)

Subclasses have to implement this method.
Returns:
gst.Pipeline
Overrides:
flumotion.component.feedcomponent010.FeedComponent.create_pipeline (inherited documentation)

do_start(self, eatersData, feedersData, clocking)

Tell the component to start, linking itself to other components.
Parameters:
eatersData
           (type=list of (feedername, host, port) tuples of elements feeding our eaters.)
feedersData
           (type=list of (name, host, port) tuples on which to produce data.)
clocking - tuple of (ip, port, base_time) of a master clock, or None not to slave the clock
           (type=tuple(str, int, long) or None.)
Overrides:
flumotion.component.component.BaseComponent.do_start

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.

parse_tmpl(self, pipeline, names, template, format)

Expand the given pipeline string representation by substituting blocks between '@' with a filled-in template.
Parameters:
pipeline - a pipeline string representation with variables
names - the element names to substitute for @...@ segments
template - the template to use for element factory info
format -

the format to use when substituting

Returns: a new pipeline string representation.

set_pipeline(self, pipeline)

Subclasses can override me. They should chain up first.
Overrides:
flumotion.component.feedcomponent010.FeedComponent.set_pipeline (inherited documentation)

Class Variable Details

DELIMITER

Type:
str
Value:
'@'                                                                    

Generated by Epydoc 2.1 on Thu Jan 25 09:31:10 2007 http://epydoc.sf.net