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

strip new_ prefix from LayerAccessStats constructors

Browse Source
This commit is contained in:
Christian Schwarz
2023-02-02 11:33:59 +01:00
committed by Christian Schwarz
parent 2e676fba96
commit 6b5253abb2
4 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pageserver/src/tenant/storage_layer.rs
View File

@@ -212,13 +212,13 @@ impl LayerAccessStats {
const LAST_ACCESSES_MAX_LEN: usize = 16;
const LAST_RESIDENCE_CHANGES_MAX_LEN: usize = 16;
pub(crate) fn new_for_loading_layer(residence_status: LayerResidenceStatus) -> Self {
pub(crate) fn for_loading_layer(residence_status: LayerResidenceStatus) -> Self {
let new = LayerAccessStats(Mutex::new(LayerAccessStatsInner::default()));
new.record_residence_change(residence_status);
new
}
pub(crate) fn new_for_new_layer_file() -> Self {
pub(crate) fn for_new_layer_file() -> Self {
let new = LayerAccessStats(Mutex::new(LayerAccessStatsInner::default()));
new.record_residence_change(LayerResidenceStatus::created());
new

4
pageserver/src/tenant/storage_layer/delta_layer.rs
View File

@@ -621,7 +621,7 @@ impl DeltaLayer {
key_range: summary.key_range,
lsn_range: summary.lsn_range,
file_size: metadata.len(),
access_stats: LayerAccessStats::new_for_loading_layer(LayerResidenceStatus::resident()),
access_stats: LayerAccessStats::for_loading_layer(LayerResidenceStatus::resident()),
inner: RwLock::new(DeltaLayerInner {
loaded: false,
file: None,
@@ -792,7 +792,7 @@ impl DeltaLayerWriterInner {
key_range: self.key_start..key_end,
lsn_range: self.lsn_range.clone(),
file_size: metadata.len(),
access_stats: LayerAccessStats::new_for_new_layer_file(),
access_stats: LayerAccessStats::for_new_layer_file(),
inner: RwLock::new(DeltaLayerInner {
loaded: false,
file: None,

4
pageserver/src/tenant/storage_layer/image_layer.rs
View File

@@ -422,7 +422,7 @@ impl ImageLayer {
key_range: summary.key_range,
lsn: summary.lsn,
file_size: metadata.len(),
access_stats: LayerAccessStats::new_for_loading_layer(LayerResidenceStatus::resident()),
access_stats: LayerAccessStats::for_loading_layer(LayerResidenceStatus::resident()),
inner: RwLock::new(ImageLayerInner {
file: None,
loaded: false,
@@ -582,7 +582,7 @@ impl ImageLayerWriterInner {
key_range: self.key_range.clone(),
lsn: self.lsn,
file_size: metadata.len(),
access_stats: LayerAccessStats::new_for_new_layer_file(),
access_stats: LayerAccessStats::for_new_layer_file(),
inner: RwLock::new(ImageLayerInner {
loaded: false,
file: None,

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

@@ -1165,7 +1165,7 @@ impl Timeline {
self.tenant_id,
&imgfilename,
file_size,
LayerAccessStats::new_for_loading_layer(LayerResidenceStatus::resident()),
LayerAccessStats::for_loading_layer(LayerResidenceStatus::resident()),
);
trace!("found layer {}", layer.path().display());
@@ -1197,7 +1197,7 @@ impl Timeline {
self.tenant_id,
&deltafilename,
file_size,
LayerAccessStats::new_for_loading_layer(LayerResidenceStatus::resident()),
LayerAccessStats::for_loading_layer(LayerResidenceStatus::resident()),
);
trace!("found layer {}", layer.path().display());
@@ -1335,7 +1335,7 @@ impl Timeline {
self.timeline_id,
imgfilename,
&remote_layer_metadata,
LayerAccessStats::new_for_loading_layer(LayerResidenceStatus::evicted()),
LayerAccessStats::for_loading_layer(LayerResidenceStatus::evicted()),
);
let remote_layer = Arc::new(remote_layer);
@@ -1360,7 +1360,7 @@ impl Timeline {
self.timeline_id,
deltafilename,
&remote_layer_metadata,
LayerAccessStats::new_for_loading_layer(LayerResidenceStatus::evicted()),
LayerAccessStats::for_loading_layer(LayerResidenceStatus::evicted()),
);
let remote_layer = Arc::new(remote_layer);
updates.insert_historic(remote_layer);