Package flumotion :: Package component :: Package producers :: Package looper :: Module looper :: Class Looper
[hide private]

Class Looper

source code

                 object --+                    
                          |                    
    common.common.InitMixin --+                
                              |                
    extern.log.log.Loggable --+                
                              |                
        component.BaseComponent --+            
                                  |            
     feedcomponent010.FeedComponent --+        
                                      |        
     feedcomponent.ParseLaunchComponent --+    
                                          |    
common.avproducer.avproducer.AVProducerBase --+
                                              |
                                             Looper

Nested Classes [hide private]
child class of BaseComponentMedium componentMediumClass
the medium class to use for this component
Instance Methods [hide private]
 
init(self)
A subclass should do as little as possible in its init method.
source code
list
_do_extra_checks(self)
Subclasses should override this method to perform aditional checks
source code
 
get_raw_video_element(self) source code
 
get_pipeline_template(self) source code
 
make_message_for_gstreamer_error(self, gerror, debug)
Make a flumotion error message to show to the user.
source code
 
run_discoverer(self) source code
 
on_segment_done(self) source code
 
on_pads_blocked(self) 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
 
do_seek(self, flushing)
Restarts the looping.
source code
 
do_setup(self)
Sets up component.
source code
 
do_stop(self)
BaseComponent vmethod for stopping.
source code
 
_parse_aditional_properties(self, properties)
Subclasses should overrride this method to parse aditional properties
source code

Inherited from common.avproducer.avproducer.AVProducerBase: check_properties, do_check, getVolume, get_pipeline_string, setVolume

Inherited from feedcomponent.ParseLaunchComponent: add_default_eater_feeder, create_pipeline, get_eater_srcpad, get_eater_template, get_feeder_sinkpad, get_feeder_template, get_queue_string, parse_pipeline, parse_tmpl, set_pipeline

Inherited from feedcomponent010.FeedComponent: addEffect, attachPadMonitorToElement, attachPadMonitorToFeeder, bus_message_received_cb, cleanup, connect_feeders, do_pipeline_playing, dump_gstreamer_debug_dot_file, eatFromFD, feedToFD, get_element, get_element_property, get_master_clock, get_pipeline, install_eater_continuity_watch, install_eater_event_probes, modify_element_property, provide_master_clock, reconnectEater, set_element_property, set_master_clock, setup_completed, stop_pipeline, try_start_pipeline, unblock_eater

Inherited from component.BaseComponent: __init__, __provides__, addMessage, adminCallRemote, checkPropertyType, fixRenamedProperties, getMood, getName, getWorkerName, modifyProperty, observerAppend, observerRemove, removeMessage, setMedium, setMood, setShutdownHook, setWorkerName, setup, stop, waitForHappy, warnDeprecatedProperties

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

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

Class Variables [hide private]

Inherited from feedcomponent.ParseLaunchComponent: DELIMITER, DEPAY_TMPL, EATER_TMPL, FDSRC_TMPL, FEEDER_TMPL, checkOffset, checkTimestamp

Inherited from feedcomponent010.FeedComponent: FEEDER_STATS_UPDATE_FREQUENCY, dropStreamHeaders, eaters, feeders, logCategory, swallowNewSegment

Inherited from component.BaseComponent: __implemented__

Instance Variables [hide private]

Inherited from component.BaseComponent: medium, name, uiState

Properties [hide private]

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_extra_checks(self)

source code 

Subclasses should override this method to perform aditional checks

Returns: list
A list of checks' defers
Overrides: common.avproducer.avproducer.AVProducerBase._do_extra_checks
(inherited documentation)

get_raw_video_element(self)

source code 
Overrides: common.avproducer.avproducer.AVProducerBase.get_raw_video_element

get_pipeline_template(self)

source code 
Overrides: common.avproducer.avproducer.AVProducerBase.get_pipeline_template

make_message_for_gstreamer_error(self, gerror, debug)

source code 

Make a flumotion error message to show to the user.

This method may be overridden by components that have special knowledge about potential errors. If the component does not know about the error, it can chain up to this implementation, which will make a generic message.

Parameters:
  • gerror - The GError from the error message posted on the GStreamer message bus.
  • debug - A string with debugging information.
Returns:
A flumotion.common.messages.Message to show to the user.
Overrides: feedcomponent010.FeedComponent.make_message_for_gstreamer_error
(inherited documentation)

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.

Overrides: feedcomponent.ParseLaunchComponent.configure_pipeline
(inherited documentation)

do_seek(self, flushing)

source code 

Restarts the looping.

Returns True if the seeking was accepted, Returns False otherwiser

do_setup(self)

source code 

Sets up component.

Invokes the create_pipeline and set_pipeline vmethods, which subclasses can provide.

Overrides: component.BaseComponent.do_setup
(inherited documentation)

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)

_parse_aditional_properties(self, properties)

source code 

Subclasses should overrride this method to parse aditional properties

Overrides: common.avproducer.avproducer.AVProducerBase._parse_aditional_properties
(inherited documentation)