// through legitimate channels.
dopplegangerAddrs map[string]struct{}
- defaultStorage storage.I
+ defaultStorage storage.Client
mu sync.RWMutex
event sync.Cond
// The chunk size to use for outbound requests. Defaults to 16KiB if not
// set.
ChunkSize int
- Storage storage.I
+ Storage storage.Client
}
func TorrentSpecFromMagnetURI(uri string) (spec *TorrentSpec, err error) {
})
}
-func fileCachePieceResourceStorage(fc *filecache.Cache) storage.I {
+func fileCachePieceResourceStorage(fc *filecache.Cache) storage.Client {
return storage.NewPiecePerResource(fc.AsResourceProvider())
}
-func fileCachePieceFileStorage(fc *filecache.Cache) storage.I {
+func fileCachePieceFileStorage(fc *filecache.Cache) storage.Client {
return storage.NewPieceFileStorage(fc.AsFileStore())
}
}
func TestClientTransferVarious(t *testing.T) {
- for _, lsf := range []func(*filecache.Cache) storage.I{
+ for _, lsf := range []func(*filecache.Cache) storage.Client{
fileCachePieceFileStorage,
fileCachePieceResourceStorage,
} {
- for _, ss := range []func(string) storage.I{
+ for _, ss := range []func(string) storage.Client{
storage.NewFile,
storage.NewMMap,
} {
ExportClientStatus bool
SetLeecherStorageCapacity bool
LeecherStorageCapacity int64
- LeecherFileCachePieceStorageFactory func(*filecache.Cache) storage.I
- SeederStorage func(string) storage.I
+ LeecherFileCachePieceStorageFactory func(*filecache.Cache) storage.Client
+ SeederStorage func(string) storage.Client
}
func testClientTransfer(t *testing.T, ps testClientTransferParams) {
}
}
-func testAddTorrentPriorPieceCompletion(t *testing.T, alreadyCompleted bool, csf func(*filecache.Cache) storage.I) {
+func testAddTorrentPriorPieceCompletion(t *testing.T, alreadyCompleted bool, csf func(*filecache.Cache) storage.Client) {
fileCacheDir, err := ioutil.TempDir("", "")
require.NoError(t, err)
defer os.RemoveAll(fileCacheDir)
DisableTCP bool `long:"disable-tcp"`
// Called to instantiate storage for each added torrent. Provided backends
// are in $REPO/data. If not set, the "file" implementation is used.
- DefaultStorage storage.I
+ DefaultStorage storage.Client
DisableEncryption bool `long:"disable-encryption"`
IPBlocklist iplist.Ranger