open.source/magic-wormhole-transit-relay
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

disconnect_redundant is redundant

Browse Source
This commit is contained in:
meejah 2021-04-10 18:37:43 -06:00
parent ce7458e604
commit a057da49cf
2 changed files with 0 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/wormhole_transit_relay/server_state.py
View File

@ -351,7 +351,6 @@ class PendingRequests(object):
# can happen if the connection hint contains multiple # can happen if the connection hint contains multiple
# addresses (we don't currently support those, but it'd # addresses (we don't currently support those, but it'd
# probably be useful in the future). # probably be useful in the future).
##leftover_tc.disconnect_redundant()
leftover_tc.partner_connection_lost() leftover_tc.partner_connection_lost()
self._requests.pop(token, None) self._requests.pop(token, None)

10
src/wormhole_transit_relay/transit_server.py
View File

@ -114,11 +114,6 @@ class TransitConnection(LineReceiver):
# receiver can handle it. # receiver can handle it.
self._state.got_bytes(data) self._state.got_bytes(data)
def disconnect_redundant(self):
# this is called if a buddy connected and we were found unnecessary.
# Any token-tracking cleanup will have been done before we're called.
self.transport.loseConnection()
def connectionLost(self, reason): def connectionLost(self, reason):
self._state.connection_lost() self._state.connection_lost()
# XXX this probably resulted in a log message we've not refactored yet # XXX this probably resulted in a log message we've not refactored yet
@ -272,11 +267,6 @@ class WebSocketTransitConnection(WebSocketServerProtocol):
log.err("Failed to send to partner: {}".format(e)) log.err("Failed to send to partner: {}".format(e))
self.sendClose(3000, "send to partner failed") self.sendClose(3000, "send to partner failed")
def disconnect_redundant(self):
# this is called if a buddy connected and we were found unnecessary.
# Any token-tracking cleanup will have been done before we're called.
self.transport.loseConnection()
def onClose(self, wasClean, code, reason): def onClose(self, wasClean, code, reason):
""" """
IWebSocketChannel API IWebSocketChannel API