Struct BounceBufferTracker

pub struct BounceBufferTracker { /* private fields */ }

Tracks active bounce buffers against a set limit of pages. If no limit is specified a default of 8Mb will be applied. This limit is tracked per thread specified by the backing AffinitizedThreadpool.

Implementations

impl BounceBufferTracker

pub fn new(max_bounce_buffer_pages: usize, threads: usize) -> Self

Create a new bounce buffer tracker.

pub async fn acquire_bounce_buffers<'a, 'b>( &'b self, size: usize, thread: usize, ) -> Box<TrackedBounceBuffer<'a>>

where 'b: 'a,

Attempts to acquire bounce buffers from the tracker proceeding if pages are available or waiting until a tracked bounce buffer is dropped, which triggers the per-thread event to indicate newly freed pages.

Trait Implementations

impl Debug for BounceBufferTracker

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

Formats the value using the given formatter.