| 883 | } |
| 884 | |
| 885 | func (rrc *randReaderCtx) sentCallback(hdr transport.ObjHdr, _ io.ReadCloser, _ interface{}, err error) { |
| 886 | if err != nil { |
| 887 | rrc.t.Errorf("sent-callback %d(%s) returned an error: %v", rrc.idx, hdr.FullName(), err) |
| 888 | } |
| 889 | rr := rrc.rr |
| 890 | if rr != nil { |
| 891 | rr.slab.Free(rr.buf) |
| 892 | } |
| 893 | rrc.mu.Lock() |
| 894 | rrc.posted[rrc.idx] = nil |
| 895 | if rrc.idx > 0 && rrc.posted[rrc.idx-1] != nil { |
| 896 | rrc.t.Errorf("sent-callback %d(%s) fired out of order", rrc.idx, hdr.FullName()) |
| 897 | } |
| 898 | rrc.posted[rrc.idx] = nil |
| 899 | rrc.mu.Unlock() |
| 900 | } |