tune live network modules

Author: ZeroBitsTech

examples/LiveNetworkBaseline/LiveNetworkBaseline.ino

@@ -89,7 +89,13 @@ void ensureWiFi() {
     return;
   }
 
+#if defined(ARDUINO_ARCH_ESP8266)
+  if (WiFi.status() == WL_DISCONNECTED) {
+    WiFi.begin(kWiFiSsid, kWiFiPassword);
+  }
+#else
   WiFi.begin(kWiFiSsid, kWiFiPassword);
+#endif
   ++g_wifiAttempts;
   g_nextWiFiAttemptAtMs =
       applyBackoffWithJitter(nowMs, kWiFiRetryBaseMs, &g_currentWiFiRetryMs,
@@ -167,7 +173,11 @@ bool sendHttpNow(const char* body, size_t length) {
         statusLine += ch;
       }
     }
+#if defined(ARDUINO_ARCH_ESP8266)
+    yield();
+#else
     delay(1);
+#endif
   }
 
   g_httpClient.stop();
@@ -237,7 +247,7 @@ void dispatchTask() {
 unsigned long percentage(unsigned long ok, unsigned long fail) {
   const unsigned long total = ok + fail;
   if (total == 0) {
-    return 100;
+    return 0;
   }
   return (ok * 100UL) / total;
 }

examples/LiveNetworkNode/LiveNetworkNode.ino

@@ -67,9 +67,17 @@ bool isWiFiConnected() {
 }
 
 void connectWiFi() {
-  if (WiFi.status() != WL_CONNECTED) {
+  const wl_status_t status = WiFi.status();
+  if (status == WL_CONNECTED || status == WL_IDLE_STATUS) {
+    return;
+  }
+#if defined(ARDUINO_ARCH_ESP8266)
+  if (status == WL_DISCONNECTED) {
     WiFi.begin(kWiFiSsid, kWiFiPassword);
   }
+#else
+  WiFi.begin(kWiFiSsid, kWiFiPassword);
+#endif
 }
 
 void disconnectWiFi() {
@@ -258,7 +266,7 @@ void mqttPumpTask() {
 unsigned long percentage(unsigned long ok, unsigned long fail) {
   const unsigned long total = ok + fail;
   if (total == 0) {
-    return 100;
+    return 0;
   }
   return (ok * 100UL) / total;
 }
@@ -322,20 +330,26 @@ void setup() {
   ZeroKernel.subscribeTypedFast(kMqttStateTopic, onTypedState);
 
   ZeroWiFiMaintainer::Config wifiConfig;
-  wifiConfig.pollIntervalMs = 250;
-  wifiConfig.retryBaseMs = 800;
-  wifiConfig.retryMaxMs = 8000;
-  wifiConfig.retryJitterMs = 250;
+  wifiConfig.pollIntervalMs = 500;
+#if defined(ARDUINO_ARCH_ESP8266)
+  wifiConfig.retryBaseMs = 3000;
+  wifiConfig.retryMaxMs = 15000;
+  wifiConfig.retryJitterMs = 500;
+#else
+  wifiConfig.retryBaseMs = 1000;
+  wifiConfig.retryMaxMs = 10000;
+  wifiConfig.retryJitterMs = 300;
+#endif
   wifiConfig.manageCapabilities = true;
   wifiConfig.capabilityMask = Kernel::kCapNetwork;
   wifiConfig.stateTopicKey = kWiFiStateTopic;
   g_wifiMaintainer.begin(ZeroKernel, isWiFiConnected, connectWiFi, disconnectWiFi, wifiConfig);
 
   ZeroHttpPump::Config httpConfig;
-  httpConfig.pollIntervalMs = 25;
-  httpConfig.retryBaseMs = 300;
-  httpConfig.retryMaxMs = 1500;
-  httpConfig.retryJitterMs = 120;
+  httpConfig.pollIntervalMs = 75;
+  httpConfig.retryBaseMs = 500;
+  httpConfig.retryMaxMs = 3000;
+  httpConfig.retryJitterMs = 150;
   httpConfig.maxRetries = 2;
   g_httpPump.begin(ZeroKernel,
                    httpConnectStep,
@@ -345,10 +359,10 @@ void setup() {
                    httpConfig);
 
   ZeroMqttPump::Config mqttConfig;
-  mqttConfig.pollIntervalMs = 25;
-  mqttConfig.retryBaseMs = 400;
-  mqttConfig.retryMaxMs = 2000;
-  mqttConfig.retryJitterMs = 180;
+  mqttConfig.pollIntervalMs = 75;
+  mqttConfig.retryBaseMs = 500;
+  mqttConfig.retryMaxMs = 3000;
+  mqttConfig.retryJitterMs = 200;
   mqttConfig.maxRetries = 2;
   mqttConfig.stateTopicKey = kMqttStateTopic;
   g_mqttPump.begin(ZeroKernel,
@@ -359,17 +373,17 @@ void setup() {
                    mqttConfig);
 
   ZeroKernel.addTask("Sample", sampleTask, 100, 0);
-  ZeroKernel.addTask("WiFiMaint", wifiMaintainerTask, 50, 0);
-  ZeroKernel.addTask("HttpPump", httpPumpTask, 25, 0);
-  ZeroKernel.addTask("MqttPump", mqttPumpTask, 25, 0);
-  ZeroKernel.addTask("Dispatch", dispatchTask, 50, 0);
+  ZeroKernel.addTask("WiFiMaint", wifiMaintainerTask, 100, 0);
+  ZeroKernel.addTask("HttpPump", httpPumpTask, 75, 0);
+  ZeroKernel.addTask("MqttPump", mqttPumpTask, 75, 0);
+  ZeroKernel.addTask("Dispatch", dispatchTask, 100, 0);
   ZeroKernel.addTask("Report", reportTask, 250, 0);
 
   ZeroKernel.setTaskPriority("Sample", Kernel::kPriorityCritical);
   ZeroKernel.setTaskPriority("WiFiMaint", Kernel::kPriorityHigh);
-  ZeroKernel.setTaskPriority("HttpPump", Kernel::kPriorityHigh);
-  ZeroKernel.setTaskPriority("MqttPump", Kernel::kPriorityHigh);
-  ZeroKernel.setTaskPriority("Dispatch", Kernel::kPriorityHigh);
+  ZeroKernel.setTaskPriority("HttpPump", Kernel::kPriorityNormal);
+  ZeroKernel.setTaskPriority("MqttPump", Kernel::kPriorityNormal);
+  ZeroKernel.setTaskPriority("Dispatch", Kernel::kPriorityNormal);
   ZeroKernel.setTaskPriority("Report", Kernel::kPriorityLow);
 
   g_startedAtMs = millis();

src/modules/net/ZeroHttpPump.h

@@ -9,7 +9,7 @@ namespace modules {
 namespace net {
 
 // Optional cooperative HTTP request pump. Header-only and only linked when included.
-// BETA: suitable for evaluation, but still under active transport and retry tuning.
+// BETA: live transport reliability improved, but still under active validation on real boards.
 class ZeroHttpPump {
  public:
   enum StepResult : int8_t {
@@ -67,7 +67,7 @@ class ZeroHttpPump {
   };
 
   static const uint8_t kQueueCapacity = ZEROKERNEL_HTTP_PUMP_QUEUE_CAPACITY;
-  static const uint8_t kImmediatePhaseBudget = 4;
+  static const uint8_t kImmediatePhaseBudget = 2;
 
   ZeroHttpPump()
       : kernel_(NULL),

src/modules/net/ZeroMqttPump.h

@@ -9,7 +9,7 @@ namespace modules {
 namespace net {
 
 // Optional cooperative MQTT pump. Header-only and only linked when included.
-// BETA: suitable for evaluation, but still under active transport and retry tuning.
+// BETA: transport cadence is tuned, but release-grade validation is still in progress.
 class ZeroMqttPump {
  public:
   struct Message {
@@ -52,7 +52,7 @@ class ZeroMqttPump {
   };
 
   static const uint8_t kQueueCapacity = ZEROKERNEL_MQTT_PUMP_QUEUE_CAPACITY;
-  static const uint8_t kPublishBurstPerTick = 2;
+  static const uint8_t kPublishBurstPerTick = 1;
 
   ZeroMqttPump()
       : kernel_(NULL),

src/modules/net/ZeroWiFiMaintainer.h

@@ -8,7 +8,7 @@ namespace modules {
 namespace net {
 
 // Optional Wi-Fi link helper. No runtime cost unless this module is included.
-// BETA: validated on desktop and ESP32 smoke tests, still under active tuning.
+// BETA: suitable for live evaluation, but still under reconnect and long-run soak validation.
 class ZeroWiFiMaintainer {
  public:
   typedef bool (*LinkProbe)();

tests/desktop/KernelTests.cpp

@@ -956,10 +956,16 @@ int testHttpPumpModule() {
   g_fakeNowMs = 2;
   isolatedKernel.tick();
   pump.tick();
-  expectTrue(pump.phase() == zerokernel::modules::net::ZeroHttpPump::kPhaseConnecting,
-             "http pump retries after collapsed phase failure");
+  expectTrue(pump.phase() == zerokernel::modules::net::ZeroHttpPump::kPhaseReading,
+             "http pump advances to read after connect and write");
   expectTrue(g_httpWriteCalls == 1, "http pump collapses write phase in same tick");
-  expectTrue(g_httpReadCalls == 1, "http pump collapses read phase in same tick");
+
+  g_fakeNowMs = 3;
+  isolatedKernel.tick();
+  pump.tick();
+  expectTrue(g_httpReadCalls == 1, "http pump executes read phase");
+  expectTrue(pump.phase() == zerokernel::modules::net::ZeroHttpPump::kPhaseConnecting,
+             "http pump retries after read failure");
 
   g_fakeNowMs = 10;
   isolatedKernel.tick();
@@ -970,6 +976,10 @@ int testHttpPumpModule() {
   isolatedKernel.tick();
   pump.tick();
 
+  g_fakeNowMs = 25;
+  isolatedKernel.tick();
+  pump.tick();
+
   const zerokernel::modules::net::ZeroTransportMetrics::Snapshot httpMetrics =
       pump.metrics().snapshot();
   expectTrue(!pump.isBusy(), "http pump returns idle after success");