piecedownloader

Documentation

Index

• type PieceDownloader
  • func New(pi *piece.Piece, pe *peer.Peer, 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)
  • func (d *PieceDownloader) Rejected(block *piece.Block)
  • func (d *PieceDownloader) RequestBlocks(queueLength int)

Types

type PieceDownloader

type PieceDownloader struct {
	Piece  *piece.Piece
	Peer   *peer.Peer
	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.Peer, 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)

func (*PieceDownloader) Rejected

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

func (*PieceDownloader) RequestBlocks

func (d *PieceDownloader) RequestBlocks(queueLength int)