From 8fda7a6183504486d406e18d40e8a7bc0111409c Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Wed, 17 Nov 2021 12:50:46 +0300 Subject: [PATCH] Fix indentation --- control_plane/src/compute.rs | 2 +- pageserver/src/buffered_repository.rs | 22 +++++++++++----------- 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/control_plane/src/compute.rs b/control_plane/src/compute.rs index 2fd17fa063..63d6d7c014 100644 --- a/control_plane/src/compute.rs +++ b/control_plane/src/compute.rs @@ -294,7 +294,7 @@ impl PostgresNode { conf.append("max_wal_senders", "10"); // wal_log_hints is mandatory when running against pageserver (see gh issue#192) // TODO: is it possible to check wal_log_hints at pageserver side via XLOG_PARAMETER_CHANGE? -// conf.append("wal_log_hints", "on"); + // conf.append("wal_log_hints", "on"); conf.append("max_replication_slots", "10"); conf.append("hot_standby", "on"); conf.append("shared_buffers", "1MB"); diff --git a/pageserver/src/buffered_repository.rs b/pageserver/src/buffered_repository.rs index fdfc9f30a6..5a3738f362 100644 --- a/pageserver/src/buffered_repository.rs +++ b/pageserver/src/buffered_repository.rs @@ -23,7 +23,7 @@ use std::convert::TryInto; use std::fs; use std::fs::{File, OpenOptions}; use std::io::Write; -use std::ops::{Bound::{*}, Deref}; +use std::ops::{Bound::*, Deref}; use std::path::PathBuf; use std::sync::atomic::{AtomicUsize, Ordering}; use std::sync::{Arc, Mutex, MutexGuard, RwLock}; @@ -846,16 +846,16 @@ impl Timeline for BufferedTimeline { Ok(ZERO_PAGE.clone()) } }; - /* - if let Some(key) = reconstruct_key { - if let Ok(img) = &result { - let mut store = self.store.write().unwrap(); - store - .data - .put(&StoreKey::Data(key).ser()?, &PageVersion::Page(img.clone()).ser()?)?; + /* + if let Some(key) = reconstruct_key { + if let Ok(img) = &result { + let mut store = self.store.write().unwrap(); + store + .data + .put(&StoreKey::Data(key).ser()?, &PageVersion::Page(img.clone()).ser()?)?; + } } - } - */ + */ result } @@ -1679,7 +1679,7 @@ impl BufferedTimeline { seg: dk.blknum / BRIN_SEGMENT_SIZE, }; // At first iteration we need to scan the whole storage, - // because BRIN does't have enough information + // because BRIN does't have enough information if last_gc != Lsn(0) && store.brin.get(&seg_tag).map_or(true, |lsn| *lsn <= last_gc) {