diff --git a/src/protocol/pool_proto_modules.c b/src/protocol/pool_proto_modules.c index e62a3e0bf..71bad97d2 100644 --- a/src/protocol/pool_proto_modules.c +++ b/src/protocol/pool_proto_modules.c @@ -1469,6 +1469,12 @@ Parse(POOL_CONNECTION * frontend, POOL_CONNECTION_POOL * backend, { int i; + /* + * Temporarily unset query in progress so that all live backend + * are processed. + */ + pool_unset_query_in_progress(); + /* synchronize transaction state */ for (i = 0; i < NUM_BACKENDS; i++) {