From b2c5aa7720019d4a22a31b241c5baeb33dd09769 Mon Sep 17 00:00:00 2001 From: Heikki Linnakangas Date: Mon, 14 Jul 2025 20:42:25 +0300 Subject: [PATCH] cargo fmt --- pgxn/neon/communicator/src/worker_process/callbacks.rs | 1 + .../neon/communicator/src/worker_process/worker_interface.rs | 5 +---- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/pgxn/neon/communicator/src/worker_process/callbacks.rs b/pgxn/neon/communicator/src/worker_process/callbacks.rs index 32ae116bd8..6af3fa7afe 100644 --- a/pgxn/neon/communicator/src/worker_process/callbacks.rs +++ b/pgxn/neon/communicator/src/worker_process/callbacks.rs @@ -30,6 +30,7 @@ pub struct LfcMetrics { // index 59 is size of working set accessed within last 60 minutes. pub lfc_approximate_working_set_size_windows: [i64; 60], } + pub fn callback_get_lfc_metrics() -> LfcMetrics { unsafe { callback_get_lfc_metrics_unsafe() } } diff --git a/pgxn/neon/communicator/src/worker_process/worker_interface.rs b/pgxn/neon/communicator/src/worker_process/worker_interface.rs index f60fa3329f..a01c5a3595 100644 --- a/pgxn/neon/communicator/src/worker_process/worker_interface.rs +++ b/pgxn/neon/communicator/src/worker_process/worker_interface.rs @@ -32,10 +32,7 @@ pub extern "C" fn communicator_worker_process_launch( .build() .unwrap(); - let worker_struct = runtime.block_on(main_loop::init( - tenant_id, - timeline_id, - )); + let worker_struct = runtime.block_on(main_loop::init(tenant_id, timeline_id)); let worker_struct = Box::leak(Box::new(worker_struct)); runtime.block_on(worker_struct.launch_metrics_exporter());