rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-14 00:42:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Move WaitEventSetWait after PQgetCopyData

Browse Source
This commit is contained in:
Konstantin Knizhnik
2025-03-24 13:17:21 +02:00
parent 83eb3e0ec9
commit 38e184dd5c
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pgxn/neon/libpagestore.c
View File

@@ -1152,16 +1152,16 @@ pageserver_try_receive(shardno_t shard_no)
while (true)
{
WaitEvent event;
if (WaitEventSetWait(shard->wes_read, 0, &event, 1,
WAIT_EVENT_NEON_PS_READ) != 1
|| (event.events & WL_SOCKET_READABLE) == 0)
{
return NULL;
}
rc = PQgetCopyData(shard->conn, &resp_buff.data, 1 /* async */);
if (rc == 0)
{
WaitEvent event;
if (WaitEventSetWait(shard->wes_read, 0, &event, 1,
WAIT_EVENT_NEON_PS_READ) != 1
|| (event.events & WL_SOCKET_READABLE) == 0)
{
return NULL;
}
if (!PQconsumeInput(shard->conn))
{
return NULL;