From d201842e730b02d76b36c3cd7ec431f29dc17551 Mon Sep 17 00:00:00 2001 From: YouROK <8yourok8@mail.ru> Date: Mon, 29 Mar 2021 15:06:56 +0300 Subject: [PATCH] remove mutex --- server/torr/storage/torrstor/piece.go | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/server/torr/storage/torrstor/piece.go b/server/torr/storage/torrstor/piece.go index f5ce3d7..68fa28d 100644 --- a/server/torr/storage/torrstor/piece.go +++ b/server/torr/storage/torrstor/piece.go @@ -3,7 +3,6 @@ package torrstor import ( "errors" "io" - "sync" "time" "github.com/anacrolix/torrent" @@ -20,14 +19,10 @@ type Piece struct { accessed int64 buffer []byte - mu sync.RWMutex cache *Cache } func (p *Piece) WriteAt(b []byte, off int64) (n int, err error) { - p.mu.Lock() - defer p.mu.Unlock() - if p.buffer == nil { go p.cache.cleanPieces() p.buffer = make([]byte, p.cache.pieceLength, p.cache.pieceLength) @@ -39,9 +34,6 @@ func (p *Piece) WriteAt(b []byte, off int64) (n int, err error) { } func (p *Piece) ReadAt(b []byte, off int64) (n int, err error) { - p.mu.RLock() - defer p.mu.RUnlock() - size := len(b) if size+int(off) > len(p.buffer) { size = len(p.buffer) - int(off) @@ -84,8 +76,6 @@ func (p *Piece) Completion() storage.Completion { } func (p *Piece) Release() { - p.mu.Lock() - defer p.mu.Unlock() if p.buffer != nil { p.buffer = nil }