Module mcpu

source code

Module implementing the logic behind the cluster operations

This module implements the logic for doing operations in the cluster. There are two kinds of classes defined:

logical units, which know how to deal with their specific opcode only
the processor, which dispatches the opcodes to their logical units

Classes

[hide private]

LockAcquireTimeout
Exception to report timeouts on acquiring locks.

LockAttemptTimeoutStrategy
Class with lock acquire timeout strategy.

OpExecCbBase
Base class for OpCode execution callbacks.

Processor
Object which runs OpCodes

Functions

[hide private]

_CalculateLockAttemptTimeouts()
Calculate timeouts for lock attempts.

source code

_LUNameForOpName(opname)
Computes the LU name for a given OpCode name.

source code

_ComputeDispatchTable()
Computes the opcode-to-lu dispatch table.

source code

_SetBaseOpParams(src, defcomment, dst)
Copies basic opcode parameters.

source code

_ProcessResult(submit_fn, op, result)
Examines opcode result.

source code

_FailingSubmitManyJobs(_)
Implementation of OpExecCbBase.SubmitManyJobs to raise an exception.

source code

a list of strings

_LockList(names)
If 'names' is a string, make it a single-element list.

source code

_CheckSecretParameters(op)
Check if secret parameters are expected, but missing.

source code

Variables

[hide private]

sighupReceived = [False]

lusExecuting = [0]

_OP_PREFIX = "Op"

_LU_PREFIX = "LU"

Imports: sys, logging, random, time, itertools, traceback, opcodes, opcodes_base, constants, errors, hooksmaster, cmdlib, locking, utils, compat, wconfd

Function Details

[hide private]

_SetBaseOpParams(src, defcomment, dst)

source code

Copies basic opcode parameters.

Parameters:

src (opcodes.OpCode) - Source opcode
defcomment (string) - Comment to specify if not already given
dst (opcodes.OpCode) - Destination opcode

_ProcessResult(submit_fn, op, result)

source code

Examines opcode result.

If necessary, additional processing on the result is done.

_LockList(names)

source code

If 'names' is a string, make it a single-element list.

Parameters:

names (list or string or NoneType) - Lock names

Returns: a list of strings

if 'names' argument is an iterable, a list of it; if it's a string, make it a one-element list; if locking.ALL_SET, locking.ALL_SET