Package flumotion :: Package component :: Package consumers :: Package disker :: Module disker :: Class Disker
[hide private]

Class Disker

source code

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

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
 
get_pipeline_string(self, properties)
Method that must be implemented by subclasses to produce the gstparse string for the component's pipeline.
source code
 
setTimeRotate(self, time) source code
 
setSizeRotate(self, size) source code
 
_rotateTimeCallback(self, time) source code
 
_rotateSizeCallback(self, size) source code
 
get_mime(self) source code
 
get_content_type(self) source code
 
change_filename(self, filenameTemplate=None, timeOrTuple=None) source code
 
update_symlink(self, src, dest) source code
 
stop_recording(self) source code
 
_notify_caps_cb(self, pad, param) source code
 
_client_removed_cb(self, element, arg0, client_status) source code
 
_client_error_cb(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
 
eventStarted(self, event) source code
 
eventEnded(self, event) source code
 
parse_ical(self, icsStr) source code
 
_plug_recording_started(self, file, location) source code
 
_plug_recording_stopped(self, file, location) source code
 
_markers_event_probe(self, element, event) source code
 
_on_marker_stop(self) source code
 
_on_marker_start(self, data) source code

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

Inherited from feedcomponent010.FeedComponent: addEffect, attachPadMonitorToFeeder, bus_message_received_cb, cleanup, connect_feeders, do_pipeline_playing, do_setup, do_stop, 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, 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, check_properties, do_check, fixRenamedProperties, getMood, getName, getWorkerName, setMedium, setMood, setShutdownHook, setWorkerName, setup, stop, waitForHappy

Inherited from component.BaseComponent (private): _pollCPU, _pollMemory

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

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

Class Variables [hide private]
  checkOffset = True
whether to check continuity of offsets for eaters
  pipe_template = 'multifdsink sync-method=1 name=fdsink mode=1 ...
  file = None
  directory = None
  location = None
  caps = None

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

Inherited from feedcomponent010.FeedComponent: FEEDER_STATS_UPDATE_FREQUENCY, logCategory

Inherited from extern.log.log.Loggable: __implemented__, __provides__

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)

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.

Overrides: feedcomponent.ParseLaunchComponent.get_pipeline_string
(inherited documentation)

setTimeRotate(self, time)

source code 
Parameters:
  • time - duration of file (in seconds)

setSizeRotate(self, size)

source code 
Parameters:
  • size - size of file (in bytes)

change_filename(self, filenameTemplate=None, timeOrTuple=None)

source code 
Parameters:
  • filenameTemplate - strftime formatted string to decide filename
  • timeOrTuple - a valid time to pass to strftime, defaulting to time.localtime(). A 9-tuple may be passed instead.

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)

Class Variable Details [hide private]

pipe_template

Value:
'multifdsink sync-method=1 name=fdsink mode=1 sync=false'