Class ChildIOProcessor

source code

Instance Methods

[hide private]

__init__(self, debug, status_file, logger, throughput_samples, exp_size)
Initializes this class.

source code

GetLineSplitter(self, prog)
Returns the line splitter for a program.

source code

FlushAll(self)
Flushes all line splitters.

source code

CloseAll(self)
Closes all line splitters.

source code

NotifyDd(self)
Tells dd(1) to write statistics.

source code

_ProcessOutput(self, line, prog)
Takes care of child process output.

source code

_ProcessDdOutput(self, line)
Interprets a line of dd(1)'s output.

source code

_UpdateDdProgress(self, seconds, mbytes)
Updates the internal status variables for dd(1) progress.

source code

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

Static Methods

[hide private]

_ProcessSocatOutput(status_file, level, msg)
Interprets socat log output.

source code

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self, debug, status_file, logger, throughput_samples, exp_size)
(Constructor)

source code

Initializes this class.

Overrides: object.__init__

_ProcessOutput(self, line, prog)

source code

Takes care of child process output.

Parameters:

line (string) - Child output line
prog (number) - Program from which the line originates

_UpdateDdProgress(self, seconds, mbytes)

source code

Updates the internal status variables for dd(1) progress.

Parameters:

seconds (float) - Timestamp of this update
mbytes (float) - Total number of MiB transferred so far

Class ChildIOProcessor

__init__(self, debug, status_file, logger, throughput_samples, exp_size) (Constructor)

_ProcessOutput(self, line, prog)

_UpdateDdProgress(self, seconds, mbytes)

init(self, debug, status_file, logger, throughput_samples, exp_size)
(Constructor)