ganeti.masterd.instance.DiskImport

class documentation

class DiskImport(_DiskImportExportBase):

Undocumented

Method	`__init__`	Initializes this class.
Method	`CheckListening`	Checks whether the daemon is listening.
Constant	`MODE_TEXT`	Undocumented
Property	`listen_port`	Returns the port the daemon is listening on.
Method	`_GetConnectedCheckEpoch`	Returns the time since we started listening.
Method	`_StartDaemon`	Starts the import daemon.
Instance Variable	`_dest`	Undocumented
Instance Variable	`_dest_args`	Undocumented
Instance Variable	`_ts_listening`	Undocumented

Inherited from _DiskImportExportBase:

Method	`Abort`	Sends SIGTERM to import/export daemon (if still active).
Method	`CheckConnected`	Checks whether the daemon is connected.
Method	`CheckDaemon`	Checks whether daemon has been started and if not, starts it.
Method	`CheckFinished`	Checks whether the daemon exited.
Method	`Finalize`	Finalizes this import/export.
Method	`GetDaemonName`	Returns the daemon name.
Method	`SetDaemonData`	Updates daemon status data.
Method	`SetLoop`	Sets the parent loop.
Instance Variable	`final_message`	Undocumented
Instance Variable	`node_name`	Undocumented
Instance Variable	`node_uuid`	Undocumented
Instance Variable	`success`	Undocumented
Property	`active`	Determines whether this transport is still active.
Property	`loop`	Returns parent loop.
Property	`magic`	Returns the magic value for this import/export.
Property	`progress`	Returns transfer progress information.
Property	`recent_output`	Returns the most recent output from the daemon.
Method	`_CheckProgress`	Checks whether a progress update should be reported.
Method	`_Finalize`	Makes the RPC call to finalize this import/export.
Method	`_ReportFinished`	Transfer is finished or daemon exited.
Method	`_SetDaemonData`	Internal function for updating status daemon data.
Instance Variable	`_cbs`	Undocumented
Instance Variable	`_component`	Undocumented
Instance Variable	`_daemon`	Undocumented
Instance Variable	`_daemon_name`	Undocumented
Instance Variable	`_instance`	Undocumented
Instance Variable	`_loop`	Undocumented
Instance Variable	`_lu`	Undocumented
Instance Variable	`_opts`	Undocumented
Instance Variable	`_private`	Undocumented
Instance Variable	`_timeouts`	Undocumented
Instance Variable	`_ts_begin`	Undocumented
Instance Variable	`_ts_cleanup`	Undocumented
Instance Variable	`_ts_connected`	Undocumented
Instance Variable	`_ts_finished`	Undocumented
Instance Variable	`_ts_last_error`	Undocumented
Instance Variable	`_ts_last_progress`	Undocumented

def __init__(self, lu, node_uuid, opts, instance, component, dest, dest_args, timeouts, cbs, private=None): ¶

overrides ganeti.masterd.instance._DiskImportExportBase.__init__

Initializes this class.

Parameters
lu	Logical unit instance
node_uuid:string	Node name for import
opts:`objects.ImportExportOptions`	Import/export daemon options
instance:`objects.Instance`	Instance object
component:string	which part of the instance is being imported
dest	I/O destination
dest_args	I/O arguments
timeouts:`ImportExportTimeouts`	Timeouts for this import
cbs:`ImportExportCbBase`	Callbacks
private	Private data for callback functions

def CheckListening(self): ¶

overrides ganeti.masterd.instance._DiskImportExportBase.CheckListening

Checks whether the daemon is listening.

Returns
bool	Whether the daemon is listening

MODE_TEXT: str = ¶

overrides ganeti.masterd.instance._DiskImportExportBase.MODE_TEXT

Undocumented

Value

'import'

@property
listen_port = ¶

Returns the port the daemon is listening on.

def _GetConnectedCheckEpoch(self): ¶

overrides ganeti.masterd.instance._DiskImportExportBase._GetConnectedCheckEpoch

Returns the time since we started listening.

def _StartDaemon(self): ¶

overrides ganeti.masterd.instance._DiskImportExportBase._StartDaemon

Starts the import daemon.

_dest = ¶

Undocumented

_dest_args = ¶

Undocumented

_ts_listening = ¶

Undocumented