NotificationsYou must be signed in to change notification settings
Fork4.9k
Star17.7k

Commitdf0a67f

committed

Fix incorrect calculation in shm_mq_receive.

If some, but not all, of the length word has already been read, and thenext attempt to read sees exactly the number of bytes needed to completethe length word, or fewer, then we'll incorrectly read less than all ofthe available data.Antonin Houska

1 parent0e141c0 commitdf0a67fCopy full SHA for df0a67f

File tree

1 file changed

-1

lines changed

src/backend/storage/ipc
- shm_mq.c

1 file changed

-1

lines changed

`‎src/backend/storage/ipc/shm_mq.c`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -584,7 +584,7 @@ shm_mq_receive(shm_mq_handle mqh, Size nbytesp, void **datap, bool nowait)`
`584`	`584`	`if (mqh->mqh_partial_bytes+rb>sizeof(Size))`
`585`	`585`	`lengthbytes=sizeof(Size)-mqh->mqh_partial_bytes;`
`586`	`586`	`else`
`587`		`-lengthbytes=rb-mqh->mqh_partial_bytes;`
	`587`	`+lengthbytes=rb;`
`588`	`588`	`memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes],rawdata,`
`589`	`589`	`lengthbytes);`
`590`	`590`	`mqh->mqh_partial_bytes+=lengthbytes;`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commitdf0a67f

File tree

1 file changed

1 file changed

`‎src/backend/storage/ipc/shm_mq.c`

0 commit comments