Struct parallel_processor::memory_fs::file::flush::GlobalFlush

pub struct GlobalFlush;

Implementations

impl GlobalFlush

pub fn global_queue_occupation() -> (usize, usize)

pub fn is_queue_empty() -> bool

pub fn add_item_to_flush_queue(item: FlushableItem)

pub fn is_initialized() -> bool

pub fn init(flush_queue_size: usize, threads_count: usize)

pub fn schedule_disk_write( file: Arc<(PathBuf, Mutex<File>)>, buffer: AllocatedChunk, offset: u64 )

pub fn flush_to_disk()

pub fn terminate()