- clients = self.tags.get(tag)
- if clients:
- #log.debug("(%s %s) -> [%s]",
- # tag,
- # " ".join(str(x) for x in data),
- # " ".join(repr(x) for x,_ in clients))
- for ref, client in clients:
- client(*data)
+ with self.lock:
+ log.info("(%s %s)", tag, " ".join(str(x) for x in data))
+ clients = self.tags.get(tag)
+ if clients:
+ for ref, client in clients:
+ client(*data)