shm_mq: Repair breakage from previous commit.

If the counterparty writes some data into the queue and then detaches,
it's wrong to return SHM_MQ_DETACHED right away.  If we do that, we
fail to read whatever was written.

diff --git a/src/backend/storage/ipc/shm_mq.c b/src/backend/storage/ipc/shm_mq.c
index 296f0bda40cabd57c37f3767bb244969d8cb9ded..c386b2207a1191466e28d2aa4ed5517497ca3b37 100644 (file)
--- a/src/backend/storage/ipc/shm_mq.c
+++ b/src/backend/storage/ipc/shm_mq.c
@@ -405,10 +405,12 @@ shm_mq_receive(shm_mq_handle *mqh, Size *nbytesp, void **datap, bool nowait)
    {
        if (nowait)
        {
-           if (shm_mq_counterparty_gone(mq, mqh->mqh_handle))
-               return SHM_MQ_DETACHED;
            if (shm_mq_get_sender(mq) == NULL)
+           {
+               if (shm_mq_counterparty_gone(mq, mqh->mqh_handle))
+                   return SHM_MQ_DETACHED;
                return SHM_MQ_WOULD_BLOCK;
+           }
        }
        else if (!shm_mq_wait_internal(mq, &mq->mq_sender, mqh->mqh_handle)
                 && shm_mq_get_sender(mq) == NULL)