diff --git a/pageserver/src/tenant/timeline.rs b/pageserver/src/tenant/timeline.rs index b16a99442b..b0f755f356 100644 --- a/pageserver/src/tenant/timeline.rs +++ b/pageserver/src/tenant/timeline.rs @@ -1562,53 +1562,6 @@ impl Timeline { Err(EvictionError::Timeout) => Ok(Some(false)), } } - - fn should_roll( - &self, - layer_size: u64, - projected_layer_size: u64, - checkpoint_distance: u64, - projected_lsn: Lsn, - last_freeze_at: Lsn, - last_freeze_ts: Instant, - ) -> bool { - let distance = projected_lsn.widening_sub(last_freeze_at); - - // Rolling the open layer can be triggered by: - // 1. The distance from the last LSN we rolled at. This bounds the amount of WAL that - // the safekeepers need to store. For sharded tenants, we multiply by shard count to - // account for how writes are distributed across shards: we expect each node to consume - // 1/count of the LSN on average. - // 2. The size of the currently open layer. - // 3. The time since the last roll. It helps safekeepers to regard pageserver as caught - // up and suspend activity. - if distance >= checkpoint_distance as i128 * self.shard_identity.count.count() as i128 { - info!( - "Will roll layer at {} with layer size {} due to LSN distance ({})", - projected_lsn, layer_size, distance - ); - - true - } else if projected_layer_size >= checkpoint_distance { - info!( - "Will roll layer at {} with layer size {} due to layer size ({})", - projected_lsn, layer_size, projected_layer_size - ); - - true - } else if distance > 0 && last_freeze_ts.elapsed() >= self.get_checkpoint_timeout() { - info!( - "Will roll layer at {} with layer size {} due to time since last flush ({:?})", - projected_lsn, - layer_size, - last_freeze_ts.elapsed() - ); - - true - } else { - false - } - } } /// Number of times we will compute partition within a checkpoint distance.