(resp *types.SignedResponseHeader)
| 37 | } |
| 38 | |
| 39 | func (i *multiAckIndex) addResponse(resp *types.SignedResponseHeader) (err error) { |
| 40 | var key = resp.ResponseHeader.Request.GetQueryKey() |
| 41 | log.Debugf("adding key %s <-- resp %s", &key, resp.Hash()) |
| 42 | i.Lock() |
| 43 | defer i.Unlock() |
| 44 | if oresp, ok := i.respIndex[key]; ok { |
| 45 | if oresp.Hash() != resp.Hash() { |
| 46 | err = errors.Wrapf(ErrResponseSeqNotMatch, "add key %s <-- resp %s", &key, resp.Hash()) |
| 47 | return |
| 48 | } |
| 49 | return |
| 50 | } |
| 51 | i.respIndex[key] = resp |
| 52 | atomic.AddInt32(&i.owner.responseCount, 1) |
| 53 | return |
| 54 | } |
| 55 | |
| 56 | func (i *multiAckIndex) register(ack *types.SignedAckHeader) (err error) { |
| 57 | var ( |
no test coverage detected