Struct massa_execution_worker::request_queue::RequestQueue

pub(crate) struct RequestQueue<T, R> {
    max_items: usize,
    queue: VecDeque<RequestWithResponseSender<T, R>>,
}

Structure representing an execution request queue with maximal length. Each request is a RequestWithResponseSender that comes with an MPSC sender to return the execution result when the execution is over (or an error).

Fields

max_items: usize

Max number of item in the queue. When the queue is full, extra new items are cancelled and dropped.

queue: VecDeque<RequestWithResponseSender<T, R>>

The actual underlying queue

Implementations

impl<T, R> RequestQueue<T, R>

pub fn new(max_items: usize) -> Self

Create a new request queue

Arguments

• max_items: the maximal number of items in the queue. When full, extra new elements are cancelled and dropped.

pub fn capacity(&self) -> usize

Returns the max number of items the queue can contain

pub fn extend(&mut self, other: RequestQueue<T, R>)

Extends Self with the contents of another RequestQueue. The contents of the incoming queue are appended last. Excess items with respect to self.max_items are canceled and dropped.

pub fn cancel(&mut self, err: ExecutionError)

Cancel all queued items.

Arguments

• err: the error to send through the response channel of cancelled items

pub fn pop(&mut self) -> Option<RequestWithResponseSender<T, R>>

Pop out the oldest element of the queue

Returns

The oldest element of the queue, or None if the queue is empty

pub fn push(&mut self, req: RequestWithResponseSender<T, R>)

Push a new element at the end of the queue. May fail if maximum capacity is reached, in which case the request is canceled and dropped.

Returns

The oldest element of the queue, or None if the queue is empty

pub fn is_full(&self) -> bool

Take all the elements into a new queue and reset the current queue Checks whether the queue is full

Returns

true if the queue is full, false otherwise

pub fn is_empty(&self) -> bool

Checks whether the queue is empty

Returns

true if the queue is empty, false otherwise

Trait Implementations

impl<T: Debug, R: Debug> Debug for RequestQueue<T, R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.