Struct CompatQueue 

pub struct CompatQueue { /* private fields */ }

A suitable queue implementation that only requires semaphores from the OS.

Register in your OS implementation by adding the following code:

use esp_radio_rtos_driver::{queue::CompatQueue, register_queue_implementation};

register_queue_implementation!(CompatQueue);

Trait Implementations

impl QueueImplementation for CompatQueue

fn create(capacity: usize, item_size: usize) -> QueuePtr

Creates a new, empty queue instance.

unsafe fn delete(queue: QueuePtr)

Deletes a queue instance.

unsafe fn send_to_front( queue: QueuePtr, item: *const u8, timeout_us: Option<u32>, ) -> bool

Enqueues a high-priority item.

unsafe fn send_to_back( queue: QueuePtr, item: *const u8, timeout_us: Option<u32>, ) -> bool

Enqueues an item.

unsafe fn try_send_to_back_from_isr( queue: QueuePtr, item: *const u8, higher_prio_task_waken: Option<&mut bool>, ) -> bool

Attempts to enqueues an item.

unsafe fn receive( queue: QueuePtr, item: *mut u8, timeout_us: Option<u32>, ) -> bool

Dequeues an item from the queue.

unsafe fn try_receive_from_isr( queue: QueuePtr, item: *mut u8, higher_prio_task_waken: Option<&mut bool>, ) -> bool

Attempts to dequeue an item from the queue.

unsafe fn remove(queue: QueuePtr, item: *const u8)

Removes an item from the queue.

fn messages_waiting(queue: QueuePtr) -> usize

Returns the number of messages in the queue.