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

Method sendQuery

src/QueryPipeline/RemoteQueryExecutor.cpp:405–418  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

403}
404
405void RemoteQueryExecutor::sendQuery(ClientInfo::QueryKind query_kind, AsyncCallback async_callback)
406{
407 /// Query cannot be canceled in the middle of the send query,
408 /// since there are multiple packets:
409 /// - Query
410 /// - Data (multiple times)
411 ///
412 /// And after the Cancel packet none Data packet can be sent, otherwise the remote side will throw:
413 ///
414 /// Unexpected packet Data received from client
415 ///
416 LockAndBlocker guard(was_cancelled_mutex);
417 sendQueryUnlocked(query_kind, async_callback);
418}
419
420void RemoteQueryExecutor::sendQueryUnlocked(ClientInfo::QueryKind query_kind, AsyncCallback async_callback)
421{

Callers 2

sendQueryUnlockedMethod · 0.45
initializeMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected