forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/storage/localstore: fix a possible deadlock in tests

Browse source
This commit is contained in:
Janos Guljas 2019-02-21 12:21:36 +01:00
parent c580854f35
commit 09c184aa0e
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
swarm/storage/localstore/subscription_pull_test.go
View file

@ -473,14 +473,14 @@ func readPullSubscriptionBin(ctx context.Context, bin uint8, ch <-chan ChunkDesc
if !ok { if !ok {
return return
} }
var err error
addrsMu.Lock() addrsMu.Lock()
if i+1 > len(addrs[bin]) { if i+1 > len(addrs[bin]) {
errChan <- fmt.Errorf("got more chunk addresses %v, then expected %v, for bin %v", i+1, len(addrs[bin]), bin) err = fmt.Errorf("got more chunk addresses %v, then expected %v, for bin %v", i+1, len(addrs[bin]), bin)
} }
want := addrs[bin][i] want := addrs[bin][i]
addrsMu.Unlock() addrsMu.Unlock()
var err error if err == nil && !bytes.Equal(got.Address, want) {
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) err = fmt.Errorf("got chunk address %v in bin %v %s, want %s", i, bin, got.Address.Hex(), want)
} }
i++ i++