diff options
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 { } |