Documentation

Convenience function to obtain a QueuedOpCode from a MetaOpCode

From a job-id and a list of op-codes create a job. This is the pure part of job creation, as allocating a new job id lives in IO.

Change the priority of a QueuedOpCode, if it is not already finalized.

Change the priority of a job, i.e., change the priority of the non-finalized opcodes.

Transform a QueuedJob that has not been started into its canceled form.

Transform a QueuedJob that has not been started into its failed form.

Obtain a Timestamp from a given clock time

Missing timestamp type.

Get the current time in the job-queue timestamp format.

From a given timestamp, obtain the timestamp of the time that is the given number of seconds later.

Build a timestamp in the format expected by the reason trail (nanoseconds) starting from a JQueue Timestamp.

Attach a received timestamp to a Queued Job.

Append an element to the reason trail of all the OpCodes of a queued job.

From a queued job obtain the list of jobs it depends on.

Determine whether an opcode status is finalized.

Tries to extract the opcode summary from an InputOpCode. This duplicates some functionality from the opSummary function in Ganeti.OpCodes.

Computes a queued job's status.

Determine if a job has started

Determine if a job is finalised.

Determine if a job is finalized and its timestamp is before a given time.

Compute a job's priority.

Computes the filename for a given job ID.

Computes the full path to a live job.

Computes the full path to an archives job. BROKEN.

Build list of directories containing job files. Note: compared to the Python version, this doesn't ignore a potential lost+found file.

Computes the list of all jobs in the given directories.

Sorts the a list of job IDs.

Loads a job from disk.

Failed to load job error.

Read the job serial number from disk.

Allocate new job ids. To avoid races while accessing the serial file, the threads synchronize over a lock, as usual provided by a Lock.

Allocate one new job id.

Write a job to disk.

Replicate many jobs to all master candidates.

Writes a job to a file and replicates it to master candidates.

Decide if job queue is open

Start enqueued jobs by executing the Python code.

Try to cancel a job that has already been handed over to execution, by terminating the process.

Inform a job that it is requested to change its priority. This is done by writing the new priority to a file and sending SIGUSR1.

Notify a job that something relevant happened, e.g., a lock became available. We do this by sending sigHUP to the process.

Waits for a job's process to exit

Permissions for the archive directories.

Archive jobs older than the given time, but do not exceed the timeout for carrying out this task.

The ganeti queue timestamp type. It represents the time as the pair of seconds since the epoch and microseconds since the beginning of the second.

An input opcode.