From 777333ff834744ac5665fa9abe5ec6373d25cda8 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期三, 01 三月 2023 09:22:30 +0800
Subject: [PATCH] bug fixed ps_sub thread join
---
message.h | 25 ++++++++++++++++++++++++-
1 files changed, 24 insertions(+), 1 deletions(-)
diff --git a/message.h b/message.h
index aa5b703..7767d15 100644
--- a/message.h
+++ b/message.h
@@ -91,6 +91,10 @@
size_t procidl;
char* msg; // request娑堟伅浣�
size_t msgl;
+ char* path;
+ size_t pathl;
+ char* body;
+ size_t bodyl;
};
// decode stack err msg
/*
@@ -147,6 +151,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 +193,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 +290,11 @@
const char* data, const size_t datal);
void free_reply_msg(struct crepmsg* msg);
+/*
+ 閲婃斁 query procs 浠巆enter鑾峰彇鎵�鏈夌殑procs淇℃伅
+*/
+void free_query_procs(struct cqueryprocs* procs, const size_t count);
+
#ifdef __cplusplus
}
#endif
--
Gitblit v1.8.0