Package flumotion :: Package component :: Package common :: Package streamer :: Module fragmentedstreamer :: Class FragmentedStreamer
[hide private]

Class FragmentedStreamer

source code

             object --+                    
                      |                    
common.common.InitMixin --+                
                          |                
extern.log.log.Loggable --+                
                          |                
    component.BaseComponent --+            
                              |            
 feedcomponent010.FeedComponent --+        
                                  |        
 feedcomponent.ParseLaunchComponent --+    
                                      |    
                         object --+   |    
                                  |   |    
                     streamer.Stats --+    
                                      |    
                      streamer.Streamer --+
                                          |
                         object --+       |
                                  |       |
                     streamer.Stats --+   |
                                      |   |
                                  Stats --+
                                          |
                                         FragmentedStreamer

Nested Classes [hide private]
  siteClass
A web site: manage log, sessions, and resources.

Inherited from streamer.Streamer: componentMediumClass

Instance Methods [hide private]
 
init(self)
A subclass should do as little as possible in its init method.
source code
 
isReady(self) source code
 
do_pipeline_playing(self)
Invoked when the pipeline has changed the state to playing.
source code
 
configure_pipeline(self, pipeline, props)
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
 
remove_client(self, session_id) source code
 
update_bytes_received(self, length) source code
 
__repr__(self)
repr(x)
source code
 
_get_root(self) source code
 
_configure_sink(self)
Configure sink properties.
source code
 
_connect_sink_signals(self) source code
 
_sink_pad_probe(self, pad, buffer, none) source code
 
_eos(self, appsink) source code

Inherited from streamer.Streamer: __provides__, check_properties, configure_auth_and_resource, do_setup, do_stop, getDescription, getLoadData, getMaxClients, getStreamData, getUrl, get_content_type, get_mime, get_pipeline_string, hasCaps, parseProperties, remove_all_clients, updatePorterDetails, update_ui_state

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, 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, make_message_for_gstreamer_error, 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__, addMessage, adminCallRemote, checkPropertyType, do_check, fixRenamedProperties, getMood, getName, getWorkerName, modifyProperty, observerAppend, observerRemove, removeMessage, setMedium, setMood, setShutdownHook, setWorkerName, setup, stop, waitForHappy, warnDeprecatedProperties

Inherited from Stats: getBytesReceived, getBytesSent

Inherited from streamer.Stats: __providedBy__, clientAdded, clientRemoved, getAverageClients, getClients, getCurrentBitrate, getLoadDeltas, getPeakClients, getPeakEpoch, getUptime, updateState

Inherited from streamer.Stats (private): _updateAverage, _updateStats

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

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

Class Variables [hide private]
  DEFAULT_MIN_WINDOW = 2
hash(x)
  DEFAULT_MAX_WINDOW = 5
  DEFAULT_SECRET_KEY = 'aR%$w34Y=&08gFm%&!s8080'
  DEFAULT_SESSION_TIMEOUT = 30
  logCategory = 'fragmented-streamer'
Implementors can provide a category to log their messages under.
  multi_files = True

Inherited from streamer.Streamer: __implemented__, checkOffset, pipe_template

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

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

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

source code 

Invoked when the pipeline has changed the state to playing. The default implementation sets the component's mood to HAPPY.

Overrides: feedcomponent010.FeedComponent.do_pipeline_playing
(inherited documentation)

configure_pipeline(self, pipeline, props)

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)

__repr__(self)
(Representation operator)

source code 

repr(x)

Overrides: object.__repr__
(inherited documentation)

_get_root(self)

source code 
Overrides: streamer.Streamer._get_root

_configure_sink(self)

source code 

Configure sink properties. Can be used by subclasses to set configuration parameters in the element