Package flumotion :: Package component :: Package base :: Module producer :: Class Producer
[show private | hide private]
[frames | no frames]

Type Producer

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


Method Summary
  __init__(self, name, feeders, pipeline)
    Inherited from ParseLaunchComponent
  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.
  setup_pipeline(self)
  start(self, eatersData, feedersData)
Tell the component to start, linking itself to other components.
  _expandElementName(self, block)
Expand the given string to a full element name for an eater or feeder.
  _expandElementNames(self, block)
Expand each @..@ block to use the full element name for eater or feeder.
    Inherited from FeedComponent
  addEffect(self, effect)
  cleanup(self)
  create_pipeline(self)
  eater_state_change_cb(self, element, old, state)
Called when the eater element changes state.
  effectPropertyChanged(self, effectName, propertyName, value)
Notify the manager that an effect property has changed to a new value.
  feeder_state_change_cb(self, element, old, state, feed_name)
  get_eater_names(self)
Return the list of feeder names this component eats from.
  get_element(self, element_name)
  get_element_names(self)
Return the names of all elements in the GStreamer pipeline.
  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)
  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)
  pause(self)
  pipeline_pause(self)
  pipeline_play(self)
  pipeline_stop(self)
  play(self)
  restart(self)
  set_element_property(self, element_name, property, value)
Sets a property on an element in the GStreamer pipeline.
  set_feed_ports(self, feed_ports)
  set_state_and_iterate(self, state)
  stop(self)
Tell the component to stop.
  updateMood(self)
Update the mood because a mood condition has changed.
  _eaterReconnect(self, element)
  _pipeline_error_cb(self, object, element, error, arg)
  _setup_eaters(self, eatersData)
Set up the feeded GStreamer elements in our pipeline based on information in the tuple.
  _setup_feeders(self, feedersData)
Set up the feeding GStreamer elements in our pipeline based on information in the tuple.
    Inherited from BaseComponent
  adminCallRemote(self, methodName, *args, **kwargs)
Call a remote method on all admin client views on this component.
  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.
  setWorkerName(self, workerName)
  startHeartbeat(self)
Start sending heartbeats.
  stopHeartbeat(self)
Stop sending heartbeats.
  _heartbeat(self)
Send heartbeat to manager and reschedule.
    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.
    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 logCategory: Implementors can provide a category to log their messages under.
    Inherited from ParseLaunchComponent
str DELIMETER = '@'
str EATER_TMPL = 'tcpclientsrc'
str FEEDER_TMPL = 'tcpserversink buffers-max=500 buffers-sof...
    Inherited from FeedComponent
GType __gtype__ = <GType flumotion+component+feedcomponent+Fee...
int _reconnectInterval = 3                                                                     
    Inherited from BaseComponent
tuple __remote_interfaces__ = (<class 'flumotion.common.interf...
int _heartbeatInterval = 5                                                                     
    Inherited from GObject
str __gdoc__ = 'Object GObject\n\nSignals from GObject:\n  n...
getset_descriptor __grefcount__ = <attribute '__grefcount__' of 'gobject.G...

Class Variable Details

logCategory

Implementors can provide a category to log their messages under.
Type:
str
Value:
'prod-pipe'                                                            

Generated by Epydoc 2.1 on Wed Feb 16 07:22:59 2005 http://epydoc.sf.net