[runtime] Add page cache metrics

consensus/fuzz/src/lib.rs

@@ -381,6 +381,7 @@ where
         application::Application::new(context.with_label("application"), app_cfg);
     actor.start();
 
+    let page_cache = CacheRef::from_pooler(context.with_label("cache"), PAGE_SIZE, PAGE_CACHE_SIZE);
     let blocker = oracle.control(validator.clone());
     let engine_cfg = config::Config {
         blocker,
@@ -401,7 +402,7 @@ where
         fetch_concurrent: 1,
         replay_buffer: NZUsize!(1024 * 1024),
         write_buffer: NZUsize!(1024 * 1024),
-        page_cache: CacheRef::from_pooler(&context, PAGE_SIZE, PAGE_CACHE_SIZE),
+        page_cache,
         strategy: Sequential,
         forwarding: ForwardingPolicy::Disabled,
     };
@@ -615,6 +616,11 @@ fn run_with_twin_mutator<P: simplex::Simplex>(input: FuzzInput) {
                 application::Application::new(primary_context.with_label("application"), app_cfg);
             actor.start();
 
+            let page_cache = CacheRef::from_pooler(
+                primary_context.with_label("cache"),
+                PAGE_SIZE,
+                PAGE_CACHE_SIZE,
+            );
             let blocker = oracle.control(validator.clone());
             let engine_cfg = config::Config {
                 blocker,
@@ -635,7 +641,7 @@ fn run_with_twin_mutator<P: simplex::Simplex>(input: FuzzInput) {
                 fetch_concurrent: 1,
                 replay_buffer: NZUsize!(1024 * 1024),
                 write_buffer: NZUsize!(1024 * 1024),
-                page_cache: CacheRef::from_pooler(&primary_context, PAGE_SIZE, PAGE_CACHE_SIZE),
+                page_cache,
                 strategy: Sequential,
                 forwarding: ForwardingPolicy::Disabled,
             };

consensus/src/aggregation/mod.rs

@@ -234,6 +234,8 @@ mod tests {
             let blocker = oracle.control(participant.clone());
 
             // Create and start engine
+            let page_cache =
+                CacheRef::from_pooler(context.with_label("cache"), PAGE_SIZE, PAGE_CACHE_SIZE);
             let engine = Engine::new(
                 context.with_label("engine"),
                 Config {
@@ -252,7 +254,7 @@ mod tests {
                     journal_replay_buffer: NZUsize!(4096),
                     journal_heights_per_section: std::num::NonZeroU64::new(6).unwrap(),
                     journal_compression: Some(3),
-                    journal_page_cache: CacheRef::from_pooler(&context, PAGE_SIZE, PAGE_CACHE_SIZE),
+                    journal_page_cache: page_cache,
                     strategy: Sequential,
                 },
             );
@@ -479,6 +481,11 @@ mod tests {
                         let blocker = oracle.control(participant.clone());
 
                         // Create and start engine
+                        let journal_page_cache = CacheRef::from_pooler(
+                            validator_context.with_label("cache"),
+                            PAGE_SIZE,
+                            PAGE_CACHE_SIZE,
+                        );
                         let engine = Engine::new(
                             validator_context.with_label("engine"),
                             Config {
@@ -497,11 +504,7 @@ mod tests {
                                 journal_replay_buffer: NZUsize!(4096),
                                 journal_heights_per_section: std::num::NonZeroU64::new(6).unwrap(),
                                 journal_compression: Some(3),
-                                journal_page_cache: CacheRef::from_pooler(
-                                    &context,
-                                    PAGE_SIZE,
-                                    PAGE_CACHE_SIZE,
-                                ),
+                                journal_page_cache,
                                 strategy: Sequential,
                             },
                         );
@@ -631,6 +634,11 @@ mod tests {
                     let blocker = oracle.control(participant.clone());
 
                     // Create and start engine
+                    let journal_page_cache = CacheRef::from_pooler(
+                        validator_context.with_label("cache"),
+                        PAGE_SIZE,
+                        PAGE_CACHE_SIZE,
+                    );
                     let engine = Engine::new(
                         validator_context.with_label("engine"),
                         Config {
@@ -651,11 +659,7 @@ mod tests {
                             journal_replay_buffer: NZUsize!(4096),
                             journal_heights_per_section: std::num::NonZeroU64::new(6).unwrap(),
                             journal_compression: Some(3),
-                            journal_page_cache: CacheRef::from_pooler(
-                                &context,
-                                PAGE_SIZE,
-                                PAGE_CACHE_SIZE,
-                            ),
+                            journal_page_cache,
                             strategy: Sequential,
                         },
                     );
@@ -718,6 +722,11 @@ mod tests {
                     let blocker = oracle.control(participant.clone());
 
                     // Create and start engine
+                    let journal_page_cache = CacheRef::from_pooler(
+                        validator_context.with_label("cache"),
+                        PAGE_SIZE,
+                        PAGE_CACHE_SIZE,
+                    );
                     let engine = Engine::new(
                         validator_context.with_label("engine"),
                         Config {
@@ -738,11 +747,7 @@ mod tests {
                             journal_replay_buffer: NZUsize!(4096),
                             journal_heights_per_section: std::num::NonZeroU64::new(6).unwrap(),
                             journal_compression: Some(3),
-                            journal_page_cache: CacheRef::from_pooler(
-                                &context,
-                                PAGE_SIZE,
-                                PAGE_CACHE_SIZE,
-                            ),
+                            journal_page_cache,
                             strategy: Sequential,
                         },
                     );
@@ -1068,6 +1073,11 @@ mod tests {
                 let blocker = oracle.control(participant.clone());
 
                 // Create and start engine
+                let journal_page_cache = CacheRef::from_pooler(
+                    context.with_label("cache"),
+                    PAGE_SIZE,
+                    PAGE_CACHE_SIZE,
+                );
                 let engine = Engine::new(
                     context.with_label("engine"),
                     Config {
@@ -1086,11 +1096,7 @@ mod tests {
                         journal_replay_buffer: NZUsize!(4096),
                         journal_heights_per_section: std::num::NonZeroU64::new(6).unwrap(),
                         journal_compression: Some(3),
-                        journal_page_cache: CacheRef::from_pooler(
-                            &context,
-                            PAGE_SIZE,
-                            PAGE_CACHE_SIZE,
-                        ),
+                        journal_page_cache,
                         strategy: Sequential,
                     },
                 );