PieceLength: pieceLength,
Length: pieceLength * numPieces,
}))
+ t.onSetInfo()
assert.EqualValues(b, 13410, t.numPieces())
for i := 0; i < 7; i += 1 {
r := t.NewReader()
}
t.DownloadPieces(0, t.numPieces())
for i := 0; i < b.N; i += 1 {
- t.updateAllPiecePriorities()
+ t.updateAllPiecePriorities("")
}
}
defer tt.Drop()
tt.DownloadAll()
require.True(t, cl.WaitAll())
+ assert.True(t, tt.Complete.Bool())
assert.True(t, missinggo.FilePathExists(fp))
}
func TestPieceHashFailed(t *testing.T) {
mi := testutil.GreetingMetaInfo()
- cl := new(Client)
- cl.config = TestingConfig(t)
- cl.initLogger()
+ cl := newTestingClient(t)
tt := cl.newTorrent(mi.HashInfoBytes(), badStorage{})
tt.setChunkSize(2)
require.NoError(t, tt.setInfoBytesLocked(mi.InfoBytes))
func TestTorrentMetainfoIncompleteMetadata(t *testing.T) {
cfg := TestingConfig(t)
cfg.Debug = true
+ // Disable this just because we manually initiate a connection without it.
+ cfg.MinPeerExtensions.SetBit(pp.ExtensionBitFast, false)
cl, err := NewClient(cfg)
require.NoError(t, err)
defer cl.Close()