ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2025-12-05 16:58:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

add more logging

Browse Source
This commit is contained in:
CJ Cobb
2021-01-21 11:23:21 -05:00
parent eca85b3538
commit 5d233fce1b
5 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
handlers/LedgerData.cpp
View File

@@ -53,6 +53,8 @@ doLedgerData(
auto start = std::chrono::system_clock::now(); auto start = std::chrono::system_clock::now();
auto [results, returnedMarker] = auto [results, returnedMarker] =
backend.doUpperBound(marker, ledger, limit); backend.doUpperBound(marker, ledger, limit);
BOOST_LOG_TRIVIAL(debug)
<< "doUpperBound returned " << results.size() << " results";
auto end = std::chrono::system_clock::now(); auto end = std::chrono::system_clock::now();

2
reporting/ReportingBackend.cpp
View File

@@ -273,6 +273,8 @@ flatMapReadObjectCallback(CassFuture* fut, void* cbData)
else else
{ {
auto finish = [&requestParams]() { auto finish = [&requestParams]() {
BOOST_LOG_TRIVIAL(trace)
<< "flatMapReadObjectCallback - finished a read";
size_t batchSize = requestParams.batchSize; size_t batchSize = requestParams.batchSize;
if (++(requestParams.numFinished) == batchSize) if (++(requestParams.numFinished) == batchSize)
requestParams.cv.notify_all(); requestParams.cv.notify_all();

4
reporting/ReportingBackend.h
View File

@@ -996,6 +996,7 @@ public:
std::uint32_t seq, std::uint32_t seq,
std::uint32_t limit) const std::uint32_t limit) const
{ {
BOOST_LOG_TRIVIAL(debug) << "Starting doUpperBound";
CassStatement* statement = cass_prepared_bind(upperBound_); CassStatement* statement = cass_prepared_bind(upperBound_);
cass_statement_set_consistency(statement, CASS_CONSISTENCY_QUORUM); cass_statement_set_consistency(statement, CASS_CONSISTENCY_QUORUM);
int64_t markerVal = marker ? marker.value() : INT64_MIN; int64_t markerVal = marker ? marker.value() : INT64_MIN;
@@ -1058,6 +1059,7 @@ public:
cass_statement_free(statement); cass_statement_free(statement);
cass_future_free(fut); cass_future_free(fut);
BOOST_LOG_TRIVIAL(debug) << "doUpperBound - got keys";
std::vector<ripple::uint256> keys; std::vector<ripple::uint256> keys;
CassIterator* iter = cass_iterator_from_result(res); CassIterator* iter = cass_iterator_from_result(res);
@@ -1081,6 +1083,8 @@ public:
} }
keys.push_back(ripple::uint256::fromVoid(outData)); keys.push_back(ripple::uint256::fromVoid(outData));
} }
BOOST_LOG_TRIVIAL(debug)
<< "doUpperBound - populated keys. num keys = " << keys.size();
if (keys.size()) if (keys.size())
{ {
std::vector<LedgerObject> results; std::vector<LedgerObject> results;

4
test.py
View File

@@ -52,7 +52,7 @@ async def ledger_data(ip, port, ledger, limit):
address = 'ws://' + str(ip) + ':' + str(port) address = 'ws://' + str(ip) + ':' + str(port)
try: try:
async with websockets.connect(address) as ws: async with websockets.connect(address) as ws:
await ws.send(json.dumps({"command":"ledger_data","ledger_index":int(ledger),"limit":int(limit)})) await ws.send(json.dumps({"command":"ledger_data","ledger_index":int(ledger),"limit":int(limit),"binary":True}))
res = json.loads(await ws.recv()) res = json.loads(await ws.recv())
print(res) print(res)
except websockets.exceptions.connectionclosederror as e: except websockets.exceptions.connectionclosederror as e:
@@ -66,7 +66,7 @@ async def ledger_data_full(ip, port, ledger):
marker = None marker = None
while True: while True:
if marker is None: if marker is None:
await ws.send(json.dumps({"command":"ledger_data","ledger_index":int(ledger)})) await ws.send(json.dumps({"command":"ledger_data","ledger_index":int(ledger),"binary":True}))
res = json.loads(await ws.recv()) res = json.loads(await ws.recv())
print(res) print(res)

1
websocket_server_async.cpp
View File

@@ -70,6 +70,7 @@ buildResponse(
std::shared_ptr<PgPool>& pgPool) std::shared_ptr<PgPool>& pgPool)
{ {
std::string command = request.at("command").as_string().c_str(); std::string command = request.at("command").as_string().c_str();
BOOST_LOG_TRIVIAL(info) << "Received rpc command : " << request;
boost::json::object response; boost::json::object response;
switch (commandMap[command]) switch (commandMap[command])
{ {