Investigate and fix memory leaks in Asterisk

Fixed memory leaks that were found in Asterisk.

ASTERISK-24693 #close
Reported by:  Kevin Harwell
Review: https://reviewboard.asterisk.org/r/4347/
........

Merged revisions 430999 from http://svn.asterisk.org/svn/asterisk/branches/13

git-svn-id: https://origsvn.digium.com/svn/asterisk/certified/branches/13.1@431016 65c4cc65-6c06-0410-ace0-fbb531ad65f3

diff --git a/channels/chan_iax2.c b/channels/chan_iax2.c
index 39861db0e3013a5226bfabab3b816dc6bd015a20..8128a6d4ab606cdaab431e7371af0980ed57e8f0 100644 (file)
--- a/channels/chan_iax2.c
+++ b/channels/chan_iax2.c
@@ -4406,7 +4406,7 @@ static struct iax2_peer *realtime_peer(const char *peername, struct ast_sockaddr
                if (var && !ast_sockaddr_isnull(addr)) {
                        for (tmp = var; tmp; tmp = tmp->next) {
                                if (!strcasecmp(tmp->name, "host")) {
-                                       struct ast_sockaddr *hostaddr;
+                                       struct ast_sockaddr *hostaddr = NULL;
 
                                        if (!ast_sockaddr_resolve(&hostaddr, tmp->value, PARSE_PORT_FORBID, AST_AF_UNSPEC)
                                                || ast_sockaddr_cmp_addr(hostaddr, addr)) {
@@ -4414,6 +4414,7 @@ static struct iax2_peer *realtime_peer(const char *peername, struct ast_sockaddr
                                                ast_variables_destroy(var);
                                                var = NULL;
                                        }
+                                       ast_free(hostaddr);
                                        break;
                                }
                        }
@@ -4528,7 +4529,7 @@ static struct iax2_user *realtime_user(const char *username, struct ast_sockaddr
                if (var) {
                        for (tmp = var; tmp; tmp = tmp->next) {
                                if (!strcasecmp(tmp->name, "host")) {
-                                       struct ast_sockaddr *hostaddr;
+                                       struct ast_sockaddr *hostaddr = NULL;
 
                                        if (!ast_sockaddr_resolve(&hostaddr, tmp->value, PARSE_PORT_FORBID, AST_AF_UNSPEC)
                                                || ast_sockaddr_cmp_addr(hostaddr, addr)) {
@@ -4536,6 +4537,7 @@ static struct iax2_user *realtime_user(const char *username, struct ast_sockaddr
                                                ast_variables_destroy(var);
                                                var = NULL;
                                        }
+                                       ast_free(hostaddr);
                                        break;
                                }
                        }

diff --git a/include/asterisk/stasis_app.h b/include/asterisk/stasis_app.h
index e47275480152c04a178abe56ad3d3609860d5bdf..0d04caa3db60344bcc103263487e15f750e7d838 100644 (file)
--- a/include/asterisk/stasis_app.h
+++ b/include/asterisk/stasis_app.h
@@ -245,8 +245,7 @@ enum stasis_app_user_event_res {
  * \param event_name Name of the Userevent.
  * \param source_uris URIs for the source objects to attach to event.
  * \param sources_count Array size of source_uris.
- * \param userevent_data Custom parameters for the user event
- * \param userevents_count Array size of userevent_data
+ * \param json_variables event blob variables.
  *
  * \return \ref stasis_app_user_event_res return code.
  */

diff --git a/res/parking/parking_applications.c b/res/parking/parking_applications.c
index c5214b36a336323d5808e22b2a1ee9a0267e0aae..002d60a765544ea813dd20d707385743da8e5b83 100644 (file)
--- a/res/parking/parking_applications.c
+++ b/res/parking/parking_applications.c
@@ -610,6 +610,7 @@ static int parked_call_app_exec(struct ast_channel *chan, const char *data)
        }
 
        /* The parked call needs to know who is retrieving it before we move it out of the parking bridge */
+       ast_assert(pu->retriever == NULL);
        pu->retriever = ast_channel_snapshot_create(chan);
 
        /* Create bridge */

diff --git a/res/res_ari_channels.c b/res/res_ari_channels.c
index 8cc25f1d87bcba4b3c2d17eb02945c1350e4a2ac..d8cb8760043da61a22ee670e6bbe155136974c97 100644 (file)
--- a/res/res_ari_channels.c
+++ b/res/res_ari_channels.c
@@ -226,7 +226,7 @@ static void ast_ari_channels_originate_cb(
                        goto fin;
                }
        }
-       args.variables = ast_json_ref(body);
+       args.variables = body;
        ast_ari_channels_originate(headers, &args, response);
 #if defined(AST_DEVMODE)
        code = response->response_code;
@@ -442,7 +442,7 @@ static void ast_ari_channels_originate_with_id_cb(
                        goto fin;
                }
        }
-       args.variables = ast_json_ref(body);
+       args.variables = body;
        ast_ari_channels_originate_with_id(headers, &args, response);
 #if defined(AST_DEVMODE)
        code = response->response_code;

diff --git a/res/res_ari_endpoints.c b/res/res_ari_endpoints.c
index 071d66bec472562798fc4db8bd248a8af5af83dc..3ebe668585979231fa75744d5fdacc62dd21aa63 100644 (file)
--- a/res/res_ari_endpoints.c
+++ b/res/res_ari_endpoints.c
@@ -170,7 +170,7 @@ static void ast_ari_endpoints_send_message_cb(
                        goto fin;
                }
        }
-       args.variables = ast_json_ref(body);
+       args.variables = body;
        ast_ari_endpoints_send_message(headers, &args, response);
 #if defined(AST_DEVMODE)
        code = response->response_code;
@@ -396,7 +396,7 @@ static void ast_ari_endpoints_send_message_to_endpoint_cb(
                        goto fin;
                }
        }
-       args.variables = ast_json_ref(body);
+       args.variables = body;
        ast_ari_endpoints_send_message_to_endpoint(headers, &args, response);
 #if defined(AST_DEVMODE)
        code = response->response_code;

diff --git a/res/res_ari_events.c b/res/res_ari_events.c
index 2a596d0a8c25f57759b4f9b3cceadf42e67b7bfa..c601f571fa2799bb461ea71a8bee75b788dc489a 100644 (file)
--- a/res/res_ari_events.c
+++ b/res/res_ari_events.c
@@ -281,7 +281,7 @@ static void ast_ari_events_user_event_cb(
                        goto fin;
                }
        }
-       args.variables = ast_json_ref(body);
+       args.variables = body;
        ast_ari_events_user_event(headers, &args, response);
 #if defined(AST_DEVMODE)
        code = response->response_code;

diff --git a/res/res_pjsip/pjsip_global_headers.c b/res/res_pjsip/pjsip_global_headers.c
index eff8703149367d743678b141ada03ac552f02dd4..0fcc3a1398d0d951e413d389c610f01f0d79da64 100644 (file)
--- a/res/res_pjsip/pjsip_global_headers.c
+++ b/res/res_pjsip/pjsip_global_headers.c
@@ -111,6 +111,7 @@ static void remove_header(struct header_list *headers, const char *to_remove)
        AST_LIST_TRAVERSE_SAFE_BEGIN(headers, iter, next) {
                if (!strcasecmp(iter->name, to_remove)) {
                        AST_LIST_REMOVE_CURRENT(next);
+                       destroy_header(iter);
                        break;
                }
        }

diff --git a/res/res_pjsip_mwi.c b/res/res_pjsip_mwi.c
index bf0925dd480e0c678bdbf60a3713474237377d83..f85ba997c7775e54a2d20885f8e7cd54a83c2ee7 100644 (file)
--- a/res/res_pjsip_mwi.c
+++ b/res/res_pjsip_mwi.c
@@ -658,7 +658,7 @@ static struct mwi_subscription *mwi_subscribe_all(
 static int mwi_new_subscribe(struct ast_sip_endpoint *endpoint,
                const char *resource)
 {
-       struct ast_sip_aor *aor;
+       RAII_VAR(struct ast_sip_aor *, aor, NULL, ao2_cleanup);
 
        if (ast_strlen_zero(resource)) {
                if (ast_sip_for_each_aor(endpoint->aors, mwi_validate_for_aor, endpoint)) {

diff --git a/res/res_pjsip_pubsub.c b/res/res_pjsip_pubsub.c
index 490f694d240d4cb42a03e44f083587436f9ec3cd..df185119824fa9f3ea655e9e2b158263a42b21ed 100644 (file)
--- a/res/res_pjsip_pubsub.c
+++ b/res/res_pjsip_pubsub.c
@@ -949,7 +949,7 @@ static void resource_tree_destroy(struct resource_tree *tree)
 static int build_resource_tree(struct ast_sip_endpoint *endpoint, const struct ast_sip_subscription_handler *handler,
                const char *resource, struct resource_tree *tree, int has_eventlist_support)
 {
-       struct resource_list *list;
+       RAII_VAR(struct resource_list *, list, NULL, ao2_cleanup);
        struct resources visited;
 
        if (!has_eventlist_support || !(list = retrieve_resource_list(resource, handler->event_name))) {
@@ -975,7 +975,6 @@ static int build_resource_tree(struct ast_sip_endpoint *endpoint, const struct a
 
        build_node_children(endpoint, handler, list, tree->root, &visited);
        AST_VECTOR_FREE(&visited);
-       ao2_cleanup(list);
 
        if (AST_VECTOR_SIZE(&tree->root->children) > 0) {
                return 200;
@@ -3177,7 +3176,6 @@ static int serialized_pubsub_on_client_refresh(void *userdata)
                pjsip_evsub_send_request(sub_tree->evsub, tdata);
        } else {
                pjsip_evsub_terminate(sub_tree->evsub, PJ_TRUE);
-               return 0;
        }
        ao2_cleanup(sub_tree);
        return 0;

diff --git a/res/res_stasis.c b/res/res_stasis.c
index ad081d412ab024958779db20895a33e341a58a0c..2da15f1a6088a4678534e64af291e9764cb360f0 100644 (file)
--- a/res/res_stasis.c
+++ b/res/res_stasis.c
@@ -1804,6 +1804,8 @@ enum stasis_app_user_event_res stasis_app_user_event(const char *app_name,
        blob = json_variables;
        if (!blob) {
                blob = ast_json_pack("{}");
+       } else {
+               ast_json_ref(blob);
        }
        json_value = ast_json_string_create(event_name);
        if (!json_value) {

diff --git a/rest-api-templates/param_parsing.mustache b/rest-api-templates/param_parsing.mustache
index 2dde4b33fad37f4abc9885a4ee988096eb4888a6..247c121d9c94cf1ff192a124af9134b95145f239 100644 (file)
--- a/rest-api-templates/param_parsing.mustache
+++ b/rest-api-templates/param_parsing.mustache
@@ -101,7 +101,7 @@
                }
        }
 {{#body_parameter}}
-       args.{{c_name}} = ast_json_ref(body);
+       args.{{c_name}} = body;
 {{/body_parameter}}
 {{^body_parameter}}
        if (ast_ari_{{c_name}}_{{c_nickname}}_parse_body(body, &args)) {