rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-05-18 05:30:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add assert check thsat timeout is registered

Browse Source
This commit is contained in:
Kosntantin Knizhnik
2025-07-19 09:25:13 +03:00
committed by Konstantin Knizhnik
parent 1ef0f71a95
commit df49def453
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pgxn/neon/communicator.c
View File

@@ -2533,8 +2533,7 @@ void
communicator_reconfigure_timeout_if_needed(void)
{
bool needs_set = (MyPState->ring_receive != MyPState->ring_unused ||
(RecoveryInProgress() &&
MIN_BACKEND_PREFETCH_LSN != InvalidXLogRecPtr &&
(MIN_BACKEND_PREFETCH_LSN != InvalidXLogRecPtr &&
MIN_BACKEND_PREFETCH_LSN != GetXLogReplayRecPtr(NULL))) &&
!AmPrewarmWorker && /* do not pump prefetch state in prewarm worker */
readahead_getpage_pull_timeout_ms > 0;
@@ -2549,6 +2548,7 @@ communicator_reconfigure_timeout_if_needed(void)
if (unlikely(PS_TIMEOUT_ID == 0))
{
PS_TIMEOUT_ID = RegisterTimeout(USER_TIMEOUT, pagestore_timeout_handler);
Assert(PS_TIMEOUT_ID >= 0);
}
if (needs_set)