Compare commits

...

3 Commits

Author SHA1 Message Date
Bojan Serafimov
688f68ecba Undo whitespace 2022-08-04 09:43:27 +02:00
Bojan Serafimov
fb2ffac8b9 Ignore metrics static 2022-08-04 09:42:27 +02:00
Bojan Serafimov
8173e36a1b Find all problematic statics 2022-08-04 09:30:22 +02:00
5 changed files with 5 additions and 0 deletions

View File

@@ -55,6 +55,7 @@ use utils::{
use crate::layered_repository::writeback_ephemeral_file;
use crate::repository::Key;
// TODO move ownership into a new PageserverState struct
static PAGE_CACHE: OnceCell<PageCache> = OnceCell::new();
const TEST_PAGE_CACHE_SIZE: usize = 50;

View File

@@ -220,6 +220,7 @@ lazy_static! {
.expect("failed to register pageserver remote index upload vec");
}
// TODO move ownership into a new PageserverState struct
static SYNC_QUEUE: OnceCell<SyncQueue> = OnceCell::new();
/// A timeline status to share with pageserver's sync counterpart,

View File

@@ -25,6 +25,7 @@ use utils::lsn::Lsn;
use utils::zid::{ZTenantId, ZTenantTimelineId, ZTimelineId};
// TODO move ownership into a new PageserverState struct
mod tenants_state {
use anyhow::ensure;
use std::{

View File

@@ -87,6 +87,7 @@ async fn compaction_loop(tenantid: ZTenantId, mut cancel: watch::Receiver<()>) {
);
}
// TODO move ownership into a new PageserverState struct
static START_GC_LOOP: OnceCell<mpsc::Sender<ZTenantId>> = OnceCell::new();
static START_COMPACTION_LOOP: OnceCell<mpsc::Sender<ZTenantId>> = OnceCell::new();

View File

@@ -51,6 +51,7 @@ use utils::zid::{ZTenantId, ZTimelineId};
use crate::shutdown_pageserver;
// TODO move ownership into a new PageserverState struct
lazy_static! {
/// Each thread that we track is associated with a "thread ID". It's just
/// an increasing number that we assign, not related to any system thread