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

Merge pull request #61824 from ClickHouse/remove-datastreams

Browse Source 
Remove DataStreams
This commit is contained in:
Alexey Milovidov 2024-03-24 19:12:05 +03:00 committed by GitHub
commit 5768daf666
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Server/TCPHandler.cpp
View File

@ -38,7 +38,6 @@
#include <Core/ServerSettings.h>
#include <Access/AccessControl.h>
#include <Access/Credentials.h>
#include <DataTypes/DataTypeLowCardinality.h>
#include <Compression/CompressionFactory.h>
#include <Common/logger_useful.h>
#include <Common/CurrentMetrics.h>
@ -537,7 +536,7 @@ void TCPHandler::runImpl()
}
else if (state.io.pipeline.pulling())
{
processOrdinaryQueryWithProcessors();
processOrdinaryQuery();
finish_or_cancel();
}
else if (state.io.pipeline.completed())
@ -992,7 +991,7 @@ void TCPHandler::processInsertQuery()
}
void TCPHandler::processOrdinaryQueryWithProcessors()
void TCPHandler::processOrdinaryQuery()
{
auto & pipeline = state.io.pipeline;
@ -2184,7 +2183,7 @@ void TCPHandler::sendData(const Block & block)
/// For testing hedged requests
if (unknown_packet_in_send_data)
{
constexpr UInt64 marker = (1ULL<<63) - 1;
constexpr UInt64 marker = (1ULL << 63) - 1;
--unknown_packet_in_send_data;
if (unknown_packet_in_send_data == 0)
writeVarUInt(marker, *out);

2
src/Server/TCPHandler.h
View File

@ -278,8 +278,6 @@ private:
/// Process a request that does not require the receiving of data blocks from the client
void processOrdinaryQuery();
void processOrdinaryQueryWithProcessors();
void processTablesStatusRequest();
void sendHello();