15 fusefs "bazil.org/fuse/fs"
16 _ "github.com/anacrolix/envpprof"
17 "github.com/anacrolix/missinggo"
18 "github.com/stretchr/testify/assert"
19 "github.com/stretchr/testify/require"
20 netContext "golang.org/x/net/context"
22 "github.com/anacrolix/torrent"
23 "github.com/anacrolix/torrent/internal/testutil"
24 "github.com/anacrolix/torrent/metainfo"
25 "github.com/anacrolix/torrent/storage"
29 log.SetFlags(log.Flags() | log.Lshortfile)
32 func TestTCPAddrString(t *testing.T) {
33 l, err := net.Listen("tcp4", "localhost:0")
38 c, err := net.Dial("tcp", l.Addr().String())
43 ras := c.RemoteAddr().String()
45 IP: net.IPv4(127, 0, 0, 1),
46 Port: missinggo.AddrPort(l.Addr()),
54 type testLayout struct {
58 Metainfo *metainfo.MetaInfo
61 func (tl *testLayout) Destroy() error {
62 return os.RemoveAll(tl.BaseDir)
65 func newGreetingLayout() (tl testLayout, err error) {
66 tl.BaseDir, err = ioutil.TempDir("", "torrentfs")
70 tl.Completed = filepath.Join(tl.BaseDir, "completed")
71 os.Mkdir(tl.Completed, 0777)
72 tl.MountDir = filepath.Join(tl.BaseDir, "mnt")
73 os.Mkdir(tl.MountDir, 0777)
74 testutil.CreateDummyTorrentData(tl.Completed)
75 tl.Metainfo = testutil.GreetingMetaInfo()
79 // Unmount without first killing the FUSE connection while there are FUSE
80 // operations blocked inside the filesystem code.
81 func TestUnmountWedged(t *testing.T) {
82 layout, err := newGreetingLayout()
83 require.NoError(t, err)
85 err := layout.Destroy()
90 client, err := torrent.NewClient(&torrent.Config{
91 DataDir: filepath.Join(layout.BaseDir, "incomplete"),
92 DisableTrackers: true,
97 require.NoError(t, err)
99 tt, err := client.AddTorrent(layout.Metainfo)
100 require.NoError(t, err)
102 fuseConn, err := fuse.Mount(layout.MountDir)
105 case "cannot locate OSXFUSE",
106 "fusermount: exit status 1":
112 server := fusefs.New(fuseConn, &fusefs.Config{
113 Debug: func(msg interface{}) {
120 if err := fuseConn.MountError; err != nil {
121 t.Fatalf("mount error: %s", err)
123 // Read the greeting file, though it will never be available. This should
124 // "wedge" FUSE, requiring the fs object to be forcibly destroyed. The
125 // read call will return with a FS error.
127 _, err := ioutil.ReadFile(filepath.Join(layout.MountDir, tt.Info().Name))
129 t.Fatal("expected error reading greeting")
133 // Wait until the read has blocked inside the filesystem code.
135 for fs.blockedReads != 1 {
143 err = fuse.Unmount(layout.MountDir)
145 t.Logf("error unmounting: %s", err)
146 time.Sleep(time.Millisecond)
152 err = fuseConn.Close()
154 t.Fatalf("error closing fuse conn: %s", err)
158 func TestDownloadOnDemand(t *testing.T) {
159 layout, err := newGreetingLayout()
160 require.NoError(t, err)
161 defer layout.Destroy()
162 seeder, err := torrent.NewClient(&torrent.Config{
163 DataDir: layout.Completed,
164 DisableTrackers: true,
166 ListenAddr: "localhost:0",
169 require.NoError(t, err)
171 testutil.ExportStatusWriter(seeder, "s")
172 _, err = seeder.AddMagnet(fmt.Sprintf("magnet:?xt=urn:btih:%s", layout.Metainfo.HashInfoBytes().HexString()))
173 require.NoError(t, err)
174 leecher, err := torrent.NewClient(&torrent.Config{
175 DisableTrackers: true,
177 ListenAddr: "localhost:0",
179 DefaultStorage: storage.NewMMap(filepath.Join(layout.BaseDir, "download")),
180 // This can be used to check if clients can connect to other clients
182 // PeerID: seeder.PeerID(),
184 require.NoError(t, err)
185 testutil.ExportStatusWriter(leecher, "l")
186 defer leecher.Close()
187 leecherTorrent, _ := leecher.AddTorrent(layout.Metainfo)
188 leecherTorrent.AddPeers([]torrent.Peer{
190 IP: missinggo.AddrIP(seeder.ListenAddr()),
191 Port: missinggo.AddrPort(seeder.ListenAddr()),
197 node, _ := root.(fusefs.NodeStringLookuper).Lookup(netContext.Background(), "greeting")
199 node.Attr(netContext.Background(), &attr)
201 resp := &fuse.ReadResponse{
202 Data: make([]byte, size),
204 node.(fusefs.HandleReader).Read(netContext.Background(), &fuse.ReadRequest{
207 assert.EqualValues(t, testutil.GreetingFileContents, resp.Data)
210 func TestIsSubPath(t *testing.T) {
211 for _, case_ := range []struct {
218 {"a/b", "a/bc", false},
219 {"a/b", "a/b", false},
220 {"a/b", "a/b/c", true},
221 {"a/b", "a//b", false},
223 assert.Equal(t, case_.is, isSubPath(case_.parent, case_.child))