imt_queue.h

Go to the documentation of this file.

#ifndef IMT_QUEUE_H
#define IMT_QUEUE_H
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include <stdint.h>
#include <stdlib.h>
#include <string.h>
#include <stdbool.h>
 
#ifndef IMT_QUEUE_SIZE
    #define IMT_QUEUE_SIZE 1U
#endif
 
#define IMT_CRC_SIZE 2U
 
#ifdef ARDUINO
    #ifndef IMT_PAYLOAD_SIZE
        #define IMT_PAYLOAD_SIZE 5000U + IMT_CRC_SIZE
    #endif
#else
    #ifndef IMT_PAYLOAD_SIZE
        #define IMT_PAYLOAD_SIZE 100000U + IMT_CRC_SIZE
    #endif
#endif
 
typedef struct
{
    uint16_t id;            
    uint8_t * buffer;       
    size_t length;          
    uint16_t topic;         
    bool readyToProcess;    
    bool ready;             
} imt_t;
 
typedef struct
{
    imt_t messages[IMT_QUEUE_SIZE]; 
    uint16_t count;                 
    uint16_t head;                  
    uint16_t tail;                  
    uint16_t maxLength;             
} imt_queue_t;
 
bool imtQueueMoAdd(const uint16_t topic, const char * data, const size_t length);
 
bool imtQueueMtAdd(const uint16_t topic, const uint16_t id, const size_t length);
 
bool imtQueueMoRemove(void);
 
bool imtQueueMtRemove(void);
 
imt_t * imtQueueMoGetFirst(void);
 
imt_t * imtQueueMtGetFirst(void);
 
imt_t * imtQueueMtGetLast(void);
 
void imtQueueMtLock(bool lock);
 
void imtQueueInit (void);
 
inline size_t imtQueueSize(imt_queue_t * queue)
{
    return queue->count;
}
 
#ifdef __cplusplus
}
#endif
 
#endif