"fmt"
"io"
"io/ioutil"
- "log"
"os"
"path/filepath"
"reflect"
LeecherDownloadRateLimiter *rate.Limiter
}
-func logPieceStateChanges(t *Torrent) {
- sub := t.SubscribePieceStateChanges()
- go func() {
- defer sub.Close()
- for e := range sub.Values {
- log.Printf("%p %#v", t, e)
- }
- }()
-}
-
// Creates a seeder and a leecher, and ensures the data transfers when a read
// is attempted on the leecher.
func testClientTransfer(t *testing.T, ps testClientTransferParams) {
assert.True(t, new)
require.True(t, cl.WaitAll())
tor.Drop()
- tor, new, err = cl.AddTorrentSpec(TorrentSpecFromMetaInfo(mi))
+ _, new, err = cl.AddTorrentSpec(TorrentSpecFromMetaInfo(mi))
require.NoError(t, err)
assert.True(t, new)
require.True(t, cl.WaitAll())