"path/filepath"
"time"
- _ "github.com/anacrolix/envpprof"
+ "github.com/anacrolix/envpprof"
"github.com/anacrolix/log"
"github.com/anacrolix/sync"
"github.com/dustin/go-humanize"
"github.com/anacrolix/torrent"
"github.com/anacrolix/torrent/bencode"
"github.com/anacrolix/torrent/metainfo"
+ "github.com/anacrolix/torrent/storage"
)
func assertNil(x any) {
}
func main() {
+ defer envpprof.Stop()
tmpDir, err := os.MkdirTemp("", "peers-bootstrapping")
assertNil(err)
slog.Info("made temp dir", slog.String("tmpDir", tmpDir))
var clients []*torrent.Client
var torrents []*torrent.Torrent
clientConfig := newClientConfig()
- clientConfig.DataDir = sourceDir
+ clientConfig.DefaultStorage = storage.NewMMap(sourceDir)
initialClient, err := torrent.NewClient(clientConfig)
assertNil(err)
clientIndex := 0
clientIndex := clientIndex
storageDir := filepath.Join(tmpDir, fmt.Sprintf("client%v", clientIndex))
clientConfig := newClientConfig()
- clientConfig.DataDir = storageDir
+ clientConfig.DefaultStorage = storage.NewMMap(storageDir)
clientConfig.Logger = log.Default.WithValues(slog.Int("clientIndex", clientIndex))
//clientConfig.Logger.Levelf(log.Critical, "test")
client, err := torrent.NewClient(clientConfig)
humanize.Bytes(uint64(read.Int64())),
)
}
+ assertNil(os.RemoveAll(tmpDir))
}