diff options
| author | Roy Ben Shabat <roy.mail.net@gmail.com> | 2025-09-01 02:33:22 +0300 |
|---|---|---|
| committer | Roy Ben Shabat <roy.mail.net@gmail.com> | 2025-09-01 02:33:22 +0300 |
| commit | 1d8115b0221779497d2cf33378b970b04a833d03 (patch) | |
| tree | d9e9dbf640aa3b9304534fafe0fbde4fb0c57592 /Software/Visual_Studio/Tango.Telemetry | |
| parent | d9e07aff4a8160de7ce19ea536e69ed8f9a7a6d5 (diff) | |
| download | Tango-1d8115b0221779497d2cf33378b970b04a833d03.tar.gz Tango-1d8115b0221779497d2cf33378b970b04a833d03.zip | |
Fixed telemetry logs cyclic loop
Diffstat (limited to 'Software/Visual_Studio/Tango.Telemetry')
4 files changed, 5 insertions, 1 deletions
diff --git a/Software/Visual_Studio/Tango.Telemetry/ITelemetryStorageManager.cs b/Software/Visual_Studio/Tango.Telemetry/ITelemetryStorageManager.cs index 882cc0411..9376f6adf 100644 --- a/Software/Visual_Studio/Tango.Telemetry/ITelemetryStorageManager.cs +++ b/Software/Visual_Studio/Tango.Telemetry/ITelemetryStorageManager.cs @@ -9,7 +9,7 @@ namespace Tango.Telemetry /// <summary> /// Defines the contract for managing telemetry storage, including pending telemetries and history source checkpoints. /// </summary> - public interface ITelemetryStorageManager + public interface ITelemetryStorageManager : IDisposable { /// <summary> /// Initializes the storage manager with the specified checkpoints recovery client. diff --git a/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryLogsStreamingSource.cs b/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryLogsStreamingSource.cs index 2c8020f7c..2f592f22a 100644 --- a/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryLogsStreamingSource.cs +++ b/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryLogsStreamingSource.cs @@ -64,6 +64,8 @@ namespace Tango.Telemetry.Sources if (IsStarted) { if (!Config.Categories.Contains(log.Category)) return; + if (log.ClassName != null && log.ClassName.StartsWith("Telemetry")) return; + TelemetryLog tLog = LogMapper.MapLog(log); TelemetryAvailable?.Invoke(this, new TelemetryAvailableEventArgs() { TelemetryObject = tLog }); diff --git a/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs b/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs index ab0ff2b58..13781d6dc 100644 --- a/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs +++ b/Software/Visual_Studio/Tango.Telemetry/TelemetryLiteDBStorageManager.cs @@ -251,6 +251,7 @@ namespace Tango.Telemetry try { _disposed = true; + _database.Checkpoint(); _database.Dispose(); _database = null; } diff --git a/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs b/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs index 07b421406..8c05524ed 100644 --- a/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs +++ b/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs @@ -1008,6 +1008,7 @@ namespace Tango.Telemetry { try { + Debug.WriteLine($"[TELEMETRY] Package Publish Result Available: {result}"); PublishResultAvailable?.Invoke(this, new TelemetryPublishResultAvailableEventArgs() { Package = package, PublishResult = result }); } catch { } |