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

Improve readability

preventConflictingFlags
Onder Kalaci 2020-04-06 12:28:17 +02:00
parent dd36dd2530
commit ef49e8ba04
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/backend/distributed/connection/shared_connection_stats.c
View File

@ -35,6 +35,8 @@
#define REMOTE_CONNECTION_STATS_COLUMNS 4 #define REMOTE_CONNECTION_STATS_COLUMNS 4
#define ADJUST_POOLSIZE_AUTOMATICALLY 0
#define DISABLE_CONNECTION_THROTTLING -1
/* /*
* The data structure used to store data in shared memory. This data structure is only * The data structure used to store data in shared memory. This data structure is only
@ -205,7 +207,7 @@ RemoveAllSharedConnectionEntriesForNode(char *hostname, int port)
int int
GetMaxSharedPoolSize(void) GetMaxSharedPoolSize(void)
{ {
if (MaxSharedPoolSize == 0) if (MaxSharedPoolSize == ADJUST_POOLSIZE_AUTOMATICALLY)
{ {
return MaxConnections; return MaxConnections;
} }
@ -246,7 +248,7 @@ WaitOrErrorForSharedConnection(const char *hostname, int port)
bool bool
TryToIncrementSharedConnectionCounter(const char *hostname, int port) TryToIncrementSharedConnectionCounter(const char *hostname, int port)
{ {
if (GetMaxSharedPoolSize() == -1) if (GetMaxSharedPoolSize() == DISABLE_CONNECTION_THROTTLING)
{ {
/* connection throttling disabled */ /* connection throttling disabled */
return true; return true;
@ -322,7 +324,7 @@ IncrementSharedConnectionCounter(const char *hostname, int port)
{ {
SharedConnStatsHashKey connKey; SharedConnStatsHashKey connKey;
if (GetMaxSharedPoolSize() == -1) if (GetMaxSharedPoolSize() == DISABLE_CONNECTION_THROTTLING)
{ {
/* connection throttling disabled */ /* connection throttling disabled */
return; return;
@ -368,7 +370,7 @@ DecrementSharedConnectionCounter(const char *hostname, int port)
{ {
SharedConnStatsHashKey connKey; SharedConnStatsHashKey connKey;
if (GetMaxSharedPoolSize() == -1) if (GetMaxSharedPoolSize() == DISABLE_CONNECTION_THROTTLING)
{ {
/* connection throttling disabled */ /* connection throttling disabled */
return; return;