thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-25 17:12:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Sane constant while reading requests

Browse Source
This commit is contained in:
alesapin 2021-02-19 12:57:39 +03:00
parent 86a74ca6b5
commit 6c9322bb2e
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Server/NuKeeperTCPHandler.cpp
View File

@ -342,6 +342,7 @@ void NuKeeperTCPHandler::runImpl()
PollResult result = poll_wrapper->poll(session_timeout);
if (result.has_requests && !close_received)
{
size_t requests_read = 0;
do
{
auto [received_op, received_xid] = receiveRequest();
@ -358,6 +359,10 @@ void NuKeeperTCPHandler::runImpl()
LOG_TRACE(log, "Received heartbeat for session #{}", session_id);
session_stopwatch.restart();
}
if (requests_read > 50)
break;
requests_read++;
}
while (in->available());
}