arnekeller/KIT-ILIAS-downloader
1
0
Fork 0
mirror of https://github.com/FliegendeWurst/KIT-ILIAS-downloader.git synced 2024-08-28 04:04:18 +00:00
Code Issues Projects Releases Wiki Activity

Add missing await

Browse Source
This commit is contained in:
FliegendeWurst 2021-06-02 11:53:50 +02:00
parent e7354e0ad1
commit 1459ff5ae4
2 changed files with 1 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main.rs
View File

@ -188,7 +188,7 @@ fn process_gracefully(ilias: Arc<ILIAS>, path: PathBuf, obj: Object) -> impl Fut
PROGRESS_BAR.inc_length(1); PROGRESS_BAR.inc_length(1);
} }
async move { async move {
let permit = queue::get_ticket(); let permit = queue::get_ticket().await;
let path_text = path.to_string_lossy().into_owned(); let path_text = path.to_string_lossy().into_owned();
if let Err(e) = process(ilias, path, obj).await.context("failed to process URL") { if let Err(e) = process(ilias, path, obj).await.context("failed to process URL") {
error!("Syncing {}", path_text; e); error!("Syncing {}", path_text; e);

8
src/queue.rs
View File

@ -29,14 +29,6 @@ pub fn set_download_rate(rate: usize) {
let mut interval = time::interval(time::Duration::from_secs_f64(60.0 / rate as f64)); let mut interval = time::interval(time::Duration::from_secs_f64(60.0 / rate as f64));
loop { loop {
interval.tick().await; interval.tick().await;
log!(
0,
"interval ticked @ {}",
std::time::SystemTime::now()
.duration_since(std::time::SystemTime::UNIX_EPOCH)
.unwrap()
.as_secs()
);
REQUEST_TICKETS.add_permits(1); REQUEST_TICKETS.add_permits(1);
} }
}); });