diff --git a/pgxn/neon/communicator/src/integrated_cache.rs b/pgxn/neon/communicator/src/integrated_cache.rs index 8cf0119691..bc1dd1ea00 100644 --- a/pgxn/neon/communicator/src/integrated_cache.rs +++ b/pgxn/neon/communicator/src/integrated_cache.rs @@ -133,6 +133,8 @@ struct BlockEntry { lw_lsn: Lsn, cache_block: Option, + io_in_progress: AtomicBool, + // 'referenced' bit for the clock algorithm referenced: AtomicBool, } diff --git a/pgxn/neon/communicator_new.c b/pgxn/neon/communicator_new.c index 64dfca395b..475af2fdc9 100644 --- a/pgxn/neon/communicator_new.c +++ b/pgxn/neon/communicator_new.c @@ -391,7 +391,7 @@ communicator_new_prefetch_register_bufferv(NRelFileInfo rinfo, ForkNumber forkNu }; struct NeonIOResult result; - elog(LOG, "prefetch called for rel %u/%u/%u.%u block %u (%u blocks)", + elog(DEBUG5, "prefetch called for rel %u/%u/%u.%u block %u (%u blocks)", RelFileInfoFmt(rinfo), forkNum, blockno, nblocks); if (num_inflight_requests >= MAX_INFLIGHT_ASYNC_REQUESTS) @@ -553,7 +553,7 @@ communicator_new_read_at_lsnv(NRelFileInfo rinfo, ForkNumber forkNum, BlockNumbe } }; - elog(LOG, "getpagev called for rel %u/%u/%u.%u block %u (%u blocks)", + elog(DEBUG5, "getpagev called for rel %u/%u/%u.%u block %u (%u blocks)", RelFileInfoFmt(rinfo), forkNum, blockno, nblocks); /* Fill in the destination buffers in the request */