Package ganeti :: Module locking :: Class SingleNotifyPipeCondition

Class SingleNotifyPipeCondition

Condition which can only be notified once.

This condition class uses pipes and poll, internally, to be able to wait for notification with a timeout, without resorting to polling. It is almost compatible with Python's threading.Condition, with the following differences:

notifyAll can only be called once, and no wait can happen after that
notify is not supported, only notifyAll

Nested Classes

[hide private]

_waiter_class
Helper class for SingleNotifyPipeCondition

Instance Methods

[hide private]

__init__(self, lock)
Constructor for SingleNotifyPipeCondition

source code

_check_unnotified(self)
Throws an exception if already notified.

source code

_Cleanup(self)
Cleanup open file descriptors, if any.

source code

wait(self, timeout=None)
Wait for a notification.

source code

notifyAll(self)
Close the writing side of the pipe to notify all waiters.

source code

Inherited from _BaseCondition (private): _base_acquire_restore, _base_is_owned, _base_release_save, _check_owned

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