Merge #8857: [qa] mininode: Only allow named args in wait_until
fa66609
[qa] mininode: Only allow named args in wait_until (MarcoFalke)
This commit is contained in:
commit
6013c73b33
3 changed files with 3 additions and 3 deletions
|
@ -75,7 +75,7 @@ class TestNode(NodeConnCB):
|
||||||
def received_pong():
|
def received_pong():
|
||||||
return (self.last_pong.nonce == self.ping_counter)
|
return (self.last_pong.nonce == self.ping_counter)
|
||||||
self.connection.send_message(msg_ping(nonce=self.ping_counter))
|
self.connection.send_message(msg_ping(nonce=self.ping_counter))
|
||||||
success = wait_until(received_pong, timeout)
|
success = wait_until(received_pong, timeout=timeout)
|
||||||
self.ping_counter += 1
|
self.ping_counter += 1
|
||||||
return success
|
return success
|
||||||
|
|
||||||
|
|
|
@ -63,7 +63,7 @@ class TestNode(NodeConnCB):
|
||||||
def received_pong():
|
def received_pong():
|
||||||
return (self.last_pong.nonce == self.ping_counter)
|
return (self.last_pong.nonce == self.ping_counter)
|
||||||
self.connection.send_message(msg_ping(nonce=self.ping_counter))
|
self.connection.send_message(msg_ping(nonce=self.ping_counter))
|
||||||
success = wait_until(received_pong, timeout)
|
success = wait_until(received_pong, timeout=timeout)
|
||||||
self.ping_counter += 1
|
self.ping_counter += 1
|
||||||
return success
|
return success
|
||||||
|
|
||||||
|
|
|
@ -1320,7 +1320,7 @@ class msg_reject(object):
|
||||||
% (self.message, self.code, self.reason, self.data)
|
% (self.message, self.code, self.reason, self.data)
|
||||||
|
|
||||||
# Helper function
|
# Helper function
|
||||||
def wait_until(predicate, attempts=float('inf'), timeout=float('inf')):
|
def wait_until(predicate, *, attempts=float('inf'), timeout=float('inf')):
|
||||||
attempt = 0
|
attempt = 0
|
||||||
elapsed = 0
|
elapsed = 0
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue