Struct BufferPool 

pub struct BufferPool { /* private fields */ }

Static Buffer pool managing multiple memory arenas of which [ArenaBuffer]s are returned for requested allocations

Implementations

impl BufferPool

pub const DEFAULT_ARENA_SIZE: usize

3MB Default size for each Arena. Any higher and it will fail to register the second arena with io_uring due to RL_MEMLOCK limit for un-privileged processes being 8MB total.

pub const TEST_ARENA_SIZE: usize

1MB size For testing/CI

pub const DEFAULT_PAGE_SIZE: usize = 4096

4KB default page_size

pub fn allocate(&self, len: usize) -> Buffer

Request a Buffer of size len

pub fn get_page(&self) -> Buffer

Request a Buffer the size of the db_page_size the BufferPool was initialized with.

pub fn get_wal_frame(&self) -> Buffer

Request a Buffer for use with a WAL frame, [Database::page_size] + WAL_FRAME_HEADER_SIZE`

pub fn begin_init(io: &Arc<dyn IO>, arena_size: usize) -> Arc<Self>

Create a static BufferPool initialize the pool to the default page size, without populating the Arenas. Arenas will not be created until [BufferPool::finalize_page_size], and the pool will temporarily return temporary buffers to prevent reallocation of the arena if the page size is set to something other than the default value.

pub fn finalize_with_page_size(&self, page_size: usize) -> Result<()>

Call when [Database::db_state] is initialized, providing the page_size to allocate an arena for the pool. Before this call, the pool will use temporary buffers which are cached in thread local storage.

Trait Implementations

impl Default for BufferPool

fn default() -> Self

Returns the “default value” for a type.

impl Send for BufferPool

impl Sync for BufferPool