ganeti.rpc.transport.FdTransport

class documentation

class FdTransport(object):

View In Hierarchy

Low-level transport class that works on arbitrary file descriptors.

Unlike Transport, this doesn't use timeouts.

Method __init__ Constructor for the Client class.
Method Call Send a message and wait for the response.
Method Close Close the socket
Method close Undocumented
Method Recv Try to receive a message from the read part of the socket.
Method Send Send a message.
Method _CheckSocket Make sure we are connected.
Instance Variable _buffer Undocumented
Instance Variable _msgs Undocumented
Instance Variable _rstream Undocumented
Instance Variable _wstream Undocumented
def __init__(self, fds, timeouts=None, allow_non_master=None):

Constructor for the Client class.

Parameters
fds:pair of file descriptorsthe file descriptor for reading (the first in the pair) and the file descriptor for writing (the second)
timeouts:intunused
allow_non_master:boolunused
def Call(self, msg):

Send a message and wait for the response.

This is just a wrapper over Send and Recv.

def Close(self):

Close the socket

def close(self):

Undocumented

def Recv(self):

Try to receive a message from the read part of the socket.

In case we already have messages queued, we just return from the queue.

def Send(self, msg):

Send a message.

This just sends a message and doesn't wait for the response.

def _CheckSocket(self):

Make sure we are connected.

_buffer =

Undocumented

_msgs =

Undocumented

_rstream =

Undocumented

_wstream =

Undocumented