| | |
| | | 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 |
| | | var cr CommonReply |
| | | if err = json.Unmarshal(ret[0].Data, &cr); err == nil { |
| | | return &cr, nil |
| | | } else { |
| | | h.printLog("unmarshal to CommonReply err:", err) |
| | | } |
| | | } |
| | | return nil, fmt.Errorf("request center err") |
| | |
| | | Topic: TOPIC_QUERYPROC, |
| | | } |
| | | cr, err := ms.handle.RequestCenter(&r) |
| | | ms.printLog("requestCenter reply:", *cr, "err:", err) |
| | | ms.printLog("requestCenter reply:", cr, "err:", err) |
| | | if err != nil { |
| | | return nil, err |
| | | } |