ToxicMushroom/mare.server
1
0
Fork 0
mirror of https://github.com/Caraxi/mare.server.git synced 2025-12-12 22:17:22 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

add ordering

Browse source
This commit is contained in:
rootdarkarchon 2023-11-17 00:29:57 +01:00
parent 8c8c3509d3
commit 6b5b45ff77
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
MareSynchronosServer/MareSynchronosStaticFilesServer/Services/FileCleanupService.cs
View file

@ -165,7 +165,7 @@ public class FileCleanupService : IHostedService
DirectoryInfo dir = new(_cacheDir); DirectoryInfo dir = new(_cacheDir);
var allFilesInDir = dir.GetFiles("*", SearchOption.AllDirectories); var allFilesInDir = dir.GetFiles("*", SearchOption.AllDirectories);
int filesToTake = 10000; int filesToTake = 10000;
var filesChunk = await dbContext.Files.Take(filesToTake).ToListAsync().ConfigureAwait(false); var filesChunk = await dbContext.Files.OrderBy(f => f.Hash).Take(filesToTake).ToListAsync().ConfigureAwait(false);
int iterations = 1; int iterations = 1;
var allFiles = new List<FileCache>(); var allFiles = new List<FileCache>();
while (filesChunk.Any()) while (filesChunk.Any())
@ -222,7 +222,7 @@ public class FileCleanupService : IHostedService
} }
allFiles.AddRange(filesChunk); allFiles.AddRange(filesChunk);
filesChunk = await dbContext.Files.Skip(filesToTake * iterations).Take(filesToTake).ToListAsync(cancellationToken: ct).ConfigureAwait(false); filesChunk = await dbContext.Files.OrderBy(f => f.Hash).Skip(filesToTake * iterations).Take(filesToTake).ToListAsync(cancellationToken: ct).ConfigureAwait(false);
iterations++; iterations++;
} }