message.h

Go to the documentation of this file.

/****************************************************************************/
 
#ifndef MESSAGE_H
#define MESSAGE_H
 
#ifdef __cplusplus
extern "C"
{
#endif
 
#include "config.h"
 
#include <stdint.h>
#include <stdbool.h>

    typedef struct msg msg_t;
    typedef struct msg_queue msg_queue_t;
    typedef struct msg_pool msg_pool_t;

    typedef enum
    {
        MSG_TYPE_PURE = 0, 
        MSG_TYPE_DYNAMIC   
    } msg_type_t;

    struct msg
    {
        msg_t *next;          
        uint8_t size;         
        int32_t sig;          
        uint8_t *content_ptr; 
        msg_type_t type;      
        uint8_t src_thread_id; 
        uint8_t des_thread_id; 
    };

    struct msg_queue
    {
        msg_t *head_ptr;    
        msg_t *tail_ptr;    
        uint8_t size_max;   
        uint8_t size_curr;  
    };

        void akos_message_init(void);

        void akos_message_free(msg_t *p_msg);

        void akos_message_queue_init(msg_queue_t *p_msg_q, uint8_t size);

        void akos_message_queue_put_dynamic(msg_queue_t *p_msg_q, int32_t sig, void *p_content, uint8_t size);

        void akos_message_queue_put_pure(msg_queue_t *p_msg_q, int32_t sig);

        msg_t *akos_message_queue_get(msg_queue_t *p_msg_q);

        void *akos_message_get_dynamic_data(msg_t *p_msg, uint8_t *p_msg_size);

        msg_t *akos_message_queue_get_pure(msg_queue_t *p_msg_q);

        int32_t akos_message_get_pure_data(msg_t *p_msg);
 
#ifdef __cplusplus
}
#endif
#endif /* MESSAGE_H */