Struct Counter 

pub struct Counter {
    data: Arc<SharedCounterData>,
    id: String,
    nonblocking: AtomicBool,
}

Counter object for eventfd-like IPC

Fields

data: Arc<SharedCounterData>

Shared data

id: String

Unique identifier for debugging

nonblocking: AtomicBool

Non-blocking flag

Implementations

impl Counter

pub fn new(initval: u32, semaphore: bool) -> Self

Create a new counter object

pub fn create_pair( initval: u32, semaphore: bool, ) -> (KernelObject, KernelObject)

Create a new counter pair as KernelObjects (returns same counter twice for dup semantics)

pub fn create_kernel_object(initval: u32, flags: u32) -> KernelObject

Create a single counter as KernelObject

fn do_read(&self, buffer: &mut [u8]) -> Result<usize, StreamError>

Read the counter value (8 bytes)

fn do_write(&self, buffer: &[u8]) -> Result<usize, StreamError>

Write to the counter (8 bytes)

Trait Implementations

impl Clone for Counter

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CloneOps for Counter

fn custom_clone(&self) -> KernelObject

Perform a custom clone operation and return the cloned object

impl CounterObject for Counter

fn is_semaphore(&self) -> bool

Check if this is a semaphore mode counter

impl Selectable for Counter

fn current_ready(&self, interest: ReadyInterest) -> ReadySet

Return current readiness for the given interest set.

fn wait_until_ready( &self, interest: ReadyInterest, trapframe: &mut Trapframe, timeout_ticks: Option<u64>, ) -> SelectWaitOutcome

Block the current task using the provided trapframe until the interest becomes ready or the optional timeout (in ticks) expires.

fn set_nonblocking(&self, enabled: bool)

Enable or disable non-blocking I/O semantics on this object.

fn is_nonblocking(&self) -> bool

Query whether non-blocking I/O semantics are enabled on this object.

impl StreamOps for Counter

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

Read data from the stream

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

Write data to the stream