From eedf791a8d7b65230605941991ce1823527f462f Mon Sep 17 00:00:00 2001 From: Kishore Nallan Date: Sun, 1 Aug 2021 19:20:26 +0530 Subject: [PATCH] Reduce logging. --- src/batched_indexer.cpp | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/batched_indexer.cpp b/src/batched_indexer.cpp index ac6871ff..8b78daaf 100644 --- a/src/batched_indexer.cpp +++ b/src/batched_indexer.cpp @@ -23,7 +23,7 @@ void BatchedIndexer::enqueue(const std::shared_ptr& req, const std::sh const std::string& req_key_prefix = get_req_prefix_key(req->start_ts); const std::string& request_chunk_key = req_key_prefix + StringUtils::serialize_uint32_t(chunk_sequence); - LOG(INFO) << "req_id: " << req->start_ts << ", chunk_sequence: " << chunk_sequence; + //LOG(INFO) << "req_id: " << req->start_ts << ", chunk_sequence: " << chunk_sequence; store->insert(request_chunk_key, req->serialize()); req->body = ""; @@ -45,6 +45,8 @@ void BatchedIndexer::enqueue(const std::shared_ptr& req, const std::sh } if(req->last_chunk_aggregate) { + //LOG(INFO) << "Last chunk for req_id: " << req->start_ts; + { std::unique_lock lk(qmutuxes[queue_id]); req_res_t req_res(req, res, batch_begin_ts); @@ -118,7 +120,7 @@ void BatchedIndexer::run() { iter->Next(); } - LOG(INFO) << "Erasing request data from disk and memory for request " << req_res.req->start_ts; + //LOG(INFO) << "Erasing request data from disk and memory for request " << req_res.req->start_ts; // we can delete the buffered request content store->delete_range(req_key_prefix, req_key_prefix + StringUtils::serialize_uint32_t(UINT32_MAX));