diff --git a/src/backend/distributed/connection/shared_connection_stats.c b/src/backend/distributed/connection/shared_connection_stats.c index af4bac71f..341d53020 100644 --- a/src/backend/distributed/connection/shared_connection_stats.c +++ b/src/backend/distributed/connection/shared_connection_stats.c @@ -274,6 +274,8 @@ WaitLoopForSharedConnection(const char *hostname, int port) { while (!TryToIncrementSharedConnectionCounter(hostname, port)) { + CHECK_FOR_INTERRUPTS(); + WaitForSharedConnection(); }