ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2026-04-29 15:37:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

change etl failover timeout to 10 seconds

Browse Source
This commit is contained in:
CJ Cobb
2022-03-21 15:12:38 -04:00
committed by CJ Cobb
parent 39459ef6da
commit 945222840b
2 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/etl/ReportingETL.cpp
View File

@@ -858,13 +858,13 @@ ReportingETL::monitor()
<< "Ledger with sequence = " << nextSequence
<< " has been validated by the network. "
<< "Attempting to find in database and publish";
// Attempt to take over responsibility of ETL writer after 2 failed
// Attempt to take over responsibility of ETL writer after 10 failed
// attempts to publish the ledger. publishLedger() fails if the
// ledger that has been validated by the network is not found in the
// database after the specified number of attempts. publishLedger()
// waits one second between each attempt to read the ledger from the
// database
constexpr size_t timeoutSeconds = 2;
constexpr size_t timeoutSeconds = 10;
bool success = publishLedger(nextSequence, timeoutSeconds);
if (!success)
{

8
test.py
View File

@@ -974,7 +974,7 @@ parser = argparse.ArgumentParser(description='test script for xrpl-reporting')
parser.add_argument('action', choices=["account_info", "tx", "txs","account_tx", "account_tx_full","ledger_data", "ledger_data_full", "book_offers","ledger","ledger_range","ledger_entry", "ledgers", "ledger_entries","account_txs","account_infos","account_txs_full","book_offerses","ledger_diff","perf","fee","server_info", "gaps","subscribe","verify_subscribe","call"])
parser.add_argument('--ip', default='127.0.0.1')
parser.add_argument('--port', default='8080')
parser.add_argument('--port', default='51233')
parser.add_argument('--hash')
parser.add_argument('--account')
parser.add_argument('--ledger')
@@ -1018,6 +1018,10 @@ def run(args):
asyncio.get_event_loop().run_until_complete(
call(args.ip,args.port,args.request))
return
elif args.action == "server_info":
asyncio.get_event_loop().run_until_complete(server_info(args.ip, args.port))
return
rng =asyncio.get_event_loop().run_until_complete(ledger_range(args.ip, args.port))
if args.ledger is None:
args.ledger = rng[1]
@@ -1027,8 +1031,6 @@ def run(args):
args.minLedger = rng[0]
if args.action == "fee":
asyncio.get_event_loop().run_until_complete(fee(args.ip, args.port))
elif args.action == "server_info":
asyncio.get_event_loop().run_until_complete(server_info(args.ip, args.port))
elif args.action == "perf":
asyncio.get_event_loop().run_until_complete(
perf(args.ip,args.port))