|
|
@ -223,7 +223,7 @@ def wait_for_bitcoind_start(process, url, i): |
|
|
|
raise # unknown IO error |
|
|
|
raise # unknown IO error |
|
|
|
except JSONRPCException as e: # Initialization phase |
|
|
|
except JSONRPCException as e: # Initialization phase |
|
|
|
if e.error['code'] != -28: # RPC in warmup? |
|
|
|
if e.error['code'] != -28: # RPC in warmup? |
|
|
|
raise # unkown JSON RPC exception |
|
|
|
raise # unknown JSON RPC exception |
|
|
|
time.sleep(0.25) |
|
|
|
time.sleep(0.25) |
|
|
|
|
|
|
|
|
|
|
|
def initialize_chain(test_dir, num_nodes, cachedir): |
|
|
|
def initialize_chain(test_dir, num_nodes, cachedir): |
|
|
@ -257,7 +257,7 @@ def initialize_chain(test_dir, num_nodes, cachedir): |
|
|
|
print("initialize_chain: bitcoind started, waiting for RPC to come up") |
|
|
|
print("initialize_chain: bitcoind started, waiting for RPC to come up") |
|
|
|
wait_for_bitcoind_start(bitcoind_processes[i], rpc_url(i), i) |
|
|
|
wait_for_bitcoind_start(bitcoind_processes[i], rpc_url(i), i) |
|
|
|
if os.getenv("PYTHON_DEBUG", ""): |
|
|
|
if os.getenv("PYTHON_DEBUG", ""): |
|
|
|
print("initialize_chain: RPC succesfully started") |
|
|
|
print("initialize_chain: RPC successfully started") |
|
|
|
|
|
|
|
|
|
|
|
rpcs = [] |
|
|
|
rpcs = [] |
|
|
|
for i in range(MAX_NODES): |
|
|
|
for i in range(MAX_NODES): |
|
|
@ -344,7 +344,7 @@ def start_node(i, dirname, extra_args=None, rpchost=None, timewait=None, binary= |
|
|
|
url = rpc_url(i, rpchost) |
|
|
|
url = rpc_url(i, rpchost) |
|
|
|
wait_for_bitcoind_start(bitcoind_processes[i], url, i) |
|
|
|
wait_for_bitcoind_start(bitcoind_processes[i], url, i) |
|
|
|
if os.getenv("PYTHON_DEBUG", ""): |
|
|
|
if os.getenv("PYTHON_DEBUG", ""): |
|
|
|
print("start_node: RPC succesfully started") |
|
|
|
print("start_node: RPC successfully started") |
|
|
|
proxy = get_rpc_proxy(url, i, timeout=timewait) |
|
|
|
proxy = get_rpc_proxy(url, i, timeout=timewait) |
|
|
|
|
|
|
|
|
|
|
|
if COVERAGE_DIR: |
|
|
|
if COVERAGE_DIR: |
|
|
|