syndicate-lang
/
mini-syndicate-py
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Warn on duplicate/missing captures

This commit is contained in:
Tony Garnock-Jones 2019-03-22 14:21:10 +00:00
parent d45d6b63d3
commit 489252c9e7
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
syndicate/mini/core.py
View File

@ -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)