Skip to content

Commit 5025d3c

Browse files
committed
gh-347 Update log statement for debugging
Signed-off-by: Victor Chang <[email protected]>
1 parent 222c747 commit 5025d3c

File tree

5 files changed

+8
-5
lines changed

5 files changed

+8
-5
lines changed

src/Api/Storage/Payload.cs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,9 @@ public TimeSpan Elapsed
7575

7676
public string? CalledAeTitle { get => Files.OfType<DicomFileStorageMetadata>().Select(p => p.CalledAeTitle).FirstOrDefault(); }
7777

78+
public int FilesUploaded { get => Files.Count(p => p.IsUploaded); }
79+
public int FilesFailedToUpload { get => Files.Count(p => p.IsUploadFailed); }
80+
7881
public Payload(string key, string correlationId, uint timeout)
7982
{
8083
Guard.Against.NullOrWhiteSpace(key);

src/InformaticsGateway/Logging/Log.3000.PayloadAssembler.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,8 @@ public static partial class Log
3333
[LoggerMessage(EventId = 3004, Level = LogLevel.Trace, Message = "Number of incomplete payloads waiting for processing: {count}.")]
3434
public static partial void BucketsActive(this ILogger logger, int count);
3535

36-
[LoggerMessage(EventId = 3005, Level = LogLevel.Trace, Message = "Checking elapsed time for bucket: {key}.")]
37-
public static partial void BucketElapsedTime(this ILogger logger, string key);
36+
[LoggerMessage(EventId = 3005, Level = LogLevel.Trace, Message = "Checking elapsed time for bucket: {key} with timeout set to {timeout}s. Elapsed {elapsed}s with {failedFiles} failures out of {totalNumberOfFiles}.")]
37+
public static partial void BucketElapsedTime(this ILogger logger, string key, uint timeout, double elapsed, int totalNumberOfFiles, int failedFiles);
3838

3939
[LoggerMessage(EventId = 3007, Level = LogLevel.Information, Message = "Bucket {key} sent to processing queue with {count} files.")]
4040
public static partial void BucketReady(this ILogger logger, string key, int count);

src/InformaticsGateway/Logging/Log.4000.ObjectUploadService.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public static partial class Log
3636
[LoggerMessage(EventId = 4004, Level = LogLevel.Debug, Message = "Error removing objects that are pending upload during startup.")]
3737
public static partial void ErrorRemovingPendingUploadObjects(this ILogger logger, Exception ex);
3838

39-
[LoggerMessage(EventId = 4005, Level = LogLevel.Debug, Message = "Error uploading temporary store. Waiting {timeSpan} before next retry. Retry attempt {retryCount}.")]
39+
[LoggerMessage(EventId = 4005, Level = LogLevel.Error, Message = "Error uploading temporary store. Waiting {timeSpan} before next retry. Retry attempt {retryCount}.")]
4040
public static partial void ErrorUploadingFileToTemporaryStore(this ILogger logger, TimeSpan timespan, int retryCount, Exception ex);
4141

4242
[LoggerMessage(EventId = 4006, Level = LogLevel.Information, Message = "File uploaded to temporary store at {filePath}.")]

src/InformaticsGateway/Services/Connectors/PayloadAssembler.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,10 +132,10 @@ private async void OnTimedEvent(Object source, System.Timers.ElapsedEventArgs e)
132132
}
133133
foreach (var key in _payloads.Keys)
134134
{
135-
_logger.BucketElapsedTime(key);
136135
var payload = await _payloads[key].Task.ConfigureAwait(false);
137136
using var loggerScope = _logger.BeginScope(new LoggingDataDictionary<string, object> { { "CorrelationId", payload.CorrelationId } });
138137

138+
_logger.BucketElapsedTime(key, payload.Timeout, payload.ElapsedTime().TotalSeconds, payload.Files.Count, payload.FilesFailedToUpload);
139139
// Wait for timer window closes before sending payload for processing
140140
if (payload.HasTimedOut)
141141
{

src/InformaticsGateway/Services/Connectors/PayloadExtensions.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ public static bool IsUploadCompleted(this Payload payload)
3030

3131
public static bool IsUploadCompletedWithFailures(this Payload payload)
3232
{
33-
return payload.Files.Count(p => p.IsUploadFailed) + payload.Files.Count(p => p.IsUploaded) == payload.Count; ;
33+
return (payload.FilesFailedToUpload + payload.FilesUploaded) == payload.Count; ;
3434
}
3535

3636
public static bool IsMoveCompleted(this Payload payload)

0 commit comments

Comments
 (0)