From 7d2d5cb0a77fa8445a35be2fd126832dcc6ede53 Mon Sep 17 00:00:00 2001 From: hxy7yx <1595670487@qq.com> Date: Sun, 12 Apr 2026 18:55:21 -0700 Subject: [PATCH] mqtt: report driver node state immediately --- plugins/mqtt/mqtt_plugin_intf.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/plugins/mqtt/mqtt_plugin_intf.c b/plugins/mqtt/mqtt_plugin_intf.c index 61435a653..d3c85bafd 100644 --- a/plugins/mqtt/mqtt_plugin_intf.c +++ b/plugins/mqtt/mqtt_plugin_intf.c @@ -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)