#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
|
