Struct PosixDiskIo 

pub struct PosixDiskIo { /* private fields */ }

POSIX disk I/O backend with unified buffer pool (combined read cache + write buffer under a single byte budget).

Replaces the previous separate ArcCache + WriteBuffer design with a single [BufferPool] that uses a byte-budget ARC for read caching and tracks in-flight writes as Writing entries.

Implementations

impl PosixDiskIo

pub fn new(config: &DiskConfig) -> Self

Create a new POSIX disk I/O backend with the given configuration.

Trait Implementations

impl DiskIoBackend for PosixDiskIo

fn name(&self) -> &'static str

Human-readable backend name (e.g., “posix”, “mmap”, “disabled”).

fn register(&self, info_hash: Id20, storage: Arc<dyn TorrentStorage>)

Register a torrent’s storage for I/O operations.

fn unregister(&self, info_hash: Id20)

Unregister a torrent’s storage.

fn write_chunk( &self, info_hash: Id20, piece: u32, begin: u32, data: Bytes, flush: bool, ) -> Result<()>

Write a chunk of piece data. If flush is true, persist immediately.

fn read_chunk( &self, info_hash: Id20, piece: u32, begin: u32, length: u32, volatile: bool, ) -> Result<Bytes>

Read a chunk of piece data. volatile hints the data won’t be re-read soon.

fn read_piece(&self, info_hash: Id20, piece: u32) -> Result<Vec<u8>>

Read an entire piece from storage, returning its raw bytes.

fn hash_piece( &self, info_hash: Id20, piece: u32, expected: &Id20, ) -> Result<bool>

Verify a piece against its expected SHA-1 hash.

fn hash_piece_v2( &self, info_hash: Id20, piece: u32, expected: &Id32, ) -> Result<bool>

Verify a piece against its expected SHA-256 hash (BEP 52).

fn hash_block( &self, info_hash: Id20, piece: u32, begin: u32, length: u32, ) -> Result<Id32>

Compute SHA-256 hash of a single block within a piece (BEP 52 Merkle).

fn clear_piece(&self, info_hash: Id20, piece: u32)

Discard buffered data for a piece (e.g., after hash failure).

fn flush_piece(&self, info_hash: Id20, piece: u32) -> Result<()>

Flush buffered writes for a piece to persistent storage.

fn flush_all(&self) -> Result<()>

Flush all buffered writes across all torrents.

fn cached_pieces(&self, info_hash: Id20) -> Vec<u32>

Return piece indices currently held in cache (for SuggestPiece, M44).

fn stats(&self) -> DiskIoStats

Return current I/O statistics.

fn write_block_direct( &self, info_hash: Id20, piece: u32, begin: u32, s0: &[u8], s1: &[u8], ) -> Result<()>

Write a block directly to storage from two slices (vectored write).