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

Crank down the logging

Browse Source 
More logs is useful during debugging, but it's time to crank it down a
notch...
This commit is contained in:
Heikki Linnakangas
2025-07-30 21:24:19 +03:00
parent af5e3da381
commit 688990e7ec
3 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pgxn/neon/communicator/src/integrated_cache.rs
View File

@@ -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<u32>, 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

8
pgxn/neon/communicator/src/worker_process/main_loop.rs
View File

@@ -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
);

2
pgxn/neon/communicator_new.c
View File

@@ -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;
}