Struct MergeSubmitter 

pub struct MergeSubmitter<C: CbArgs, S: BlockingTxTrait<Box<IOEvent<C>>>> { /* private fields */ }

Manages the submission of IO events, attempting to merge sequential events before sending them to the IO driver.

This component buffers incoming IOEvents into a MergeBuffer. It ensures that events for the same file descriptor and IO action are considered for merging to optimize system calls.

Implementations

impl<C: CbArgs, S: BlockingTxTrait<Box<IOEvent<C>>>> MergeSubmitter<C, S>

pub fn new( fd: RawFd, sender: S, merge_size_limit: usize, action: IOAction, ) -> Self

Creates a new MergeSubmitter.

Arguments

• fd - The raw file descriptor for IO operations.
• sender - A channel sender to send prepared IOEvents to the IO driver.
• merge_size_limit - The maximum data size for a merged event buffer.
• action - The primary IO action (Read/Write) for this submitter.

pub fn add_event(&mut self, event: IOEvent<C>) -> Result<(), Errno>

Adds an IOEvent to the internal buffer, potentially triggering a flush.

If the event cannot be merged with current buffered events (e.g., non-contiguous, exceeding merge limit), the existing buffered events are flushed first. If adding the new event fills the buffer to its merge_size_limit, a flush is also triggered.

Arguments

• event - The IOEvent to add.

Returns

An Ok(()) on success. When submit sender closed, set Errno::SHUTDOWN on event and return the same Errno On debug mode, will validate event.fd and event.action.

pub fn flush(&mut self) -> Result<(), Errno>

Explicitly flushes any pending buffered events to the IO driver.

Returns

An Ok(()) on success, or an rustix::Errno when sending the submit tx closed.