Drop DirEntries as soon as possible to avoid running out of open file…

…-descriptors

common/src/cmp.rs

@@ -216,7 +216,9 @@ pub async fn cmp(
             || async move { cmp(prog_track, &entry_path, &dst_path, &log, &settings).await };
         join_set.spawn(do_cmp());
     }
-
+    // unfortunately ReadDir is opening file-descriptors and there's not a good way to limit this,
+    // one thing we CAN do however is to drop it as soon as we're done with it
+    drop(src_entries);
     event!(Level::DEBUG, "process contents of 'dst' directory");
     let mut dst_entries = tokio::fs::read_dir(dst)
         .await
@@ -249,6 +251,9 @@ pub async fn cmp(
         )
         .await?;
     }
+    // unfortunately ReadDir is opening file-descriptors and there's not a good way to limit this,
+    // one thing we CAN do however is to drop it as soon as we're done with it
+    drop(dst_entries);
     while let Some(res) = join_set.join_next().await {
         match res? {
             Ok(summary) => cmp_summary = cmp_summary + summary,

common/src/copy.rs

@@ -462,6 +462,9 @@ pub async fn copy(
         };
         join_set.spawn(do_copy());
     }
+    // unfortunately ReadDir is opening file-descriptors and there's not a good way to limit this,
+    // one thing we CAN do however is to drop it as soon as we're done with it
+    drop(entries);
     while let Some(res) = join_set.join_next().await {
         match res {
             Ok(result) => match result {

common/src/link.rs

@@ -428,6 +428,9 @@ pub async fn link(
         };
         join_set.spawn(do_link());
     }
+    // unfortunately ReadDir is opening file-descriptors and there's not a good way to limit this,
+    // one thing we CAN do however is to drop it as soon as we're done with it
+    drop(src_entries);
     // only process update if the path was provided and the directory is present
     if update_metadata_opt.is_some() {
         let update = update.as_ref().unwrap();
@@ -476,6 +479,9 @@ pub async fn link(
             };
             join_set.spawn(do_copy());
         }
+        // unfortunately ReadDir is opening file-descriptors and there's not a good way to limit this,
+        // one thing we CAN do however is to drop it as soon as we're done with it
+        drop(update_entries);
     }
     while let Some(res) = join_set.join_next().await {
         match res {

common/src/rm.rs

@@ -120,6 +120,9 @@ pub async fn rm(
         let do_rm = || async move { rm(prog_track, &entry_path, &settings).await };
         join_set.spawn(do_rm());
     }
+    // unfortunately ReadDir is opening file-descriptors and there's not a good way to limit this,
+    // one thing we CAN do however is to drop it as soon as we're done with it
+    drop(entries);
     let mut rm_summary = RmSummary {
         directories_removed: 0,
         ..Default::default()