Skip to content

Commit f54478e

Browse files
Skully17David Ellis
andauthored
Unregistering when RemoteSession leaves (#2129)
Co-authored-by: David Ellis <david.ellis@atamate.com>
1 parent 47255ca commit f54478e

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

crossbar/worker/rlink.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -426,7 +426,7 @@ def on_registration_delete(session_id, reg_id, details=None):
426426

427427
del self._regs[reg_id]
428428

429-
self.log.debug("{other} unsubscribed from {uri}".format(other=other, uri=uri))
429+
self.log.debug("{other} unregistered from {uri}".format(other=other, uri=uri))
430430

431431
@inlineCallbacks
432432
def register_current():
@@ -697,9 +697,13 @@ def onLeave(self, details):
697697
for k, v in self._subs.items():
698698
if v['sub'].active:
699699
yield v['sub'].unsubscribe()
700-
701700
self._subs = {}
702701

702+
for k, v, in self._regs.items():
703+
if v["reg"] and v["reg"].active:
704+
yield v["reg"].unregister()
705+
self._regs = {}
706+
703707
self.config.extra['other']._tracker.connected = False
704708
self.log.warn(
705709
'{klass}.onLeave(): rlink remote session left! (realm={realm}, authid={authid}, authrole={authrole}, session={session}, details={details}) {method}',

0 commit comments

Comments
 (0)