hbusc.go
@@ -452,6 +452,19 @@ return nil, fmt.Errorf("request err") } func (h *BHBus) RequestOnly(rData []byte, rNodes []bhomebus.NetNode) ([]byte, error) { var ret []bhomebus.Mesg n := h.sockWorker.sock.SendandrecvTimeout(rNodes, rData, &ret, h.conf.sendTimeOut) if n > 0 && len(ret) > 0 { return ret[0].Data, nil } else { h.printLog("Request n: ", n, " len(ret): ", len(ret)) } return nil, fmt.Errorf("request err") } func (h *BHBus) Reply(replyKey int, i *Reply) error { data,err := json.Marshal(*i) if err != nil {