Add Davis WLL collision avoidance to Realtime requests

cumulusmx · Dec 29, 2022 · 3d22b98 · 3d22b98
1 parent 779a454
commit 3d22b98
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/CumulusMX/DavisWllStation.cs b/CumulusMX/DavisWllStation.cs
@@ -417,6 +417,17 @@ private async void GetWllRealtime(object source, ElapsedEventArgs e)
 
 					if (CheckIpValid(ip))
 					{
+						var timeSinceLastMessage = (int) (DateTime.Now.Subtract(LastDataReadTimestamp).TotalMilliseconds % 2500);
+						if (timeSinceLastMessage > 1500)
+						{
+							// Another broadcast is due in the next second or less
+							var delay = Math.Max(200, 2600 - timeSinceLastMessage);
+							cumulus.LogDebugMessage($"GetWllRealtime: Delaying {delay} ms");
+							tmrRealtime.Stop();
+							await Task.Delay(delay);
+							tmrRealtime.Start();
+						}
+
 						var urlRealtime = "http://" + ip + "/v1/real_time?duration=" + cumulus.WllBroadcastDuration;
 
 						cumulus.LogDebugMessage($"GetWllRealtime: Sending GET real time request to WLL: {urlRealtime} ...");