[PGPRO-6693] Checking the result of shm_mq_send (according to Svace).

Ekaterina Sokolova · Ekaterina Sokolova · commit bf7eef433573 · 2022-11-09T10:25:58.000+03:00
Tags: pg_query_state.
diff --git a/pg_query_state.c b/pg_query_state.c
@@ -864,9 +864,12 @@ SendBgWorkerPids(void)
 	int				 i;
 	shm_mq_handle 	*mqh;
 	LOCKTAG		     tag;
+	shm_mq_result	result;
 
 	LockShmem(&tag, PG_QS_SND_KEY);
 
+	elog(WARNING, "where am i?");
+
 	mqh = shm_mq_attach(mq, NULL, NULL);
 
 	foreach(iter, QueryDescStack)
@@ -893,10 +896,15 @@ SendBgWorkerPids(void)
 	}
 
 #if PG_VERSION_NUM < 150000
-	shm_mq_send(mqh, msg_len, msg, false);
+	result = shm_mq_send(mqh, msg_len, msg, false);
 #else
-	shm_mq_send(mqh, msg_len, msg, false, true);
+	result = shm_mq_send(mqh, msg_len, msg, false, true);
 #endif
+
+	/* Check for failure. */
+	if(result == SHM_MQ_DETACHED)
+		elog(WARNING, "could not send message queue to shared-memory queue: receiver has been detached");
+
 	UnlockShmem(&tag);
 }
 
