Package flumotion :: Package component :: Package common :: Package streamer :: Module multifdsinkstreamer :: Class MultifdSinkStreamer
[hide private]

Class MultifdSinkStreamer

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 --+
                                          |
                                         MultifdSinkStreamer
Known Subclasses:

Nested Classes [hide private]

Inherited from streamer.Streamer: componentMediumClass, siteClass

Instance Methods [hide private]
 
setup_burst_mode(self, sink) source code
 
parseExtraProperties(self, properties) source code
 
_configure_sink(self, sink) source code
 
check_properties(self, props, addMessage)
BaseComponent convenience vmethod for running checks.
source code
 
configure_auth_and_resource(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
 
_get_root(self) source code
 
__repr__(self)
repr(x)
source code
 
getMaxClients(self) source code
 
get_mime(self) source code
 
get_content_type(self) source code
 
add_client(self, fd, request) source code
 
remove_client(self, fd) source code
 
remove_all_clients(self)
Remove all the clients.
source code
 
_client_added_handler(self, sink, fd) source code
 
_client_removed_handler(self, sink, fd, reason, stats) source code
 
_notify_caps_cb(self, element, pad, param) source code
 
_client_removed_cb(self, sink, fd, reason) source code
 
_client_fd_removed_cb(self, sink, fd) source code

Inherited from streamer.Streamer: __provides__, do_pipeline_playing, do_setup, do_stop, getDescription, getLoadData, getStreamData, getUrl, get_pipeline_string, hasCaps, init, parseProperties, 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]
  pipe_template = 'multifdsink name=sink sync=false recover-poli...
  defaultSyncMethod = 0

Inherited from streamer.Streamer: __implemented__, checkOffset, logCategory, multi_files

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]

check_properties(self, props, addMessage)

source code 

BaseComponent convenience vmethod for running checks.

A component implementation can override this method to run any checks that it needs to. Typically, a check_properties implementation will call the provided addMessage() callback to note warnings or errors. For errors, addMessage() will set component's mood to sad, which will abort the init process before getting to do_setup().

Parameters:
  • properties - The component's properties
  • addMessage - Thunk to add a message to the component state. Will raise an exception if the message is of level ERROR.
Overrides: component.BaseComponent.check_properties
(inherited documentation)

configure_auth_and_resource(self)

source code 
Overrides: streamer.Streamer.configure_auth_and_resource

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)

_get_root(self)

source code 
Overrides: streamer.Streamer._get_root

__repr__(self)
(Representation operator)

source code 

repr(x)

Overrides: object.__repr__
(inherited documentation)

getMaxClients(self)

source code 
Overrides: streamer.Streamer.getMaxClients

get_mime(self)

source code 
Overrides: streamer.Streamer.get_mime

get_content_type(self)

source code 
Overrides: streamer.Streamer.get_content_type

remove_all_clients(self)

source code 

Remove all the clients.

Returns a deferred fired once all clients have been removed.

Overrides: streamer.Streamer.remove_all_clients

Class Variable Details [hide private]

pipe_template

Value:
'multifdsink name=sink sync=false recover-policy=3'