QP/C  7.0.1
Real-Time Embedded Framework
QEQueue Class Reference

Native QF Event Queue. More...

#include <qequeue.h>

Public Member Functions

void QEQueue_init (QEQueue *const me, QEvt const **const qSto, uint_fast16_t const qLen)
 
bool QEQueue_post (QEQueue *const me, QEvt const *const e, uint_fast16_t const margin, uint_fast8_t const qs_id)
 
void QEQueue_postLIFO (QEQueue *const me, QEvt const *const e, uint_fast8_t const qs_id)
 
QEvt const * QEQueue_get (QEQueue *const me, uint_fast8_t const qs_id)
 

Public Attributes

QEvt const *volatile frontEvt
 
QEvt const ** ring
 
QEQueueCtr end
 
QEQueueCtr volatile head
 
QEQueueCtr volatile tail
 
QEQueueCtr volatile nFree
 
QEQueueCtr nMin
 

Detailed Description

Description
This class describes the native QF event queue, which can be used as the event queue for active objects, or as a simple "raw" event queue for thread-safe event passing among non-framework entities, such as ISRs, device drivers, or other third-party components.

The native QF event queue is configured by defining the macro QF_EQUEUE_TYPE as QEQueue in the specific QF port header file.

The QEQueue structure contains only data members for managing an event queue, but does not contain the storage for the queue buffer, which must be provided externally during the queue initialization.

The event queue can store only event pointers, not the whole events. The internal implementation uses the standard ring-buffer plus one external location that optimizes the queue operation for the most frequent case of empty queue.

The QEQueue structure is used with two sets of functions. One set is for the active object event queue, which might need to block the active object task when the event queue is empty and might need to unblock it when events are posted to the queue. The interface for the native active object event queue consists of the following functions: QActive_post(), QActive_postLIFO(), and QActive_get_(). Additionally the function QEQueue_init() is used to initialize the queue.

The other set of functions, uses QEQueue as a simple "raw" event queue to pass events between entities other than active objects, such as ISRs. The "raw" event queue is not capable of blocking on the get() operation, but is still thread-safe because it uses QF critical section to protect its integrity. The interface for the "raw" thread-safe queue consists of the following functions: QEQueue_post(), QEQueue_postLIFO(), and QEQueue_get(). Additionally the function QEQueue_init() is used to initialize the queue.


ote Most event queue operations (both the active object queues and the "raw" queues) internally use the QF critical section. You should be careful not to invoke those operations from other critical sections when nesting of critical sections is not supported.

See also
QEQueue for the description of the data members

Definition at line 119 of file qequeue.h.

Member Function Documentation

◆ QEQueue_init()

void QEQueue_init ( QEQueue *const  me,
QEvt const **const  qSto,
uint_fast16_t const  qLen 
)

Initialize the native QF event queue.

Description
Initialize the event queue by giving it the storage for the ring buffer.
Parameters
[in,out]mepointer (see oop)
[in]qStoan array of pointers to QEvt to sereve as the ring buffer for the event queue
[in]qLenthe length of the qSto buffer (in QEvt pointers)
Note
The actual capacity of the queue is qLen + 1, because of the extra location forntEvt.
This function is also used to initialize the event queues of active objects in the built-int QV and QK kernels, as well as other QP ports to OSes/RTOSes that do provide a suitable message queue.

Definition at line 46 of file qf_qeq.c.

◆ QEQueue_post()

bool QEQueue_post ( QEQueue *const  me,
QEvt const *const  e,
uint_fast16_t const  margin,
uint_fast8_t const  qs_id 
)

Post an event to the "raw" thread-safe event queue (FIFO).

Description
Post an event to the "raw" thread-safe event queue using the First-In-First-Out (FIFO) order.
Parameters
[in,out]mepointer (see oop)
[in]epointer to the event to be posted to the queue
[in]marginnumber of required free slots in the queue after posting the event. The special value QF_NO_MARGIN means that this function will assert if posting
Note
The QF_NO_MARGIN value of the margin parameter is special and denotes situation when the post() operation is assumed to succeed (event delivery guarantee). An assertion fires, when the event cannot be delivered in this case.
Returns
'true' (success) when the posting succeeded with the provided margin and 'false' (failure) when the posting fails.
Note
This function can be called from any task context or ISR context.
See also
QEQueue_postLIFO(), QEQueue_get()

Definition at line 61 of file qf_qeq.c.

◆ QEQueue_postLIFO()

void QEQueue_postLIFO ( QEQueue *const  me,
QEvt const *const  e,
uint_fast8_t const  qs_id 
)

Post an event to the "raw" thread-safe event queue (LIFO).

Description
Post an event to the "raw" thread-safe event queue using the Last-In-First-Out (LIFO) order.
Parameters
[in,out]mepointer (see oop)
[in]epointer to the event to be posted to the queue
Attention
The LIFO policy should be used only with great caution, because it alters the order of events in the queue.
Note
This function can be called from any task context or ISR context.
this function is used for the "raw" thread-safe queues and not for the queues of active objects.
See also
QEQueue_post(), QEQueue_get(), QActive_defer()

Definition at line 137 of file qf_qeq.c.

◆ QEQueue_get()

QEvt const * QEQueue_get ( QEQueue *const  me,
uint_fast8_t const  qs_id 
)

Obtain an event from the "raw" thread-safe queue.

Description
Retrieves an event from the front of the "raw" thread-safe queue and returns a pointer to this event to the caller.
Parameters
[in,out]mepointer (see oop)
Returns
pointer to event at the front of the queue, if the queue is not empty and NULL if the queue is empty.
Note
this function is used for the "raw" thread-safe queues and not for the queues of active objects.
See also
QEQueue_post(), QEQueue_postLIFO(), QActive_recall()

Definition at line 184 of file qf_qeq.c.

Member Data Documentation

◆ frontEvt

QEvt const* volatile frontEvt

pointer to event at the front of the queue.

Description
All incoming and outgoing events pass through the frontEvt location. When the queue is empty (which is most of the time), the extra frontEvt location allows to bypass the ring buffer altogether, greatly optimizing the performance of the queue. Only bursts of events engage the ring buffer.


ote The additional role of this attribute is to indicate the empty status of the queue. The queue is empty when frontEvt is NULL.

Definition at line 131 of file qequeue.h.

◆ ring

QEvt const** ring

pointer to the start of the ring buffer.

Definition at line 134 of file qequeue.h.

◆ end

offset of the end of the ring buffer from the start of the buffer.

Definition at line 137 of file qequeue.h.

◆ head

QEQueueCtr volatile head

offset to where next event will be inserted into the buffer.

Definition at line 140 of file qequeue.h.

◆ tail

QEQueueCtr volatile tail

offset of where next event will be extracted from the buffer.

Definition at line 143 of file qequeue.h.

◆ nFree

QEQueueCtr volatile nFree

number of free events in the ring buffer.

Definition at line 146 of file qequeue.h.

◆ nMin

QEQueueCtr nMin

minimum number of free events ever in the ring buffer.

Description
this attribute remembers the low-watermark of the ring buffer, which provides a valuable information for sizing event queues.
See also
QF_getQueueMargin().

Definition at line 154 of file qequeue.h.


The documentation for this class was generated from the following file: