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());