Wait for 10 seconds for consumers to finish before destroying shared q.

This matches with the comments and timeout in SharedQueueUnBind()

diff --git a/src/backend/executor/producerReceiver.c b/src/backend/executor/producerReceiver.c
index 3b82a0acefd0d68ace38115a6718818afac6a70a..401a8349b7ad9fc7c979462e384b974532bf55a2 100644 (file)
--- a/src/backend/executor/producerReceiver.c
+++ b/src/backend/executor/producerReceiver.c
@@ -161,7 +161,7 @@ producerDestroyReceiver(DestReceiver *self)
                }
                else
                {
-                       pg_usleep(10000l);
+                       pg_usleep(10*1000*1000l);
                        /*
                         * Do not wait for consumers that was not even connected after 10
                         * seconds after start waiting for their disconnection.