disableTCP: cfg.DisableTCP,
_configDir: cfg.ConfigDir,
config: *cfg,
- torrentDataOpener: func(md *metainfo.Info) (TorrentData, error) {
+ torrentDataOpener: func(md *metainfo.Info) (Data, error) {
return filePkg.TorrentData(md, cfg.DataDir), nil
},
}
// Storage cannot be changed once it's set.
-func (cl *Client) setStorage(t *torrent, td TorrentData) (err error) {
+func (cl *Client) setStorage(t *torrent, td Data) (err error) {
err = t.setStorage(td)
cl.event.Broadcast()
if err != nil {
return
}
-type TorrentDataOpener func(*metainfo.Info) (TorrentData, error)
+type TorrentDataOpener func(*metainfo.Info) (Data, error)
func (cl *Client) setMetaData(t *torrent, md metainfo.Info, bytes []byte) (err error) {
err = t.setMetadata(md, bytes, &cl.mu)
NoDefaultBlocklist: true,
- TorrentDataOpener: func(info *metainfo.Info) (torrent.TorrentData, error) {
+ TorrentDataOpener: func(info *metainfo.Info) (torrent.Data, error) {
return mmap.TorrentData(info, filepath.Join(layout.BaseDir, "download"))
},
Port int
}
-type TorrentData interface {
+type Data interface {
ReadAt(p []byte, off int64) (n int, err error)
Close()
WriteAt(p []byte, off int64) (n int, err error)
Pieces []*piece
length int64
- data TorrentData
+ data Data
Info *metainfo.Info
// Active peer connections.
return
}
-func (t *torrent) setStorage(td TorrentData) (err error) {
+func (t *torrent) setStorage(td Data) (err error) {
if t.data != nil {
t.data.Close()
}