niryo_libraries.rospy.topics._TopicImpl

class documentation

class _TopicImpl(object):

Known subclasses: niryo_libraries.rospy.topics._PublisherImpl, niryo_libraries.rospy.topics._SubscriberImpl

Constructor: _TopicImpl(name, data_class)

View In Hierarchy

Base class of internal topic implementations. Each topic has a singleton _TopicImpl implementation for managing the underlying connections.

Method __del__ Undocumented
Method __init__ Base constructor @param name: graph resource name of topic, e.g. 'laser'. @type name: str @param data_class: message data class @type data_class: L{Message}
Method add_connection Add a connection to this topic. If any previous connections to same endpoint exist, drop them.
Method check Undocumented
Method close close I/O
Method get_num_connections Undocumented
Method get_stats Get the stats for this topic (API stub)
Method get_stats_info Get the stats for this topic @return: stats for topic in getBusInfo() format:
Method has_connection Query whether or not a connection with the associated \x07 endpoint has been added to this object. @param endpoint_id: endpoint ID associated with connection. @type endpoint_id: str
Method has_connections Check to see if this topic is connected to other publishers/subscribers @return: True if topic is connected @rtype: bool
Method remove_connection Remove connection from topic. @param c: connection instance to remove @type c: Transport
Instance Variable c_lock Undocumented
Instance Variable closed Undocumented
Instance Variable connection_poll Undocumented
Instance Variable connections Undocumented
Instance Variable data_class Undocumented
Instance Variable handler Undocumented
Instance Variable name Undocumented
Instance Variable ref_count Undocumented
Instance Variable resolved_name Undocumented
Instance Variable seq Undocumented
Instance Variable type Undocumented
Method _remove_connection Undocumented
def __del__(self):

Undocumented

def __init__(self, name, data_class):
overridden in niryo_libraries.rospy.topics._PublisherImpl, niryo_libraries.rospy.topics._SubscriberImpl

Base constructor @param name: graph resource name of topic, e.g. 'laser'. @type name: str @param data_class: message data class @type data_class: L{Message}

def add_connection(self, c):
overridden in niryo_libraries.rospy.topics._PublisherImpl

Add a connection to this topic. If any previous connections to same endpoint exist, drop them.

@param c: connection instance @type c: Transport @return: True if connection was added, bool

def check(self):

Undocumented

def close(self):
overridden in niryo_libraries.rospy.topics._PublisherImpl, niryo_libraries.rospy.topics._SubscriberImpl

close I/O

def get_num_connections(self):

Undocumented

def get_stats(self):
overridden in niryo_libraries.rospy.topics._PublisherImpl, niryo_libraries.rospy.topics._SubscriberImpl

Get the stats for this topic (API stub)

def get_stats_info(self):

Get the stats for this topic @return: stats for topic in getBusInfo() format:

Publisher:
((connection_id, destination_caller_id, direction, transport, topic_name, connected, connection_info_string)*)
Subscriber:
((connection_id, publisher_xmlrpc_uri, direction, transport, topic_name, connected, connection_info_string)*)

@rtype: list

def has_connection(self, endpoint_id):

Query whether or not a connection with the associated \x07 endpoint has been added to this object. @param endpoint_id: endpoint ID associated with connection. @type endpoint_id: str

def has_connections(self):

Check to see if this topic is connected to other publishers/subscribers @return: True if topic is connected @rtype: bool

def remove_connection(self, c):
overridden in niryo_libraries.rospy.topics._PublisherImpl

Remove connection from topic. @param c: connection instance to remove @type c: Transport

c_lock =

Undocumented

closed: bool =

Undocumented

connection_poll =

Undocumented

connections =

Undocumented

data_class =

Undocumented

handler =

Undocumented

name =

Undocumented

ref_count: int =

Undocumented

resolved_name =

Undocumented

seq: int =

Undocumented

type =

Undocumented

def _remove_connection(self, connections, c):

Undocumented