Package ganeti :: Module jqueue :: Class _OpExecCallbacks
[hide private]
[frames] | no frames]

Class _OpExecCallbacks

source code


Instance Methods [hide private]
 
__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 [hide private]

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

source code 

Initializes this class.

Parameters:

NotifyStart(self)

source code 

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)

source code 

Internal feedback append function, with locks

Decorators:
  • @locking.ssynchronized(_QUEUE, shared= 1)

Feedback(self, *args)

source code 

Append a log entry.

Overrides: mcpu.OpExecCbBase.Feedback

CurrentPriority(self)

source code 

Returns current priority for opcode.

Overrides: mcpu.OpExecCbBase.CurrentPriority

SubmitManyJobs(self, jobs)

source code 

Submits jobs for processing.

See JobQueue.SubmitManyJobs.

Overrides: mcpu.OpExecCbBase.SubmitManyJobs