bhsgo实现QueryProcs

liuxiaolong

2021-05-20 b0598b2b53dc72ca7e259b993c1a13cf7de1e59a

 hbusc.go

@@ -274,9 +274,15 @@
   return errors.New("reply return false")
}

func (h *BHBus) RequestCenter(req *bhome_msg.MsgRequestTopic) (*Reply, error) {

   return nil, errors.New("")
func (h *BHBus) RequestCenter() ([]*bhome_msg.MsgQueryProcReply_Info, error) {
   dest := &bhome_msg.BHAddress{}
   topic := &bhome_msg.MsgQueryProc{}
   rep := &bhome_msg.MsgQueryProcReply{}
   if bhsgo.QueryProcs(dest, topic, rep, h.conf.sendTimeOut) {
      return rep.ProcList, nil
   } else {
      return nil, errors.New("QueryProcs ret flase")
   }
}