Package flumotion :: Package component :: Package consumers :: Package disker :: Module disker :: Class Disker

Class Disker

             object --+                
                      |                
common.common.InitMixin --+            
                          |            
    common.log.Loggable --+            
                          |            
             object --+   |            
                      |   |            
             ??.GObject --+            
                          |            
    component.BaseComponent --+        
                              |        
 feedcomponent010.FeedComponent --+    
                                  |    
 feedcomponent.ParseLaunchComponent --+
                                      |
                common.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)

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

schedule_recording(self, whenStart, whenEnd, recur=None, filenameTemplate=None)
Sets a recording to start at a time in the future for a specified duration.

source code

start_scheduled_recording(self, recurRule, when, filenameTemplate)

source code

stop_scheduled_recording(self, recurRule, when)

source code

parse_ical(self, icsStr)

source code

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

Inherited from feedcomponent.ParseLaunchComponent (private): _expandElementName, _expandElementNames

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, link, parseEaterConfig, parseFeederConfig, pipeline_stop, provide_master_clock, removeClientCallback, set_element_property, set_master_clock, setup_pipeline, unblock_eater

Inherited from feedcomponent010.FeedComponent (private): _addStateChangeDeferred, _add_buffer_probe, _buffer_probe_cb, _checkEater, _depay_eater_event_probe_cb, _eater_event_probe_cb, _feeder_probe_calllater, _getStateChange, _reconnectEater

Inherited from component.BaseComponent: __init__, addMessage, adminCallRemote, do_check, emit, fixRenamedProperties, getMood, getName, getWorkerName, setMedium, setMood, setShutdownHook, setWorkerName, setup, start, stop

Inherited from component.BaseComponent (private): _setConfig, _updateCPUUsage

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

Inherited from unreachable.GObject: __cmp__, __copy__, __deepcopy__, __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: __format__, __getattribute__, __reduce__, __reduce_ex__, __sizeof__, __str__, __subclasshook__

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
hash(x)

directory = None
hash(x)

location = None
hash(x)

caps = None
hash(x)

__gtype__ = <GType flumotion+component+consumers+disker+disker...

Inherited from feedcomponent.ParseLaunchComponent: DELIMITER

Inherited from feedcomponent010.FeedComponent: BUFFER_CHECK_FREQUENCY, BUFFER_PROBE_ADD_FREQUENCY, BUFFER_TIME_THRESHOLD, DEPAY_TMPL, FDSRC_TMPL, FEEDER_TMPL, checkTimestamp, logCategory

Inherited from feedcomponent010.FeedComponent (private): _reconnectInterval

Inherited from common.log.Loggable: __implemented__, __provides__

Instance Variables

[hide private]

Inherited from component.BaseComponent: medium, name

Properties

[hide private]

Inherited from unreachable.GObject: __grefcount__

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)

source code

Parameters:

filenameTemplate - strftime formatted string to decide filename

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)

schedule_recording(self, whenStart, whenEnd, recur=None, filenameTemplate=None)

source code

Sets a recording to start at a time in the future for a specified duration. @param whenStart time of when to start recording @type whenStart datetime @param whenEnd time of when to end recording @type whenEnd datetime @param recur recurrence rule @type recur icalendar.props.vRecur @param filenameTemplate strftime formatted string to decide filename @type filenameTemplate string

Class Variable Details

[hide private]

pipe_template

Value:

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

gtype

Value:

<GType flumotion+component+consumers+disker+disker+Disker (35011104)>