#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;
|
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;
|
int hbcnt;
|
int dcnt;
|
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
|
Update = 1, //Update
|
Delete = 2, //Delete
|
};
|
|
// 数据库变化信息
|
struct DbChangeMsg{
|
TableChanged table; //变化的表
|
struct cstr id; //变化数据id
|
DbAction action; //action
|
struct cstr info; //变化内容
|
};
|
|
// 订阅消息
|
struct csubmsg{
|
struct cstr topic;
|
|
// private
|
// enum MsgT {NONE=0, DB, PROCLIST} type;
|
struct cstr msg;
|
};
|
|
// 其他注册进程列表，如数据库进程需要启动再运行pollcontrol逻辑
|
struct cproclist{
|
struct cclient* cli;
|
size_t clientsize;
|
};
|
|
//////////////////////////////////////////
|
// request msg
|
struct creqmsg{
|
struct cstr procid;
|
struct cstr msg;
|
};
|
// decode stack err msg
|
struct cstackmsgerr{
|
struct cstr stackid;
|
struct cstr fileid;
|
};
|
// stack file
|
struct cstackfile{
|
struct cstr id;
|
struct cstr name;
|
struct cstr path;
|
int type;
|
void* noused;
|
};
|
// decode stack success msg
|
struct cstackmsg{
|
int procnum;
|
struct cstr stackid;
|
struct cstr stackname;
|
int type;
|
int shmkey;
|
int width;
|
int height;
|
int fps;
|
struct cstackfile* files;
|
size_t filescnt;
|
};
|
|
// reply msg
|
struct crepmsg{
|
int errcode;
|
struct cstr errmsg;
|
struct cstr data;
|
};
|
|
#ifdef __cplusplus
|
extern "C"{
|
#endif
|
|
struct cstr cstr_new(const char* str, const size_t len);
|
void cstr_free(struct cstr str);
|
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);
|
|
void free_creg(struct creg* reg);
|
|
struct cproc* clone_proc_info(struct cproc* pi);
|
void free_proc_info(struct cproc* pi);
|
|
// 订阅消息相关，订阅数据库db消息和进程列表proclist消息
|
struct csubmsg* to_submsg(const char* data, const size_t size);
|
void free_submsg(struct csubmsg* msg);
|
// db msg
|
struct DbChangeMsg* get_submsg_db(struct csubmsg* msg);
|
void free_submsg_db(struct DbChangeMsg* msg);
|
// proclist msg
|
struct cproclist* get_submsg_proclist(struct csubmsg* msg);
|
void free_submsg_proclist(struct cproclist* ppl);
|
|
// request msg
|
struct creqmsg* to_reqmsg(const char* pid,const size_t pids,const char* data,const size_t size);
|
struct creqmsg* make_req_msg(const char* topic, const size_t topics,
|
const char* data, const size_t datal);
|
|
void free_reqmsg(struct creqmsg* msg);
|
// decode err msg
|
struct cstackmsgerr* get_reqmsg_stackerr(struct creqmsg* msg);
|
void free_reqmsg_stackerr(struct cstackmsgerr* msg);
|
// decode success msg
|
struct cstackmsg* get_reqmsg_stack(struct creqmsg* msg);
|
void free_reqmsg_stack(struct cstackmsg* msg);
|
|
// reply msg
|
struct cstr make_reply_msg_json(const int success, const char* msg, const size_t msgl,
|
const char* data, const size_t datal);
|
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
|
