def __init__(self, path): self.path = path self.subs = {} # format: 'node: handle, ...' self.pubs = {} #self.pub_lock = _thread.allocate_lock()