"encoding/binary"
"fmt"
"io"
- "io/ioutil"
"os"
"path/filepath"
"reflect"
defer seeder.Close()
seederTorrent, _, _ := seeder.AddTorrentSpec(TorrentSpecFromMetaInfo(mi))
seederTorrent.VerifyData()
- leecherDataDir, err := ioutil.TempDir("", "")
- require.Nil(t, err)
- defer os.RemoveAll(leecherDataDir)
+ leecherDataDir := t.TempDir()
cfg = TestingConfig(t)
cfg.DataDir = leecherDataDir
leecher, err := NewClient(cfg)
defer seeder.Close()
seederTorrent, _, _ := seeder.AddTorrentSpec(TorrentSpecFromMetaInfo(mi))
seederTorrent.VerifyData()
- leecherDataDir, err := ioutil.TempDir("", "")
- require.Nil(t, err)
- defer os.RemoveAll(leecherDataDir)
+ leecherDataDir := t.TempDir()
cfg = TestingConfig(t)
cfg.DataDir = leecherDataDir
leecher, err := NewClient(cfg)
}
func testAddTorrentPriorPieceCompletion(t *testing.T, alreadyCompleted bool, csf func(*filecache.Cache) storage.ClientImpl) {
- fileCacheDir, err := ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(fileCacheDir)
+ fileCacheDir := t.TempDir()
fileCache, err := filecache.NewCache(fileCacheDir)
require.NoError(t, err)
greetingDataTempDir, greetingMetainfo := testutil.GreetingTestTorrent()
defer testutil.ExportStatusWriter(seeder, "s", t)()
seederTorrent, _, _ := seeder.AddTorrentSpec(TorrentSpecFromMetaInfo(mi))
seederTorrent.VerifyData()
- leecherDataDir, err := ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(leecherDataDir)
+ leecherDataDir := t.TempDir()
fc, err := filecache.NewCache(leecherDataDir)
require.NoError(t, err)
if ps.SetLeecherStorageCapacity {
return os.RemoveAll(tl.BaseDir)
}
-func newGreetingLayout() (tl testLayout, err error) {
- tl.BaseDir, err = ioutil.TempDir("", "torrentfs")
- if err != nil {
- return
- }
+func newGreetingLayout(t *testing.T) (tl testLayout, err error) {
+ tl.BaseDir = t.TempDir()
tl.Completed = filepath.Join(tl.BaseDir, "completed")
os.Mkdir(tl.Completed, 0o777)
tl.MountDir = filepath.Join(tl.BaseDir, "mnt")
// Unmount without first killing the FUSE connection while there are FUSE
// operations blocked inside the filesystem code.
func TestUnmountWedged(t *testing.T) {
- layout, err := newGreetingLayout()
+ layout, err := newGreetingLayout(t)
require.NoError(t, err)
defer func() {
err := layout.Destroy()
}
func TestDownloadOnDemand(t *testing.T) {
- layout, err := newGreetingLayout()
+ layout, err := newGreetingLayout(t)
require.NoError(t, err)
defer layout.Destroy()
cfg := torrent.NewDefaultClientConfig()
package torrent
import (
- "io/ioutil"
- "os"
"testing"
"github.com/anacrolix/log"
)
func TestHashPieceAfterStorageClosed(t *testing.T) {
- td, err := ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(td)
+ td := t.TempDir()
tt := &Torrent{
storageOpener: storage.NewClient(storage.NewFile(td)),
logger: log.Default,
}
func TestBuildFromFilePathOrder(t *testing.T) {
- td, err := ioutil.TempDir("", "anacrolix")
- require.NoError(t, err)
- defer os.RemoveAll(td)
+ td := t.TempDir()
require.NoError(t, touchFile(filepath.Join(td, "b")))
require.NoError(t, touchFile(filepath.Join(td, "a")))
info := Info{
package storage
import (
- "io/ioutil"
- "os"
"testing"
"github.com/stretchr/testify/assert"
)
func TestBoltPieceCompletion(t *testing.T) {
- td, err := ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(td)
+ td := t.TempDir()
pc, err := NewBoltPieceCompletion(td)
require.NoError(t, err)
import (
"bytes"
"io"
- "io/ioutil"
"os"
"path/filepath"
"testing"
)
func TestShortFile(t *testing.T) {
- td, err := ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(td)
+ td := t.TempDir()
s := NewFile(td)
info := &metainfo.Info{
Name: "a",
package storage
import (
- "io/ioutil"
- "os"
"testing"
"github.com/anacrolix/missinggo/v2/resource"
}
func TestIssue95File(t *testing.T) {
- td, err := ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(td)
+ td := t.TempDir()
testIssue95(t, NewFile(td))
}
func TestIssue95MMap(t *testing.T) {
- td, err := ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(td)
+ td := t.TempDir()
testIssue95(t, NewMMap(td))
}
func TestIssue95ResourcePieces(t *testing.T) {
- td, err := ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(td)
testIssue95(t, NewResourcePieces(resource.OSFileProvider{}))
}
package storage
import (
- "io/ioutil"
- "os"
"testing"
"github.com/stretchr/testify/require"
)
func testMarkedCompleteMissingOnRead(t *testing.T, csf func(string) ClientImplCloser) {
- td, err := ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(td)
+ td := t.TempDir()
cs := NewClient(csf(td))
info := &metainfo.Info{
PieceLength: 1,
cfg = torrent.TestingConfig(t)
cfg.Seed = true
- cfg.DataDir, err = ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(cfg.DataDir)
+ cfg.DataDir = t.TempDir()
leecher, err := torrent.NewClient(cfg)
require.NoError(t, err)
defer leecher.Close()
cfg = torrent.TestingConfig(t)
cfg.Seed = false
- cfg.DataDir, err = ioutil.TempDir("", "")
- require.NoError(t, err)
- defer os.RemoveAll(cfg.DataDir)
+ cfg.DataDir = t.TempDir()
leecherLeecher, _ := torrent.NewClient(cfg)
require.NoError(t, err)
defer leecherLeecher.Close()
package dirwatch
import (
- "io/ioutil"
- "os"
"testing"
"github.com/stretchr/testify/require"
)
func TestDirwatch(t *testing.T) {
- tempDirName, err := ioutil.TempDir("", "")
- if err != nil {
- t.Fatal(err)
- }
- defer os.RemoveAll(tempDirName)
+ tempDirName := t.TempDir()
t.Logf("tempdir: %q", tempDirName)
dw, err := New(tempDirName)
require.NoError(t, err)