)
func (t *Torrent) updatePieceRequestOrder(pieceIndex int) {
+ if t.storage == nil {
+ return
+ }
t.cl.pieceRequestOrder[t.clientPieceRequestOrderKey()].Update(
t.pieceRequestOrderKey(pieceIndex),
t.requestStrategyPieceOrderState(pieceIndex))
}
func (t *Torrent) deletePieceRequestOrder() {
+ if t.storage == nil {
+ return
+ }
cpro := t.cl.pieceRequestOrder
key := t.clientPieceRequestOrderKey()
pro := cpro[key]
}
func (t *Torrent) initPieceRequestOrder() {
+ if t.storage == nil {
+ return
+ }
if t.cl.pieceRequestOrder == nil {
t.cl.pieceRequestOrder = make(map[interface{}]*request_strategy.PieceRequestOrder)
}
}
func (t *Torrent) addRequestOrderPiece(i int) {
+ if t.storage == nil {
+ return
+ }
t.cl.pieceRequestOrder[t.clientPieceRequestOrderKey()].Add(
t.pieceRequestOrderKey(i),
t.requestStrategyPieceOrderState(i))
}
func (t *Torrent) pieceCompleteUncached(piece pieceIndex) storage.Completion {
+ if t.storage == nil {
+ return storage.Completion{Complete: false, Ok: true}
+ }
return t.pieces[piece].Storage().Completion()
}
PieceLength: pieceLength,
Length: pieceLength * numPieces,
}))
+ t.onSetInfo()
assert.EqualValues(b, 13410, t.numPieces())
for i := 0; i < 7; i += 1 {
r := t.NewReader()