ganeti.jqueue._OpExecCallbacks

class documentation

class _OpExecCallbacks(mcpu.OpExecCbBase):

View In Hierarchy

Undocumented

Method __init__ Initializes this class.
Method CurrentPriority Returns current priority for opcode.
Method Feedback Append a log entry.
Method NotifyRetry Mark opcode again as lock-waiting.
Method NotifyStart Mark the opcode as running, not lock-waiting.
Method SubmitManyJobs Submits jobs for processing.
Method _AppendFeedback Internal feedback append function, with locks
Method _CheckCancel Raises an exception to cancel the job if asked to.
Instance Variable _job Undocumented
Instance Variable _op Undocumented
Instance Variable _queue Undocumented
def __init__(self, queue, job, op):

Initializes this class.

Parameters
queue:JobQueueJob queue
job:_QueuedJobJob object
op:_QueuedOpCodeOpCode
def CurrentPriority(self):
overrides ganeti.mcpu.OpExecCbBase.CurrentPriority

Returns current priority for opcode.

def Feedback(self, *args):
overrides ganeti.mcpu.OpExecCbBase.Feedback

Append a log entry.

Calling conventions: arg[0]: (optional) string, message type (Types.ELogType) arg[1]: data to be interpreted as a message

def NotifyRetry(self):
overrides ganeti.mcpu.OpExecCbBase.NotifyRetry

Mark opcode again as lock-waiting.

This is called from the mcpu code just after calling PrepareRetry. The opcode will now again acquire locks (more, hopefully).

def NotifyStart(self):
overrides ganeti.mcpu.OpExecCbBase.NotifyStart

Mark the opcode as running, not lock-waiting.

This is called from the mcpu code as a notifier function, when the LU is finally about to start the Exec() method. Of course, to have end-user visible results, the opcode must be initially (before calling into Processor.ExecOpCode) set to OP_STATUS_WAITING.

def SubmitManyJobs(self, jobs):
overrides ganeti.mcpu.OpExecCbBase.SubmitManyJobs

Submits jobs for processing.

See JobQueue.SubmitManyJobs.

def _AppendFeedback(self, timestamp, log_type, log_msgs):

Internal feedback append function, with locks

Parameters
timestamp:tuple (int, int)timestamp of the log message
log_type:stringlog type (one of Types.ELogType)
log_msgs:anylog data to append
def _CheckCancel(self):

Raises an exception to cancel the job if asked to.

_job =

Undocumented

_op =

Undocumented

_queue =

Undocumented