Package ganeti :: Module jqueue :: Class _OpExecCallbacks

[frames] | no frames]

Class _OpExecCallbacks

Instance Methods

__init__(self, queue, job, op)
Initializes this class.

source code

_CheckCancel(self)
Raises an exception to cancel the job if asked to.

source code

NotifyStart(self)
Mark the opcode as running, not lock-waiting.

source code

_AppendFeedback(self, timestamp, log_type, log_msg)
Internal feedback append function, with locks

source code

Feedback(self, *args)
Append a log entry.

source code

CheckCancel(self)
Check whether job has been cancelled.

source code

Method Details

init(self, queue, job, op)
(Constructor)

Initializes this class.

Parameters:

queue (JobQueue) - Job queue
job (_QueuedJob) - Job object
op (_QueuedOpCode) - OpCode

NotifyStart(self)

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_WAITLOCK.

Decorators:

@locking.ssynchronized(_QUEUE, shared= 1)

Overrides: mcpu.OpExecCbBase.NotifyStart

_AppendFeedback(self, timestamp, log_type, log_msg)

Internal feedback append function, with locks

Decorators:

@locking.ssynchronized(_QUEUE, shared= 1)

Feedback(self, *args)

Append a log entry.

Overrides: mcpu.OpExecCbBase.Feedback

CheckCancel(self)

Check whether job has been cancelled.

Overrides: mcpu.OpExecCbBase.CheckCancel