thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 00:30:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use ConnectionPoolPtr instead of raw pointer

Browse Source
This commit is contained in:
Igor Nikonov 2024-02-05 12:56:03 +00:00
parent 92a36109c3
commit 45bcc04d98
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Processors/QueryPlan/ReadFromRemote.cpp
View File

@ -439,7 +439,7 @@ void ReadFromParallelRemoteReplicasStep::initializePipeline(QueryPipelineBuilder
void ReadFromParallelRemoteReplicasStep::addPipeForSingeReplica(
Pipes & pipes, IConnectionPool * pool, IConnections::ReplicaInfo replica_info)
Pipes & pipes, const ConnectionPoolPtr & pool, IConnections::ReplicaInfo replica_info)
{
bool add_agg_info = stage == QueryProcessingStage::WithMergeableState;
bool add_totals = false;

2
src/Processors/QueryPlan/ReadFromRemote.h
View File

@ -90,7 +90,7 @@ public:
void enforceAggregationInOrder();
private:
void addPipeForSingeReplica(Pipes & pipes, IConnectionPool * pool, IConnections::ReplicaInfo replica_info);
void addPipeForSingeReplica(Pipes & pipes, const ConnectionPoolPtr & pool, IConnections::ReplicaInfo replica_info);
ClusterPtr cluster;
ASTPtr query_ast;

2
src/QueryPipeline/RemoteQueryExecutor.cpp
View File

@ -64,7 +64,7 @@ RemoteQueryExecutor::RemoteQueryExecutor(
}
RemoteQueryExecutor::RemoteQueryExecutor(
IConnectionPool * pool,
ConnectionPoolPtr pool,
const String & query_,
const Block & header_,
ContextPtr context_,

2
src/QueryPipeline/RemoteQueryExecutor.h
View File

@ -54,7 +54,7 @@ public:
/// Takes a connection pool for a node (not cluster)
RemoteQueryExecutor(
IConnectionPool * pool,
ConnectionPoolPtr pool,
const String & query_,
const Block & header_,
ContextPtr context_,