ganeti.impexpd.ChildIOProcessor

class documentation

class ChildIOProcessor(object):

Undocumented

Method	`__init__`	Initializes this class.
Method	`CloseAll`	Closes all line splitters.
Method	`FlushAll`	Flushes all line splitters.
Method	`GetLineSplitter`	Returns the line splitter for a program.
Method	`NotifyDd`	Tells dd(1) to write statistics.
Static Method	`_ProcessSocatOutput`	Interprets socat log output.
Method	`_ProcessDdOutput`	Interprets a line of dd(1)'s output.
Method	`_ProcessOutput`	Takes care of child process output.
Method	`_UpdateDdProgress`	Updates the internal status variables for dd(1) progress.
Instance Variable	`_dd_pid`	Undocumented
Instance Variable	`_dd_progress`	Undocumented
Instance Variable	`_dd_ready`	Undocumented
Instance Variable	`_dd_tp_samples`	Undocumented
Instance Variable	`_debug`	Undocumented
Instance Variable	`_exp_size`	Undocumented
Instance Variable	`_logger`	Undocumented
Instance Variable	`_splitter`	Undocumented
Instance Variable	`_status_file`	Undocumented

def __init__(self, debug, status_file, logger, throughput_samples, exp_size): ¶

Initializes this class.

def CloseAll(self): ¶

Closes all line splitters.

def FlushAll(self): ¶

Flushes all line splitters.

def GetLineSplitter(self, prog): ¶

Returns the line splitter for a program.

def NotifyDd(self): ¶

Tells dd(1) to write statistics.

@staticmethod
def _ProcessSocatOutput(status_file, level, msg): ¶

Interprets socat log output.

def _ProcessDdOutput(self, line): ¶

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

def _ProcessOutput(self, line, prog): ¶

Takes care of child process output.

Parameters
line:string	Child output line
prog:number	Program from which the line originates

def _UpdateDdProgress(self, seconds, mbytes): ¶

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

_dd_pid = ¶

Undocumented

_dd_progress: list = ¶

Undocumented

_dd_ready: bool = ¶

Undocumented

_dd_tp_samples = ¶

Undocumented

_debug = ¶

Undocumented

_exp_size = ¶

Undocumented

_logger = ¶

Undocumented

_splitter = ¶

Undocumented

_status_file = ¶

Undocumented