Package ganeti :: Package jqueue
[hide private]
[frames] | no frames]

Package jqueue

source code

Module implementing the job queue handling.

Locking: there's a single, large lock in the JobQueue class. It's used by all other classes in this module.

Submodules [hide private]

Classes [hide private]
Special exception to cancel a job.
Encapsulates an opcode object.
In-memory job representation.
The actual job workers.
Simple class implementing a job-processing workerpool.
Keeps track of job dependencies.
Queue used to manage the jobs.
Functions [hide private]
Returns the current timestamp.
source code
_CallJqUpdate(runner, names, file_name, content)
Updates job queue file after virtualizing filename.
source code
Encodes an error which occurred while processing an opcode.
source code
_EvaluateJobProcessorResult(depmgr, job, result)
Looks at a result from _JobProcessor for a job.
source code
Variables [hide private]
the number of worker threads we start for processing jobs
  _LOCK = "_lock"
  _QUEUE = "_queue"
  _GetIdAttr = operator.attrgetter("id")
Retrieves "id" attribute

Imports: logging, errno, time, weakref, threading, itertools, operator, os, pyinotify, asyncnotifier, constants, serializer, workerpool, locking, luxi, opcodes, opcodes_base, errors, mcpu, utils, jstore, rpc, runtime, netutils, compat, ht, query, qlang, pathutils, vcluster, cluster

Function Details [hide private]


source code 

Returns the current timestamp.

Returns: tuple
the current time in the (seconds, microseconds) format

_EvaluateJobProcessorResult(depmgr, job, result)

source code 

Looks at a result from _JobProcessor for a job.

To be used in a _JobQueueWorker.