status-im/torrent
2
0
Fork 0
mirror of synced 2025-02-24 14:48:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

Changes to missinggo resource package

Browse Source
This commit is contained in:
Matt Joiner 2016-05-16 22:32:00 +10:00
parent c1e0d37266
commit 869fb25cbc
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
storage/piece_resource.go
View File

@ -5,16 +5,16 @@ import (
"path" "path"
"github.com/anacrolix/missinggo" "github.com/anacrolix/missinggo"
"github.com/anacrolix/missinggo/uniform" "github.com/anacrolix/missinggo/resource"
"github.com/anacrolix/torrent/metainfo" "github.com/anacrolix/torrent/metainfo"
) )
type piecePerResource struct { type piecePerResource struct {
p uniform.Provider p resource.Provider
} }
func NewResourcePieces(p uniform.Provider) Client { func NewResourcePieces(p resource.Provider) Client {
return &piecePerResource{ return &piecePerResource{
p: p, p: p,
} }
@ -29,11 +29,11 @@ func (s *piecePerResource) Close() error {
} }
func (s *piecePerResource) Piece(p metainfo.Piece) Piece { func (s *piecePerResource) Piece(p metainfo.Piece) Piece {
completed, err := s.p.NewResource(path.Join("completed", p.Hash().HexString())) completed, err := s.p.NewInstance(path.Join("completed", p.Hash().HexString()))
if err != nil { if err != nil {
panic(err) panic(err)
} }
incomplete, err := s.p.NewResource(path.Join("incomplete", p.Hash().HexString())) incomplete, err := s.p.NewInstance(path.Join("incomplete", p.Hash().HexString()))
if err != nil { if err != nil {
panic(err) panic(err)
} }
@ -46,8 +46,8 @@ func (s *piecePerResource) Piece(p metainfo.Piece) Piece {
type piecePerResourcePiece struct { type piecePerResourcePiece struct {
p metainfo.Piece p metainfo.Piece
c uniform.Resource c resource.Instance
i uniform.Resource i resource.Instance
} }
func (s piecePerResourcePiece) GetIsComplete() bool { func (s piecePerResourcePiece) GetIsComplete() bool {
@ -56,7 +56,7 @@ func (s piecePerResourcePiece) GetIsComplete() bool {
} }
func (s piecePerResourcePiece) MarkComplete() error { func (s piecePerResourcePiece) MarkComplete() error {
return uniform.Move(s.i, s.c) return resource.Move(s.i, s.c)
} }
func (s piecePerResourcePiece) ReadAt(b []byte, off int64) (n int, err error) { func (s piecePerResourcePiece) ReadAt(b []byte, off int64) (n int, err error) {