From 418bc6e7c106326796e2abaf04a8a5066daa57ee Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期二, 31 八月 2021 14:33:08 +0800
Subject: [PATCH] Merge branch 'master' of http://192.168.5.5:10010/r/valib/bhomedbapi
---
client.go | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/client.go b/client.go
index e4f4704..ecda831 100644
--- a/client.go
+++ b/client.go
@@ -1,7 +1,7 @@
package bhomedbapi
import (
- "basic.com/valib/bhshmq.git/proto/source/bhome_msg"
+ "basic.com/valib/c_bhomebus.git/proto/source/bhome_msg"
"errors"
"fmt"
"strconv"
@@ -44,21 +44,21 @@
}
}
-var getNetNode = func(topic string) []bhome_msg.BHAddress{
+var getNetNode = func(topic string) []*bhome_msg.MsgQueryTopicReply_BHNodeAddress{
return nil
}
-func InitGetNetNode(fn func(name string)[]bhome_msg.BHAddress) {
- if fn != nil {
- getNetNode = fn
- }
+func InitGetNetNode(fn func(name string)[]*bhome_msg.MsgQueryTopicReply_BHNodeAddress) {
+ //if fn != nil {
+ // getNetNode = fn
+ //}
}
-var busReq = func(req *bhome_msg.MsgRequestTopic,dest []bhome_msg.BHAddress) ([]byte, error) {
+var busReq = func(req *bhome_msg.MsgRequestTopic,dest []*bhome_msg.MsgQueryTopicReply_BHNodeAddress) ([]byte, error) {
return nil, errors.New("please init InitDoReq first")
}
-func InitDoReq(fn func(*bhome_msg.MsgRequestTopic, []bhome_msg.BHAddress) ([]byte, error)) {
+func InitDoReq(fn func(*bhome_msg.MsgRequestTopic, []*bhome_msg.MsgQueryTopicReply_BHNodeAddress) ([]byte, error)) {
if fn != nil {
busReq = fn
}
--
Gitblit v1.8.0