From fdfeb869a148ee17177a6ae38c8e3814753f93f3 Mon Sep 17 00:00:00 2001 From: Kishore Nallan Date: Tue, 20 Dec 2022 16:29:39 +0530 Subject: [PATCH] Terminate batch indexing iter early on resource exhaustion. --- src/batched_indexer.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/batched_indexer.cpp b/src/batched_indexer.cpp index 9d8bea08..98d314e1 100644 --- a/src/batched_indexer.cpp +++ b/src/batched_indexer.cpp @@ -203,8 +203,9 @@ void BatchedIndexer::run() { if (resource_check != cached_resource_stat_t::OK && orig_req->http_method != "DELETE") { orig_res->set_422("Rejecting write: running out of resource type: " + std::string(magic_enum::enum_name(resource_check))); - orig_res->final = true; - async_res = false; + async_req_res_t* async_req_res = new async_req_res_t(orig_req, orig_res, true); + server->get_message_dispatcher()->send_message(HttpServer::STREAM_RESPONSE_MESSAGE, async_req_res); + break; } else if(route_found) {