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

Small fixes

pull/7286/head
ivyazmitinov 2023-10-13 21:52:08 +07:00
parent 23e6b36e23
commit d44b1dd99a
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -416,7 +416,7 @@ IncrementSharedConnectionCounterInternal(uint32 externalFlags,
workerNodeConnectionEntry->count = 0; workerNodeConnectionEntry->count = 0;
} }
/* Initialized SharedWorkerNodeDatabaseConnStatsHash the same way */ /* Initialize SharedWorkerNodeDatabaseConnStatsHash the same way */
SharedWorkerNodeDatabaseConnStatsHashKey workerNodeDatabaseKey = SharedWorkerNodeDatabaseConnStatsHashKey workerNodeDatabaseKey =
PrepareWorkerNodeDatabaseHashKey(hostname, port, database); PrepareWorkerNodeDatabaseHashKey(hostname, port, database);
bool workerNodeDatabaseEntryFound = false; bool workerNodeDatabaseEntryFound = false;
@ -504,15 +504,6 @@ static bool isConnectionSlotAvailable(SharedWorkerNodeConnStatsHashKey *connKey,
*/ */
void void
DecrementSharedConnectionCounter(const char *hostname, int port) DecrementSharedConnectionCounter(const char *hostname, int port)
{
DecrementSharedConnectionCounterInternal(hostname, port);
UnLockConnectionSharedMemory();
WakeupWaiterBackendsForSharedConnection();
}
static void
DecrementSharedConnectionCounterInternal(const char *hostname, int port)
{ {
/* /*
* Do not call GetMaxSharedPoolSize() here, since it may read from * Do not call GetMaxSharedPoolSize() here, since it may read from
@ -526,6 +517,17 @@ DecrementSharedConnectionCounterInternal(const char *hostname, int port)
LockConnectionSharedMemory(LW_EXCLUSIVE); LockConnectionSharedMemory(LW_EXCLUSIVE);
DecrementSharedConnectionCounterInternal(hostname, port);
UnLockConnectionSharedMemory();
WakeupWaiterBackendsForSharedConnection();
}
static void
DecrementSharedConnectionCounterInternal(const char *hostname, int port)
{
bool workerNodeEntryFound = false; bool workerNodeEntryFound = false;
SharedWorkerNodeConnStatsHashKey workerNodeKey = PrepareWorkerNodeHashKey(hostname, port); SharedWorkerNodeConnStatsHashKey workerNodeKey = PrepareWorkerNodeHashKey(hostname, port);
SharedWorkerNodeConnStatsHashEntry *workerNodeEntry = SharedWorkerNodeConnStatsHashEntry *workerNodeEntry =