From bb3fedcd5517641a4111f6629049052b6a3bda31 Mon Sep 17 00:00:00 2001 From: Alexey Milovidov Date: Tue, 16 Oct 2012 17:34:05 +0000 Subject: [PATCH] dbms: addition to prev. revision [#CONV-2944]. --- dbms/include/DB/DataStreams/RemoteBlockInputStream.h | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/dbms/include/DB/DataStreams/RemoteBlockInputStream.h b/dbms/include/DB/DataStreams/RemoteBlockInputStream.h index 2b97411fe2a..b160cbb1190 100644 --- a/dbms/include/DB/DataStreams/RemoteBlockInputStream.h +++ b/dbms/include/DB/DataStreams/RemoteBlockInputStream.h @@ -81,7 +81,11 @@ public: /// Если ещё прочитали не все данные, но они больше не нужны, то отправим просьбу прервать выполнение запроса. if (sent_query && !finished) { - connection.sendCancel(); + if (!cancelled) + { + cancelled = true; + connection.sendCancel(); + } /// Получим оставшиеся пакеты, чтобы не было рассинхронизации в соединении с сервером. while (true)