Package ganeti :: Package impexpd :: Class ChildIOProcessor
[hide private]
[frames] | no frames]

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