postgres/typesense
1
0
Fork 0
mirror of https://github.com/typesense/typesense.git synced 2025-05-21 22:33:27 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Log req IDs if they are stuck in req_map.

Browse Source
This commit is contained in:
Kishore Nallan 2023-11-20 10:49:55 +05:30
parent af43190b82
commit 03f0c7e100
1 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/batched_indexer.cpp
View File

@ -272,6 +272,9 @@ void BatchedIndexer::run() {
});
}
uint64_t stuck_counter = 0;
uint64_t prev_count = 0;
while(!quit) {
std::this_thread::sleep_for(std::chrono::milliseconds (1000));
@ -284,6 +287,27 @@ void BatchedIndexer::run() {
std::unique_lock lk(mutex);
LOG(INFO) << "Running GC for aborted requests, req map size: " << req_res_map.size();
if(req_res_map.size() > 0 && prev_count == req_res_map.size()) {
stuck_counter++;
if(stuck_counter > 3) {
size_t max_loop = 0;
for(const auto& it : req_res_map) {
max_loop++;
LOG(INFO) << "Stuck req_key: " << it.first;
if(max_loop == 5) {
break;
}
}
stuck_counter = 0;
}
} else {
stuck_counter = 0;
}
prev_count = req_res_map.size();
// iterate through all map entries and delete ones which are not complete but > GC_PRUNE_MAX_SECONDS
for (auto it = req_res_map.cbegin(); it != req_res_map.cend();) {
uint64_t seconds_since_batch_update = std::chrono::duration_cast<std::chrono::seconds>(