From 7b84c595bb128d0ae72555b4e8f93df516499584 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期五, 21 五月 2021 16:10:24 +0800
Subject: [PATCH] fix api test get error.
---
proto/source/bhome_msg.proto | 20 ++++++++++++++++++--
1 files changed, 18 insertions(+), 2 deletions(-)
diff --git a/proto/source/bhome_msg.proto b/proto/source/bhome_msg.proto
index 6a4942d..f34aebb 100644
--- a/proto/source/bhome_msg.proto
+++ b/proto/source/bhome_msg.proto
@@ -16,8 +16,10 @@
repeated BHAddress route = 2; // for reply and proxy.
int64 timestamp = 3;
int32 type = 4;
- bytes proc_id = 5;
- bytes topic = 6; // for request route
+ uint64 ssn_id = 5; // node mq id
+ bytes proc_id = 6;
+ bytes topic = 7; // for request route
+ BHAddress dest = 8; // other host
}
@@ -27,6 +29,8 @@
kMsgTypeCommonReply = 2;
+ kMsgTypeProcInit = 8;
+ kMsgTypeProcInitReply = 9;
kMsgTypeRegister= 10;
// kMsgTypeRegisterReply= 11;
kMsgTypeHeartbeat = 12;
@@ -46,6 +50,8 @@
// kMsgTypeUnsubscribeReply = 25;
kMsgTypeUnregister = 26;
// kMsgTypeUnregisterReply = 27;
+ kMsgTypeQueryProc = 28;
+ kMsgTypeQueryProcReply = 29;
}
@@ -59,6 +65,16 @@
MsgTopicList topics = 1;
}
+message MsgProcInit{
+ int32 extra_mq_num = 1;
+} // proc_id is in header.
+
+message MsgProcInitReply {
+ ErrorMsg errmsg = 1;
+ int32 proc_index = 2;
+ repeated BHAddress extra_mqs = 3;
+}
+
service TopicRPC {
rpc Query (MsgQueryTopic) returns (MsgQueryTopicReply);
rpc Request (MsgRequestTopic) returns (MsgQueryTopicReply);
--
Gitblit v1.8.0