From dd26ff3d5f762a946fe3bafef9ea3ae6d47526cf Mon Sep 17 00:00:00 2001 From: yourok <8yourok8@mail.ru> Date: Sun, 27 Aug 2023 21:46:20 +0300 Subject: [PATCH] fix nil piece --- server/torr/storage/torrstor/cache.go | 2 +- server/torr/storage/torrstor/piecefake.go | 33 +++++++++++++++++++++++ 2 files changed, 34 insertions(+), 1 deletion(-) create mode 100644 server/torr/storage/torrstor/piecefake.go diff --git a/server/torr/storage/torrstor/cache.go b/server/torr/storage/torrstor/cache.go index 3074b31..efe861d 100644 --- a/server/torr/storage/torrstor/cache.go +++ b/server/torr/storage/torrstor/cache.go @@ -83,7 +83,7 @@ func (c *Cache) Piece(m metainfo.Piece) storage.PieceImpl { if val, ok := c.pieces[m.Index()]; ok { return val } - return nil + return &PieceFake{} } func (c *Cache) Close() error { diff --git a/server/torr/storage/torrstor/piecefake.go b/server/torr/storage/torrstor/piecefake.go new file mode 100644 index 0000000..6434bb2 --- /dev/null +++ b/server/torr/storage/torrstor/piecefake.go @@ -0,0 +1,33 @@ +package torrstor + +import ( + "errors" + "github.com/anacrolix/torrent/storage" +) + +type PieceFake struct{} + +func (PieceFake) ReadAt(p []byte, off int64) (n int, err error) { + err = errors.New("fake") + return +} + +func (PieceFake) WriteAt(p []byte, off int64) (n int, err error) { + err = errors.New("fake") + return +} + +func (PieceFake) MarkComplete() error { + return errors.New("fake") +} + +func (PieceFake) MarkNotComplete() error { + return errors.New("fake") +} + +func (PieceFake) Completion() storage.Completion { + return storage.Completion{ + Complete: false, + Ok: true, + } +}