Struct BufferPoolManager 

pub struct BufferPoolManager {
    pub pool: Vec<Arc<RwLock<Page>>>,
    pub replacer: Arc<RwLock<LRUKReplacer>>,
    pub disk_scheduler: Arc<DiskScheduler>,
    pub page_table: Arc<DashMap<PageId, FrameId>>,
    pub free_list: Arc<RwLock<VecDeque<FrameId>>>,
    pub inflight_loads: Arc<DashMap<PageId, Arc<Mutex<()>>>>,
    pub tiny_lfu: Option<Arc<RwLock<TinyLFU>>>,
    pub dirty_pages: Arc<DashSet<PageId>>,
    pub dirty_page_table: DashMap<PageId, Lsn>,
    pub wal_manager: Arc<RwLock<Option<Arc<WalManager>>>>,
}

Fields

pool: Vec<Arc<RwLock<Page>>>

replacer: Arc<RwLock<LRUKReplacer>>

disk_scheduler: Arc<DiskScheduler>

page_table: Arc<DashMap<PageId, FrameId>>

free_list: Arc<RwLock<VecDeque<FrameId>>>

inflight_loads: Arc<DashMap<PageId, Arc<Mutex<()>>>>

Per-page inflight load guards to serialize concurrent loads of the same page

tiny_lfu: Option<Arc<RwLock<TinyLFU>>>

Optional TinyLFU admission filter

dirty_pages: Arc<DashSet<PageId>>

Dirty page tracking for checkpoints and background writers

dirty_page_table: DashMap<PageId, Lsn>

Dirty page table: page id -> first dirty LSN (recLSN)

wal_manager: Arc<RwLock<Option<Arc<WalManager>>>>

Optional WAL manager to enforce write-ahead rule on flush

Implementations

impl BufferPoolManager

pub fn new(num_pages: usize, disk_scheduler: Arc<DiskScheduler>) -> Self

pub fn new_with_config( config: BufferPoolConfig, disk_scheduler: Arc<DiskScheduler>, ) -> Self

pub fn set_wal_manager(&self, wal_manager: Arc<WalManager>)

pub fn wal_manager(&self) -> Option<Arc<WalManager>>

pub fn dirty_page_ids(&self) -> Vec<PageId>

pub fn dirty_page_table_snapshot(&self) -> Vec<(PageId, Lsn)>

pub fn new_page(self: &Arc<Self>) -> QuillSQLResult<WritePageGuard>

创建一个新页面。

pub fn fetch_page_read( self: &Arc<Self>, page_id: PageId, ) -> QuillSQLResult<ReadPageGuard>

获取一个只读页面。

pub fn fetch_page_write( self: &Arc<Self>, page_id: PageId, ) -> QuillSQLResult<WritePageGuard>

获取一个可写页面。

pub fn complete_unpin( &self, page_id: PageId, is_dirty: bool, old_pin_count: u32, rec_lsn_hint: Option<Lsn>, ) -> QuillSQLResult<()>

完成 unpin 的后续处理：根据旧的 pin_count 决定是否可驱逐，并处理脏位。 该函数必须在未持有页面锁的情况下调用，以避免与 fetch_page_write 的锁序形成死锁。

pub fn fetch_table_page( self: &Arc<Self>, page_id: PageId, schema: SchemaRef, ) -> QuillSQLResult<(ReadPageGuard, TablePage)>

pub fn fetch_tree_page( self: &Arc<Self>, page_id: PageId, key_schema: SchemaRef, ) -> QuillSQLResult<(ReadPageGuard, BPlusTreePage)>

pub fn fetch_tree_internal_page( self: &Arc<Self>, page_id: PageId, key_schema: SchemaRef, ) -> QuillSQLResult<(ReadPageGuard, BPlusTreeInternalPage)>

pub fn fetch_tree_leaf_page( self: &Arc<Self>, page_id: PageId, key_schema: SchemaRef, ) -> QuillSQLResult<(ReadPageGuard, BPlusTreeLeafPage)>

pub fn prefetch_page(self: &Arc<Self>, page_id: PageId) -> QuillSQLResult<()>

Best-effort prefetch: fetch+drop to warm the cache without holding the pin.

pub fn fetch_header_page( self: &Arc<Self>, page_id: PageId, ) -> QuillSQLResult<(ReadPageGuard, BPlusTreeHeaderPage)>

pub fn flush_page(&self, page_id: PageId) -> QuillSQLResult<bool>

pub fn flush_all_pages(&self) -> QuillSQLResult<()>

pub fn delete_page(&self, page_id: PageId) -> QuillSQLResult<bool>

Trait Implementations

impl Debug for BufferPoolManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.