Merge pull request #650 from gc87/branch-mqtt

fix(mqtt): free ctx if msg send error
2026-10-29 15:09:11 +08:00 · 2022-07-18 18:38:07 +08:00
parent a98c9ae272 b820d74796
commit e9d0052791
1 changed files with 1 additions and 0 deletions
@@ -618,6 +618,7 @@ static neu_err_code_e nodes_get(neu_plugin_t *plugin, neu_reqresp_head_t *head,
        strcpy(cmd.node, info->node);
        int ret = neu_plugin_op(plugin, header, &cmd);
        if (ret != 0) {
+            free(head->ctx);
            return -1;
        }
    }