restruct

zhangmeng

2022-12-27 7a77e0a80e633bdb5cb3f2b633eebdbf70f6a430

 message.h

@@ -147,6 +147,15 @@
    size_t datal;
};

/*
    对应 bhome_msg.MsgQueryProcReply_Info query procs 返回值
*/
struct cqueryprocs{
    char* id;
    size_t idl;
    int online;
};

#ifdef __cplusplus
extern "C"{
#endif
@@ -180,12 +189,17 @@
                                    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_rep_topic(const creg* reg, size_t* count);
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);
@@ -272,6 +286,11 @@
                                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