Package ganeti :: Module daemon :: Class AsyncAwaker

Class AsyncAwaker

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.

Instance Methods

[hide private]

__init__(self, signal_fn=None)
Constructor for AsyncAwaker

source code

handle_read(self)

source code

close(self)

source code

signal(self)
Signal the asyncore main loop.

source code

Inherited from GanetiBaseAsyncoreDispatcher: handle_error, writable

Inherited from asyncore.dispatcher: __getattr__, __repr__, __str__, accept, add_channel, bind, connect, create_socket, del_channel, handle_accept, handle_close, handle_connect, handle_connect_event, handle_expt, handle_expt_event, handle_read_event, handle_write, handle_write_event, listen, log, log_info, readable, recv, send, set_reuse_addr, set_socket