From 43b6d67522311c6842a12782c7ea8e72b715b276 Mon Sep 17 00:00:00 2001 From: nikk gitanes Date: Sun, 9 Apr 2023 11:10:27 +0300 Subject: [PATCH] cosmetics --- server/torr/preload.go | 4 ++-- server/torr/storage/torrstor/cache.go | 16 ++++++++-------- server/torr/storage/torrstor/reader.go | 1 - 3 files changed, 10 insertions(+), 11 deletions(-) diff --git a/server/torr/preload.go b/server/torr/preload.go index 62f1c3c..6e9dadf 100644 --- a/server/torr/preload.go +++ b/server/torr/preload.go @@ -84,8 +84,8 @@ func (t *Torrent) Preload(index int, size int64) { // startend -> 8/16 MB startend := t.Info().PieceLength - if startend < 8*1024*1024 { - startend = 8 * 1024 * 1024 + if startend < 8<<20 { + startend = 8 << 20 } readerStart := file.NewReader() diff --git a/server/torr/storage/torrstor/cache.go b/server/torr/storage/torrstor/cache.go index 54873dc..eabcad7 100644 --- a/server/torr/storage/torrstor/cache.go +++ b/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) } diff --git a/server/torr/storage/torrstor/reader.go b/server/torr/storage/torrstor/reader.go index ffb2cf6..79f5770 100644 --- a/server/torr/storage/torrstor/reader.go +++ b/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 {