rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-01-15 01:12:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

cargo fmt

Browse Source
This commit is contained in:
Heikki Linnakangas
2025-07-24 01:33:02 +03:00
parent 3d209dcaae
commit 5a5ea9cb9f
2 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pgxn/neon/communicator/src/backend_interface.rs
View File

@@ -254,9 +254,7 @@ pub unsafe extern "C" fn bcomm_cache_iterate_next(
#[allow(clippy::missing_safety_doc)]
#[unsafe(no_mangle)]
pub unsafe extern "C" fn bcomm_cache_get_num_pages_used(
bs: &mut CommunicatorBackendStruct,
) -> u64 {
pub unsafe extern "C" fn bcomm_cache_get_num_pages_used(bs: &mut CommunicatorBackendStruct) -> u64 {
bs.integrated_cache.get_num_buckets_in_use() as u64
}

10
pgxn/neon/communicator/src/worker_process/main_loop.rs
View File

@@ -116,10 +116,9 @@ pub(super) fn init(
file_cache_path: Option<PathBuf>,
) -> Result<&'static CommunicatorWorkerProcessStruct<'static>, String> {
// The caller validated these already
let tenant_id = TenantId::from_str(tenant_id)
.map_err(|e| format!("invalid tenant ID: {e}"))?;
let timeline_id = TimelineId::from_str(timeline_id)
.map_err(|e| format!("invalid timeline ID: {e}"))?;
let tenant_id = TenantId::from_str(tenant_id).map_err(|e| format!("invalid tenant ID: {e}"))?;
let timeline_id =
TimelineId::from_str(timeline_id).map_err(|e| format!("invalid timeline ID: {e}"))?;
let shard_spec =
ShardSpec::new(shard_map, stripe_size).map_err(|e| format!("invalid shard spec: {e}:"))?;
@@ -363,7 +362,8 @@ impl<'t> CommunicatorWorkerProcessStruct<'t> {
};
let read_lsn = self.request_lsns(not_modified_since);
match self.client
match self
.client
.get_rel_size(page_api::GetRelSizeRequest {
read_lsn,
rel,