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

Store initial_peers in state

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

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

@ -1179,6 +1179,7 @@ impl Session {
output_folder, output_folder,
disk_write_queue: self.disk_write_tx.clone(), disk_write_queue: self.disk_write_tx.clone(),
ratelimits: opts.ratelimits, ratelimits: opts.ratelimits,
initial_peers: opts.initial_peers.clone().unwrap_or_default(),
#[cfg(feature = "disable-upload")] #[cfg(feature = "disable-upload")]
_disable_upload: self._disable_upload, _disable_upload: self._disable_upload,
}, },
@ -1391,7 +1392,7 @@ impl Session {
handle.shared().trackers.clone().into_iter().collect(), handle.shared().trackers.clone().into_iter().collect(),
true, true,
handle.shared().options.force_tracker_interval, handle.shared().options.force_tracker_interval,
Default::default(), handle.shared().options.initial_peers.clone(),
)?; )?;
handle.start(peer_rx, false)?; handle.start(peer_rx, false)?;
self.try_update_persistence_metadata(handle).await; self.try_update_persistence_metadata(handle).await;

2
crates/librqbit/src/torrent_state/mod.rs
View file

@ -6,6 +6,7 @@ mod streaming;
pub mod utils; pub mod utils;
use std::collections::HashSet; use std::collections::HashSet;
use std::net::SocketAddr;
use std::path::PathBuf; use std::path::PathBuf;
use std::sync::atomic::Ordering; use std::sync::atomic::Ordering;
use std::sync::Arc; use std::sync::Arc;
@ -105,6 +106,7 @@ pub(crate) struct ManagedTorrentOptions {
pub output_folder: PathBuf, pub output_folder: PathBuf,
pub disk_write_queue: Option<DiskWorkQueueSender>, pub disk_write_queue: Option<DiskWorkQueueSender>,
pub ratelimits: LimitsConfig, pub ratelimits: LimitsConfig,
pub initial_peers: Vec<SocketAddr>,
#[cfg(feature = "disable-upload")] #[cfg(feature = "disable-upload")]
pub _disable_upload: bool, pub _disable_upload: bool,
} }