File tree Expand file tree Collapse file tree 2 files changed +0
-8
lines changed Expand file tree Collapse file tree 2 files changed +0
-8
lines changed Original file line number Diff line number Diff line change @@ -212,17 +212,13 @@ async def new_stream(
212
212
:return: stream: new stream created
213
213
"""
214
214
net_stream = await self ._network .new_stream (peer_id )
215
- logger .info ("INETSTREAM CHECKING IN" )
216
- logger .info (protocol_ids )
217
215
# Perform protocol muxing to determine protocol to use
218
216
try :
219
- logger .debug ("PROTOCOLS TRYING TO GET SENT" )
220
217
selected_protocol = await self .multiselect_client .select_one_of (
221
218
list (protocol_ids ),
222
219
MultiselectCommunicator (net_stream ),
223
220
negotitate_timeout ,
224
221
)
225
- logger .info ("PROTOCOLS GOT SENT" )
226
222
except MultiselectClientError as error :
227
223
logger .debug ("fail to open a stream to peer %s, error=%s" , peer_id , error )
228
224
await net_stream .reset ()
Original file line number Diff line number Diff line change @@ -127,7 +127,6 @@ async def dial_peer(self, peer_id: ID) -> INetConn:
127
127
:return: muxed connection
128
128
"""
129
129
if peer_id in self .connections :
130
- logger .info ("WE ARE RETURNING, PEER ALREADAY EXISTS" )
131
130
# If muxed connection already exists for peer_id,
132
131
# set muxed connection equal to existing muxed connection
133
132
return self .connections [peer_id ]
@@ -148,7 +147,6 @@ async def dial_peer(self, peer_id: ID) -> INetConn:
148
147
# Try all known addresses
149
148
for multiaddr in addrs :
150
149
try :
151
- logger .info ("HANDSHAKE GOING TO HAPPEN" )
152
150
return await self .dial_addr (multiaddr , peer_id )
153
151
except SwarmException as e :
154
152
exceptions .append (e )
@@ -223,10 +221,8 @@ async def new_stream(self, peer_id: ID) -> INetStream:
223
221
logger .debug ("attempting to open a stream to peer %s" , peer_id )
224
222
225
223
swarm_conn = await self .dial_peer (peer_id )
226
- logger .info ("INETCONN CREATED" )
227
224
228
225
net_stream = await swarm_conn .new_stream ()
229
- logger .info ("INETSTREAM CREATED" )
230
226
231
227
logger .debug ("successfully opened a stream to peer %s" , peer_id )
232
228
return net_stream
You can’t perform that action at this time.
0 commit comments