p2p

Documentation

Index

• Constants
• func AttemptDownloadPiece(c *client.Client, pw *pieceWork) ([]byte, error)
• func CheckIntegrity(pw *pieceWork, buffer []byte) error
• type Torrent
  • func (t *Torrent) CalculatePieceBounds(index int) (begin int, end int)
  • func (t *Torrent) CalculatePieceSize(index int) int
  • func (t *Torrent) Download() ([]byte, error)
  • func (t *Torrent) StartDownloadWorker(peer peers.Peer, workQueue chan *pieceWork, results chan *pieceResult)

Constants

const MaxRequestBlockSize = 2 << 13

const MaxUnfulfilledRequestBacklog = 5

Functions

func AttemptDownloadPiece

func AttemptDownloadPiece(c *client.Client, pw *pieceWork) ([]byte, error)

func CheckIntegrity

func CheckIntegrity(pw *pieceWork, buffer []byte) error

检查完整性，即 check sum

Types

type Torrent

type Torrent struct {
	Peers       []peers.Peer
	PeerID      [20]byte
	InfoHash    [20]byte
	PieceHashes [][20]byte
	PieceLength int
	Length      int
	Name        string
}

func (*Torrent) CalculatePieceBounds

func (t *Torrent) CalculatePieceBounds(index int) (begin int, end int)

func (*Torrent) CalculatePieceSize

func (t *Torrent) CalculatePieceSize(index int) int

func (*Torrent) Download

func (t *Torrent) Download() ([]byte, error)

下载整个 file ，数据存储在内存中

func (*Torrent) StartDownloadWorker

func (t *Torrent) StartDownloadWorker(
	peer peers.Peer,
	workQueue chan *pieceWork,
	results chan *pieceResult,
)