niryo_libraries.rospy.impl.udpros.UDPROSHandler

class documentation

class UDPROSHandler(rospy.transport.ProtocolHandler):

Constructor: UDPROSHandler(port)

rospy protocol handler for UDPROS. Stores the datagram server if necessary.

Method	`__init__`	ctor
Method	`create_transport`	Connect to topic resolved_name on Publisher pub_uri using UDPROS. @param resolved_name str: resolved topic name @type resolved_name: str @param pub_uri: XML-RPC URI of publisher @type pub_uri: str @param protocol_params: protocol parameters to use for connecting @type protocol_params: [XmlRpcLegal] @return: code, message, debug @rtype: (int, str, int)...
Method	`get_supported`	Get supported protocols
Method	`init_publisher`	Initialize this node to start publishing to a new UDP location.
Method	`init_server`	Initialize and start the server thread, if not already initialized.
Method	`run`	Undocumented
Method	`shutdown`	Undocumented
Method	`supports`	@param protocol: name of protocol @type protocol: str @return: True if protocol is supported @rtype: bool
Method	`topic_connection_handler`	Process incoming topic connection. Reads in topic name from handshake and creates the appropriate L{TCPROSPub} handler for the connection. @param sock: socket connection @type sock: socket.socket @param client_addr: client address @type client_addr: (str, int) @param header: key/value pairs from handshake header @type header: dict @return: error string or None @rtype: str...
Instance Variable	`buff_size`	Undocumented
Instance Variable	`port`	Undocumented
Instance Variable	`server`	Undocumented

def __init__(self, port=0): ¶

ctor

def create_transport(self, topic_name, pub_uri, protocol_params): ¶

Connect to topic resolved_name on Publisher pub_uri using UDPROS. @param resolved_name str: resolved topic name @type resolved_name: str @param pub_uri: XML-RPC URI of publisher @type pub_uri: str @param protocol_params: protocol parameters to use for connecting @type protocol_params: [XmlRpcLegal] @return: code, message, debug @rtype: (int, str, int)

def get_supported(self): ¶

Get supported protocols

def init_publisher(self, topic_name, protocol_params): ¶

Initialize this node to start publishing to a new UDP location.

@param resolved_name: topic name @type resolved__name: str

@param protocol_params: requested protocol: parameters. protocol[0] must be the string 'UDPROS'

@type protocol_params: [str, value*] @return: (code, msg, [UDPROS, addr, port]) @rtype: (int, str, list)

def init_server(self): ¶

Initialize and start the server thread, if not already initialized.

def run(self): ¶

Undocumented

def shutdown(self): ¶

Undocumented

def supports(self, protocol): ¶

@param protocol: name of protocol @type protocol: str @return: True if protocol is supported @rtype: bool

def topic_connection_handler(self, sock, client_addr, header): ¶

Process incoming topic connection. Reads in topic name from handshake and creates the appropriate L{TCPROSPub} handler for the connection. @param sock: socket connection @type sock: socket.socket @param client_addr: client address @type client_addr: (str, int) @param header: key/value pairs from handshake header @type header: dict @return: error string or None @rtype: str

buff_size = ¶

Undocumented

port = ¶

Undocumented

server = ¶

Undocumented