filepiece

type PieceStore ¶

type PieceStore struct {
	*sync.RWMutex

	Overall *TorrentStore
	Hash    metainfo.Hash
	Length  int64
	// contains filtered or unexported fields
}

func (ps *PieceStore) Completion() storage.Completion

func (ps *PieceStore) MarkComplete() error

func (ps *PieceStore) MarkNotComplete() error

func (ps *PieceStore) ReadAt(b []byte, n int64) (int, error)

func (ps *PieceStore) WriteAt(b []byte, off int64) (int, error)

type Store ¶

type Store struct {
	ParentDir string
}

Store implements the ClientImpl interface of package anacrolix/torrent/storage. It abstracts a parent directory with a subdirectory for each TorrentStore

func NewStore(datadir string) (*Store, error)

func (f *Store) Close() error

func (f *Store) OpenTorrent(info *metainfo.Info, infoHash metainfo.Hash) (storage.TorrentImpl, error)

type TorrentStore ¶

type TorrentStore struct {
	sync.RWMutex

	DataDir string
	// contains filtered or unexported fields
}

TorrentStore implements the TorrentImpl interface of package anacrolix/torrent/storage. It stores torrent pieces as individual files in a directory named by the torrent hash.

func NewTorrentStore(parentDir string, infoHashStr string) (*TorrentStore, error)

func (f *TorrentStore) Close() error

func (f *TorrentStore) NewPieceStoreHashLen(hash metainfo.Hash, leng int64) *PieceStore

func (f *TorrentStore) Piece(pmi metainfo.Piece) storage.PieceImpl