fix crash

This commit is contained in:
YouROK
2021-05-31 09:05:48 +03:00
parent 6fb9b56b63
commit 615f0b8f81

View File

@@ -137,6 +137,8 @@ func (c *Cache) GetState() *state.CacheState {
piecesState := make(map[int]state.ItemState, 0) piecesState := make(map[int]state.ItemState, 0)
var fill int64 = 0 var fill int64 = 0
if len(c.pieces) > 0 {
for _, p := range c.pieces { for _, p := range c.pieces {
if p.Size > 0 { if p.Size > 0 {
fill += p.Size fill += p.Size
@@ -148,9 +150,11 @@ func (c *Cache) GetState() *state.CacheState {
} }
} }
} }
}
readersState := make([]*state.ReaderState, 0) readersState := make([]*state.ReaderState, 0)
c.muReaders.Lock() c.muReaders.Lock()
if len(c.readers) > 0 {
for r, _ := range c.readers { for r, _ := range c.readers {
rng := r.getPiecesRange() rng := r.getPiecesRange()
pc := r.getReaderPiece() pc := r.getReaderPiece()
@@ -160,6 +164,7 @@ func (c *Cache) GetState() *state.CacheState {
Reader: pc, Reader: pc,
}) })
} }
}
c.muReaders.Unlock() c.muReaders.Unlock()
c.filled = fill c.filled = fill