hbusc.go
@@ -470,12 +470,12 @@ h.mtxWorker.Lock() defer h.mtxWorker.Unlock() var ret []bhomebus.Mesg if n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, h.conf.sendTimeOut);n > 0 { if len(ret) > 0 { n := h.sockWorker.sock.SendandrecvTimeout(rNodes, data,&ret, h.conf.sendTimeOut) h.printLog("requestCenter n:", n, "len(ret):", len(ret)) if n > 0 && len(ret) > 0{ var cr *CommonReply if err = json.Unmarshal(ret[0].Data, cr); err == nil { return cr, nil } } } return nil, fmt.Errorf("request center err")