Module locking

source code

Module implementing the Ganeti locking code.

Classes

[hide private]

_SingleNotifyPipeConditionWaiter
Helper class for SingleNotifyPipeCondition

_BaseCondition
Base class containing common code for conditions.

SingleNotifyPipeCondition
Condition which can only be notified once.

PipeCondition
Group-only non-polling condition with counters.

_PipeConditionWithMode

SharedLock
Implements a shared lock.

_AcquireTimeout
Internal exception to abort an acquire on a timeout.

Functions

[hide private]

ssynchronized(mylock, shared=0)
Shared Synchronization decorator.

source code

_TimeoutZero()
Returns the number zero.

source code

Variables

[hide private]

_EXCLUSIVE_TEXT = "exclusive"

_SHARED_TEXT = "shared"

_DELETED_TEXT = "deleted"

_DEFAULT_PRIORITY = 0

_LOCK_ACQUIRE_MIN_TIMEOUT = 1.0/ 1000
Minimum timeout required to consider scheduling a pending acquisition (seconds)

ALL_SET = None
hash(x)

LOCKSET_NAME = "[lockset]"

LEVELS = [LEVEL_CLUSTER, LEVEL_INSTANCE, LEVEL_NODEGROUP, LEVE...

LEVELS_MOD = compat.UniqueFrozenset([LEVEL_NODE_RES, LEVEL_NOD...

LEVEL_NAMES = {LEVEL_CLUSTER: "cluster", LEVEL_INSTANCE: "inst...
Lock level names (make sure to use singular form)

BGL = "BGL"

Imports: os, select, threading, errno, logging, heapq, time, errors, utils, compat, query

Function Details

[hide private]

ssynchronized(mylock, shared=0)

source code

Shared Synchronization decorator.

Calls the function holding the given lock, either in exclusive or shared mode. It requires the passed lock to be a SharedLock (or support its semantics).

Parameters:

mylock (lockable object or string) - lock to acquire or class member name of the lock to acquire

Variables Details

[hide private]

LEVELS

Value:

[LEVEL_CLUSTER, LEVEL_INSTANCE, LEVEL_NODEGROUP, LEVEL_NODE, LEVEL_NOD
E_RES, LEVEL_NETWORK,]

LEVELS_MOD

Value:

compat.UniqueFrozenset([LEVEL_NODE_RES, LEVEL_NODE, LEVEL_NODEGROUP, L
EVEL_INSTANCE, LEVEL_NETWORK,])

LEVEL_NAMES

Lock level names (make sure to use singular form)

Value:

{LEVEL_CLUSTER: "cluster", LEVEL_INSTANCE: "instance", LEVEL_NODEGROUP
: "nodegroup", LEVEL_NODE: "node", LEVEL_NODE_RES: "node-res", LEVEL_N
ETWORK: "network",}