diff options
| author | Roy Ben Shabat <Roy.mail.net@gmail.com> | 2025-07-29 02:29:02 +0300 |
|---|---|---|
| committer | Roy Ben Shabat <Roy.mail.net@gmail.com> | 2025-07-29 02:29:02 +0300 |
| commit | 72c6399ec345ec26bd7f79651667ffa585474919 (patch) | |
| tree | 687a6c9bb850b4568d1718aa51add12327737a7d /Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs | |
| parent | 3f86a214b4459e619a5a767369b996e56cd17564 (diff) | |
| download | Tango-72c6399ec345ec26bd7f79651667ffa585474919.tar.gz Tango-72c6399ec345ec26bd7f79651667ffa585474919.zip | |
Telemetry
Diffstat (limited to 'Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs')
| -rw-r--r-- | Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs b/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs index 662df9bae..8891a6cc4 100644 --- a/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs +++ b/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs @@ -12,6 +12,7 @@ using Tango.Insights; using Tango.Integration.Operation; using Tango.PMR.Diagnostics; using Tango.PMR.Insights; +using Tango.Telemetry.TelemetryObjects; namespace Tango.Telemetry { @@ -150,6 +151,8 @@ namespace Tango.Telemetry try { + _diagnosticsSamplingTimer.Stop(); + _writing = true; if (_diagnosticsQueue.Count > 0) @@ -186,17 +189,22 @@ namespace Tango.Telemetry finally { _writing = false; + _diagnosticsSamplingTimer.Start(); } } private void PendingStorageCheckTimer_Elapsed(object sender, ElapsedEventArgs e) { + _pendingStorageCheckTimer.Stop(); + var telemetryAll = PendingStorageManager.GetTelemetryAll(); foreach (var t in telemetryAll) { PushTelemetryPackage(t, TelemetrySource.PendingStorage); } + + _pendingStorageCheckTimer.Start(); } #endregion @@ -326,7 +334,7 @@ namespace Tango.Telemetry { try { - PublishingPackage?.Invoke(this, new TelemetryPackagePublishingEventArgs() { Package = package, Destination = destination }); + PackagePublished?.Invoke(this, new TelemetryPackagePublishedEventArgs() { Package = package, Destination = destination }); } catch { } } |
