thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-15 10:52:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

set chunked for testing

Browse Source
This commit is contained in:
Yakov Olkhovskiy 2024-05-31 06:35:04 +00:00
parent 1dc381dbc1
commit fdccba97a3
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Client/ConnectionParameters.cpp
View File

@ -103,8 +103,8 @@ ConnectionParameters::ConnectionParameters(const Poco::Util::AbstractConfigurati
#endif #endif
} }
proto_send_chunked = config.getString("proto_caps.send", "notchunked_optional"); proto_send_chunked = config.getString("proto_caps.send", "chunked");
proto_recv_chunked = config.getString("proto_caps.recv", "notchunked_optional"); proto_recv_chunked = config.getString("proto_caps.recv", "chunked");
quota_key = config.getString("quota_key", ""); quota_key = config.getString("quota_key", "");

8
src/Server/TCPHandler.cpp
View File

@ -303,8 +303,8 @@ void TCPHandler::runImpl()
return chunked_srv; return chunked_srv;
}; };
bool out_chunked = is_chunked(server.config().getString("proto_caps.send", "notchunked_optional"), proto_recv_chunked_cl, "send"); bool out_chunked = is_chunked(server.config().getString("proto_caps.send", "chunked"), proto_recv_chunked_cl, "send");
bool in_chunked = is_chunked(server.config().getString("proto_caps.recv", "notchunked_optional"), proto_send_chunked_cl, "recv"); bool in_chunked = is_chunked(server.config().getString("proto_caps.recv", "chunked"), proto_send_chunked_cl, "recv");
if (out_chunked) if (out_chunked)
out->enableChunked(); out->enableChunked();
@ -1645,8 +1645,8 @@ void TCPHandler::sendHello()
writeVarUInt(VERSION_PATCH, *out); writeVarUInt(VERSION_PATCH, *out);
if (client_tcp_protocol_version >= DBMS_MIN_PROTOCOL_VERSION_WITH_CHUNKED_PACKETS) if (client_tcp_protocol_version >= DBMS_MIN_PROTOCOL_VERSION_WITH_CHUNKED_PACKETS)
{ {
writeStringBinary(server.config().getString("proto_caps.send", "notchunked_optional"), *out); writeStringBinary(server.config().getString("proto_caps.send", "chunked"), *out);
writeStringBinary(server.config().getString("proto_caps.recv", "notchunked_optional"), *out); writeStringBinary(server.config().getString("proto_caps.recv", "chunked"), *out);
} }
if (client_tcp_protocol_version >= DBMS_MIN_PROTOCOL_VERSION_WITH_PASSWORD_COMPLEXITY_RULES) if (client_tcp_protocol_version >= DBMS_MIN_PROTOCOL_VERSION_WITH_PASSWORD_COMPLEXITY_RULES)
{ {