xwmq.c 文件参考

消息队列 更多...

#include <xwos/standard.h>
#include <xwos/lib/object.h>
#include <xwos/mm/memslice.h>
#include <xwmd/isc/xwmq/mif.h>

xwmq.c 的引用(Include)关系图:

浏览源代码.

函数
static void	xwmq_msg_construct (struct xwmq_msg *msg)
	消息槽的构造函数
static void	xwmq_construct (struct xwmq *mq)
static void	xwmq_destruct (struct xwmq *mq)
static xwer_t	xwmq_gc (struct xwos_object *obj)
xwsq_t	xwmq_get_tik (struct xwmq *mq)
	XWMQ API：获取消息队列对象的标签
xwer_t	xwmq_acquire (xwmq_d mqd)
	XWMQ API：检查消息队列对象的标签并增加引用计数
xwer_t	xwmq_release (xwmq_d mqd)
	XWMQ API：检查消息队列对象的标签并减少引用计数
xwer_t	xwmq_grab (struct xwmq *mq)
	XWMQ API：增加消息队列对象的引用计数
xwer_t	xwmq_put (struct xwmq *mq)
	XWMQ API：减少消息队列对象的引用计数
static xwer_t	xwmq_activate (struct xwmq *mq, struct xwmq_msg *txq, xwsz_t num, xwobj_gc_f gcfunc)
xwer_t	xwmq_init (struct xwmq *mq, struct xwmq_msg *txq, xwsz_t num)
	XWMQ API：静态方式初始化消息队列
xwer_t	xwmq_fini (struct xwmq *mq)
	XWMQ API：销毁静态方式初始化的消息队列对象
static struct xwmq_msg *	xwmq_msg_get (struct xwmq *mq)
	获取一个消息槽
static void	xwmq_msg_put (struct xwmq *mq, struct xwmq_msg *msg)
	释放一个消息槽
xwer_t	xwmq_eq (struct xwmq *mq, xwsq_t topic, void *data)
	XWMQ API：等待消息槽，成功后将消息发送到消息队列的 尾端 （入队）
xwer_t	xwmq_eq_to (struct xwmq *mq, xwsq_t topic, void *data, xwtm_t to)
	XWMQ API：限时等待消息槽，成功后将消息发送到消息队列的 尾端 （入队）
xwer_t	xwmq_eq_unintr (struct xwmq *mq, xwsq_t topic, void *data)
	XWMQ API：等待消息槽，且等待不可被中断， 成功后将消息发送到消息队列的 尾端 （入队）
xwer_t	xwmq_tryeq (struct xwmq *mq, xwsq_t topic, void *data)
	XWMQ API：尝试获取消息槽，成功后将消息发送到消息队列的 尾端 （入队）
xwer_t	xwmq_jq (struct xwmq *mq, xwsq_t topic, void *data)
	XWMQ API：等待消息槽，成功后将消息发送到消息队列的 首端 （插队）
xwer_t	xwmq_jq_to (struct xwmq *mq, xwsq_t topic, void *data, xwtm_t to)
	XWMQ API：限时等待消息槽，成功后将消息发送到消息队列的 首端 （插队）
xwer_t	xwmq_jq_unintr (struct xwmq *mq, xwsq_t topic, void *data)
	XWMQ API：等待消息槽，且等待不可被中断， 成功后将消息发送到消息队列的 首端 （插队）
xwer_t	xwmq_tryjq (struct xwmq *mq, xwsq_t topic, void *data)
	XWMQ API：尝试获取消息槽，成功后将消息发送到消息队列的 首端 （插队）
static struct xwmq_msg *	xwmq_choose_head (struct xwmq *mq)
	从消息接收队列头部选择一条消息
static struct xwmq_msg *	xwmq_choose_tail (struct xwmq *mq)
	从消息接收队列尾部选择一条消息
xwer_t	xwmq_dq (struct xwmq *mq, xwsq_t *topic, void **databuf)
	XWMQ API: 等待从消息队列 首端 接收一条消息
xwer_t	xwmq_dq_to (struct xwmq *mq, xwsq_t *topic, void **databuf, xwtm_t to)
	XWMQ API: 限时等待从消息队列 首端 接收一条消息
xwer_t	xwmq_dq_unintr (struct xwmq *mq, xwsq_t *topic, void **databuf)
	XWMQ API: 等待从消息队列 首端 接收一条消息，且等待不可被中断
xwer_t	xwmq_trydq (struct xwmq *mq, xwsq_t *topic, void **databuf)
	XWMQ API: 尝试从消息队列 首端 接收一条消息
xwer_t	xwmq_rq (struct xwmq *mq, xwsq_t *topic, void **databuf)
	XWMQ API: 等待从消息队列 尾端 接收一条消息
xwer_t	xwmq_rq_to (struct xwmq *mq, xwsq_t *topic, void **databuf, xwtm_t to)
	XWMQ API: 限时等待从消息队列 尾端 接收一条消息
xwer_t	xwmq_rq_unintr (struct xwmq *mq, xwsq_t *topic, void **databuf)
	XWMQ API: 等待从消息队列 尾端 接收一条消息，且等待不可被中断
xwer_t	xwmq_tryrq (struct xwmq *mq, xwsq_t *topic, void **databuf)
	XWMQ API: 尝试从消息队列 尾端 接收一条消息

变量
static const char	xwmq_txq_name [] = "xwmq.txq"

详细描述

消息队列

作者

• 隐星魂 (Roy Sun) xwos@.nosp@m.xwos.nosp@m..tech

版权所有

• Copyright © 2015 xwos.tech, All Rights Reserved.

  ‍This Source Code Form is subject to the terms of the Mozilla Public License, v. 2.0. If a copy of the MPL was not distributed with this file, You can obtain one at http://mozilla.org/MPL/2.0/.

在文件 xwmq.c 中定义.

函数说明

xwmq_activate()

static xwer_t xwmq_activate ( struct xwmq *  mq, struct xwmq_msg *  txq, xwsz_t  num, xwobj_gc_f  gcfunc  )

static

<No error

在文件 xwmq.c 第 90 行定义.

{
        xwer_t rc;
 
        rc = xwos_object_activate(&mq->xwobj, gcfunc);
        if (rc < 0) {
                goto err_xwobj_activate;
        }
        rc = xwmm_memslice_init(&mq->txq,
                                (xwptr_t)txq,
                                sizeof(struct xwmq_msg) * num,
                                sizeof(struct xwmq_msg), xwmq_txq_name,
                                (ctor_f)xwmq_msg_construct, NULL);
        if (rc < 0) {
                goto err_memslice_init;
        }
        xwos_sem_init(&mq->txqsem, (xwssq_t)num, (xwssq_t)num);
        xwlib_bclst_init_head(&mq->rxq);
        xwos_splk_init(&mq->rxqlock);
        xwos_sem_init(&mq->rxqsem, 0, (xwssq_t)num);
        return XWOK;
 
err_memslice_init:
        xwmq_put(mq); // cppcheck-suppress [misra-c2012-17.7]
err_xwobj_activate:
        return rc;
}

函数调用图:

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

xwmq_choose_head()

static struct xwmq_msg * xwmq_choose_head ( struct xwmq *  mq )

static

从消息接收队列头部选择一条消息

参数

[in]

mq

消息队列对象的指针

在文件 xwmq.c 第 354 行定义.

{
        struct xwmq_msg * msg;
        xwreg_t cpuirq;
 
        xwos_splk_lock_cpuirqsv(&mq->rxqlock, &cpuirq);
        msg = xwlib_bclst_first_entry(&mq->rxq,
                                      struct xwmq_msg,
                                      node);
        xwlib_bclst_del_init(&msg->node);
        xwos_splk_unlock_cpuirqrs(&mq->rxqlock, cpuirq);
        return msg;
}

函数调用图:

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

xwmq_choose_tail()

static struct xwmq_msg * xwmq_choose_tail ( struct xwmq *  mq )

static

从消息接收队列尾部选择一条消息

参数

[in]

mq

消息队列对象的指针

在文件 xwmq.c 第 373 行定义.

{
        struct xwmq_msg * msg;
        xwreg_t cpuirq;
 
        xwos_splk_lock_cpuirqsv(&mq->rxqlock, &cpuirq);
        msg = xwlib_bclst_last_entry(&mq->rxq,
                                     struct xwmq_msg,
                                     node);
        xwlib_bclst_del_init(&msg->node);
        xwos_splk_unlock_cpuirqrs(&mq->rxqlock, cpuirq);
        return msg;
}

函数调用图:

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

xwmq_construct()

static void xwmq_construct ( struct xwmq *  mq )

static

在文件 xwmq.c 第 22 行定义.

{
        xwos_object_construct(&mq->xwobj);
}

函数调用图:

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

xwmq_destruct()

static void xwmq_destruct ( struct xwmq *  mq )

static

在文件 xwmq.c 第 28 行定义.

{
        xwos_object_destruct(&mq->xwobj);
}

函数调用图:

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

xwmq_gc()

static xwer_t xwmq_gc ( struct xwos_object *  obj )

static

<No error

在文件 xwmq.c 第 34 行定义.

{
        struct xwmq * mq;
 
        mq = xwcc_derof(obj, struct xwmq, xwobj);
        xwos_sem_fini(&mq->txqsem);
        xwos_sem_fini(&mq->rxqsem);
        xwmq_destruct(mq);
        return XWOK;
}

函数调用图:

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

xwmq_msg_construct()

static void xwmq_msg_construct ( struct xwmq_msg *  msg )

static

消息槽的构造函数

参数

[in]

msg

消息槽的指针

在文件 xwmq.c 第 142 行定义.

{
        xwlib_bclst_init_node(&msg->node);
        msg->topic = 0;
        msg->data = NULL;
}

函数调用图:

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

xwmq_msg_get()

static struct xwmq_msg * xwmq_msg_get ( struct xwmq *  mq )

static

获取一个消息槽

在文件 xwmq.c 第 153 行定义.

{
        union {
                struct xwmq_msg * msg;
                void * anon;
        } mem;
 
        // cppcheck-suppress [misra-c2012-17.7]
        xwmm_memslice_alloc(&mq->txq, &mem.anon);
        return mem.msg;
}

函数调用图:

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

xwmq_msg_put()

static void xwmq_msg_put ( struct xwmq *  mq, struct xwmq_msg *  msg  )

static

释放一个消息槽

在文件 xwmq.c 第 169 行定义.

{
        // cppcheck-suppress [misra-c2012-17.7]
        xwmm_memslice_free(&mq->txq, msg);
}

函数调用图:

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

变量说明

xwmq_txq_name

const char xwmq_txq_name[] = "xwmq.txq"

static

在文件 xwmq.c 第 87 行定义.