Struct bern_kernel::sync::semaphore::Semaphore

pub struct Semaphore { /* private fields */ }

Atomic counting semaphore

similar to Struct tokio::sync::Semaphore and super::Mutex.

A semaphore can be used to

• synchronize on one or more event (e.g. interrupt)
• synchronize multiple tasks

Implementations

impl Semaphore

pub fn new(permits: usize) -> Self

pub fn register(&self) -> Result<(), Error>

Allocate an event ot the semaphore.

Note: The kernel must be initialized before calling this method.

pub fn try_acquire(&self) -> Result<SemaphorePermit<'_>, Error>

Try to acquire a semaphore permit (non-blocking). Returns a SemaphorePermit or an error if no permit is available or semaphore is poisoned.

pub fn acquire(&self, timeout: u32) -> Result<SemaphorePermit<'_>, Error>

Try to acquire a semaphore permit (blocking). Returns a SemaphorePermit or an error if the request timed out or the semaphore was poisoned.

Note: The timeout function is not implemented yet.

pub fn available_permits(&self) -> usize

Number of permits that can be issued from this semaphore

pub fn add_permits(&self, n: usize)

Trait Implementations

impl Sync for Semaphore