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

Fix lfc_prewarm

Browse Source
This commit is contained in:
Konstantin Knizhnik
2025-04-12 15:50:23 +03:00
parent 1bf91b4a01
commit f78ad4904a
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
pgxn/neon/file_cache.c
View File

@@ -791,6 +791,10 @@ lfc_prewarm(FileCacheState* fcs, uint32 worker_id, uint32 n_workers)
}
if (n_sent >= n_received + prewarm_batch || snd_idx == max_prefetch_pages)
{
if (n_received == n_sent && snd_idx == max_prefetch_pages)
{
break;
}
if ((rcv_idx >> fcs_chunk_size_log) % n_workers != worker_id)
{
/* Skip chunks processed by other workers */
@@ -817,10 +821,7 @@ lfc_prewarm(FileCacheState* fcs, uint32 worker_id, uint32 n_workers)
ws->skipped_pages += 1;
}
rcv_idx += 1;
if (++n_received == n_sent && snd_idx == max_prefetch_pages)
{
break;
}
n_received += 1;
}
}
Assert(n_sent == n_received);