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

Notify queue explicitly during restore.

Browse Source
This commit is contained in:
Kishore Nallan 2021-11-08 14:08:26 +05:30
parent babf6bf5d5
commit 012253de45
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/batched_indexer.cpp
View File

@ -186,7 +186,7 @@ void BatchedIndexer::run() {
}
else {
//LOG(INFO) << "original request: " << orig_req_res.req << ", req: " << orig_req_res.req->req;
//LOG(INFO) << "index req " << req_id << ", chunk index: " << orig_req_res.next_chunk_index;
if(route_found) {
async_res = found_rpath->async_res;
@ -211,8 +211,6 @@ void BatchedIndexer::run() {
orig_req_res.next_chunk_index++;
iter->Next();
//LOG(INFO) << "index req " << req_id << ", chunk index: " << orig_req_res.next_chunk_index;
if(quit) {
break;
}
@ -248,6 +246,7 @@ void BatchedIndexer::run() {
uint64_t seconds_since_batch_update = std::chrono::duration_cast<std::chrono::seconds>(
std::chrono::system_clock::now().time_since_epoch()).count() - it->second.last_updated;
//LOG(INFO) << "GC checking on req id: " << it->first;
//LOG(INFO) << "Seconds since last batch update: " << seconds_since_batch_update;
if(!it->second.is_complete && seconds_since_batch_update > GC_PRUNE_MAX_SECONDS) {
@ -384,6 +383,7 @@ void BatchedIndexer::load_state(const nlohmann::json& state) {
queue_ids.push_back(queue_id);
std::unique_lock qlk(qmutuxes[queue_id].mcv);
queues[queue_id].emplace_back(req->start_ts);
qmutuxes[queue_id].cv.notify_one();
}
num_reqs_restored++;