los_queue_pri.h 文件参考

浏览源代码.

结构体
struct	LosQueueCB

枚举
enum	QueueReadWrite { OS_QUEUE_READ = 0 , OS_QUEUE_WRITE = 1 , OS_QUEUE_N_RW = 2 }
	@note_pic 更多...
enum	QueueHeadTail { OS_QUEUE_HEAD = 0 , OS_QUEUE_TAIL = 1 }

函数
VOID *	OsQueueMailAlloc (UINT32 queueID, VOID *mailPool, UINT32 timeout)
	Alloc a stationary memory for a mail. 更多...
UINT32	OsQueueMailFree (UINT32 queueID, VOID *mailPool, VOID *mailMem)
	Free a stationary memory of a mail. 更多...
UINT32	OsQueueInit (VOID)

变量
LosQueueCB *	g_allQueue
	消息队列池 更多...

枚举类型说明

QueueHeadTail

enum QueueHeadTail

枚举值
OS_QUEUE_HEAD	队列头部标识
OS_QUEUE_TAIL	队列尾部标识

在文件 los_queue_pri.h 第 68 行定义.

             {
    OS_QUEUE_HEAD = 0,  ///< 队列头部标识
    OS_QUEUE_TAIL = 1   ///< 队列尾部标识
} QueueHeadTail;

QueueReadWrite

enum QueueReadWrite

@note_pic

 鸿蒙对消息队列图
                           |<-----消息内容区,有2个消息---->|
+------------+------------------------------------------------------------+
|            |             |---------------|---------------|              |
|            |             |---------------|---------------|              |
|            |             |---------------|---------------|              |
+-------------------------------------------------------------------------+
|            |             ^                               ^              |
|<消息大小>      |             |                               |              |
|            |             |head                           |tail          |
|            +             +任务读消息                          +任务写消息         |
|                                                                         |
|                                                                         |
+<-------------+      队列长度,消息点个数,                          +------------->+
 * 

枚举值
OS_QUEUE_READ	读队列
OS_QUEUE_WRITE	写队列
OS_QUEUE_N_RW

在文件 los_queue_pri.h 第 62 行定义.

             {
    OS_QUEUE_READ = 0,  ///< 读队列
    OS_QUEUE_WRITE = 1, ///< 写队列
    OS_QUEUE_N_RW = 2
} QueueReadWrite;

函数说明

OsQueueInit()

UINT32 OsQueueInit

(

VOID

)

在文件 los_queue.c 第 105 行定义.

{
    LosQueueCB *queueNode = NULL;
    UINT32 index;
    UINT32 size;
 
    size = LOSCFG_BASE_IPC_QUEUE_LIMIT * sizeof(LosQueueCB);//支持1024个IPC队列
    /* system resident memory, don't free */
    g_allQueue = (LosQueueCB *)LOS_MemAlloc(m_aucSysMem0, size);//常驻内存
    if (g_allQueue == NULL) {
        return LOS_ERRNO_QUEUE_NO_MEMORY;
    }
    (VOID)memset_s(g_allQueue, size, 0, size);//清0
    LOS_ListInit(&g_freeQueueList);//初始化空闲链表
    for (index = 0; index < LOSCFG_BASE_IPC_QUEUE_LIMIT; index++) {//循环初始化每个消息队列
        queueNode = ((LosQueueCB *)g_allQueue) + index;//一个一个来
        queueNode->queueID = index;//这可是 队列的身份证
        LOS_ListTailInsert(&g_freeQueueList, &queueNode->readWriteList[OS_QUEUE_WRITE]);//通过写节点挂到空闲队列链表上
    }//这里要注意是用 readWriteList 挂到 g_freeQueueList链上的,所以要通过 GET_QUEUE_LIST 来找到 LosQueueCB
 
    if (OsQueueDbgInitHook() != LOS_OK) {//调试队列使用的.
        return LOS_ERRNO_QUEUE_NO_MEMORY;
    }
    return LOS_OK;
}

函数调用图:

这是这个函数的调用关系图: