niryo_libraries.rospy.impl.udpros.UDPROSTransport

class documentation

class UDPROSTransport(rospy.transport.Transport):

Constructor: UDPROSTransport(protocol, name, header)

View In Hierarchy

Undocumented

Method __init__ ctor @param name: topic name @type name: str: @param protocol: protocol implementation @param protocol: UDPROSTransportProtocol @param header: handshake header if transport handshake header was already read off of transport...
Method close Undocumented
Method receive_loop Undocumented
Method receive_once block until messages are read off of socket @return: list of newly received messages @rtype: [Msg] @raise TransportException: if unable to receive message due to error
Method send_message Convenience routine for services to send a message across a particular connection. NOTE: write_data is much more efficient if same message is being sent to multiple connections. Not threadsafe. @param msg: message to send @type msg: Msg @param seq: sequence number for message @type seq: int @raise TransportException: if error occurred sending message...
Method write_data Write raw data to transport @raise TransportInitialiationError: could not be initialized @raise TransportTerminated: no longer open for publishing
Class Variable transport_type Undocumented
Instance Variable done Undocumented
Instance Variable header Undocumented
def __init__(self, protocol, name, header):

ctor @param name: topic name @type name: str: @param protocol: protocol implementation @param protocol: UDPROSTransportProtocol @param header: handshake header if transport handshake header was already read off of transport. @type header: dict @throws TransportInitError: if transport cannot be initialized according to arguments

def close(super):

Undocumented

def receive_loop(self, msgs_callback):

Undocumented

def receive_once(self):

block until messages are read off of socket @return: list of newly received messages @rtype: [Msg] @raise TransportException: if unable to receive message due to error

def send_message(self, msg, seq):

Convenience routine for services to send a message across a particular connection. NOTE: write_data is much more efficient if same message is being sent to multiple connections. Not threadsafe. @param msg: message to send @type msg: Msg @param seq: sequence number for message @type seq: int @raise TransportException: if error occurred sending message

def write_data(self, data):

Write raw data to transport @raise TransportInitialiationError: could not be initialized @raise TransportTerminated: no longer open for publishing

transport_type: str =

Undocumented

done: bool =

Undocumented

header =

Undocumented