diff --git a/pgxn/neon/communicator/src/integrated_cache.rs b/pgxn/neon/communicator/src/integrated_cache.rs index 7a7b2503bf..d8f042de2e 100644 --- a/pgxn/neon/communicator/src/integrated_cache.rs +++ b/pgxn/neon/communicator/src/integrated_cache.rs @@ -392,7 +392,7 @@ impl<'t> IntegratedCacheWriteAccess<'t> { pub fn remember_rel_size(&'t self, rel: &RelTag, nblocks: u32, lsn: Lsn) { match self.relsize_cache.entry(RelKey::from(rel)) { Entry::Vacant(e) => { - tracing::info!("inserting rel entry for {rel:?}, {nblocks} blocks"); + tracing::trace!("inserting rel entry for {rel:?}, {nblocks} blocks"); // FIXME: what to do if we run out of memory? Evict other relation entries? _ = e .insert(RelEntry { @@ -402,7 +402,7 @@ impl<'t> IntegratedCacheWriteAccess<'t> { .expect("out of memory"); } Entry::Occupied(e) => { - tracing::info!("updating rel entry for {rel:?}, {nblocks} blocks"); + tracing::trace!("updating rel entry for {rel:?}, {nblocks} blocks"); e.get().nblocks.store(nblocks, Ordering::Relaxed); e.get().lw_lsn.store(lsn); } @@ -574,7 +574,7 @@ impl<'t> IntegratedCacheWriteAccess<'t> { /// Forget information about given relation in the cache. (For DROP TABLE and such) pub fn forget_rel(&'t self, rel: &RelTag, _nblocks: Option, flush_lsn: Lsn) { - tracing::info!("forgetting rel entry for {rel:?}"); + tracing::trace!("forgetting rel entry for {rel:?}"); self.relsize_cache.remove(&RelKey::from(rel)); // update with flush LSN diff --git a/pgxn/neon/communicator/src/worker_process/main_loop.rs b/pgxn/neon/communicator/src/worker_process/main_loop.rs index b01a02c3fa..df93187161 100644 --- a/pgxn/neon/communicator/src/worker_process/main_loop.rs +++ b/pgxn/neon/communicator/src/worker_process/main_loop.rs @@ -373,7 +373,7 @@ impl<'t> CommunicatorWorkerProcessStruct<'t> { { Ok(Some(nblocks)) => { // update the cache - tracing::info!( + tracing::trace!( "updated relsize for {:?} in cache: {}, lsn {}", rel, nblocks, @@ -413,7 +413,7 @@ impl<'t> CommunicatorWorkerProcessStruct<'t> { { Ok(slru_bytes) => { if let Err(e) = tokio::fs::write(&file_path, &slru_bytes).await { - info!("could not write slru segment to file {file_path}: {e}"); + error!("could not write slru segment to file {file_path}: {e}"); return NeonIOResult::Error(e.raw_os_error().unwrap_or(libc::EIO)); } @@ -599,7 +599,7 @@ impl<'t> CommunicatorWorkerProcessStruct<'t> { .map(|(blkno, _lsn, _dest, _guard)| *blkno) .collect(); let read_lsn = self.request_lsns(not_modified_since); - info!( + trace!( "sending getpage request for blocks {:?} in rel {:?} lsns {}", block_numbers, rel, read_lsn ); @@ -626,7 +626,7 @@ impl<'t> CommunicatorWorkerProcessStruct<'t> { return Err(-1); } - info!( + trace!( "received getpage response for blocks {:?} in rel {:?} lsns {}", block_numbers, rel, read_lsn ); diff --git a/pgxn/neon/communicator_new.c b/pgxn/neon/communicator_new.c index 1edabc564d..7e619e62c2 100644 --- a/pgxn/neon/communicator_new.c +++ b/pgxn/neon/communicator_new.c @@ -528,7 +528,7 @@ start_request(NeonIORequest *request, struct NeonIOResult *immediate_result_p) inflight_requests[num_inflight_requests] = request_idx; num_inflight_requests++; - elog(LOG, "started communicator request %s at slot %d", print_neon_io_request(request), request_idx); + elog(DEBUG5, "started communicator request %s at slot %d", print_neon_io_request(request), request_idx); return request_idx; }