if _, ok := c.validReceiveChunks[req]; !ok {
torrent.Add("chunks received unexpected", 1)
- return errors.New("received unexpected chunk")
+ //return errors.New("received unexpected chunk")
}
delete(c.validReceiveChunks, req)
import (
"errors"
- "log"
"os"
"sync"
"testing"
+ "github.com/anacrolix/log"
+
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
seederClientConfig.Debug = true
seederClient, err := torrent.NewClient(seederClientConfig)
require.NoError(t, err)
+ defer seederClient.Close()
defer testutil.ExportStatusWriter(seederClient, "s")()
leecherClientConfig := torrent.TestingConfig()
leecherClientConfig.Debug = true
justOneNetwork(leecherClientConfig)
leecherClient, err := torrent.NewClient(leecherClientConfig)
require.NoError(t, err)
+ defer leecherClient.Close()
defer testutil.ExportStatusWriter(leecherClient, "l")()
info, err := metainfo.UnmarshalInfo()
require.NoError(t, err)