From 8ebfa32a0cd271476c425a73df59bf4af706a66c Mon Sep 17 00:00:00 2001 From: Alex Chi Date: Thu, 22 Jun 2023 14:24:57 -0400 Subject: [PATCH] compaction l0 adds to sorted runs Signed-off-by: Alex Chi --- pageserver/src/tenant/timeline.rs | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/pageserver/src/tenant/timeline.rs b/pageserver/src/tenant/timeline.rs index c03a35a17c..7fe09be779 100644 --- a/pageserver/src/tenant/timeline.rs +++ b/pageserver/src/tenant/timeline.rs @@ -3769,6 +3769,16 @@ impl Timeline { let (layers, _) = &mut *guard; let mut updates = layers.batch_update(); let mut new_layer_paths = HashMap::with_capacity(new_layers.len()); + + let tier_id = updates.next_tier_id(); + updates.sorted_runs().push(( + tier_id, + new_layers + .iter() + .map(|l| Arc::new(l.layer_desc().clone())) + .collect(), + )); + for l in new_layers { let new_delta_path = l.path(); @@ -3809,6 +3819,7 @@ impl Timeline { layer_names_to_delete.push(l.filename()); self.delete_historic_layer_new(layer_removal_cs.clone(), l, &mut updates)?; } + updates.flush(); drop_wlock(guard);