Package ganeti :: Module jqueue :: Class _JobQueueWorker

[frames] | no frames]

Class _JobQueueWorker

The actual job workers.

Instance Methods

RunTask(self, job)
Job executor.

source code

_RunTaskInner(self, job)
Executes a job.

source code

Inherited from workerpool.BaseWorker: GetCurrentPriority, SetTaskName, ShouldTerminate, __init__, run

Inherited from workerpool.BaseWorker (private): _HasRunningTaskUnlocked

Inherited from threading.Thread: __repr__, daemon, getName, ident, isAlive, isDaemon, is_alive, join, name, setDaemon, setName, start

Inherited from threading.Thread (private): _set_daemon, _set_ident

Inherited from threading._Verbose (private): _note

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __setattr__, __sizeof__, __str__, __subclasshook__

Static Methods

_WrapExecOpCode(setname_fn, execop_fn, op, *args, **kwargs)
Updates the worker thread name to include a short summary of the opcode.

source code

_GetWorkerName(job, op)
Sets the worker thread name.

source code

Properties

Inherited from object: __class__

Method Details

RunTask(self, job)

Job executor.

Parameters:

job (_QueuedJob) - the job to be processed

Overrides: workerpool.BaseWorker.RunTask

_RunTaskInner(self, job)

Executes a job.

Must be called with per-job lock acquired.

_WrapExecOpCode(setname_fn, execop_fn, op, *args, **kwargs)
Static Method

Updates the worker thread name to include a short summary of the opcode.

Parameters:

setname_fn - Callable setting worker thread name
execop_fn - Callable for executing opcode (usually mcpu.Processor.ExecOpCode)

_GetWorkerName(job, op)
Static Method

Sets the worker thread name.

Parameters:

job (_QueuedJob)
op (opcodes.OpCode)