boxfriend/FtpThing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

download in parallel

Browse Source
This commit is contained in:
boxfriend
2025-12-16 23:26:58 -05:00
parent db55acd188
commit 38322aa1c2
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
Program.cs
View File

@@ -107,21 +107,21 @@ static async Task RunJob(Config config, CancellationToken token)
static async Task RecurseDirectory(SftpClient client, string source, string destination, bool deleteDirectory, CancellationToken token) static async Task RecurseDirectory(SftpClient client, string source, string destination, bool deleteDirectory, CancellationToken token)
{ {
Log.Information($"Scanning directory '{source}'"); Log.Information($"Scanning directory '{source}'");
await foreach (var item in client.ListDirectoryAsync(source, token)) Parallel.ForEachAsync(client.ListDirectoryAsync(source, token), token, async (item,token) =>
{ {
if (item.Name is ".." or ".") continue; if (item.Name is ".." or ".") return;
if (item.IsDirectory) if (item.IsDirectory)
{ {
var newPath = Path.Combine(destination, item.Name); var newPath = Path.Combine(destination, item.Name);
await RecurseDirectory(client, item.FullName, newPath, true, token); await RecurseDirectory(client, item.FullName, newPath, true, token);
continue; return;
} }
await DownloadFile(client, item, destination, token); await DownloadFile(client, item, destination, token);
Log.Information($"Deleting '{item.Name}'"); Log.Information($"Deleting '{item.Name}'");
await client.DeleteAsync(item.FullName, token); await client.DeleteAsync(item.FullName, token);
} });
if (deleteDirectory) if (deleteDirectory)
{ {