| | |
|---|
| | | |
|---|
| | | var res Result |
|---|
| | | if err = json.Unmarshal(body, &res); err != nil { |
|---|
| | | logPrint("unmarshal to Result err:", err) |
|---|
| | | return false, config |
|---|
| | | } |
|---|
| | | |
|---|
| | | b, err := json.Marshal(res.Data) |
|---|
| | | if err !=nil { |
|---|
| | | logPrint("marshal res.Data err:", err) |
|---|
| | | return false,config |
|---|
| | | } else { |
|---|
| | | err = json.Unmarshal(b, &config) |
|---|
| | | if err !=nil { |
|---|
| | | logPrint("unmarshal config err:", err) |
|---|
| | | return false,config |
|---|
| | | } else { |
|---|
| | | return true,config |
|---|
| | |
|---|
| | | if n := s.SendandrecvTimeout(nodes, data, &ret, 5000);n == 0 { //n==0表示没有请求成功 |
|---|
| | | return nil, fmt.Errorf("doReq s.SendandrecvTimeout result n:%d", n) |
|---|
| | | } else { |
|---|
| | | logPrint("doReq SendandrecvTimeout n:", n) |
|---|
| | | if len(ret) > 0 { |
|---|
| | | var retMsg MsgInfo |
|---|
| | | err = json.Unmarshal(ret[0].Data, &retMsg) |
|---|
