change to use readers

server/torr/storage/torrstor/cache.go

@@ -314,6 +314,21 @@ func (c *Cache) NewReader(file *torrent.File) *Reader {
 	return newReader(file, c)
 }
 
+func (c *Cache) GetUseReaders() int {
+	if c == nil {
+		return 0
+	}
+	c.muReaders.Lock()
+	defer c.muReaders.Unlock()
+	readers := 0
+	for reader := range c.readers {
+		if reader.isUse {
+			readers++
+		}
+	}
+	return readers
+}
+
 func (c *Cache) Readers() int {
 	if c == nil {
 		return 0

server/torr/torrent.go

@@ -267,7 +267,7 @@ func (t *Torrent) drop() {
 }
 
 func (t *Torrent) Close() bool {
-	if t.cache != nil && t.cache.Readers() > 0 {
+	if t.cache != nil && t.cache.GetUseReaders() > 0 {
 		return false
 	}
 	t.Stat = state.TorrentClosed