ganeti.impexpd

package documentation

Classes and functions for import/export daemon.

From __init__.py:

Class ChildIOProcessor No class docstring; 0/9 instance variable, 8/8 methods, 1/1 static method documented
Class CommandBuilder No class docstring; 0/5 instance variable, 0/1 constant, 6/6 methods, 1/1 static method, 1/1 class method documented
Constant BUFSIZE Undocumented
Constant DD_INFO_RE Undocumented
Constant DD_INFO_SIGNAL Undocumented
Constant DD_STDERR_IGNORE Undocumented
Constant LISTENING_RE Undocumented
Constant PROG_ALL Undocumented
Constant PROG_DD Undocumented
Constant PROG_DD_PID Undocumented
Constant PROG_EXP_SIZE Undocumented
Constant PROG_OTHER Undocumented
Constant PROG_SOCAT Undocumented
Constant SOCAT_LOG_DEBUG Undocumented
Constant SOCAT_LOG_ERROR Undocumented
Constant SOCAT_LOG_FATAL Undocumented
Constant SOCAT_LOG_IGNORE Undocumented
Constant SOCAT_LOG_INFO Undocumented
Constant SOCAT_LOG_NOTICE Undocumented
Constant SOCAT_LOG_WARNING Undocumented
Constant SOCAT_OPENSSL_OPTS Undocumented
Constant SOCAT_OPTION_MAXLEN Undocumented
Constant SOCAT_TCP_OPTS Undocumented
Constant TRANSFER_LOOP_RE Undocumented
Function _CalcThroughput Calculates the throughput in MiB/second.
Function _VerifyListening Verify address given as listening address by socat.
LISTENING_RE =

Undocumented

Value
re.compile(r'^listening on\s+AF=(?P<family>\d+)\s+(?P<address>.+):(?P<port>\d+)$'↵
,
           re.I)
TRANSFER_LOOP_RE =

Undocumented

Value
re.compile(r'^starting data transfer loop with FDs\s+.*$',
           re.I)
SOCAT_LOG_DEBUG: str =

Undocumented

Value
'D'
SOCAT_LOG_INFO: str =

Undocumented

Value
'I'
SOCAT_LOG_NOTICE: str =

Undocumented

Value
'N'
SOCAT_LOG_WARNING: str =

Undocumented

Value
'W'
SOCAT_LOG_ERROR: str =

Undocumented

Value
'E'
SOCAT_LOG_FATAL: str =

Undocumented

Value
'F'
SOCAT_LOG_IGNORE =

Undocumented

Value
compat.UniqueFrozenset([SOCAT_LOG_DEBUG, SOCAT_LOG_INFO, SOCAT_LOG_NOTICE])
DD_INFO_RE =

Undocumented

Value
re.compile(r'^(?P<bytes>\d+)\s*byte(?:|s)\s.*\scopied,\s*(?P<seconds>[\d\.]+)\s*↵
s(?:|econds),.*$',
           re.I)
DD_STDERR_IGNORE =

Undocumented

Value
re.compile(r'^\d+\+\d+\s*records\s+(?:in|out)$',
           re.I)
DD_INFO_SIGNAL =

Undocumented

Value
getattr(signal, 'SIGINFO', signal.SIGUSR1)
BUFSIZE =

Undocumented

Value
1024*1024
SOCAT_TCP_OPTS: list[str] =

Undocumented

Value
['keepalive', 'keepidle=60', 'keepintvl=10', 'keepcnt=5']
SOCAT_OPENSSL_OPTS =

Undocumented

Value
['verify=1', 'cipher=%s'%constants.OPENSSL_CIPHERS]
SOCAT_OPTION_MAXLEN: int =

Undocumented

Value
400
PROG_OTHER =

Undocumented

PROG_SOCAT =

Undocumented

PROG_DD =

Undocumented

PROG_DD_PID =

Undocumented

PROG_EXP_SIZE =

Undocumented

PROG_ALL =

Undocumented

Value
compat.UniqueFrozenset([PROG_OTHER,
                        PROG_SOCAT,
                        PROG_DD,
                        PROG_DD_PID,
                        PROG_EXP_SIZE])
def _VerifyListening(family, address, port):

Verify address given as listening address by socat.

def _CalcThroughput(samples):

Calculates the throughput in MiB/second.

Parameters
samples:sequenceList of samples, each consisting of a (timestamp, mbytes) tuple
Returns
float or NoneThroughput in MiB/second