thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 09:10:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

dbms: development [#CONV-2944].

Browse Source
This commit is contained in:
Alexey Milovidov 2012-08-16 17:50:54 +00:00
parent f9027b8f0e
commit a8d30e6483
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
dbms/src/Server/TCPHandler.cpp
View File

@ -19,6 +19,9 @@
#include "TCPHandler.h"
#include <Poco/Ext/ThreadNumber.h>
/// Блокироваться в цикле ожидания запроса на указанное количество секунд.
#define POLL_INTERVAL 10
namespace DB
{
@ -54,8 +57,16 @@ void TCPHandler::runImpl()
sendHello();
while (!in->eof())
while (1)
{
/// Ждём пакета от клиента. При этом, каждые POLL_INTERVAL сек. проверяем, не требуется ли завершить работу.
while (!in->poll(POLL_INTERVAL) && !Daemon::instance().isCancelled())
;
/// Если требуется завершить работу, или клиент отсоединился.
if (Daemon::instance().isCancelled() || in->eof())
break;
Stopwatch watch;
state.reset();