summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMarko Kreen2013-04-15 11:45:49 +0000
committerMarko Kreen2013-04-15 11:45:49 +0000
commit0b2009bcce932bb5ff57e0dbe50ac8ebb6d454c9 (patch)
tree5c403fddd83a50c9584d2e9fd3b592cd7110b4e5
parent06d7f616872ba68330212a886ee4357338321e50 (diff)
remote_wait_for_cancel: wait only C_QUERY_READ connections.
Previous check was too broad and left plproxy hanging. Reported-By: Tarvi Pillessaar
-rw-r--r--src/execute.c2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/execute.c b/src/execute.c
index bfd4b0f..00d5c91 100644
--- a/src/execute.c
+++ b/src/execute.c
@@ -816,7 +816,7 @@ remote_wait_for_cancel(ProxyFunction *func)
if (!conn->run_tag)
continue;
- if (conn->cur->state != C_DONE)
+ if (conn->cur->state == C_QUERY_READ)
pending++;
check_timeouts(func, cluster, conn, now.tv_sec);
}