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

Address review

pull/7286/head
ivyazmitinov 2024-02-28 09:18:49 +01:00
parent 10f4777aaf
commit a48f2743bf
2 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -327,7 +327,7 @@ StartNodeUserDatabaseConnection(uint32 flags, const char *hostname, int32 port,
*/ */
ConnectionHashEntry *entry = hash_search(ConnectionHash, &key, HASH_ENTER, &found); ConnectionHashEntry *entry = hash_search(ConnectionHash, &key, HASH_ENTER, &found);
if (!(found && entry->isValid)) if (!found || !entry->isValid)
{ {
/* /*
* We are just building hash entry or previously it was left in an * We are just building hash entry or previously it was left in an

6
src/backend/distributed/utils/maintenanced.c
View File

@ -706,10 +706,7 @@ CitusMaintenanceDaemonMain(Datum main_arg)
timeout = Min(timeout, Recover2PCInterval); timeout = Min(timeout, Recover2PCInterval);
} }
/* /* the config value -1 disables the distributed deadlock detection */
* Execute only on the maintenance database, if it configured, otherwise run from every daemon.
* The config value -1 disables the distributed deadlock detection
*/
if (DistributedDeadlockDetectionTimeoutFactor != -1.0) if (DistributedDeadlockDetectionTimeoutFactor != -1.0)
{ {
double deadlockTimeout = double deadlockTimeout =
@ -736,7 +733,6 @@ CitusMaintenanceDaemonMain(Datum main_arg)
foundDeadlock = CheckForDistributedDeadlocks(); foundDeadlock = CheckForDistributedDeadlocks();
} }
CommitTransactionCommand(); CommitTransactionCommand();
/* /*