Package flumotion :: Package component :: Module feedcomponent :: Class ParseLaunchComponent
[hide private]

Class ParseLaunchComponent

source code

             object --+            
                      |            
common.common.InitMixin --+        
                          |        
    common.log.Loggable --+        
                          |        
             object --+   |        
                      |   |        
        gobject.GObject --+        
                          |        
    component.BaseComponent --+    
                              |    
 feedcomponent010.FeedComponent --+
                                  |
                                 ParseLaunchComponent
Known Subclasses:

A component using gst-launch syntax

Nested Classes [hide private]

Inherited from component.BaseComponent: componentMediumClass

Instance Methods [hide private]
gst.Pipeline
create_pipeline(self)
Subclasses have to implement this method.
source code
 
set_pipeline(self, pipeline)
Subclasses can override me.
source code
 
get_pipeline_string(self, properties)
Method that must be implemented by subclasses to produce the gstparse string for the component's pipeline.
source code
 
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.
source code
 
_expandElementName(self, block)
Expand the given string to a full element name for an eater or feeder.
source code
 
_expandElementNames(self, block)
Expand each @..@ block to use the full element name for eater or feeder.
source code
 
parse_tmpl(self, pipeline, names, template_func, format)
Expand the given pipeline string representation by substituting blocks between '@' with a filled-in template.
source code
 
parse_pipeline(self, pipeline) source code
 
get_eater_template(self, eaterName) source code
 
get_feeder_template(self, eaterName) source code
 
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
source code
 
do_start(self, clocking)
Tell the component to start.
source code

Inherited from feedcomponent010.FeedComponent: addEffect, bus_watch_func, cleanup, do_setup, do_stop, eatFromFD, eaterOffsetDiscont, eaterSetActive, eaterSetInactive, eaterTimestampDiscont, effectPropertyChanged, feedToFD, get_eater_names, get_element, get_element_property, get_feed_names, get_feeder_names, get_pipeline, init, 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]
  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]

create_pipeline(self)

source code 

Subclasses have to implement this method.

Returns: gst.Pipeline
Overrides: feedcomponent010.FeedComponent.create_pipeline
(inherited documentation)

set_pipeline(self, pipeline)

source code 

Subclasses can override me. They should chain up first.

Overrides: feedcomponent010.FeedComponent.set_pipeline
(inherited documentation)

get_pipeline_string(self, properties)

source code 

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.

configure_pipeline(self, pipeline, properties)

source code 

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.

_expandElementName(self, block)

source code 

Expand the given string to a full element name for an eater or feeder. The full name is of the form eater:(sourceComponentName):(feedName) or feeder:(componentName):feedName

_expandElementNames(self, block)

source code 

Expand each @..@ block to use the full element name for eater or feeder. The full name is of the form eater:(sourceComponentName):(feedName) or feeder:(componentName):feedName This also does some basic checking of the block.

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

source code 

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_func - function to call to get the template to use for element factory info
  • format - the format to use when substituting

    Returns: a new pipeline string representation.

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(str, int, long) or None.) - 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