#ifndef __OSAL_MQ_H__
#define __OSAL_MQ_H__

#include "osal_def.h"

#ifdef __cplusplus
extern "C" {
#endif

typedef void* osal_mq_t;

/* Message Queue API */
osal_mq_t osal_mq_create(const char* name,
                        osal_size_t msg_size,
                        osal_size_t max_msgs);
osal_err_t osal_mq_delete(osal_mq_t mq);
osal_err_t osal_mq_send(osal_mq_t mq, const void* buffer, osal_size_t size);
osal_err_t osal_mq_urgent(osal_mq_t mq, const void* buffer, osal_size_t size);
osal_err_t osal_mq_recv(osal_mq_t mq, void* buffer, osal_size_t size, osal_int32_t timeout);

#ifdef __cplusplus
}
#endif

#endif /* __OSAL_MQ_H__ */