bhsgo实现QueryProcs

liuxiaolong

2021-05-20 b0598b2b53dc72ca7e259b993c1a13cf7de1e59a

 micronode.go

@@ -158,30 +158,8 @@
   return netNodes
}

func (ms *MicroNode) GetRegisteredClient() ([]RegisteredClient,error) {
   r := bhome_msg.MsgRequestTopic{}
   cr, err := ms.handle.RequestCenter(&r)
   if err != nil {
      ms.printLog("requestCenter reply:", cr, "err:", err)
      return nil, err
   }
   if cr.Success {
      rd,err := json.Marshal(cr.Data)
      if err == nil {
         var list []RegisteredClient
         err = json.Unmarshal(rd, &list)
         if err == nil {
            return list, nil
         } else {
            ms.printLog("unmarshal to RegisteredClient list err:", err)
         }
      } else {
         return nil, fmt.Errorf("marshal reply.Data err:%s", err.Error())
      }
   } else {
      ms.printLog("request center failed,status:", cr.Success, "msg:", cr.Msg, " data:", cr.Data)
   }
   return nil, fmt.Errorf("GetRegisteredClient list failed")
func (ms *MicroNode) GetRegisteredClient() ([]*bhome_msg.MsgQueryProcReply_Info,error) {
   return ms.handle.RequestCenter()
}

func (ms *MicroNode) serve(ctx context.Context, msgR *MsgReq) {