Struct ProcessTable 

pub struct ProcessTable { /* private fields */ }

Concurrent process table with PID allocation.

Uses DashMap for lock-free concurrent reads and writes. PIDs are allocated monotonically from an AtomicU64 and are never reused within a kernel session.

Implementations

impl ProcessTable

pub fn new(max_processes: u32) -> Self

Create a new process table with the given maximum capacity.

pub fn allocate_pid(&self) -> Pid

Allocate the next PID without inserting an entry.

pub fn insert(&self, entry: ProcessEntry) -> Result<Pid, KernelError>

Insert a process entry into the table.

The entry’s pid field is set to the next available PID. Returns the assigned PID, or an error if the process table is at capacity.

pub fn insert_with_pid(&self, entry: ProcessEntry) -> Result<(), KernelError>

Insert a process entry with a specific PID (for kernel PID 0).

pub fn get(&self, pid: Pid) -> Option<ProcessEntry>

Get a clone of a process entry by PID.

pub fn remove(&self, pid: Pid) -> Option<ProcessEntry>

Remove a process entry by PID.

pub fn list(&self) -> Vec<ProcessEntry>

List all process entries (cloned).

pub fn update_state( &self, pid: Pid, new_state: ProcessState, ) -> Result<(), KernelError>

Update the state of a process.

Validates the state transition before applying.

pub fn update_resources( &self, pid: Pid, usage: ResourceUsage, ) -> Result<(), KernelError>

Update resource usage for a process.

pub fn len(&self) -> usize

Get the number of processes in the table.

pub fn is_empty(&self) -> bool

Check whether the process table is empty.

pub fn max_processes(&self) -> u32

Get the maximum process capacity.

pub fn set_capabilities( &self, pid: Pid, capabilities: AgentCapabilities, ) -> Result<(), KernelError>

Update the capabilities of a process.

Replaces the existing capabilities with the given ones. This is used by the supervisor when hot-updating an agent’s permissions (future work) or during restart.

pub fn count_by_state(&self, state: &ProcessState) -> usize

Count processes in the given state.