diff options
-rw-r--r-- | include/asterisk/module.h | 7 | ||||
-rw-r--r-- | main/asterisk.c | 4 | ||||
-rw-r--r-- | main/loader.c | 25 |
3 files changed, 36 insertions, 0 deletions
diff --git a/include/asterisk/module.h b/include/asterisk/module.h index 075d6a376..73bea557e 100644 --- a/include/asterisk/module.h +++ b/include/asterisk/module.h @@ -141,6 +141,13 @@ int ast_loader_register(int (*updater)(void)); */ int ast_loader_unregister(int (*updater)(void)); +/*! + * \brief Run the unload() callback for all loaded modules + * + * This function should be called when Asterisk is shutting down gracefully. + */ +void ast_module_shutdown(void); + /*! * \brief Match modules names for the Asterisk cli. * \param line Unused by this function, but this should be the line we are diff --git a/main/asterisk.c b/main/asterisk.c index efb6403d9..18a121339 100644 --- a/main/asterisk.c +++ b/main/asterisk.c @@ -126,6 +126,7 @@ int daemon(int, int); /* defined in libresolv of all places */ #include "asterisk/version.h" #include "asterisk/linkedlists.h" #include "asterisk/devicestate.h" +#include "asterisk/module.h" #include "asterisk/doxyref.h" /* Doxygen documentation */ @@ -1244,6 +1245,9 @@ static void quit_handler(int num, int nice, int safeshutdown, int restart) ast_verbose("Asterisk %s cancelled.\n", restart ? "restart" : "shutdown"); return; } + + if (nice) + ast_module_shutdown(); } if (ast_opt_console || ast_opt_remote) { if (getenv("HOME")) diff --git a/main/loader.c b/main/loader.c index 53b557f11..c1b7597c9 100644 --- a/main/loader.c +++ b/main/loader.c @@ -428,6 +428,31 @@ static struct ast_module *load_dynamic_module(const char *resource_in, unsigned } #endif +void ast_module_shutdown(void) +{ + struct ast_module *mod; + AST_LIST_HEAD_NOLOCK_STATIC(local_module_list, ast_module); + + /* We have to call the unload() callbacks in reverse order that the modules + * exist in the module list so it is the reverse order of how they were + * loaded. */ + + AST_LIST_LOCK(&module_list); + while ((mod = AST_LIST_REMOVE_HEAD(&module_list, entry))) + AST_LIST_INSERT_HEAD(&local_module_list, mod, entry); + AST_LIST_UNLOCK(&module_list); + + while ((mod = AST_LIST_REMOVE_HEAD(&local_module_list, entry))) { + if (mod->info->unload) + mod->info->unload(); + /* Since this should only be called when shutting down "gracefully", + * all channels should be down before we get to this point, meaning + * there will be no module users left. */ + AST_LIST_HEAD_DESTROY(&mod->users); + free(mod); + } +} + int ast_unload_resource(const char *resource_name, enum ast_module_unload_mode force) { struct ast_module *mod; |