niryo_libraries.rosmaster.registrations.RegistrationManager

class documentation

class RegistrationManager(object):

Constructor: RegistrationManager(thread_pool)

View In Hierarchy

Stores registrations for Master.

RegistrationManager is not threadsafe, so access must be externally locked as appropriate

Method __init__ ctor. @param thread_pool: thread pool for queueing tasks @type thread_pool: ThreadPool
Method get_node Undocumented
Method register_param_subscriber Register param subscriber @return: None
Method register_publisher Register topic publisher @return: None
Method register_service Register service provider @return: None
Method register_subscriber Register topic subscriber @return: None
Method reverse_lookup Get a NodeRef by caller_api @param caller_api: caller XML RPC URI @type caller_api: str @return: nodes that declare caller_api as their API. 99.9% of the time this should only be one node, but we allow for multiple matches as the master API does not restrict this...
Method unregister_param_subscriber Undocumented
Method unregister_publisher Undocumented
Method unregister_service Undocumented
Method unregister_subscriber Undocumented
Instance Variable nodes Undocumented
Instance Variable param_subscribers Undocumented
Instance Variable publishers Undocumented
Instance Variable services Undocumented
Instance Variable subscribers Undocumented
Instance Variable thread_pool Undocumented
Method _register Undocumented
Method _register_node_api @param caller_id: caller_id of provider @type caller_id: str @param caller_api: caller_api of provider @type caller_api: str @return: (registration_information, changed_registration). changed_registration is true if caller_api is differet than the one registered with caller_id @rtype: (NodeRef, bool)...
Method _unregister Undocumented
def __init__(self, thread_pool):

ctor. @param thread_pool: thread pool for queueing tasks @type thread_pool: ThreadPool

def get_node(self, caller_id):

Undocumented

def register_param_subscriber(self, param, caller_id, caller_api):

Register param subscriber @return: None

def register_publisher(self, topic, caller_id, caller_api):

Register topic publisher @return: None

def register_service(self, service, caller_id, caller_api, service_api):

Register service provider @return: None

def register_subscriber(self, topic, caller_id, caller_api):

Register topic subscriber @return: None

def reverse_lookup(self, caller_api):

Get a NodeRef by caller_api @param caller_api: caller XML RPC URI @type caller_api: str @return: nodes that declare caller_api as their API. 99.9% of the time this should only be one node, but we allow for multiple matches as the master API does not restrict this. @rtype: [NodeRef]

def unregister_param_subscriber(self, param, caller_id, caller_api):

Undocumented

def unregister_publisher(self, topic, caller_id, caller_api):

Undocumented

def unregister_service(self, service, caller_id, service_api):

Undocumented

def unregister_subscriber(self, topic, caller_id, caller_api):

Undocumented

nodes: dict =

Undocumented

param_subscribers =

Undocumented

publishers =

Undocumented

services =

Undocumented

subscribers =

Undocumented

thread_pool =

Undocumented

def _register(self, r, key, caller_id, caller_api, service_api=None):

Undocumented

def _register_node_api(self, caller_id, caller_api):

@param caller_id: caller_id of provider @type caller_id: str @param caller_api: caller_api of provider @type caller_api: str @return: (registration_information, changed_registration). changed_registration is true if caller_api is differet than the one registered with caller_id @rtype: (NodeRef, bool)

def _unregister(self, r, key, caller_id, caller_api, service_api=None):

Undocumented