Struct PipeFile 

pub struct PipeFile {
    buffer: Arc<SpinLock<PipeRingBuffer>>,
    end_type: PipeEnd,
    flags: SpinLock<OpenFlags>,
    owner: SpinLock<Option<i32>>,
}

管道文件实现

特点:

• 单向数据流 (读端和写端分别创建两个 PipeFile 实例)
• 流式设备 (无 offset 概念,不支持 lseek)
• 不依赖 Inode (纯内存结构)

Fields

buffer: Arc<SpinLock<PipeRingBuffer>>

共享的环形缓冲区

end_type: PipeEnd

文件端点类型

flags: SpinLock<OpenFlags>

打开标志位 (支持 O_NONBLOCK 等)

owner: SpinLock<Option<i32>>

异步 I/O 所有者 PID

Implementations

impl PipeFile

pub fn create_pair() -> (Self, Self)

创建管道对 (返回 [读端, 写端])

示例

let (pipe_read, pipe_write) = PipeFile::create_pair();
fd_table.install_at(3, Arc::new(pipe_read) as Arc<dyn File>)?;
fd_table.install_at(4, Arc::new(pipe_write) as Arc<dyn File>)?;

pub fn set_flags(&self, new_flags: OpenFlags) -> Result<(), FsError>

设置文件状态标志 (F_SETFL)

pub fn get_pipe_size(&self) -> usize

获取管道大小 (F_GETPIPE_SZ)

pub fn set_pipe_size(&self, new_size: usize) -> Result<(), FsError>

设置管道大小 (F_SETPIPE_SZ)

Trait Implementations

impl Drop for PipeFile

fn drop(&mut self)

Executes the destructor for this type.

impl File for PipeFile

fn readable(&self) -> bool

检查文件是否可读

fn writable(&self) -> bool

检查文件是否可写

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

从文件读取数据

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

向文件写入数据

fn metadata(&self) -> Result<InodeMetadata, FsError>

获取文件元数据

fn flags(&self) -> OpenFlags

获取打开标志（可选方法）

fn set_status_flags(&self, new_flags: OpenFlags) -> Result<(), FsError>

设置文件状态标志（可选方法，用于 F_SETFL）

fn get_pipe_size(&self) -> Result<usize, FsError>

获取管道大小（可选方法，用于 F_GETPIPE_SZ）

fn set_pipe_size(&self, size: usize) -> Result<(), FsError>

设置管道大小（可选方法，用于 F_SETPIPE_SZ）

fn get_owner(&self) -> Result<i32, FsError>

获取异步 I/O 所有者（可选方法，用于 F_GETOWN）

fn set_owner(&self, pid: i32) -> Result<(), FsError>

设置异步 I/O 所有者（可选方法，用于 F_SETOWN）

fn as_any(&self) -> &dyn Any

获取 Any trait 引用，用于安全的类型转换

fn lseek(&self, _offset: isize, _whence: SeekWhence) -> Result<usize, FsError>

设置文件偏移量（可选方法）

fn offset(&self) -> usize

获取当前偏移量（可选方法）

fn dentry(&self) -> Result<Arc<Dentry>, FsError>

获取目录项（可选方法）

fn inode(&self) -> Result<Arc<dyn Inode>, FsError>

获取Inode（可选方法）

fn read_at(&self, _offset: usize, _buf: &mut [u8]) -> Result<usize, FsError>

从指定位置读取数据（可选方法，用于 pread64/preadv）

fn write_at(&self, _offset: usize, _buf: &[u8]) -> Result<usize, FsError>

向指定位置写入数据（可选方法，用于 pwrite64/pwritev）

fn ioctl(&self, _request: u32, _arg: usize) -> Result<isize, FsError>

执行设备特定的控制操作（可选方法，用于 ioctl）

fn recvfrom(&self, _buf: &mut [u8]) -> Result<(usize, Option<Vec<u8>>), FsError>

从socket接收数据并获取源地址（可选方法，用于recvfrom）