ganeti.masterd.instance.ImportExportLoop

class documentation

class ImportExportLoop(object):

View In Hierarchy

Undocumented

Method __init__ Initializes this class.
Method Add Adds an import/export object to the loop.
Method FinalizeAll Finalizes all pending transfers.
Method Run Utility main loop.
Constant MAX_DELAY Undocumented
Constant MIN_DELAY Undocumented
Static Method _CollectDaemonStatus Collects the status for all import/export daemons.
Static Method _GetActiveDaemonNames Gets the names of all active daemons.
Method _AddPendingToQueue Adds all pending import/export objects to the internal queue.
Instance Variable _lu Undocumented
Instance Variable _pending_add Undocumented
Instance Variable _queue Undocumented
def __init__(self, lu):

Initializes this class.

def Add(self, diskie):

Adds an import/export object to the loop.

Parameters
diskie:Subclass of _DiskImportExportBaseImport/export object
def FinalizeAll(self):

Finalizes all pending transfers.

def Run(self):

Utility main loop.

MAX_DELAY: float =

Undocumented

Value
20.0
MIN_DELAY: float =

Undocumented

Value
1.0
@staticmethod
def _CollectDaemonStatus(lu, daemons):

Collects the status for all import/export daemons.

@staticmethod
def _GetActiveDaemonNames(queue):

Gets the names of all active daemons.

def _AddPendingToQueue(self):

Adds all pending import/export objects to the internal queue.

_lu =

Undocumented

_pending_add: list =

Undocumented

_queue: list =

Undocumented