mqtt: report driver node state immediately

2026-10-17 04:40:42 +08:00 · 2026-04-12 18:55:21 -07:00
parent feca615f61
commit 7c03aba923
1 changed files with 4 additions and 0 deletions
@@ -98,6 +98,10 @@ static void connect_cb(void *data)
    neu_plugin_t *plugin      = data;
    plugin->common.link_state = NEU_NODE_LINK_STATE_CONNECTED;
    plog_notice(plugin, "plugin `%s` connected", neu_plugin_module.module_name);
+
+    if (plugin->heartbeat_timer) {
+        heartbeat_timer_cb(plugin);
+    }
 }

 static void disconnect_cb(void *data)