From eb139e1dbd3b962a36dba95024d823f7c76ab81d Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期三, 02 六月 2021 15:45:47 +0800
Subject: [PATCH] use MsgQueryTopicReply_BHNodeAddress
---
micronode.go | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/micronode.go b/micronode.go
index d7189af..af16f1b 100644
--- a/micronode.go
+++ b/micronode.go
@@ -135,12 +135,12 @@
return ms.handle.Request(serverId, msgR, milliSecs)
}
-func (ms *MicroNode) RequestOnly(req *bhome_msg.MsgRequestTopic, dest []bhome_msg.BHAddress) ([]byte, error) {
+func (ms *MicroNode) RequestOnly(req *bhome_msg.MsgRequestTopic, dest []*bhome_msg.MsgQueryTopicReply_BHNodeAddress) ([]byte, error) {
return ms.handle.RequestOnly(req, dest)
}
//鑾峰彇鏈満涓煇涓�涓富棰樼殑 key 锛堢粨鏋滃彧鏈変竴涓厓绱狅級
-func (ms *MicroNode) GetLocalNetNodeByTopic(topicName string) []bhome_msg.BHAddress {
+func (ms *MicroNode) GetLocalNetNodeByTopic(topicName string) []*bhome_msg.MsgQueryTopicReply_BHNodeAddress {
netNodes, err := ms.handle.GetNetNodeByTopic(ms.serverId, ms.procInfo, topicName)
if err != nil {
ms.printLog("topic:",topicName, " netNodes:", netNodes, "err:", err)
@@ -150,13 +150,13 @@
}
//鑾峰彇闆嗙兢涓墍鏈夎妭鐐规煇涓富棰樼殑key淇℃伅锛� 锛堢粨鏋滃彲鑳芥湁澶氫釜锛�
-func (ms *MicroNode) GetAllNetNodesByTopic(topicName string) []bhome_msg.BHAddress {
- netNodes, err := ms.handle.GetNetNodeByTopic("", ms.procInfo, topicName)
- if err != nil {
- return nil
- }
- return netNodes
-}
+//func (ms *MicroNode) GetAllNetNodesByTopic(topicName string) []bhome_msg.BHAddress {
+// netNodes, err := ms.handle.GetNetNodeByTopic("", ms.procInfo, topicName)
+// if err != nil {
+// return nil
+// }
+// return netNodes
+//}
func (ms *MicroNode) GetRegisteredClient() ([]*bhome_msg.MsgQueryProcReply_Info,error) {
return ms.handle.RequestCenter()
--
Gitblit v1.8.0