remove osal_queue_t const qhdl from osal API
since it doesn't make any differences.
This commit is contained in:
@@ -78,9 +78,9 @@ static inline bool osal_mutex_unlock(osal_mutex_t mutex_hdl);
|
|||||||
|
|
||||||
//------------- Queue -------------//
|
//------------- Queue -------------//
|
||||||
static inline osal_queue_t osal_queue_create(osal_queue_def_t* qdef);
|
static inline osal_queue_t osal_queue_create(osal_queue_def_t* qdef);
|
||||||
static inline bool osal_queue_receive(osal_queue_t const qhdl, void* data);
|
static inline bool osal_queue_receive(osal_queue_t qhdl, void* data);
|
||||||
static inline bool osal_queue_send(osal_queue_t const qhdl, void const * data, bool in_isr);
|
static inline bool osal_queue_send(osal_queue_t qhdl, void const * data, bool in_isr);
|
||||||
static inline bool osal_queue_empty(osal_queue_t const qhdl);
|
static inline bool osal_queue_empty(osal_queue_t qhdl);
|
||||||
|
|
||||||
#if 0 // TODO remove subtask related macros later
|
#if 0 // TODO remove subtask related macros later
|
||||||
// Sub Task
|
// Sub Task
|
||||||
|
@@ -118,17 +118,17 @@ static inline osal_queue_t osal_queue_create(osal_queue_def_t* qdef)
|
|||||||
return xQueueCreateStatic(qdef->depth, qdef->item_sz, (uint8_t*) qdef->buf, &qdef->sq);
|
return xQueueCreateStatic(qdef->depth, qdef->item_sz, (uint8_t*) qdef->buf, &qdef->sq);
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline bool osal_queue_receive(osal_queue_t const qhdl, void* data)
|
static inline bool osal_queue_receive(osal_queue_t qhdl, void* data)
|
||||||
{
|
{
|
||||||
return xQueueReceive(qhdl, data, portMAX_DELAY);
|
return xQueueReceive(qhdl, data, portMAX_DELAY);
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline bool osal_queue_send(osal_queue_t const qhdl, void const * data, bool in_isr)
|
static inline bool osal_queue_send(osal_queue_t qhdl, void const * data, bool in_isr)
|
||||||
{
|
{
|
||||||
return in_isr ? xQueueSendToBackFromISR(qhdl, data, NULL) : xQueueSendToBack(qhdl, data, OSAL_TIMEOUT_WAIT_FOREVER);
|
return in_isr ? xQueueSendToBackFromISR(qhdl, data, NULL) : xQueueSendToBack(qhdl, data, OSAL_TIMEOUT_WAIT_FOREVER);
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline bool osal_queue_empty(osal_queue_t const qhdl)
|
static inline bool osal_queue_empty(osal_queue_t qhdl)
|
||||||
{
|
{
|
||||||
return uxQueueMessagesWaiting(qhdl) > 0;
|
return uxQueueMessagesWaiting(qhdl) > 0;
|
||||||
}
|
}
|
||||||
|
@@ -125,7 +125,7 @@ static inline osal_queue_t osal_queue_create(osal_queue_def_t* qdef)
|
|||||||
return (osal_queue_t) qdef;
|
return (osal_queue_t) qdef;
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline bool osal_queue_receive(osal_queue_t const qhdl, void* data)
|
static inline bool osal_queue_receive(osal_queue_t qhdl, void* data)
|
||||||
{
|
{
|
||||||
struct os_event* ev;
|
struct os_event* ev;
|
||||||
ev = os_eventq_get(&qhdl->evq);
|
ev = os_eventq_get(&qhdl->evq);
|
||||||
@@ -137,7 +137,7 @@ static inline bool osal_queue_receive(osal_queue_t const qhdl, void* data)
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline bool osal_queue_send(osal_queue_t const qhdl, void const * data, bool in_isr)
|
static inline bool osal_queue_send(osal_queue_t qhdl, void const * data, bool in_isr)
|
||||||
{
|
{
|
||||||
(void) in_isr;
|
(void) in_isr;
|
||||||
|
|
||||||
@@ -161,7 +161,7 @@ static inline bool osal_queue_send(osal_queue_t const qhdl, void const * data, b
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline bool osal_queue_empty(osal_queue_t const qhdl)
|
static inline bool osal_queue_empty(osal_queue_t qhdl)
|
||||||
{
|
{
|
||||||
return STAILQ_EMPTY(&qhdl->evq.evq_list);
|
return STAILQ_EMPTY(&qhdl->evq.evq_list);
|
||||||
}
|
}
|
||||||
|
@@ -176,7 +176,7 @@ static inline osal_queue_t osal_queue_create(osal_queue_def_t* qdef)
|
|||||||
return (osal_queue_t) qdef;
|
return (osal_queue_t) qdef;
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline bool osal_queue_receive(osal_queue_t const qhdl, void* data)
|
static inline bool osal_queue_receive(osal_queue_t qhdl, void* data)
|
||||||
{
|
{
|
||||||
_osal_q_lock(qhdl);
|
_osal_q_lock(qhdl);
|
||||||
bool success = tu_fifo_read(&qhdl->ff, data);
|
bool success = tu_fifo_read(&qhdl->ff, data);
|
||||||
@@ -185,7 +185,7 @@ static inline bool osal_queue_receive(osal_queue_t const qhdl, void* data)
|
|||||||
return success;
|
return success;
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline bool osal_queue_send(osal_queue_t const qhdl, void const * data, bool in_isr)
|
static inline bool osal_queue_send(osal_queue_t qhdl, void const * data, bool in_isr)
|
||||||
{
|
{
|
||||||
if (!in_isr) {
|
if (!in_isr) {
|
||||||
_osal_q_lock(qhdl);
|
_osal_q_lock(qhdl);
|
||||||
@@ -202,7 +202,7 @@ static inline bool osal_queue_send(osal_queue_t const qhdl, void const * data, b
|
|||||||
return success;
|
return success;
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline bool osal_queue_empty(osal_queue_t const qhdl)
|
static inline bool osal_queue_empty(osal_queue_t qhdl)
|
||||||
{
|
{
|
||||||
_osal_q_lock(qhdl);
|
_osal_q_lock(qhdl);
|
||||||
bool is_empty = tu_fifo_empty(&qhdl->ff);
|
bool is_empty = tu_fifo_empty(&qhdl->ff);
|
||||||
|
Reference in New Issue
Block a user