status-im
/
torrent
mirror of
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add AddTorrentOpts.InfoBytes

This commit is contained in:
Matt Joiner 2023-04-04 19:12:01 +10:00
parent 8d3e86e3c0
commit 069b92a98c
No known key found for this signature in database
GPG Key ID: 6B990B8185E7F782
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
client.go
View File

@ -1259,9 +1259,8 @@ func (cl *Client) AddTorrentInfoHashWithStorage(infoHash metainfo.Hash, specStor
return return
} }
// Adds a torrent by InfoHash with a custom Storage implementation. // Adds a torrent by InfoHash with a custom Storage implementation. If the torrent already exists
// If the torrent already exists then this Storage is ignored and the // then this Storage is ignored and the existing torrent returned with `new` set to `false`.
// existing torrent returned with `new` set to `false`
func (cl *Client) AddTorrentOpt(opts AddTorrentOpts) (t *Torrent, new bool) { func (cl *Client) AddTorrentOpt(opts AddTorrentOpts) (t *Torrent, new bool) {
infoHash := opts.InfoHash infoHash := opts.InfoHash
cl.lock() cl.lock()
@ -1279,6 +1278,7 @@ func (cl *Client) AddTorrentOpt(opts AddTorrentOpts) (t *Torrent, new bool) {
} }
}) })
cl.torrents[infoHash] = t cl.torrents[infoHash] = t
t.setInfoBytesLocked(opts.InfoBytes)
cl.clearAcceptLimits() cl.clearAcceptLimits()
t.updateWantPeersEvent() t.updateWantPeersEvent()
// Tickle Client.waitAccept, new torrent may want conns. // Tickle Client.waitAccept, new torrent may want conns.
@ -1290,6 +1290,7 @@ type AddTorrentOpts struct {
InfoHash infohash.T InfoHash infohash.T
Storage storage.ClientImpl Storage storage.ClientImpl
ChunkSize pp.Integer ChunkSize pp.Integer
InfoBytes []byte
} }
// Add or merge a torrent spec. Returns new if the torrent wasn't already in the client. See also // Add or merge a torrent spec. Returns new if the torrent wasn't already in the client. See also