Merge branch 'master' into old-engine

server/torr/storage/torrstor/cache.go

@@ -234,7 +234,6 @@ func (c *Cache) getRemPieces() []*Piece {
 			}
 		} else {
 			// on preload clean
-			// TODO проверить
 			if p.Size > 0 && !c.isIdInFileBE(ranges, id) {
 				piecesRemove = append(piecesRemove, p)
 			}
@@ -254,7 +253,7 @@ func (c *Cache) getRemPieces() []*Piece {
 		readerPos := r.getReaderPiece()
 		readerRAHPos := r.getReaderRAHPiece()
 		end := r.getPiecesRange().End
-		count := int(16 * 1024 * 1024 * 4 / c.pieceLength) // 64 MB window
+		count := int(64 << 20 / c.pieceLength) // 64 MB window
 		if count > 64 {
 			count = 64
 		}
@@ -289,8 +288,8 @@ func (c *Cache) getRemPieces() []*Piece {
 func (c *Cache) isIdInFileBE(ranges []Range, id int) bool {
 	// keep 8/16 MB
 	FileRangeNotDelete := int64(c.pieceLength)
-	if FileRangeNotDelete < 8*1024*1024 {
-		FileRangeNotDelete = 8 * 1024 * 1024
+	if FileRangeNotDelete < 8<<20 {
+		FileRangeNotDelete = 8 << 20
 	}
 
 	for _, rng := range ranges {
@@ -316,14 +315,15 @@ func (c *Cache) NewReader(file *torrent.File) *Reader {
 }
 
 func (c *Cache) Readers() int {
-	if c == nil {
+	// TODO проверить
+	// if c == nil {
+	// 	return 0
+	// }
+	if c == nil || c.readers == nil {
 		return 0
 	}
 	c.muReaders.Lock()
 	defer c.muReaders.Unlock()
-	if c == nil || c.readers == nil {
-		return 0
-	}
 	return len(c.readers)
 }
 

server/torr/storage/torrstor/reader.go

@@ -25,7 +25,6 @@ type Reader struct {
 	lastAccess int64
 	isUse      bool
 	mu         sync.Mutex
-	ranges     Range
 }
 
 func newReader(file *torrent.File, cache *Cache) *Reader {