summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-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);
}