external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename IsCitusInitiatedBackend to IsCitusInitiatedRemoteBackend (#4562)

pull/4539/head
Onur Tirtir 2021-01-23 01:07:43 +03:00 committed by GitHub
parent a4b5da79dd
commit 253c19062a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/commands/utility_hook.c
View File

@ -771,7 +771,7 @@ ShouldUndistributeCitusLocalTables(void)
return false;
}
if (IsCitusInitiatedBackend())
if (IsCitusInitiatedRemoteBackend())
{
/* connection from the coordinator operating on a shard */
return false;

6
src/backend/distributed/connection/connection_management.c
View File

@ -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;
}

2
src/include/distributed/connection_management.h
View File

@ -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);