#ifndef _c_bus_client_message_h_
|
#define _c_bus_client_message_h_
|
|
#include <stddef.h>
|
|
/*
|
注册进程的proc信息，包括进程名[name], 进程[id],等
|
*/
|
typedef struct cproc cproc;
|
/*
|
进程注册信息, 包括进程的proc信息 cproc
|
待注册的本进程提供请求响应的主题 topics[s], char** rep, 主题数量 repcnt
|
待注册的本进程发布的主题 topics[s], char** pub, 主题数量 pubcnt
|
待注册的本进程订阅的主题 topics[s], char** sub, 主题数量 subcnt
|
待注册的本进程订阅的[网络、远程主机]主题 topics[s], char** subnet, 主题数量 subnetcnt
|
*/
|
typedef struct creg creg;
|
|
// TableChanged enum pollcontrol 接收到的订阅消息，数据库的变化
|
enum TableChanged
|
{
|
T_Camera = 0, //摄像机变化
|
T_CameraRule = 1, //摄像机任务参数变化
|
T_Sdk = 2, // sdk变化
|
T_CameraPolygon = 3, //摄像机多边形变化
|
T_TimeRule = 4, //时间规则变化
|
T_Server = 5, //服务器信息变化
|
T_PollConfig = 6, //轮询配置变化
|
T_File = 7, //本地文件变化
|
T_FileSetting = 8, //本地文件分析设置
|
T_SdkChanSet = 9, //算法通道设置变化
|
T_FileStack = 10, //数据栈变化
|
T_ResourceConfig = 11, //对外服务配置变化
|
T_CalculationPower = 12, //需要重新计算算力占用情况
|
T_EventPush = 13, //事件推送有变化
|
T_Cluster = 14, //集群创建、加入或退出
|
T_CameraPolygonRelation = 15, //摄像机区域的关联关系
|
T_Voice = 16, //报警声音发生变化
|
};
|
// pollcontrol 接收到的订阅消息，数据库的操作
|
enum DbAction
|
{
|
Insert = 0, // Insert db
|
Update = 1, // Update db
|
Delete = 2, // Delete db
|
};
|
|
// 数据库变化信息
|
struct DbChangeMsg
|
{
|
TableChanged table; //变化的表
|
char *id; //变化数据id
|
size_t idl; // id len
|
DbAction action; // action/ DbAction[Insert/Update/Delete]
|
char *info; //变化内容
|
size_t infol;
|
};
|
|
// 订阅消息, 包括数据库消息和其他进程的消息
|
struct csubmsg
|
{
|
char *topic; // 收到的订阅消息的主题，区分那种订阅消息
|
size_t topicl;
|
|
// private
|
// enum MsgT {NONE=0, DB, PROCLIST} type;
|
char *msg; // 收到的订阅消息的body
|
size_t msgl;
|
};
|
|
// 其他进程信息, pollcontrol可能依赖其他进程的服务，可能需要等其他进程启动再开始工作
|
struct cclient
|
{
|
creg *rinfo; // 代表其他进程的进程信息
|
|
int replykey; // 没用，上一个版本用共享内存，此为key
|
int hbcnt; // 心跳次数？可能没用
|
int dcnt; // deadcount，可能没用？
|
int status; // 进程状态，可能没用？
|
};
|
|
// 其他注册进程列表，如数据库进程需要启动再运行pollcontrol逻辑
|
struct cproclist
|
{
|
struct cclient *cli; // 其他进程的列表
|
size_t count; // 其他进程的列表的count
|
};
|
|
//////////////////////////////////////////
|
// request msg
|
/*
|
此消息既作为接收的request msg的结构，也作为发送request 消息的结构
|
接收request消息会带有发出request消息的进程的id，procid
|
*/
|
struct creqmsg
|
{
|
char *procid; // 发送request消息的进程id
|
size_t procidl;
|
char *msg; // request消息体
|
size_t msgl;
|
char *path;
|
size_t pathl;
|
char *body;
|
size_t bodyl;
|
};
|
// decode stack err msg
|
/*
|
pollcontrol会接收数据栈解码发送的解码失败消息，用于置网页状态
|
*/
|
struct cstackmsgerr
|
{
|
char *stackid; // 解码失败的数据栈id
|
size_t stackidl;
|
char *fileid; // 解码失败的文件id
|
size_t fileidl;
|
};
|
// stack file
|
/*
|
数据栈的文件列表，对应 protomsg.FileAnalysis 但是此结构体非常长
|
看代码应该只需要解析出的几个
|
*/
|
struct cstackfile
|
{
|
char *id; // 文件id
|
size_t idl;
|
char *name; // 文件name
|
size_t namel;
|
char *path; // 文件路径
|
size_t pathl;
|
|
int type; // 文件类型 1：video，2：picture
|
void *noused; // 未使用
|
};
|
// decode stack success msg
|
/*
|
pollcontrol会接收数据栈解码完成的消息，然后下发新的数据栈任务
|
*/
|
struct cstackmsg
|
{
|
int procnum; // decoder 启动的进程号，数据栈可能会有数个decoder同时运行
|
char *stackid; // 数据栈 id
|
size_t stackidl;
|
char *stackname; // 数据栈 name
|
size_t stacknamel;
|
int type; // 数据栈类型 video picture
|
int shmkey; // 数据栈使用的共享内存key
|
int width; // 分辨率
|
int height;
|
int fps; // fps 采样 fps/s
|
struct cstackfile *files; // 数据栈文件列表
|
size_t filescnt;
|
};
|
|
// reply msg
|
// 对应 bhome_msg.MsgRequestTopicReply
|
struct crepmsg
|
{
|
int errcode; // 相应request请求的消息，错误码
|
char *errmsg; // 错误消息
|
size_t errmsgl;
|
char *data; // 消息体
|
size_t datal;
|
};
|
|
/*
|
对应 bhome_msg.MsgQueryProcReply_Info query procs 返回值
|
*/
|
struct cqueryprocs
|
{
|
char *id;
|
size_t idl;
|
int online;
|
};
|
|
#ifdef __cplusplus
|
extern "C"
|
{
|
#endif
|
|
/*
|
内部使用，深拷贝 cproc
|
*/
|
cproc *internal_clone_cproc(const cproc *proc);
|
void internal_cproc_free(cproc *proc);
|
/*
|
返回一个 cproc 结构，仅拷贝输入参数
|
生命周期 cproc < name[id]
|
*/
|
cproc *make_cproc(const char *name, const char *id);
|
/*
|
从已存在的 cproc 中获取 name 和 id，仅仅是 cproc 内部的引用，无需释放
|
生命周期 name[id] < cproc
|
*/
|
char *cproc_name(const cproc *proc);
|
char *cproc_id(const cproc *proc);
|
/*
|
释放 cproc 指针
|
*/
|
void cproc_free(cproc *proc);
|
|
/*
|
返回一个 creg 结构，仅拷贝输入参数
|
输入参数生命周期需覆盖返回值生命周期
|
*/
|
creg *make_creg(const cproc *proc, const char **rep, const size_t repcnt,
|
const char **pub, const size_t pubcnt,
|
const char **sub, const size_t subcnt,
|
const char **subnet, const size_t subnetcnt);
|
creg *make_creg_from_cproc(const cproc *proc);
|
void creg_add_topic_reply(creg *reg, const char **topic, const size_t count);
|
void creg_add_topic_pub(creg *reg, const char **topic, const size_t count);
|
void creg_add_topic_sub(creg *reg, const char **topic, const size_t count);
|
void creg_add_topic_subnet(creg *reg, const char **topic, const size_t count);
|
/*
|
获取已存在的 creg 中的 cproc 或者注册的主题，无需释放
|
生命周期 < creg
|
*/
|
const cproc *creg_proc(const creg *reg);
|
char **creg_reply_topic(const creg *reg, size_t *count);
|
char **creg_pub_topic(const creg *reg, size_t *count);
|
char **creg_sub_topic(const creg *reg, size_t *count);
|
char **creg_subnet_topic(const creg *reg, size_t *count);
|
/*
|
释放 creg 指针
|
*/
|
void creg_free(creg *reg);
|
|
// 订阅消息相关，订阅数据库db消息和进程列表proclist消息
|
/*
|
cbhomeclient.cpp中使用，将接收到的submsg解包成csubmsg
|
包括topic和msg数据，msg数据并未反序列化
|
必须使用free_submsg释放
|
*/
|
struct csubmsg *to_submsg(const char *data, const size_t size);
|
void free_submsg(struct csubmsg *msg);
|
// db msg
|
/*
|
接收到的submsg在pollcontrol中可能为数据库更新的通知
|
将csubmsg中未反序列化的数据解包成db的数据格式
|
必须用free_submsg_db释放
|
*/
|
struct DbChangeMsg *get_submsg_db(struct csubmsg *msg);
|
void free_submsg_db(struct DbChangeMsg *msg);
|
// proclist msg
|
/*
|
接收到的submsg在pollcontrol中可能为关心的其他进程的列表
|
将csubmsg中未反序列化的数据解包成进程的列表
|
必须用free_submsg_proclist释放
|
*/
|
struct cproclist *get_submsg_proclist(struct csubmsg *msg);
|
void free_submsg_proclist(struct cproclist *ppl);
|
|
// request msg
|
/*
|
cbhomeclient.cpp中使用，将接收到的request请求数据解包成creqmsg
|
包括request进程的procid和msg数据，msg数据并未反序列化
|
必须使用free_reqmsg释放
|
*/
|
struct creqmsg *to_reqmsg(const char *pid, const size_t pids, const char *data, const size_t size);
|
void free_reqmsg(struct creqmsg *msg);
|
/*
|
本进程向其他进程请求数据构建
|
包括请求的主题topic和请求的数据body[data]
|
必须使用free_reqmsg释放
|
*/
|
struct creqmsg *make_req_msg(const char *topic, const size_t topicl,
|
const char *data, const size_t datal);
|
|
// decode err msg
|
/*
|
接收到的creqmsg在pollcontrol中可能为数据栈解码错误信息
|
将creqmsg中未反序列化的数据解包成cstackmsgerr，包括数据栈id stackid和文件id fileid
|
必须用free_reqmsg_stackerr释放
|
*/
|
struct cstackmsgerr *get_reqmsg_stackerr(struct creqmsg *msg);
|
void free_reqmsg_stackerr(struct cstackmsgerr *msg);
|
// decode success msg
|
/*
|
接收到的creqmsg在pollcontrol中可能为数据栈解码完成信息
|
将creqmsg中未反序列化的数据解包成cstackmsg
|
包括
|
int procnum; // 启动的decoder进程num
|
struct cstr stackid;
|
struct cstr stackname;
|
int type; // video picture
|
int shmkey;
|
int width;
|
int height;
|
int fps;
|
struct cstackfile* files; // 文件列表
|
size_t filescnt; // 文件数量
|
必须用free_reqmsg_stackerr释放
|
*/
|
struct cstackmsg *get_reqmsg_stack(struct creqmsg *msg);
|
void free_reqmsg_stack(struct cstackmsg *msg);
|
|
// reply msg
|
/*
|
创建 creqmsg 包括errcode、errmsg和消息体data
|
必须使用 free_reply_msg 释放
|
*/
|
struct crepmsg *make_reply_msg(const int errcode, const char *errmsg, const size_t emsgl,
|
const char *data, const size_t datal);
|
void free_reply_msg(struct crepmsg *msg);
|
|
/*
|
释放 query procs 从center获取所有的procs信息
|
*/
|
void free_query_procs(struct cqueryprocs *procs, const size_t count);
|
|
#ifdef __cplusplus
|
}
|
#endif
|
#endif
|
