@@ -30,7 +30,7 @@ def run_test(self):
30
30
self .log .info ("setban: successfully ban single IP address" )
31
31
assert_equal (len (self .nodes [1 ].getpeerinfo ()), 2 ) # node1 should have 2 connections to node0 at this point
32
32
self .nodes [1 ].setban ("127.0.0.1" , "add" )
33
- wait_until (lambda : len (self .nodes [1 ].getpeerinfo ()) == 0 )
33
+ assert wait_until (lambda : len (self .nodes [1 ].getpeerinfo ()) == 0 , timeout = 10 )
34
34
assert_equal (len (self .nodes [1 ].getpeerinfo ()), 0 ) # all nodes must be disconnected at this point
35
35
assert_equal (len (self .nodes [1 ].listbanned ()), 1 )
36
36
@@ -64,7 +64,7 @@ def run_test(self):
64
64
self .nodes [1 ].setban ("2001:4d48:ac57:400:cacf:e9ff:fe1d:9c63/19" , "add" , 1000 ) # ban for 1000 seconds
65
65
listBeforeShutdown = self .nodes [1 ].listbanned ()
66
66
assert_equal ("192.168.0.1/32" , listBeforeShutdown [2 ]['address' ])
67
- wait_until (lambda : len (self .nodes [1 ].listbanned ()) == 3 )
67
+ assert wait_until (lambda : len (self .nodes [1 ].listbanned ()) == 3 , timeout = 10 )
68
68
69
69
stop_node (self .nodes [1 ], 1 )
70
70
@@ -78,7 +78,7 @@ def run_test(self):
78
78
self .nodes [1 ].clearbanned ()
79
79
connect_nodes_bi (self .nodes , 0 , 1 )
80
80
81
- self .log .info ("Test disconnectrnode RPCs" )
81
+ self .log .info ("Test disconnectnode RPCs" )
82
82
83
83
self .log .info ("disconnectnode: fail to disconnect when calling with address and nodeid" )
84
84
address1 = self .nodes [0 ].getpeerinfo ()[0 ]['addr' ]
@@ -91,7 +91,7 @@ def run_test(self):
91
91
self .log .info ("disconnectnode: successfully disconnect node by address" )
92
92
address1 = self .nodes [0 ].getpeerinfo ()[0 ]['addr' ]
93
93
self .nodes [0 ].disconnectnode (address = address1 )
94
- wait_until (lambda : len (self .nodes [0 ].getpeerinfo ()) == 1 )
94
+ assert wait_until (lambda : len (self .nodes [0 ].getpeerinfo ()) == 1 , timeout = 10 )
95
95
assert not [node for node in self .nodes [0 ].getpeerinfo () if node ['addr' ] == address1 ]
96
96
97
97
self .log .info ("disconnectnode: successfully reconnect node" )
@@ -102,7 +102,7 @@ def run_test(self):
102
102
self .log .info ("disconnectnode: successfully disconnect node by node id" )
103
103
id1 = self .nodes [0 ].getpeerinfo ()[0 ]['id' ]
104
104
self .nodes [0 ].disconnectnode (nodeid = id1 )
105
- wait_until (lambda : len (self .nodes [0 ].getpeerinfo ()) == 1 )
105
+ assert wait_until (lambda : len (self .nodes [0 ].getpeerinfo ()) == 1 , timeout = 10 )
106
106
assert not [node for node in self .nodes [0 ].getpeerinfo () if node ['id' ] == id1 ]
107
107
108
108
if __name__ == '__main__' :
0 commit comments