xf_task_mbus.c 文件参考

#include "xf_task_mbus.h"
#include "xf_task_queue.h"

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

浏览源代码.

结构体
struct	_xf_task_xtopic_t
struct	_xf_task_xsub_t

宏定义
#define	TAG   "mbus"
#define	DEFAULT_QUEUE_COUNT   (2)

类型定义
typedef struct _xf_task_xtopic_t	xf_task_mtopic_t
typedef struct _xf_task_xsub_t	xf_task_msub_t

函数
static void	xf_task_mbus_run (xf_task_mtopic_t *mtopic, void *data)
static xf_err_t	xf_task_mbus_find (uint32_t topic_id, xf_task_mtopic_t **topic)
xf_err_t	xf_task_mbus_reg_topic (uint32_t topic_id, uint32_t size)
	注册 topic。
xf_err_t	xf_task_mbus_unreg_topic (uint32_t topic_id)
	注销 topic
xf_err_t	xf_task_mbus_pub_async (uint32_t topic_id, void *data)
	异步发布指定的 topic ，不会阻塞代码运行。
xf_err_t	xf_task_mbus_pub_sync (uint32_t topic_id, void *data)
	同步发布，直接执行订阅者的回调，执行速度快。
xf_err_t	xf_task_mbus_sub (uint32_t topic_id, xf_task_mbus_func_t mbus_cb, void *user_data)
	订阅指定的 topic。
xf_err_t	xf_task_mbus_unsub (uint32_t topic_id, xf_task_mbus_func_t mbus_cb)
	解除订阅。
xf_err_t	xf_task_mbus_unsub_all (uint32_t topic_id)
	解除 topic下所有订阅。
void	xf_task_mbus_handle (void)
	处理异步的消息。

变量
static xf_list_t	_topic_list = XF_LIST_HEAD_INIT(_topic_list)

详细描述

作者

cangyu (sky.k.nosp@m.irto.nosp@m.@qq.c.nosp@m.om)

版本

0.1

日期

2024-04-08

版权所有

Copyright (c) 2024, CorAL. All rights reserved.

在文件 xf_task_mbus.c 中定义.

宏定义说明

TAG

#define TAG   "mbus"

在文件 xf_task_mbus.c 第 48 行定义.

DEFAULT_QUEUE_COUNT

#define DEFAULT_QUEUE_COUNT   (2)

在文件 xf_task_mbus.c 第 49 行定义.

类型定义说明

xf_task_mtopic_t

typedef struct _xf_task_xtopic_t xf_task_mtopic_t

xf_task_msub_t

typedef struct _xf_task_xsub_t xf_task_msub_t

函数说明

xf_task_mbus_run()

static void xf_task_mbus_run ( xf_task_mtopic_t *  mtopic, void *  data  )

static

在文件 xf_task_mbus.c 第 222 行定义.

xf_task_mbus_find()

static xf_err_t xf_task_mbus_find ( uint32_t  topic_id, xf_task_mtopic_t **  topic  )

static

在文件 xf_task_mbus.c 第 230 行定义.

变量说明

_topic_list

xf_list_t _topic_list = XF_LIST_HEAD_INIT(_topic_list)

static

在文件 xf_task_mbus.c 第 44 行定义.