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

Remove unused disk_work_queue_tx

Browse source
This commit is contained in:
Igor Katson 2024-05-02 09:47:18 +01:00
parent f0b63b5926
commit 776c865781
1 changed files with 1 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

17
crates/librqbit/src/torrent_state/live/mod.rs
View file

@ -176,8 +176,6 @@ pub struct TorrentStateLive {
up_speed_estimator: SpeedEstimator, up_speed_estimator: SpeedEstimator,
cancellation_token: CancellationToken, cancellation_token: CancellationToken,
disk_work_queue_tx: std::sync::mpsc::SyncSender<Box<dyn FnOnce() + Send + Sync>>,
pub(crate) streams: Arc<TorrentStreams>, pub(crate) streams: Arc<TorrentStreams>,
} }
@ -209,8 +207,6 @@ impl TorrentStateLive {
pri pri
}; };
let (disk_work_queue_tx, mut disk_work_queue_rx) = std::sync::mpsc::sync_channel(2048);
let state = Arc::new(TorrentStateLive { let state = Arc::new(TorrentStateLive {
meta: paused.info.clone(), meta: paused.info.clone(),
peers: Default::default(), peers: Default::default(),
@ -233,17 +229,8 @@ impl TorrentStateLive {
up_speed_estimator, up_speed_estimator,
cancellation_token, cancellation_token,
streams: paused.streams, streams: paused.streams,
disk_work_queue_tx,
}); });
if paused.info.options.defer_writes {
tokio::runtime::Handle::current().spawn_blocking(move || {
while let Ok(work_unit) = disk_work_queue_rx.recv() {
work_unit();
}
});
}
state.spawn( state.spawn(
error_span!(parent: state.meta.span.clone(), "speed_estimator_updater"), error_span!(parent: state.meta.span.clone(), "speed_estimator_updater"),
{ {
@ -1488,7 +1475,6 @@ impl PeerHandler {
let counters = self.counters.clone(); let counters = self.counters.clone();
let piece = piece.clone_to_owned(); let piece = piece.clone_to_owned();
let tx = self.tx.clone(); let tx = self.tx.clone();
let disk_work_queue_tx = state.disk_work_queue_tx.clone();
let work = move || { let work = move || {
if let Err(e) = write_to_disk( if let Err(e) = write_to_disk(
@ -1502,8 +1488,7 @@ impl PeerHandler {
let _ = tx.send(WriterRequest::Disconnect(Err(e))); let _ = tx.send(WriterRequest::Disconnect(Err(e)));
} }
}; };
tokio::runtime::Handle::current().spawn_blocking(work); tokio::task::spawn_blocking(work);
// disk_work_queue_tx.send(Box::new(work))?;
} else { } else {
self.state self.state
.meta .meta