swarm/storage/localstore: better want check in readPullSubscriptionBin

This commit is contained in:
Janos Guljas 2019-02-21 14:20:21 +01:00
parent 0b80043abb
commit 7e7e5ef8dc

View file

@ -445,12 +445,13 @@ func readPullSubscriptionBin(ctx context.Context, bin uint8, ch <-chan ChunkDesc
addrsMu.Lock()
if i+1 > len(addrs[bin]) {
err = fmt.Errorf("got more chunk addresses %v, then expected %v, for bin %v", i+1, len(addrs[bin]), bin)
} else {
want := addrs[bin][i]
if !bytes.Equal(got.Address, want) {
err = fmt.Errorf("got chunk address %v in bin %v %s, want %s", i, bin, got.Address.Hex(), want)
}
}
want := addrs[bin][i]
addrsMu.Unlock()
if err == nil && !bytes.Equal(got.Address, want) {
err = fmt.Errorf("got chunk address %v in bin %v %s, want %s", i, bin, got.Address.Hex(), want)
}
i++
// send one and only one error per received address
select {