Package ganeti :: Package masterd :: Module instance :: Class _DiskImportExportBase

[frames] | no frames]

Class _DiskImportExportBase

source code

Instance Methods

[hide private]

__init__(self, lu, node_name, opts, instance, timeouts, cbs, private=None)
Initializes this class.

source code

recent_output(self)
Returns the most recent output from the daemon.

source code

progress(self)
Returns transfer progress information.

source code

magic(self)
Returns the magic value for this import/export.

source code

active(self)
Determines whether this transport is still active.

source code

ImportExportLoop

loop(self)
Returns parent loop.

source code

SetLoop(self, loop)
Sets the parent loop.

source code

_StartDaemon(self)
Starts the import/export daemon.

source code

string

CheckDaemon(self)
Checks whether daemon has been started and if not, starts it.

source code

GetDaemonName(self)
Returns the daemon name.

source code

Abort(self)
Sends SIGTERM to import/export daemon (if still active).

source code

_SetDaemonData(self, data)
Internal function for updating status daemon data.

source code

SetDaemonData(self, success, data)
Updates daemon status data.

source code

CheckListening(self)
Checks whether the daemon is listening.

source code

_GetConnectedCheckEpoch(self)
Returns timeout to calculate connect timeout.

source code

bool

CheckConnected(self)
Checks whether the daemon is connected.

source code

_CheckProgress(self)
Checks whether a progress update should be reported.

source code

bool

CheckFinished(self)
Checks whether the daemon exited.

source code

_ReportFinished(self, success, message)
Transfer is finished or daemon exited.

source code

_Finalize(self)
Makes the RPC call to finalize this import/export.

source code

Finalize(self, error=None)
Finalizes this import/export.

source code

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

Class Variables

[hide private]

MODE_TEXT = None

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self, lu, node_name, opts, instance, timeouts, cbs, private=None)
(Constructor)

source code

Initializes this class.

Parameters:

lu - Logical unit instance
node_name (string) - Node name for import
opts (objects.ImportExportOptions) - Import/export daemon options
instance (objects.Instance) - Instance object
timeouts (ImportExportTimeouts) - Timeouts for this import
cbs (ImportExportCbBase) - Callbacks
private - Private data for callback functions

Overrides: object.__init__

recent_output(self)

source code

Returns the most recent output from the daemon.

Decorators:

@property

progress(self)

source code

Returns transfer progress information.

Decorators:

@property

magic(self)

source code

Returns the magic value for this import/export.

Decorators:

@property

active(self)

source code

Determines whether this transport is still active.

Decorators:

@property

loop(self)

source code

Returns parent loop.

Returns: ImportExportLoop

Decorators:

@property

SetLoop(self, loop)

source code

Sets the parent loop.

Parameters:

loop (ImportExportLoop)

CheckDaemon(self)

source code

Checks whether daemon has been started and if not, starts it.

Returns: string: Daemon name

_SetDaemonData(self, data)

source code

Internal function for updating status daemon data.

Parameters:

data (objects.ImportExportStatus) - Daemon status data

SetDaemonData(self, success, data)

source code

Updates daemon status data.

Parameters:

success (bool) - Whether fetching data was successful or not
data (objects.ImportExportStatus) - Daemon status data

CheckConnected(self)

source code

Checks whether the daemon is connected.

Returns: bool: Whether the daemon is connected

CheckFinished(self)

source code

Checks whether the daemon exited.

Returns: bool: Whether the transfer is finished

_ReportFinished(self, success, message)

source code

Transfer is finished or daemon exited.

Parameters:

success (bool) - Whether the transfer was successful
message (string) - Error message

Class _DiskImportExportBase

__init__(self, lu, node_name, opts, instance, timeouts, cbs, private=None) (Constructor)

recent_output(self)

progress(self)

magic(self)

active(self)

loop(self)

SetLoop(self, loop)

CheckDaemon(self)

_SetDaemonData(self, data)

SetDaemonData(self, success, data)

CheckConnected(self)

CheckFinished(self)

_ReportFinished(self, success, message)

init(self, lu, node_name, opts, instance, timeouts, cbs, private=None)
(Constructor)