RPCS3/archived-discord-bot
1
0
Fork 0
mirror of https://github.com/RPCS3/discord-bot.git synced 2026-01-31 01:25:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'vnext'

Browse Source
This commit is contained in:
13xforever
2025-12-03 04:05:13 +05:00
parent a1fec7ef6b f7e5d5460f
commit c8758f649c
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
CompatBot/EventHandlers/LogParsing/ArchiveHandlers/ZipHandler.cs
View File

@@ -47,18 +47,28 @@ internal sealed class ZipHandler: IArchiveHandler
{
var memory = writer.GetMemory(Config.MinimumBufferSize);
read = await zipStream.ReadAsync(memory, cancellationToken).ConfigureAwait(false);
#if DEBUG
Config.Log.Debug($"{nameof(ZipHandler)}: read {read} bytes from source stream");
#endif
if (read > 0)
writer.Advance(read);
totalRead += read;
#if DEBUG
Config.Log.Debug($"{nameof(ZipHandler)}: advanced the writer by {read} (total read {totalRead})");
#endif
SourcePosition = statsStream.Position;
#if DEBUG
Config.Log.Debug($"{nameof(ZipHandler)}: current source position is {SourcePosition}");
#endif
flushed = await writer.FlushAsync(cancellationToken).ConfigureAwait(false);
#if DEBUG
Config.Log.Debug($"{nameof(ZipHandler)}: flushed the writer");
#endif
} while (read > 0 && !(flushed.IsCompleted || flushed.IsCanceled || cancellationToken.IsCancellationRequested));
await writer.CompleteAsync().ConfigureAwait(false);
#if DEBUG
Config.Log.Debug($"{nameof(ZipHandler)}: writer completed");
#endif
return;
}
SourcePosition = statsStream.Position;