From 489252c9e70dd737bda6e164bee5e3ef1828af5f Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Fri, 22 Mar 2019 14:21:10 +0000 Subject: [PATCH] Warn on duplicate/missing captures --- syndicate/mini/core.py | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/syndicate/mini/core.py b/syndicate/mini/core.py index 2d9f609..7da9284 100644 --- a/syndicate/mini/core.py +++ b/syndicate/mini/core.py @@ -55,7 +55,12 @@ class Endpoint(object): self._del(captures) def _add(self, captures): - if captures not in self.cache: + if captures in self.cache: + log.error('Broker error: duplicate captures %r added for endpoint %r %r' % ( + captures, + self.id, + self.assertion)) + else: self.cache.add(captures) self.on_add(*captures) @@ -63,6 +68,11 @@ class Endpoint(object): if captures in self.cache: self.cache.discard(captures) self.on_del(*captures) + else: + log.error('Broker error: nonexistent captures %r removed from endpoint %r %r' % ( + captures, + self.id, + self.assertion)) def _msg(self, captures): self.on_msg(*captures)