@@ -121,19 +121,19 @@ def __repr__(self):
121
121
checked_outbound_version_msg = 0
122
122
events = []
123
123
124
- def check_p2p_message (event , inbound ):
124
+ def check_p2p_message (event , is_inbound ):
125
125
nonlocal checked_inbound_version_msg , checked_outbound_version_msg
126
126
if event .msg_type .decode ("utf-8" ) == "version" :
127
127
self .log .info (
128
- f"check_p2p_message(): { 'inbound' if inbound else 'outbound' } { event } " )
128
+ f"check_p2p_message(): { 'inbound' if is_inbound else 'outbound' } { event } " )
129
129
peer = self .nodes [0 ].getpeerinfo ()[0 ]
130
130
msg = msg_version ()
131
131
msg .deserialize (BytesIO (bytes (event .msg [:event .msg_size ])))
132
132
assert_equal (peer ["id" ], event .peer_id , peer ["id" ])
133
133
assert_equal (peer ["addr" ], event .peer_addr .decode ("utf-8" ))
134
134
assert_equal (peer ["connection_type" ],
135
135
event .peer_conn_type .decode ("utf-8" ))
136
- if inbound :
136
+ if is_inbound :
137
137
checked_inbound_version_msg += 1
138
138
else :
139
139
checked_outbound_version_msg += 1
@@ -157,8 +157,8 @@ def handle_outbound(_, data, __):
157
157
158
158
self .log .info (
159
159
"check receipt and content of in- and outbound version messages" )
160
- for event , inbound in events :
161
- check_p2p_message (event , inbound )
160
+ for event , is_inbound in events :
161
+ check_p2p_message (event , is_inbound )
162
162
assert_equal (EXPECTED_INOUTBOUND_VERSION_MSG ,
163
163
checked_inbound_version_msg )
164
164
assert_equal (EXPECTED_INOUTBOUND_VERSION_MSG ,
0 commit comments