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

swarm/storage: fix LDBStore.batchesC data race by not closing it

Browse source
This commit is contained in:
Janos Guljas 2019-02-13 09:47:35 +01:00
parent 714d871faa
commit d8f29cf694
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
swarm/storage/ldbstore.go
View file

@ -805,12 +805,12 @@ func (s *LDBStore) Put(ctx context.Context, chunk Chunk) error {
gcIdxKey := getGCIdxKey(&index) gcIdxKey := getGCIdxKey(&index)
gcIdxData := getGCIdxValue(&index, po, chunk.Address()) gcIdxData := getGCIdxValue(&index, po, chunk.Address())
s.batch.Put(gcIdxKey, gcIdxData) s.batch.Put(gcIdxKey, gcIdxData)
s.lock.Unlock()
select { select {
case s.batchesC <- struct{}{}: case s.batchesC <- struct{}{}:
default: default:
} }
s.lock.Unlock()
select { select {
case <-batch.c: case <-batch.c:
@ -1049,9 +1049,6 @@ func (s *LDBStore) Close() {
s.lock.Unlock() s.lock.Unlock()
// force writing out current batch // force writing out current batch
s.writeCurrentBatch() s.writeCurrentBatch()
s.lock.Lock()
close(s.batchesC)
s.lock.Unlock()
s.db.Close() s.db.Close()
} }