Loading ccnode/tags.py +7 −1 Original line number Diff line number Diff line Loading @@ -145,7 +145,8 @@ def tag_inspector(mod, parent=None): # whatever it is we don't care... continue logger.debug('Introspected %s with ttl %s.', n, ttl) logger.debug('Introspected %s with ttl %s, refresh %s for object %s', n, ttl, refresh, parent) # finally add the tag tags.append(Tag(n, m, ttl, refresh, parent)) Loading Loading @@ -307,16 +308,19 @@ class TagDB(object): 'Error while trying to unregister the object %s, %s("%s")') def rpc_register_tag(self, tag): logger.debug('RPC register tag %s', tag.name) ttl = None if tag.ttl == -1 else None self.rpc_call(tag.name, self.rpc_tag_register_cb, 'tags_register', tag.name, ttl, tag.value) def rpc_unregister_tag(self, tag_name): logger.debug('RPC unregister tag %s', tag_name) self.rpc_call(tag_name, self.rpc_tag_unregister_cb, 'tags_unregister', tag_name) def rpc_update_tag(self, sub_id, tag): """Update tag value on cc-server.""" logger.debug('RPC update tag %s(%s)', tag.name, sub_id) if sub_id == '__main__': self.rpc_call(sub_id + tag.name, self.rpc_update_tag_cb, 'tags_update', tag.name, tag.value) Loading @@ -325,11 +329,13 @@ class TagDB(object): 'sub_tags_update', tag.name, tag.value) def rpc_register_sub_tag(self, sub_id, tag): logger.debug('RPC register tag %s(%s)', tag.name, sub_id) ttl = None if tag.ttl == -1 else None self.rpc_call(tag.name, self.rpc_sub_tag_register_cb, 'sub_tags_register', sub_id, tag.name, ttl, tag.value) def rpc_unregister_sub_tag(self, sub_id, tag_name): logger.debug('RPC unregister tag %s(%s)', tag_name, sub_id) self.rpc_call(tag_name, self.rpc_sub_tag_unregister_cb, 'sub_tags_unregister', sub_id, tag_name) Loading Loading
ccnode/tags.py +7 −1 Original line number Diff line number Diff line Loading @@ -145,7 +145,8 @@ def tag_inspector(mod, parent=None): # whatever it is we don't care... continue logger.debug('Introspected %s with ttl %s.', n, ttl) logger.debug('Introspected %s with ttl %s, refresh %s for object %s', n, ttl, refresh, parent) # finally add the tag tags.append(Tag(n, m, ttl, refresh, parent)) Loading Loading @@ -307,16 +308,19 @@ class TagDB(object): 'Error while trying to unregister the object %s, %s("%s")') def rpc_register_tag(self, tag): logger.debug('RPC register tag %s', tag.name) ttl = None if tag.ttl == -1 else None self.rpc_call(tag.name, self.rpc_tag_register_cb, 'tags_register', tag.name, ttl, tag.value) def rpc_unregister_tag(self, tag_name): logger.debug('RPC unregister tag %s', tag_name) self.rpc_call(tag_name, self.rpc_tag_unregister_cb, 'tags_unregister', tag_name) def rpc_update_tag(self, sub_id, tag): """Update tag value on cc-server.""" logger.debug('RPC update tag %s(%s)', tag.name, sub_id) if sub_id == '__main__': self.rpc_call(sub_id + tag.name, self.rpc_update_tag_cb, 'tags_update', tag.name, tag.value) Loading @@ -325,11 +329,13 @@ class TagDB(object): 'sub_tags_update', tag.name, tag.value) def rpc_register_sub_tag(self, sub_id, tag): logger.debug('RPC register tag %s(%s)', tag.name, sub_id) ttl = None if tag.ttl == -1 else None self.rpc_call(tag.name, self.rpc_sub_tag_register_cb, 'sub_tags_register', sub_id, tag.name, ttl, tag.value) def rpc_unregister_sub_tag(self, sub_id, tag_name): logger.debug('RPC unregister tag %s(%s)', tag_name, sub_id) self.rpc_call(tag_name, self.rpc_sub_tag_unregister_cb, 'sub_tags_unregister', sub_id, tag_name) Loading