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

fewer logs

Browse Source 
Signed-off-by: Alex Chi Z <chi@neon.tech>
This commit is contained in:
Alex Chi Z
2023-06-29 09:16:46 -04:00
parent d4e262f646
commit 376762e07e
1 changed files with 7 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
pageserver/src/tenant/timeline.rs
View File

@@ -3419,9 +3419,6 @@ impl Timeline {
let guard = self.layers.read().await;
let (layers, _) = &*guard;
println!("before compaction:");
layers.dump(false, ctx)?;
let mut level0_deltas = layers.get_level0_deltas()?;
// Only compact if enough layers have accumulated.
@@ -3434,6 +3431,9 @@ impl Timeline {
return Ok(CompactLevel0Phase1Result::default());
}
println!("before compaction:");
layers.dump(false, ctx)?;
// Gather the files to compact in this iteration.
//
// Start with the oldest Level 0 delta file, and collect any other
@@ -3956,10 +3956,6 @@ impl Timeline {
let threshold = 8;
assert!(threshold >= 2);
info!("getting tiered compaction task, before compaction:");
layers.dump(false, ctx)?;
if layers.sorted_runs.num_of_tiers() < threshold {
info!(
level0_deltas = layers.sorted_runs.num_of_tiers(),
@@ -3976,7 +3972,9 @@ impl Timeline {
return Ok(None);
};
println!("tier_to_compact: {tier_to_compact:?}");
info!("getting tiered compaction task, before compaction:");
layers.dump(false, ctx)?;
for &tier in &tier_to_compact {
compacting_tiers.insert(tier);
}
@@ -3989,8 +3987,6 @@ impl Timeline {
}
}
println!("deltas_to_compact_layers: {deltas_to_compact_layers:?}");
let deltas_to_compact_layers = deltas_to_compact_layers
.into_iter()
.map(|l| self.lcache.get_from_desc(&l))
@@ -4016,8 +4012,6 @@ impl Timeline {
lsn_range.start, lsn_range.end, tier_to_compact
);
layers.dump(false, ctx)?;
(deltas_to_compact_layers, tier_to_compact, lsn_range)
};
@@ -4256,9 +4250,6 @@ impl Timeline {
drop(layer_removal_cs);
let layer_removal_cs = self.lcache.delete_guard_write().await;
println!("new_tier_at: {:?}", new_tier_at);
println!("removed_tiers: {:?}", removed_tiers);
// Before deleting any layers, we need to wait for their upload ops to finish.
// See storage_sync module level comment on consistency.
// Do it here because we don't want to hold self.layers.write() while waiting.
@@ -4340,7 +4331,7 @@ impl Timeline {
updates.flush();
println!("after compaction:");
info!("after compaction:");
layers.dump(false, ctx)?;
let mut compacting_tiers = self.compacting.lock().unwrap();