aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs
diff options
context:
space:
mode:
authorRoy Ben Shabat <Roy.mail.net@gmail.com>2025-07-29 02:29:02 +0300
committerRoy Ben Shabat <Roy.mail.net@gmail.com>2025-07-29 02:29:02 +0300
commit72c6399ec345ec26bd7f79651667ffa585474919 (patch)
tree687a6c9bb850b4568d1718aa51add12327737a7d /Software/Visual_Studio/Tango.Telemetry/TelemetryPublisher.cs
parent3f86a214b4459e619a5a767369b996e56cd17564 (diff)
downloadTango-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.cs10
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 { }
}