Skip to content

Commit 6be8a54

Browse files
committed
fix: clear inserted logs correctly
1 parent e13025b commit 6be8a54

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

src/GZCTF/Extensions/DatabaseSinkExtension.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -94,18 +94,18 @@ async Task WriteToDatabase(CancellationToken token = default)
9494
affectedRows = await dbContext.SaveChangesAsync(token);
9595
}
9696
catch (Exception ex)
97+
{
98+
var logger = scope.ServiceProvider.GetRequiredService<ILogger<DatabaseSink>>();
99+
logger.LogErrorMessage(ex);
100+
}
101+
finally
97102
{
98103
if (affectedRows > 0)
99104
{
100105
// If some logs were saved, we need to remove them from the buffer
101106
lockedLogBuffer.RemoveAll(logModel => logModel.Id != 0);
102107
}
103108

104-
var logger = scope.ServiceProvider.GetRequiredService<ILogger<DatabaseSink>>();
105-
logger.LogErrorMessage(ex);
106-
}
107-
finally
108-
{
109109
_lastFlushTime = DateTimeOffset.Now;
110110
}
111111
}

0 commit comments

Comments
 (0)