add log

liuxiaolong

2022-06-28 ef5b487f6cad063a6c5a885f43f203a651c412f6

 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,25 @@
   }
}

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) {
var n_getNetNode = func(topic string) []*bhome_msg.MsgQueryTopicReply_BHNodeAddress{
   return nil
}

func InitGetNetNode(fn func(name string)[]*bhome_msg.MsgQueryTopicReply_BHNodeAddress) {
   if fn != nil {
      getNetNode = fn
      n_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
   }