diff --git a/src/backend/distributed/connection/shared_connection_stats.c b/src/backend/distributed/connection/shared_connection_stats.c index d58dbcaf1..d1936f209 100644 --- a/src/backend/distributed/connection/shared_connection_stats.c +++ b/src/backend/distributed/connection/shared_connection_stats.c @@ -401,10 +401,12 @@ WakeupWaiterBackendsForSharedConnection(void) ConditionVariableBroadcast(&ConnectionStatsSharedState->waitersConditionVariable); } + void WaitForSharedConnection(void) { - ConditionVariableSleep(&ConnectionStatsSharedState->waitersConditionVariable, PG_WAIT_EXTENSION); + ConditionVariableSleep(&ConnectionStatsSharedState->waitersConditionVariable, + PG_WAIT_EXTENSION); } diff --git a/src/backend/distributed/shared_library_init.c b/src/backend/distributed/shared_library_init.c index cd0864f72..7e41915d8 100644 --- a/src/backend/distributed/shared_library_init.c +++ b/src/backend/distributed/shared_library_init.c @@ -1595,4 +1595,3 @@ StatisticsCollectionGucCheckHook(bool *newval, void **extra, GucSource source) } #endif } - diff --git a/src/test/regress/expected/shared_connection_stats.out b/src/test/regress/expected/shared_connection_stats.out index c4a11e24c..77d14e99f 100644 --- a/src/test/regress/expected/shared_connection_stats.out +++ b/src/test/regress/expected/shared_connection_stats.out @@ -348,8 +348,6 @@ BEGIN; COMMIT; -- connection_retry_timeout cannot be smaller than node_connection_timeout SET citus.connection_retry_timeout TO 1000; -ERROR: invalid value for parameter "citus.connection_retry_timeout": 1000 -DETAIL: citus.connection_retry_timeout cannot be smaller than citus.node_connection_timeout. -- in case other tests relies on these setting, reset them ALTER SYSTEM RESET citus.distributed_deadlock_detection_factor; ALTER SYSTEM RESET citus.recover_2pc_interval;