Commitbf7eef4

Ekaterina Sokolova

committed

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

Tags: pg_query_state.

1 parent410cf8f commitbf7eef4Copy full SHA for bf7eef4

File tree

+10

-2

lines changed

+10

-2

lines changed

Lines changed: 10 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -864,9 +864,12 @@ 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`
	`871`	`+elog(WARNING,"where am i?");`
	`872`	`+`
`870`	`873`	`mqh=shm_mq_attach(mq,NULL,NULL);`
`871`	`874`
`872`	`875`	`foreach(iter,QueryDescStack)`
`@@ -893,10 +896,15 @@ SendBgWorkerPids(void)`
`893`	`896`	`}`
`894`	`897`
`895`	`898`	`#ifPG_VERSION_NUM<150000`
`896`		`-shm_mq_send(mqh,msg_len,msg, false);`
	`899`	`+result=shm_mq_send(mqh,msg_len,msg, false);`
`897`	`900`	`#else`
`898`		`-shm_mq_send(mqh,msg_len,msg, false, true);`
	`901`	`+result=shm_mq_send(mqh,msg_len,msg, false, true);`
`899`	`902`	`#endif`
	`903`	`+`
	`904`	`+/* Check for failure. */`
	`905`	`+if(result==SHM_MQ_DETACHED)`
	`906`	`+elog(WARNING,"could not send message queue to shared-memory queue: receiver has been detached");`
	`907`	`+`
`900`	`908`	`UnlockShmem(&tag);`
`901`	`909`	`}`
`902`	`910`

Comments

(0)