diff --git a/src/backend/distributed/commands/utility_hook.c b/src/backend/distributed/commands/utility_hook.c index 7ff9470de..9fe4985d8 100644 --- a/src/backend/distributed/commands/utility_hook.c +++ b/src/backend/distributed/commands/utility_hook.c @@ -771,7 +771,7 @@ ShouldUndistributeCitusLocalTables(void) return false; } - if (IsCitusInitiatedBackend()) + if (IsCitusInitiatedRemoteBackend()) { /* connection from the coordinator operating on a shard */ return false; diff --git a/src/backend/distributed/connection/connection_management.c b/src/backend/distributed/connection/connection_management.c index b9361db1c..f64fa03ce 100644 --- a/src/backend/distributed/connection/connection_management.c +++ b/src/backend/distributed/connection/connection_management.c @@ -1298,7 +1298,7 @@ ShouldShutdownConnection(MultiConnection *connection, const int cachedConnection * escalating the number of cached connections. We can recognize such backends * from their application name. */ - return IsCitusInitiatedBackend() || + return IsCitusInitiatedRemoteBackend() || connection->initilizationState != POOL_STATE_INITIALIZED || cachedConnectionCount >= MaxCachedConnectionsPerWorker || connection->forceCloseAtTransactionEnd || @@ -1308,11 +1308,11 @@ ShouldShutdownConnection(MultiConnection *connection, const int cachedConnection /* - * IsCitusInitiatedBackend returns true if we are in a backend that citus + * IsCitusInitiatedRemoteBackend returns true if we are in a backend that citus * initiated via remote connection. */ bool -IsCitusInitiatedBackend(void) +IsCitusInitiatedRemoteBackend(void) { return application_name && strcmp(application_name, CITUS_APPLICATION_NAME) == 0; } diff --git a/src/include/distributed/connection_management.h b/src/include/distributed/connection_management.h index d8dde1067..29408d78c 100644 --- a/src/include/distributed/connection_management.h +++ b/src/include/distributed/connection_management.h @@ -252,7 +252,7 @@ extern void FinishConnectionListEstablishment(List *multiConnectionList); extern void FinishConnectionEstablishment(MultiConnection *connection); extern void ClaimConnectionExclusively(MultiConnection *connection); extern void UnclaimConnection(MultiConnection *connection); -extern bool IsCitusInitiatedBackend(void); +extern bool IsCitusInitiatedRemoteBackend(void); /* time utilities */ extern double MillisecondsPassedSince(instr_time moment);