MCPcopy Create free account
hub / github.com/ClickHouse/ClickHouse / receiveLogsAndProfileEvents

Method receiveLogsAndProfileEvents

src/Client/ClientBase.cpp:2332–2343  ·  view source on GitHub ↗

Process Log packets, used when inserting data by blocks

Source from the content-addressed store, hash-verified

2330
2331/// Process Log packets, used when inserting data by blocks
2332void ClientBase::receiveLogsAndProfileEvents(ASTPtr parsed_query)
2333{
2334 auto packet_type = connection->checkPacket(0);
2335
2336 while (packet_type && (*packet_type == Protocol::Server::Log
2337 || *packet_type == Protocol::Server::ProfileEvents
2338 || *packet_type == Protocol::Server::TimezoneUpdate))
2339 {
2340 receiveAndProcessPacket(parsed_query, false);
2341 packet_type = connection->checkPacket(0);
2342 }
2343}
2344
2345
2346/// Process Log packets, exit when receive Exception or EndOfStream

Callers

nothing calls this directly

Calls 1

checkPacketMethod · 0.45

Tested by

no test coverage detected