ganeti.daemon.AsyncUDPSocket

class documentation

class AsyncUDPSocket(GanetiBaseAsyncoreDispatcher):

Known subclasses: ganeti.confd.client.ConfdAsyncUDPClient

View In Hierarchy

An improved asyncore udp socket.

Method __init__ Constructor for AsyncUDPSocket
Method enqueue_send Enqueue a datagram to be sent when possible
Method handle_connect Undocumented
Method handle_datagram Handle an already read udp datagram
Method handle_read Undocumented
Method handle_write Undocumented
Method process_next_packet Process the next datagram, waiting for it if necessary.
Method writable Most of the time we don't want to check for writability.
Instance Variable _family Undocumented
Instance Variable _out_queue Undocumented

Inherited from GanetiBaseAsyncoreDispatcher:

Method handle_error Log an error in handling any request, and proceed.
def __init__(self, family):
overridden in ganeti.confd.client.ConfdAsyncUDPClient

Constructor for AsyncUDPSocket

def enqueue_send(self, ip, port, payload):

Enqueue a datagram to be sent when possible

def handle_connect(self):

Undocumented

def handle_datagram(self, payload, ip, port):
overridden in ganeti.confd.client.ConfdAsyncUDPClient

Handle an already read udp datagram

def handle_read(self):

Undocumented

def handle_write(self):

Undocumented

def process_next_packet(self, timeout=0):

Process the next datagram, waiting for it if necessary.

Parameters
timeout:floathow long to wait for data
Returns
booleanTrue if some data has been handled, False otherwise
def writable(self):
overrides ganeti.daemon.GanetiBaseAsyncoreDispatcher.writable

Most of the time we don't want to check for writability.

_family =

Undocumented

_out_queue: list =

Undocumented