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

Avoid race condition in network request scheduling

Browse Source 
oops
This commit is contained in:
FliegendeWurst 2020-07-13 09:41:00 +02:00
parent 1aa28f0d00
commit 1610db4c3c
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main.rs
View File

@ -89,10 +89,16 @@ lazy_static!{
fn process_gracefully(ilias: Arc<ILIAS>, path: PathBuf, obj: Object) -> impl Future<Output = ()> + Send { async move { fn process_gracefully(ilias: Arc<ILIAS>, path: PathBuf, obj: Object) -> impl Future<Output = ()> + Send { async move {
*TASKS_QUEUED.lock() += 1; *TASKS_QUEUED.lock() += 1;
while *TASKS_RUNNING.lock() >= ilias.opt.jobs { loop {
tokio::time::delay_for(Duration::from_millis(100)).await; { // limit scope of lock
let mut running = TASKS_RUNNING.lock();
if *running < ilias.opt.jobs {
*running += 1;
break;
}
}
tokio::time::delay_for(Duration::from_millis(50)).await;
} }
*TASKS_RUNNING.lock() += 1;
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") {
println!("Syncing {}: {:?}", path_text, e); println!("Syncing {}: {:?}", path_text, e);