From 7c03aba923466264e96efbaf87c0ceeb56f39dbd 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 42c5e859..46812877 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)