friendlynamazu/server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add try catch to the initial file rawsize calc

Browse Source
This commit is contained in:
Stanley Dimant
2024-09-06 10:51:52 +02:00
parent 106dd05ab9
commit 4fd1ce3d6e
1 changed files with 17 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
MareSynchronosServer/MareSynchronosStaticFilesServer/Services/MainFileCleanupService.cs
View File

@@ -243,6 +243,23 @@ public class MainFileCleanupService : IHostedService
deleteCurrentFile = true; deleteCurrentFile = true;
} }
// only used if file in db has no raw size for whatever reason
if (!deleteCurrentFile && file != null && fileCache.RawSize == 0)
{
try
{
var length = LZ4Codec.Unwrap(File.ReadAllBytes(file.FullName)).LongLength;
_logger.LogInformation("Setting Raw File Size of " + fileCache.Hash + " to " + length);
fileCache.RawSize = length;
if (fileCounter % 1000 == 0)
await dbContext.SaveChangesAsync().ConfigureAwait(false);
}
catch (Exception ex)
{
_logger.LogError(ex, "Could not unpack {fileName}", file.FullName);
}
}
// do actual deletion of file and remove also from db if needed // do actual deletion of file and remove also from db if needed
if (deleteCurrentFile) if (deleteCurrentFile)
{ {
@@ -263,16 +280,6 @@ public class MainFileCleanupService : IHostedService
await dbContext.SaveChangesAsync().ConfigureAwait(false); await dbContext.SaveChangesAsync().ConfigureAwait(false);
} }
// only used if file in db has no raw size for whatever reason
if (!deleteCurrentFile && file != null && fileCache.RawSize == 0)
{
var length = LZ4Codec.Unwrap(File.ReadAllBytes(file.FullName)).LongLength;
_logger.LogInformation("Setting Raw File Size of " + fileCache.Hash + " to " + length);
fileCache.RawSize = length;
if (fileCounter % 1000 == 0)
await dbContext.SaveChangesAsync().ConfigureAwait(false);
}
fileCounter++; fileCounter++;
ct.ThrowIfCancellationRequested(); ct.ThrowIfCancellationRequested();