ganeti.daemon.AsyncAwaker

class documentation

class AsyncAwaker(GanetiBaseAsyncoreDispatcher):

View In Hierarchy

A way to notify the asyncore loop that something is going on.

If an asyncore daemon is multithreaded when a thread tries to push some data to a socket, the main loop handling asynchronous requests might be sleeping waiting on a select(). To avoid this it can create an instance of the AsyncAwaker, which other threads can use to wake it up.

Method __init__ Constructor for AsyncAwaker
Method close Undocumented
Method handle_read Undocumented
Method signal Signal the asyncore main loop.
Instance Variable connected Undocumented
Instance Variable in_socket Undocumented
Instance Variable need_signal Undocumented
Instance Variable out_socket Undocumented
Instance Variable signal_fn Undocumented

Inherited from GanetiBaseAsyncoreDispatcher:

Method handle_error Log an error in handling any request, and proceed.
Method writable Most of the time we don't want to check for writability.
def __init__(self, signal_fn=None):

Constructor for AsyncAwaker

Parameters
signal_fn:functionfunction to call when awaken
def close(self):

Undocumented

def handle_read(self):

Undocumented

def signal(self):

Signal the asyncore main loop.

Any data we send here will be ignored, but it will cause the select() call to return.

connected: bool =

Undocumented

in_socket =

Undocumented

need_signal: bool =

Undocumented

out_socket =

Undocumented

signal_fn =

Undocumented