Package flumotion :: Package component :: Package producers :: Package unixdomain :: Module unixdomain :: Class UnixDomainProvider
[hide private]

Class UnixDomainProvider

source code

             object --+                
                      |                
common.common.InitMixin --+            
                          |            
    common.log.Loggable --+            
                          |            
             object --+   |            
                      |   |            
        gobject.GObject --+            
                          |            
    component.BaseComponent --+        
                              |        
 feedcomponent010.FeedComponent --+    
                                  |    
 feedcomponent.ParseLaunchComponent --+
                                      |
                common.log.Loggable --+
                                      |
                                     UnixDomainProvider

Nested Classes [hide private]

Inherited from component.BaseComponent: componentMediumClass

Instance Methods [hide private]
 
init(self)
A subclass should do as little as possible in its init method.
source code
 
do_setup(self)
Sets up component.
source code
 
setUnixTransport(self, transport) source code
 
get_pipeline_string(self, properties)
return the pipeline
source code
 
do_stop(self)
BaseComponent vmethod for stopping.
source code
 
do_start(self, clocking)
Tell the component to start.
source code

Inherited from feedcomponent.ParseLaunchComponent: configure_pipeline, create_pipeline, get_eater_template, get_feeder_template, get_queue_string, parse_pipeline, parse_tmpl, set_pipeline

Inherited from feedcomponent010.FeedComponent: addEffect, bus_watch_func, cleanup, eatFromFD, eaterOffsetDiscont, eaterSetActive, eaterSetInactive, eaterTimestampDiscont, effectPropertyChanged, feedToFD, get_eater_names, get_element, get_element_property, get_feed_names, get_feeder_names, get_pipeline, link, parseEaterConfig, parseFeederConfig, pipeline_stop, provide_master_clock, removeClientCallback, set_element_property, set_master_clock, setup_pipeline, unblock_eater

Inherited from component.BaseComponent: __init__, addMessage, adminCallRemote, do_check, emit, fixRenamedProperties, getMood, getName, getWorkerName, setMedium, setMood, setShutdownHook, setWorkerName, setup, start, stop

Inherited from common.log.Loggable: __providedBy__, debug, doLog, error, info, log, logFunction, logObjectName, warning, warningFailure

Inherited from gobject.GObject: __cmp__, __delattr__, __gdoc__, __gobject_init__, __hash__, __new__, __repr__, __setattr__, chain, connect, connect_after, connect_object, connect_object_after, disconnect, disconnect_by_func, emit_stop_by_name, freeze_notify, get_data, get_properties, get_property, handler_block, handler_block_by_func, handler_disconnect, handler_is_connected, handler_unblock, handler_unblock_by_func, notify, props, set_data, set_properties, set_property, stop_emission, thaw_notify, weak_ref

Inherited from object: __getattribute__, __reduce__, __reduce_ex__, __str__

Class Variables [hide private]

Inherited from feedcomponent.ParseLaunchComponent: DELIMITER

Inherited from feedcomponent010.FeedComponent: BUFFER_CHECK_FREQUENCY, BUFFER_PROBE_ADD_FREQUENCY, BUFFER_TIME_THRESHOLD, DEPAY_TMPL, FDSRC_TMPL, FEEDER_TMPL, __gtype__, checkOffset, checkTimestamp, logCategory

Inherited from common.log.Loggable: __implemented__, __provides__

Instance Variables [hide private]

Inherited from component.BaseComponent: medium, name

Properties [hide private]

Inherited from gobject.GObject: __grefcount__

Inherited from object: __class__

Method Details [hide private]

init(self)

source code 

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.

Overrides: component.BaseComponent.init
(inherited documentation)

do_setup(self)

source code 

Sets up component.

Returns:
twisted.internet.defer.Deferred
Overrides: component.BaseComponent.do_setup
(inherited documentation)

get_pipeline_string(self, properties)

source code 

return the pipeline

Overrides: feedcomponent.ParseLaunchComponent.get_pipeline_string

do_stop(self)

source code 

BaseComponent vmethod for stopping. The component should do any cleanup it needs, but must not set the component's mood to sleeping.

Returns:
twisted.internet.defer.Deferred
Overrides: component.BaseComponent.do_stop
(inherited documentation)

do_start(self, clocking)

source code 

Tell the component to start. Whatever is using the component is responsible for making sure all eaters have received their file descriptor to eat from.

Parameters:
  • clocking - tuple of (ip, port, base_time) of a master clock, or None not to slave the clock
Returns:
twisted.internet.defer.Deferred
Overrides: component.BaseComponent.do_start
(inherited documentation)