|
|
@ -121,7 +121,7 @@ def hex_str_to_bytes(hex_str): |
|
|
|
def str_to_b64str(string): |
|
|
|
def str_to_b64str(string): |
|
|
|
return b64encode(string.encode('utf-8')).decode('ascii') |
|
|
|
return b64encode(string.encode('utf-8')).decode('ascii') |
|
|
|
|
|
|
|
|
|
|
|
def sync_blocks(rpc_connections, wait=1, timeout=60): |
|
|
|
def sync_blocks(rpc_connections, wait=0.125, timeout=60): |
|
|
|
""" |
|
|
|
""" |
|
|
|
Wait until everybody has the same tip |
|
|
|
Wait until everybody has the same tip |
|
|
|
""" |
|
|
|
""" |
|
|
@ -133,7 +133,7 @@ def sync_blocks(rpc_connections, wait=1, timeout=60): |
|
|
|
timeout -= wait |
|
|
|
timeout -= wait |
|
|
|
raise AssertionError("Block sync failed") |
|
|
|
raise AssertionError("Block sync failed") |
|
|
|
|
|
|
|
|
|
|
|
def sync_mempools(rpc_connections, wait=1, timeout=60): |
|
|
|
def sync_mempools(rpc_connections, wait=0.5, timeout=60): |
|
|
|
""" |
|
|
|
""" |
|
|
|
Wait until everybody has the same transactions in their memory |
|
|
|
Wait until everybody has the same transactions in their memory |
|
|
|
pools |
|
|
|
pools |
|
|
|