linse/frappy
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

unsubscribe upon disconnect

Browse Source 
Change-Id: I45f53526b8f65741fede170a0420f0f4aabc00fb
This commit is contained in:
Enrico Faulhaber 2016-08-31 11:32:42 +02:00
parent 9b93f7d5af
commit 4f42b32385
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/protocol/dispatcher.py
View File

@ -145,7 +145,8 @@ class Dispatcher(object):
"""removes now longer functional connection""" """removes now longer functional connection"""
if conn in self._dispatcher_connections: if conn in self._dispatcher_connections:
self._dispatcher_connections.remove(conn) self._dispatcher_connections.remove(conn)
# XXX: also clean _dispatcher_subscriptions ! for _evt, conns in self._dispatcher_subscriptions.items():
conns.discard(conn)
def register_device(self, devobj, devname, export=True): def register_device(self, devobj, devname, export=True):
self.log.debug('registering Device %r as %s (export=%r)' % self.log.debug('registering Device %r as %s (export=%r)' %