Struct ThreadsScheme 

pub struct ThreadsScheme {
    states: SpinLock<BTreeMap<u64, OpState>>,
}

Fields

states: SpinLock<BTreeMap<u64, OpState>>

Implementations

impl ThreadsScheme

pub fn new() -> Self

Creates a new instance.

fn alloc_file_id(op: Op) -> u64

fn state_for(&self, file_id: u64) -> Result<(Op, OpState), SyscallError>

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

fn parse_join(path: &str) -> Result<u32, SyscallError>

Parse join/<tid> and validate kinship synchronously so errors surface at open time (self-join => EINVAL, missing/reaped child => ENOENT).

The blocking reap itself happens on read(), via thread_ops::join_task.

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

Parse kill/<tid>; the kill itself is performed by open() (Plan 9 style: opening the control file performs the action). Errors: ESRCH unknown tid, EPERM other thread group.

fn root_listing(&self) -> Result<String, SyscallError>

Directory listing of the calling process’ threads (pattern procfs).

fn handle_create_write(&self, buf: &[u8]) -> Result<u32, SyscallError>

Handle a write to /thread/create: parse the request, build the task with a kernel-owned stack, register it, and remember its TID.

Trait Implementations

impl Default for ThreadsScheme

fn default() -> Self

Returns the “default value” for a type.

impl Scheme for ThreadsScheme

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

Open a file/resource at the given path within this scheme.

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

Read bytes from an open file.

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

Write bytes to an open file.

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

Close an open file.

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

Get metadata for an open file.

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

Read directory entries from an open directory handle.

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 create_file(&self, path: &str, mode: u32) -> Result<OpenResult, SyscallError>

Create a new regular file.

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

Create a new directory.

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

Remove a file or directory.

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.