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

CurrentPriority(self)
Returns current priority for opcode.

source code

SubmitManyJobs(self, jobs)
Submits jobs for processing.

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

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

CurrentPriority(self)

Returns current priority for opcode.

Overrides: mcpu.OpExecCbBase.CurrentPriority

SubmitManyJobs(self, jobs)

Submits jobs for processing.

See JobQueue.SubmitManyJobs.

Overrides: mcpu.OpExecCbBase.SubmitManyJobs