#ifndef _c_bus_client_message_h_
|
#define _c_bus_client_message_h_
|
|
#include <stddef.h>
|
|
struct cstr{
|
char* str; // 字符串内容
|
size_t size; // 字符串长度
|
};
|
// 进程信息
|
struct cproc{
|
struct cstr name; // 进程名字
|
struct cstr id; // 进程id
|
struct cstr info; // 进程其他信息，目前没用
|
};
|
|
struct cstrarr{
|
struct cstr* arr; // 字符串数组
|
size_t count; // 字符串数组长度
|
};
|
// 进程注册信息
|
struct creg{
|
struct cproc* pinfo; // 需要注册的进程信息
|
|
cstrarr channel; // 进程提供的请求响应服务的主题
|
cstrarr topic_pub; // 进程提供的发布订阅的发布主题
|
cstrarr topic_sub; // 进程需要订阅的主题
|
cstrarr topic_sub_net; // 进程需要订阅的网络主题，目前没用
|
};
|
|
// 其他进程信息
|
struct cclient{
|
struct creg* rinfo; // 代表其他进程的进程信息
|
|
int replykey; // 没用，上一个版本用共享内存，此为key
|
int hbcnt; // 心跳次数？可能没用
|
int dcnt; // deadcount，可能没用？
|
int status; // 进程状态，可能没用？
|
};
|
|
//TableChanged enum
|
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, //报警声音发生变化
|
};
|
enum DbAction {
|
Insert = 0, //Insert db
|
Update = 1, //Update db
|
Delete = 2, //Delete db
|
};
|
|
// 数据库变化信息
|
struct DbChangeMsg{
|
TableChanged table; //变化的表
|
struct cstr id; //变化数据id
|
DbAction action; //action/ DbAction[Insert/Update/Delete]
|
struct cstr info; //变化内容
|
};
|
|
// 订阅消息
|
struct csubmsg{
|
struct cstr topic; // 收到的订阅消息的主题，区分那种订阅消息
|
|
// private
|
// enum MsgT {NONE=0, DB, PROCLIST} type;
|
struct cstr msg; // 收到的订阅消息的body
|
};
|
|
// 其他注册进程列表，如数据库进程需要启动再运行pollcontrol逻辑
|
struct cproclist{
|
struct cclient* cli; // 其他进程的列表
|
size_t count; // 其他进程的列表的count
|
};
|
|
//////////////////////////////////////////
|
// request msg
|
/*
|
此消息既作为接收的request msg的结构，也作为发送request 消息的结构
|
接收request消息会带有发出request消息的进程的id，procid
|
*/
|
struct creqmsg{
|
struct cstr procid; // 发送request消息的进程id
|
struct cstr msg; // request消息体
|
};
|
// decode stack err msg
|
/*
|
pollcontrol会接收数据栈解码发送的解码失败消息，用于置网页状态
|
*/
|
struct cstackmsgerr{
|
struct cstr stackid; // 解码失败的数据栈id
|
struct cstr fileid; // 解码失败的文件id
|
};
|
// stack file
|
/*
|
数据栈的文件列表，对应 protomsg.FileAnalysis 但是此结构体非常长
|
看代码应该只需要解析出的几个
|
*/
|
struct cstackfile{
|
struct cstr id; // 文件id
|
struct cstr name; // 文件name
|
struct cstr path; // 文件路径
|
int type; // 文件类型 1：video，2：picture
|
void* noused; // 未使用
|
};
|
// decode stack success msg
|
/*
|
pollcontrol会接收数据栈解码完成的消息，然后下发新的数据栈任务
|
*/
|
struct cstackmsg{
|
int procnum; // decoder 启动的进程号，数据栈可能会有数个decoder同时运行
|
struct cstr stackid; // 数据栈 id
|
struct cstr stackname; // 数据栈 name
|
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请求的消息，错误码
|
struct cstr errmsg; // 错误消息
|
struct cstr data; // 消息体
|
};
|
|
#ifdef __cplusplus
|
extern "C"{
|
#endif
|
/*
|
封装了C接口的string
|
cstr_new 创建一个string，包括内存地址和长度，会拷贝参数
|
必须使用cstr_free释放
|
*/
|
struct cstr cstr_new(const char* str, const size_t len);
|
void cstr_free(struct cstr str);
|
/*
|
封装字符串数组，其中是一个struct cstr数组，包括指向数组的指针和count
|
通过cstr_arr_add添加字符串，内部会拷贝字符串
|
必须使用cstr_arr_free释放
|
*/
|
struct cstrarr cstr_arr_new(const size_t count);
|
void cstr_arr_add(struct cstrarr* arr, const char* data, const size_t len, const size_t idx);
|
void cstr_arr_free(struct cstrarr arr);
|
|
/*
|
创建struct cproc 结构，对应procinfo，保存proc的name，id，info[当前没有使用]
|
必须使用free_proc_info释放
|
*/
|
struct cproc* make_proc_info(const struct cstr name, const struct cstr id, const struct cstr info);
|
/*
|
从已存在的proc克隆，会拷贝，使用free_proc_info释放
|
*/
|
struct cproc* clone_proc_info(const struct cproc* pi);
|
void free_proc_info(struct cproc* pi);
|
|
/*
|
释放creg结构指针
|
creg结构可以使用上述make_proc_info、cstr_arr_new、cstr_new函数创建
|
*/
|
void free_creg(struct 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
|
/*
|
no use 将reply消息序列化为json，目前没有使用
|
使用 cstr_free 释放
|
*/
|
struct cstr make_reply_msg_json(const int success, const char* msg, const size_t msgl,
|
const char* data, const size_t datal);
|
/*
|
创建 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);
|
|
#ifdef __cplusplus
|
}
|
#endif
|
#endif
|
