Line data    Source code

       1              : use std::{num::NonZeroUsize, sync::Arc};
       2              : 
       3              : #[derive(Debug, PartialEq, Eq, Clone)]
       4              : pub enum L0FlushConfig {
       5              :     Direct { max_concurrency: NonZeroUsize },
       6              : }
       7              : 
       8              : impl Default for L0FlushConfig {
       9         1206 :     fn default() -> Self {
      10         1206 :         Self::Direct {
      11         1206 :             // TODO: using num_cpus results in different peak memory usage on different instance types.
      12         1206 :             max_concurrency: NonZeroUsize::new(usize::max(1, num_cpus::get())).unwrap(),
      13         1206 :         }
      14         1206 :     }
      15              : }
      16              : 
      17              : impl From<pageserver_api::models::L0FlushConfig> for L0FlushConfig {
      18            0 :     fn from(config: pageserver_api::models::L0FlushConfig) -> Self {
      19            0 :         match config {
      20            0 :             pageserver_api::models::L0FlushConfig::Direct { max_concurrency } => {
      21            0 :                 Self::Direct { max_concurrency }
      22            0 :             }
      23            0 :         }
      24            0 :     }
      25              : }
      26              : 
      27              : #[derive(Clone)]
      28              : pub struct L0FlushGlobalState(Arc<Inner>);
      29              : 
      30              : pub enum Inner {
      31              :     Direct { semaphore: tokio::sync::Semaphore },
      32              : }
      33              : 
      34              : impl L0FlushGlobalState {
      35          576 :     pub fn new(config: L0FlushConfig) -> Self {
      36          576 :         match config {
      37          576 :             L0FlushConfig::Direct { max_concurrency } => {
      38          576 :                 let semaphore = tokio::sync::Semaphore::new(max_concurrency.get());
      39          576 :                 Self(Arc::new(Inner::Direct { semaphore }))
      40          576 :             }
      41          576 :         }
      42          576 :     }
      43              : 
      44         2904 :     pub fn inner(&self) -> &Arc<Inner> {
      45         2904 :         &self.0
      46         2904 :     }
      47              : }