piecedownloader

Documentation

Index

• Variables
• type Peer
• type PieceDownloader
  • func New(pi *piece.Piece, pe Peer, allowedFast bool, buf bufferpool.Buffer) *PieceDownloader
  • func (d *PieceDownloader) CancelPending()
  • func (d *PieceDownloader) Choked()
  • func (d *PieceDownloader) Done() bool
  • func (d *PieceDownloader) GotBlock(block piece.Block, data []byte) error
  • func (d *PieceDownloader) Rejected(block piece.Block)
  • func (d *PieceDownloader) RequestBlocks(queueLength int)

Variables

var (
	ErrBlockDuplicate    = errors.New("received duplicate block")
	ErrBlockNotRequested = errors.New("received not requested block")
)

Types

type Peer

type Peer interface {
	RequestPiece(index, begin, length uint32)
	CancelPiece(index, begin, length uint32)
}

type PieceDownloader

type PieceDownloader struct {
	Piece       *piece.Piece
	Peer        Peer
	AllowedFast bool
	Buffer      bufferpool.Buffer
	// contains filtered or unexported fields
}

PieceDownloader downloads all blocks of a piece from a peer.

func New

func New(pi *piece.Piece, pe Peer, allowedFast bool, buf bufferpool.Buffer) *PieceDownloader

func (*PieceDownloader) CancelPending

func (d *PieceDownloader) CancelPending()

func (*PieceDownloader) Choked

func (d *PieceDownloader) Choked()

func (*PieceDownloader) Done

func (d *PieceDownloader) Done() bool

func (*PieceDownloader) GotBlock

func (d *PieceDownloader) GotBlock(block piece.Block, data []byte) error

func (*PieceDownloader) Rejected

func (d *PieceDownloader) Rejected(block piece.Block)

func (*PieceDownloader) RequestBlocks

func (d *PieceDownloader) RequestBlocks(queueLength int)