Commit8e0d02e

Ekaterina Sokolova

committed

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

Tags: pg_query_state.

1 parent410cf8f commit8e0d02eCopy full SHA for 8e0d02e

File tree

-2

lines changed

-2

lines changed

Lines changed: 8 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -864,6 +864,7 @@ SendBgWorkerPids(void)`
`864`	`864`	`inti;`
`865`	`865`	`shm_mq_handle*mqh;`
`866`	`866`	`LOCKTAGtag;`
	`867`	`+shm_mq_resultresult;`
`867`	`868`
`868`	`869`	`LockShmem(&tag,PG_QS_SND_KEY);`
`869`	`870`
`@@ -893,10 +894,15 @@ SendBgWorkerPids(void)`
`893`	`894`	`}`
`894`	`895`
`895`	`896`	`#ifPG_VERSION_NUM<150000`
`896`		`-shm_mq_send(mqh,msg_len,msg, false);`
	`897`	`+result=shm_mq_send(mqh,msg_len,msg, false);`
`897`	`898`	`#else`
`898`		`-shm_mq_send(mqh,msg_len,msg, false, true);`
	`899`	`+result=shm_mq_send(mqh,msg_len,msg, false, true);`
`899`	`900`	`#endif`
	`901`	`+`
	`902`	`+/* Check for failure. */`
	`903`	`+if(result==SHM_MQ_DETACHED)`
	`904`	`+elog(WARNING,"could not send tuple to shared-memory queue: receiver of message queue has been detached");`
	`905`	`+`
`900`	`906`	`UnlockShmem(&tag);`
`901`	`907`	`}`
`902`	`908`

Comments

(0)