Package ganeti :: Package impexpd

[frames] | no frames]

Package impexpd

source code

Classes and functions for import/export daemon.

Classes

[hide private]

CommandBuilder

ChildIOProcessor

Functions

[hide private]

_VerifyListening(family, address, port)
Verify address given as listening address by socat.

source code

float or None

_CalcThroughput(samples)
Calculates the throughput in MiB/second.

source code

Variables

[hide private]

LISTENING_RE = re.compile(r"^listening on\s+" r"AF=(?P<family>...
Used to recognize point at which socat(1) starts to listen on its socket.

TRANSFER_LOOP_RE = re.compile(r"^starting data transfer loop w...
Used to recognize point at which socat(1) is sending data over the wire

SOCAT_LOG_DEBUG = "D"

SOCAT_LOG_INFO = "I"

SOCAT_LOG_NOTICE = "N"

SOCAT_LOG_WARNING = "W"

SOCAT_LOG_ERROR = "E"

SOCAT_LOG_FATAL = "F"

SOCAT_LOG_IGNORE = frozenset([SOCAT_LOG_DEBUG, SOCAT_LOG_INFO,...

DD_INFO_RE = re.compile(r"^(?P<bytes>\d+)\s*byte(?:|s)\s.*\sco...
Used to parse GNU dd(1) statistics

DD_STDERR_IGNORE = re.compile(r"^\d+\+\d+\s*records\s+(?:in|ou...
Used to ignore "N+N records in/out" on dd(1)'s stderr

DD_INFO_SIGNAL = getattr(signal, "SIGINFO", signal.SIGUSR1)
Signal upon which dd(1) will print statistics (on some platforms, SIGINFO is unavailable and SIGUSR1 is used instead)

BUFSIZE = 1024* 1024
Buffer size: at most this many bytes are transferred at once

SOCAT_TCP_OPTS = ["keepalive", "keepidle=60", "keepintvl=10", ...

SOCAT_OPENSSL_OPTS = ["verify=1", "method=TLSv1", "cipher=%s" ...

SOCAT_OPTION_MAXLEN = 400

PROG_ALL = frozenset([PROG_OTHER, PROG_SOCAT, PROG_DD, PROG_DD...

Imports: os, re, socket, logging, signal, errno, time, StringIO, constants, errors, utils

Function Details

[hide private]

_CalcThroughput(samples)

source code

Calculates the throughput in MiB/second.

Parameters:

samples (sequence) - List of samples, each consisting of a (timestamp, mbytes) tuple

Returns: float or None

Throughput in MiB/second

Variables Details

[hide private]

LISTENING_RE

Used to recognize point at which socat(1) starts to listen on its socket. The local address is required for the remote peer to connect (in particular the port number).

Value:

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

TRANSFER_LOOP_RE

Used to recognize point at which socat(1) is sending data over the wire

Value:

re.compile(r"^starting data transfer loop with FDs\s+.*$", re.I)

SOCAT_LOG_IGNORE

Value:

frozenset([SOCAT_LOG_DEBUG, SOCAT_LOG_INFO, SOCAT_LOG_NOTICE,])

DD_INFO_RE

Used to parse GNU dd(1) statistics

Value:

re.compile(r"^(?P<bytes>\d+)\s*byte(?:|s)\s.*\scopied,\s*" r"(?P<secon
ds>[\d.]+)\s*s(?:|econds),.*$", re.I)

DD_STDERR_IGNORE

Used to ignore "N+N records in/out" on dd(1)'s stderr

Value:

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

SOCAT_TCP_OPTS

Value:

["keepalive", "keepidle=60", "keepintvl=10", "keepcnt=5"]

SOCAT_OPENSSL_OPTS

Value:

["verify=1", "method=TLSv1", "cipher=%s" % constants.OPENSSL_CIPHERS]

PROG_ALL

Value:

frozenset([PROG_OTHER, PROG_SOCAT, PROG_DD, PROG_DD_PID, PROG_EXP_SIZE
,])