Cleanup pbx on exit.

* Cleanup CLI commands on exit.

* Unreference hints and statecbs containers on exit.

(issue ASTERISK-20649)
Reported by: Corey Farrell
Patches:
      pbx-cleanup-1_8.patch (license #5909) patch uploaded by Corey Farrell
      pbx-cleanup-10.patch (license #5909) patch uploaded by Corey Farrell
      pbx-cleanup-11-trunk.patch (license #5909) patch uploaded by Corey Farrell
      Modified

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

diff --git a/main/pbx.c b/main/pbx.c
index 76ea6a50471b80d294533b5b1f16bcb45398188d..fbe06fc7644f62f62b91aee8570cf24fad1279b6 100644 (file)
--- a/main/pbx.c
+++ b/main/pbx.c
@@ -10557,12 +10557,17 @@ static void unload_pbx(void)
        if (device_state_sub) {
                device_state_sub = ast_event_unsubscribe(device_state_sub);
        }
+       if (device_state_tps) {
+               ast_taskprocessor_unreference(device_state_tps);
+               device_state_tps = NULL;
+       }
 
        /* Unregister builtin applications */
        for (x = 0; x < ARRAY_LEN(builtins); x++) {
                ast_unregister_application(builtins[x].name);
        }
        ast_manager_unregister("ShowDialPlan");
+       ast_cli_unregister_multiple(pbx_cli, ARRAY_LEN(pbx_cli));
        ast_custom_function_unregister(&exception_function);
        ast_custom_function_unregister(&testtime_function);
        ast_data_unregister(NULL);
@@ -10572,6 +10577,8 @@ int load_pbx(void)
 {
        int x;
 
+       ast_register_atexit(unload_pbx);
+
        /* Initialize the PBX */
        ast_verb(1, "Asterisk PBX Core Initializing\n");
        if (!(device_state_tps = ast_taskprocessor_get("pbx-core", 0))) {
@@ -10601,7 +10608,6 @@ int load_pbx(void)
                return -1;
        }
 
-       ast_register_atexit(unload_pbx);
        return 0;
 }
 
@@ -10962,10 +10968,24 @@ static int statecbs_cmp(void *obj, void *arg, int flags)
        return (state_cb->change_cb == change_cb) ? CMP_MATCH | CMP_STOP : 0;
 }
 
+static void pbx_shutdown(void)
+{
+       if (hints) {
+               ao2_ref(hints, -1);
+               hints = NULL;
+       }
+       if (statecbs) {
+               ao2_ref(statecbs, -1);
+               statecbs = NULL;
+       }
+}
+
 int ast_pbx_init(void)
 {
        hints = ao2_container_alloc(HASH_EXTENHINT_SIZE, hint_hash, hint_cmp);
        statecbs = ao2_container_alloc(1, NULL, statecbs_cmp);
 
+       ast_register_atexit(pbx_shutdown);
+
        return (hints && statecbs) ? 0 : -1;
 }