(action string, body []byte, caller string)
| 257 | } |
| 258 | |
| 259 | func (p *proxy) recvCluMetaBytes(action string, body []byte, caller string) error { |
| 260 | var cm cluMeta |
| 261 | if err := jsoniter.Unmarshal(body, &cm); err != nil { |
| 262 | return fmt.Errorf(cmn.FmtErrUnmarshal, p, "reg-meta", cos.BHead(body), err) |
| 263 | } |
| 264 | return p.recvCluMeta(&cm, action, caller) |
| 265 | } |
| 266 | |
| 267 | func (p *proxy) recvCluMeta(cluMeta *cluMeta, action, caller string) (err error) { |
| 268 | msg := p.newAmsgStr(action, cluMeta.BMD) |
no test coverage detected