GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-22 09:23:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #983 from eeff/eeff/monitor

Browse Source 
fix: monitor plugin memory leak
This commit is contained in:
fengzeroz
2022-12-15 14:01:30 +08:00
committed by GitHub
parent b3eb9d55bd 96aa7cd69f
commit ea27fdedff
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/monitor/monitor.c
+8 -8
View File
@@ -331,20 +331,20 @@ static int monitor_plugin_config(neu_plugin_t *plugin, const char *setting)
}
}
if (plugin->mqtt_client && neu_mqtt_client_is_open(plugin->mqtt_client)) {
rv = neu_mqtt_client_close(plugin->mqtt_client);
if (0 != rv) {
plog_error(plugin, "neu_mqtt_client_close fail");
rv = NEU_ERR_EINTERNAL;
goto error;
}
} else {
if (NULL == plugin->mqtt_client) {
plugin->mqtt_client = neu_mqtt_client_new(NEU_MQTT_VERSION_V311);
if (NULL == plugin->mqtt_client) {
plog_error(plugin, "neu_mqtt_client_new fail");
rv = NEU_ERR_EINTERNAL;
goto error;
}
} else if (neu_mqtt_client_is_open(plugin->mqtt_client)) {
rv = neu_mqtt_client_close(plugin->mqtt_client);
if (0 != rv) {
plog_error(plugin, "neu_mqtt_client_close fail");
rv = NEU_ERR_EINTERNAL;
goto error;
}
}
rv = config_mqtt_client(plugin, plugin->mqtt_client, &config);