@@ -100,8 +100,8 @@ def run_test(self):
100
100
101
101
# disconnect nodes & make a txn that remains in the unbroadcast set.
102
102
self .disconnect_nodes (0 , 1 )
103
- assert (len (self .nodes [0 ].getpeerinfo ()) == 0 )
104
- assert (len (self .nodes [0 ].p2ps ) == 0 )
103
+ assert_equal (len (self .nodes [0 ].getpeerinfo ()), 0 )
104
+ assert_equal (len (self .nodes [0 ].p2ps ), 0 )
105
105
self .mini_wallet .send_self_transfer (from_node = self .nodes [0 ])
106
106
self .connect_nodes (0 , 2 )
107
107
@@ -178,17 +178,18 @@ def test_persist_unbroadcast(self):
178
178
179
179
# ensure node0 doesn't have any connections
180
180
# make a transaction that will remain in the unbroadcast set
181
- assert (len (node0 .getpeerinfo ()) == 0 )
182
- assert (len (node0 .p2ps ) == 0 )
181
+ assert_equal (len (node0 .getpeerinfo ()), 0 )
182
+ assert_equal (len (node0 .p2ps ), 0 )
183
183
self .mini_wallet .send_self_transfer (from_node = node0 )
184
184
185
185
# shutdown, then startup with wallet disabled
186
186
self .restart_node (0 , extra_args = ["-disablewallet" ])
187
187
188
188
# check that txn gets broadcast due to unbroadcast logic
189
189
conn = node0 .add_p2p_connection (P2PTxInvStore ())
190
- node0 .mockscheduler (16 * 60 ) # 15 min + 1 for buffer
190
+ node0 .mockscheduler (16 * 60 ) # 15 min + 1 for buffer
191
191
self .wait_until (lambda : len (conn .get_invs ()) == 1 )
192
192
193
- if __name__ == '__main__' :
193
+
194
+ if __name__ == "__main__" :
194
195
MempoolPersistTest ().main ()
0 commit comments