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], ) -> (IpcMessage, usize)

Build an IPC message for write operation.

Returns the message and the number of bytes actually packed.

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.