9#ifndef __OSAL_MSGQUEUE_H__
10#define __OSAL_MSGQUEUE_H__
18#ifdef LOS_WAIT_FOREVER
19#define OSAL_MSGQ_WAIT_FOREVER LOS_WAIT_FOREVER
21#define OSAL_MSGQ_WAIT_FOREVER 0xFFFFFFFF
25#define OSAL_MSGQ_NO_WAIT LOS_NO_WAIT
27#define OSAL_MSGQ_NO_WAIT 0
55int osal_msg_queue_create(
const char *name,
unsigned short queue_len,
unsigned long *queue_id,
unsigned int flags,
56 unsigned short max_msgsize);
93 unsigned int timeout);
131 unsigned int timeout);
168 unsigned int timeout);
int osal_msg_queue_is_full(unsigned long queue_id)
Check whether the message queue is full.
Definition osal_msgqueue.c:69
void osal_msg_queue_delete(unsigned long queue_id)
Delete a queue.
Definition osal_msgqueue.c:61
int osal_msg_queue_write_head_copy(unsigned long queue_id, void *buffer_addr, unsigned int buffer_size, unsigned int timeout)
Write data into a queue header.
Definition osal_msgqueue.c:41
int osal_msg_queue_read_copy(unsigned long queue_id, void *buffer_addr, unsigned int *buffer_size, unsigned int timeout)
Read a queue.
Definition osal_msgqueue.c:52
unsigned int osal_msg_queue_get_msg_num(unsigned long queue_id)
Obtains the number of messages in the current message queue.
Definition osal_msgqueue.c:86
int osal_msg_queue_write_copy(unsigned long queue_id, void *buffer_addr, unsigned int buffer_size, unsigned int timeout)
Write data into a queue.
Definition osal_msgqueue.c:31
int osal_msg_queue_create(const char *name, unsigned short queue_len, unsigned long *queue_id, unsigned int flags, unsigned short max_msgsize)
Create a message queue.
Definition osal_msgqueue.c:16