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

Method run

src/Client/PacketReceiver.cpp:60–70  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

58}
59
60void PacketReceiver::Task::run(AsyncCallback async_callback, SuspendCallback suspend_callback)
61{
62 while (true)
63 {
64 {
65 AsyncCallbackSetter<Connection> async_setter(receiver.connection, async_callback);
66 receiver.packet = receiver.connection->receivePacket();
67 }
68 suspend_callback();
69 }
70}
71
72}
73

Callers 2

parseAndCheckOptionsMethod · 0.45
tryGetEntryMethod · 0.45

Calls 1

receivePacketMethod · 0.45

Tested by

no test coverage detected