leyoda/rqbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

"make_peer_rx_managed_torrent"

Browse source
This commit is contained in:
Igor Katson 2024-12-05 21:57:44 +00:00
parent 8131ba0482
commit 96946d5a81
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
1 changed files with 17 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

25
crates/librqbit/src/session.rs
View file

@ -1330,6 +1330,21 @@ impl Session {
Ok(())
}
pub fn make_peer_rx_managed_torrent(
self: &Arc<Self>,
t: &Arc<ManagedTorrent>,
announce: bool,
) -> anyhow::Result<PeerStream> {
self.make_peer_rx(
t.info_hash(),
t.shared().trackers.iter().cloned().collect(),
announce,
t.shared().options.force_tracker_interval,
t.shared().options.initial_peers.clone(),
)?
.context("no peer source")
}
// Get a peer stream from both DHT and trackers.
fn make_peer_rx(
self: &Arc<Self>,
@ -1387,14 +1402,8 @@ impl Session {
}
pub async fn unpause(self: &Arc<Self>, handle: &ManagedTorrentHandle) -> anyhow::Result<()> {
let peer_rx = self.make_peer_rx(
handle.info_hash(),
handle.shared().trackers.clone().into_iter().collect(),
true,
handle.shared().options.force_tracker_interval,
handle.shared().options.initial_peers.clone(),
)?;
handle.start(peer_rx, false)?;
let peer_rx = self.make_peer_rx_managed_torrent(handle, true)?;
handle.start(Some(peer_rx), false)?;
self.try_update_persistence_metadata(handle).await;
Ok(())
}