diff --git a/src/wormhole_transit_relay/server_state.py b/src/wormhole_transit_relay/server_state.py index 31a4040..d7e7055 100644 --- a/src/wormhole_transit_relay/server_state.py +++ b/src/wormhole_transit_relay/server_state.py @@ -351,7 +351,6 @@ class PendingRequests(object): # can happen if the connection hint contains multiple # addresses (we don't currently support those, but it'd # probably be useful in the future). - ##leftover_tc.disconnect_redundant() leftover_tc.partner_connection_lost() self._requests.pop(token, None) diff --git a/src/wormhole_transit_relay/transit_server.py b/src/wormhole_transit_relay/transit_server.py index 15d235d..d85e383 100644 --- a/src/wormhole_transit_relay/transit_server.py +++ b/src/wormhole_transit_relay/transit_server.py @@ -114,11 +114,6 @@ class TransitConnection(LineReceiver): # receiver can handle it. 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): self._state.connection_lost() # 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)) 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): """ IWebSocketChannel API