Struct PipeRingBuffer 

struct PipeRingBuffer {
    buffer: VecDeque<u8>,
    capacity: usize,
    write_end_count: usize,
    read_end_count: usize,
}

管道环形缓冲区

容量默认 4KB（POSIX 最小 512 字节）。

Fields

buffer: VecDeque<u8>

内部缓冲区

capacity: usize

缓冲区容量

write_end_count: usize

写端引用计数 (用于检测写端关闭)

read_end_count: usize

读端引用计数 (用于检测读端关闭)

Implementations

impl PipeRingBuffer

const DEFAULT_CAPACITY: usize = 4_096usize

const MIN_CAPACITY: usize = 4_096usize

const MAX_CAPACITY: usize = 1_048_576usize

fn new() -> Self

fn get_capacity(&self) -> usize

获取管道容量

fn set_capacity(&mut self, new_capacity: usize) -> Result<(), FsError>

设置管道容量

fn read(&mut self, buf: &mut [u8]) -> Result<usize, FsError>

读取数据 (非阻塞)

fn write(&mut self, buf: &[u8]) -> Result<usize, FsError>

写入数据 (非阻塞)