request_strategy

Documentation

Index

• func GetRequestablePieces(input Input, pro *PieceRequestOrder, f func(ih metainfo.Hash, pieceIndex int))
• type ChunkIndex
• type ChunkSpec
• type ChunksIter
• type ChunksIterFunc
• type Input
• type PeerRequestState
• type Piece
• type PieceRequestOrder
  • func NewPieceOrder() *PieceRequestOrder
  • func (me *PieceRequestOrder) Add(key PieceRequestOrderKey, state PieceRequestOrderState)
  • func (me *PieceRequestOrder) Delete(key PieceRequestOrderKey)
  • func (me *PieceRequestOrder) Len() int
  • func (me *PieceRequestOrder) Update(key PieceRequestOrderKey, state PieceRequestOrderState)
• type PieceRequestOrderKey
• type PieceRequestOrderState
• type Request
• type RequestIndex
• type Torrent

Functions

func GetRequestablePieces

func GetRequestablePieces(input Input, pro *PieceRequestOrder, f func(ih metainfo.Hash, pieceIndex int))

Calls f with requestable pieces in order.

Types

type ChunkIndex

type ChunkIndex = uint32

type ChunkSpec

type ChunkSpec = types.ChunkSpec

This can be made into a type-param later, will be great for testing.

type ChunksIter

type ChunksIter interface {
	Iter(func(ci ChunkIndex))
}

type ChunksIterFunc

type ChunksIterFunc func(func(ChunkIndex))

type Input

type Input interface {
	Torrent(metainfo.Hash) Torrent
	// Storage capacity, shared among all Torrents with the same storage.TorrentCapacity pointer in
	// their storage.Torrent references.
	Capacity() (cap int64, capped bool)
	// Across all the Torrents. This might be partitioned by storage capacity key now.
	MaxUnverifiedBytes() int64
}

type PeerRequestState

type PeerRequestState struct {
	Interested bool
	// Expecting
	Requests roaring.Bitmap
	// Cancelled and waiting response
	Cancelled roaring.Bitmap
}

type Piece

type Piece interface {
	Request() bool
	NumPendingChunks() int
}

type PieceRequestOrder

type PieceRequestOrder struct {
	// contains filtered or unexported fields
}

func NewPieceOrder

func NewPieceOrder() *PieceRequestOrder

func (*PieceRequestOrder) Add

func (me *PieceRequestOrder) Add(key PieceRequestOrderKey, state PieceRequestOrderState)

func (*PieceRequestOrder) Delete

func (me *PieceRequestOrder) Delete(key PieceRequestOrderKey)

func (*PieceRequestOrder) Len

func (me *PieceRequestOrder) Len() int

func (*PieceRequestOrder) Update

func (me *PieceRequestOrder) Update(key PieceRequestOrderKey, state PieceRequestOrderState)

type PieceRequestOrderKey

type PieceRequestOrderKey struct {
	InfoHash metainfo.Hash
	Index    int
}

type PieceRequestOrderState

type PieceRequestOrderState struct {
	Priority     piecePriority
	Partial      bool
	Availability int64
}

type Request

type Request = types.Request

type RequestIndex

type RequestIndex = uint32

type Torrent

type Torrent interface {
	Piece(int) Piece
	ChunksPerPiece() uint32
	PieceLength() int64
}