summaryrefslogtreecommitdiff
path: root/recipes-bsp/esp32spid/src/msgq.c
diff options
context:
space:
mode:
authorUros Majstorovic <majstor@majstor.org>2021-08-27 03:06:13 +0200
committerUros Majstorovic <majstor@majstor.org>2021-08-27 03:06:13 +0200
commit76ec318118106cb25d762de83857f6579c13e273 (patch)
treeac1025b9e79a5eae04b6036d56599c0df98dcb08 /recipes-bsp/esp32spid/src/msgq.c
parent6d270f43cfea8e840463c260b43a6afbd24c1149 (diff)
yocto rename
Diffstat (limited to 'recipes-bsp/esp32spid/src/msgq.c')
-rw-r--r--recipes-bsp/esp32spid/src/msgq.c42
1 files changed, 0 insertions, 42 deletions
diff --git a/recipes-bsp/esp32spid/src/msgq.c b/recipes-bsp/esp32spid/src/msgq.c
deleted file mode 100644
index ff9f59e..0000000
--- a/recipes-bsp/esp32spid/src/msgq.c
+++ /dev/null
@@ -1,42 +0,0 @@
-#include <stdlib.h>
-#include <pthread.h>
-
-#include "msgq.h"
-
-#define IDX_MASK(IDX, SIZE) ((IDX) & ((SIZE) - 1))
-
-int msgq_init(MSGQueue *msgq, unsigned char **array, uint16_t size) {
- int rv;
-
- msgq->idx_r = 0;
- msgq->idx_w = 0;
- msgq->size = size;
- msgq->array = array;
- rv = pthread_mutex_init(&msgq->mutex, NULL);
- if (rv) {
- return MSGQ_ERR;
- }
-
- rv = pthread_cond_init(&msgq->cond, NULL);
- if (rv) {
- pthread_mutex_destroy(&msgq->mutex);
- return MSGQ_ERR;
- }
-}
-
-int msgq_push(MSGQueue *msgq, unsigned char *buffer) {
- if ((uint16_t)(msgq->idx_w - msgq->idx_r) == msgq->size) return MSGQ_ERR_FULL;
-
- msgq->array[IDX_MASK(msgq->idx_w++, msgq->size)] = buffer;
- return MSGQ_OK;
-}
-
-unsigned char *msgq_pop(MSGQueue *msgq) {
- if (msgq->idx_r == msgq->idx_w) return NULL;
-
- return msgq->array[IDX_MASK(msgq->idx_r++, msgq->size)];
-}
-
-uint16_t msgq_len(MSGQueue *msgq) {
- return (uint16_t)(msgq->idx_w - msgq->idx_r);
-}