thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 10:02:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

small fix

Browse Source
This commit is contained in:
Antonio Andelic 2023-03-27 07:36:39 +00:00
parent f355bc5342
commit 79e22d13fb
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Coordination/KeeperDispatcher.cpp
View File

@ -92,7 +92,7 @@ void KeeperDispatcher::requestThread()
KeeperStorage::RequestsForSessions current_batch;
size_t current_batch_bytes_size = 0;
bool has_read_request{false};
bool has_read_request = false;
/// If new request is not read request or we must to process it through quorum.
/// Otherwise we will process it locally.
@ -101,8 +101,6 @@ void KeeperDispatcher::requestThread()
current_batch_bytes_size += request.request->bytesSize();
current_batch.emplace_back(request);
size_t read_requests = 0;
const auto try_get_request = [&]
{
/// Trying to get batch requests as fast as possible
@ -112,7 +110,6 @@ void KeeperDispatcher::requestThread()
/// Don't append read request into batch, we have to process them separately
if (!coordination_settings->quorum_reads && request.request->isReadRequest())
{
++read_requests;
const auto & last_request = current_batch.back();
std::lock_guard lock(read_request_queue_mutex);
read_request_queue[last_request.session_id][last_request.request->xid].push_back(request);