We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b9b5d82 commit ca133a6Copy full SHA for ca133a6
src/full_node/full_node.py
@@ -222,6 +222,9 @@ async def on_connect() -> OutboundMessageGenerator:
222
yield OutboundMessage(NodeType.INTRODUCER, msg, Delivery.RESPOND)
223
224
while not self._shut_down:
225
+ for connection in self.server.global_connections.get_connections():
226
+ if connection.connection_type == NodeType.INTRODUCER:
227
+ await self.server.global_connections.close(connection)
228
# The first time connecting to introducer, keep trying to connect
229
if self._num_needed_peers():
230
if not await self.server.start_client(
0 commit comments