Struct IpcScheme 

pub struct IpcScheme {
    port_id: PortId,
    open_file_flags: SpinLock<BTreeMap<u64, FileFlags>>,
}

IPC-based scheme: forwards operations to a userspace server via IPC.

Fields

port_id: PortId

open_file_flags: SpinLock<BTreeMap<u64, FileFlags>>

Implementations

impl IpcScheme

pub fn new(port_id: PortId) -> Self

Creates a new instance.

fn remember_open_flags(&self, file_id: u64, flags: FileFlags)

fn take_open_flags(&self, file_id: u64)

fn open_flags_for(&self, file_id: u64) -> FileFlags

fn build_open_msg( path: &str, flags: OpenFlags, ) -> Result<IpcMessage, SyscallError>

Build an IPC message for open operation.

fn build_read_msg(file_id: u64, offset: u64, count: u32) -> IpcMessage

Build an IPC message for read operation.

fn build_write_msg( file_id: u64, offset: u64, data: &[u8], ) -> Result<(IpcMessage, usize), SyscallError>

Build an IPC message for write operation.

Returns the message and the number of bytes actually packed, or MessageSize if data exceeds the inline capacity (the caller’s chunking logic guarantees this never happens; we refuse rather than truncate or emit an empty write).

fn build_close_msg(file_id: u64) -> IpcMessage

Build an IPC message for close operation.

fn build_readdir_msg(file_id: u64, cursor: u16) -> IpcMessage

Performs the build readdir msg operation.

fn parse_status(reply: &IpcMessage) -> Result<(), SyscallError>

Parses status.

impl IpcScheme

fn call(&self, msg: IpcMessage) -> Result<IpcMessage, SyscallError>

Perform a synchronous IPC call: send msg to the server port and block the current task until the server calls ipc_reply. This mirrors sys_ipc_call exactly so that sys_ipc_reply can correctly route the reply back to us via reply::deliver_reply.

impl IpcScheme

fn handle_create_op( &self, opcode: u32, path: &str, mode: u32, ) -> Result<OpenResult, SyscallError>

Handles create op.

Trait Implementations

impl Scheme for IpcScheme

fn open(&self, path: &str, flags: OpenFlags) -> Result<OpenResult, SyscallError>

Performs the open operation.

fn read( &self, file_id: u64, offset: u64, buf: &mut [u8], ) -> Result<usize, SyscallError>

Performs the read operation.

fn write( &self, file_id: u64, offset: u64, buf: &[u8], ) -> Result<usize, SyscallError>

Performs the write operation.

fn close(&self, file_id: u64) -> Result<(), SyscallError>

Performs the close operation.

fn create_file(&self, path: &str, mode: u32) -> Result<OpenResult, SyscallError>

Creates file.

fn create_directory( &self, path: &str, mode: u32, ) -> Result<OpenResult, SyscallError>

Creates directory.

fn unlink(&self, path: &str) -> Result<(), SyscallError>

Performs the unlink operation.

fn readdir(&self, file_id: u64) -> Result<Vec<DirEntry>, SyscallError>

Performs the readdir operation.

fn async_read( &self, file_id: u64, offset: u64, user_buf_vaddr: u64, len: usize, _ring_id: u64, _user_data: u64, ) -> Result<AsyncSubmitResult, SyscallError>

Submit a read against a userspace buffer for async I/O.

fn async_write( &self, file_id: u64, offset: u64, user_buf_vaddr: u64, len: usize, _ring_id: u64, _user_data: u64, ) -> Result<AsyncSubmitResult, SyscallError>

Submit a write sourced from a userspace buffer for async I/O.

fn size(&self, file_id: u64) -> Result<u64, SyscallError>

Get file size (if supported).

fn truncate(&self, file_id: u64, new_size: u64) -> Result<(), SyscallError>

Truncate/resize a file (if supported).

fn truncate_by_path( &self, _path: &str, _new_size: u64, ) -> Result<(), SyscallError>

Truncate a file by path (avoids open/close round-trip).

fn sync(&self, file_id: u64) -> Result<(), SyscallError>

Sync file to storage (if applicable).

fn stat(&self, file_id: u64) -> Result<FileStat, SyscallError>

Get metadata for an open file.

fn rename(&self, old_path: &str, new_path: &str) -> Result<(), SyscallError>

Rename/move an entry within this scheme.

fn chmod(&self, path: &str, mode: u32) -> Result<(), SyscallError>

Change permission bits on a path.

fn fchmod(&self, file_id: u64, mode: u32) -> Result<(), SyscallError>

Change permission bits on an open file handle.

fn link(&self, old_path: &str, new_path: &str) -> Result<(), SyscallError>

Create a hard link.

fn symlink(&self, target: &str, link_path: &str) -> Result<(), SyscallError>

Create a symbolic link.

fn readlink(&self, path: &str) -> Result<String, SyscallError>

Read the target of a symbolic link.