upate bhsgo,use MsgQueryTopicReply_BHNodeAddress

liuxiaolong

2021-06-02 e67dc008802aafb884dc94da054f2090da4005e2

 client.go

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