Go to the source code of this file.
Functions | |
void | ast_autoservice_init (void) |
void | ast_builtins_init (void) |
initialize the _full_cmd string in * each of the builtins. | |
int | ast_cel_engine_init (void) |
int | ast_cel_engine_reload (void) |
void | ast_channels_init (void) |
int | ast_cli_perms_init (int reload) |
int | ast_data_init (void) |
int | ast_device_state_engine_init (void) |
Initialize the device state engine in separate thread. | |
int | ast_event_init (void) |
int | ast_features_init (void) |
int | ast_file_init (void) |
int | ast_http_init (void) |
int | ast_http_reload (void) |
int | ast_indications_init (void) |
Load indications module. | |
int | ast_indications_reload (void) |
Reload indications module. | |
int | ast_module_reload (const char *name) |
Reload asterisk modules. | |
int | ast_plc_reload (void) |
Reload genericplc configuration value from codecs.conf. | |
void | ast_process_pending_reloads (void) |
Process reload requests received during startup. | |
int | ast_ssl_init (void) |
void | ast_stun_init (void) |
Initialize the STUN system in Asterisk. | |
int | ast_term_init (void) |
int | ast_test_init (void) |
int | ast_timing_init (void) |
int | ast_tps_init (void) |
int | ast_xmldoc_load_documentation (void) |
Load XML documentation. Provided by xmldoc.c. | |
int | astdb_init (void) |
int | astobj2_init (void) |
void | close_logger (void) |
int | dnsmgr_init (void) |
int | dnsmgr_reload (void) |
void | dnsmgr_start_refresh (void) |
int | init_framer (void) |
int | init_logger (void) |
int | load_modules (unsigned int) |
int | load_pbx (void) |
void | threadstorage_init (void) |
Definition in file _private.h.
void ast_autoservice_init | ( | void | ) |
Provided by autoservice.c
Definition at line 319 of file autoservice.c.
References as_cond, and ast_cond_init.
Referenced by main().
00320 { 00321 ast_cond_init(&as_cond, NULL); 00322 }
void ast_builtins_init | ( | void | ) |
initialize the _full_cmd string in * each of the builtins.
Provided by cli.c
Definition at line 1871 of file cli.c.
References ARRAY_LEN, ast_cli_register_multiple(), and cli_cli.
Referenced by main().
01872 { 01873 ast_cli_register_multiple(cli_cli, ARRAY_LEN(cli_cli)); 01874 }
int ast_cel_engine_init | ( | void | ) |
Provided by cel.c
Definition at line 652 of file cel.c.
References ao2_container_alloc, ao2_ref, app_cmp(), app_hash(), appset, ast_cel_engine_term(), ast_cli_register(), ast_register_atexit(), cli_status, do_reload(), and NUM_APP_BUCKETS.
Referenced by main().
00653 { 00654 if (!(appset = ao2_container_alloc(NUM_APP_BUCKETS, app_hash, app_cmp))) { 00655 return -1; 00656 } 00657 00658 if (do_reload()) { 00659 ao2_ref(appset, -1); 00660 appset = NULL; 00661 return -1; 00662 } 00663 00664 if (ast_cli_register(&cli_status)) { 00665 ao2_ref(appset, -1); 00666 appset = NULL; 00667 return -1; 00668 } 00669 00670 ast_register_atexit(ast_cel_engine_term); 00671 00672 return 0; 00673 }
int ast_cel_engine_reload | ( | void | ) |
Provided by cel.c
Definition at line 675 of file cel.c.
References do_reload().
00676 { 00677 return do_reload(); 00678 }
void ast_channels_init | ( | void | ) |
Provided by channel.c
Definition at line 7950 of file channel.c.
References ao2_container_alloc, ARRAY_LEN, ast_channel_cmp_cb(), ast_channel_hash_cb(), ast_cli_register_multiple(), ast_data_register_multiple_core, ast_plc_reload(), channel_providers, channels, cli_channel, and NUM_CHANNEL_BUCKETS.
Referenced by main().
07951 { 07952 channels = ao2_container_alloc(NUM_CHANNEL_BUCKETS, 07953 ast_channel_hash_cb, ast_channel_cmp_cb); 07954 07955 ast_cli_register_multiple(cli_channel, ARRAY_LEN(cli_channel)); 07956 07957 ast_data_register_multiple_core(channel_providers, ARRAY_LEN(channel_providers)); 07958 07959 ast_plc_reload(); 07960 }
int ast_cli_perms_init | ( | int | reload | ) |
Provided by cli.c
Definition at line 1748 of file cli.c.
References ast_calloc, ast_category_browse(), ast_config_load2(), ast_free, AST_LIST_TRAVERSE, ast_log(), ast_mutex_trylock, ast_mutex_unlock, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, ast_strdup, ast_strlen_zero(), ast_variable_browse(), CONFIG_FLAG_FILEUNCHANGED, config_flags, CONFIG_STATUS_FILEUNCHANGED, destroy_user_perms(), usergroup_cli_perm::gid, cli_perm::list, LOG_NOTICE, LOG_WARNING, ast_variable::name, ast_variable::next, perms_config, usergroup_cli_perm::uid, and ast_variable::value.
Referenced by handle_cli_reload_permissions(), and main().
01749 { 01750 struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 }; 01751 struct ast_config *cfg; 01752 char *cat = NULL; 01753 struct ast_variable *v; 01754 struct usergroup_cli_perm *user_group, *cp_entry; 01755 struct cli_perm *perm = NULL; 01756 struct passwd *pw; 01757 struct group *gr; 01758 01759 if (ast_mutex_trylock(&permsconfiglock)) { 01760 ast_log(LOG_NOTICE, "You must wait until last 'cli reload permissions' command finish\n"); 01761 return 1; 01762 } 01763 01764 cfg = ast_config_load2(perms_config, "" /* core, can't reload */, config_flags); 01765 if (!cfg) { 01766 ast_mutex_unlock(&permsconfiglock); 01767 return 1; 01768 } else if (cfg == CONFIG_STATUS_FILEUNCHANGED) { 01769 ast_mutex_unlock(&permsconfiglock); 01770 return 0; 01771 } 01772 01773 /* free current structures. */ 01774 destroy_user_perms(); 01775 01776 while ((cat = ast_category_browse(cfg, cat))) { 01777 if (!strcasecmp(cat, "general")) { 01778 /* General options */ 01779 for (v = ast_variable_browse(cfg, cat); v; v = v->next) { 01780 if (!strcasecmp(v->name, "default_perm")) { 01781 cli_default_perm = (!strcasecmp(v->value, "permit")) ? 1: 0; 01782 } 01783 } 01784 continue; 01785 } 01786 01787 /* users or groups */ 01788 gr = NULL, pw = NULL; 01789 if (cat[0] == '@') { 01790 /* This is a group */ 01791 gr = getgrnam(&cat[1]); 01792 if (!gr) { 01793 ast_log (LOG_WARNING, "Unknown group '%s'\n", &cat[1]); 01794 continue; 01795 } 01796 } else { 01797 /* This is a user */ 01798 pw = getpwnam(cat); 01799 if (!pw) { 01800 ast_log (LOG_WARNING, "Unknown user '%s'\n", cat); 01801 continue; 01802 } 01803 } 01804 user_group = NULL; 01805 /* Check for duplicates */ 01806 AST_RWLIST_WRLOCK(&cli_perms); 01807 AST_LIST_TRAVERSE(&cli_perms, cp_entry, list) { 01808 if ((pw && cp_entry->uid == pw->pw_uid) || (gr && cp_entry->gid == gr->gr_gid)) { 01809 /* if it is duplicated, just added this new settings, to 01810 the current list. */ 01811 user_group = cp_entry; 01812 break; 01813 } 01814 } 01815 AST_RWLIST_UNLOCK(&cli_perms); 01816 01817 if (!user_group) { 01818 /* alloc space for the new user config. */ 01819 user_group = ast_calloc(1, sizeof(*user_group)); 01820 if (!user_group) { 01821 continue; 01822 } 01823 user_group->uid = (pw ? pw->pw_uid : -1); 01824 user_group->gid = (gr ? gr->gr_gid : -1); 01825 user_group->perms = ast_calloc(1, sizeof(*user_group->perms)); 01826 if (!user_group->perms) { 01827 ast_free(user_group); 01828 continue; 01829 } 01830 } 01831 for (v = ast_variable_browse(cfg, cat); v; v = v->next) { 01832 if (ast_strlen_zero(v->value)) { 01833 /* we need to check this condition cause it could break security. */ 01834 ast_log(LOG_WARNING, "Empty permit/deny option in user '%s'\n", cat); 01835 continue; 01836 } 01837 if (!strcasecmp(v->name, "permit")) { 01838 perm = ast_calloc(1, sizeof(*perm)); 01839 if (perm) { 01840 perm->permit = 1; 01841 perm->command = ast_strdup(v->value); 01842 } 01843 } else if (!strcasecmp(v->name, "deny")) { 01844 perm = ast_calloc(1, sizeof(*perm)); 01845 if (perm) { 01846 perm->permit = 0; 01847 perm->command = ast_strdup(v->value); 01848 } 01849 } else { 01850 /* up to now, only 'permit' and 'deny' are possible values. */ 01851 ast_log(LOG_WARNING, "Unknown '%s' option\n", v->name); 01852 continue; 01853 } 01854 if (perm) { 01855 /* Added the permission to the user's list. */ 01856 AST_LIST_INSERT_TAIL(user_group->perms, perm, list); 01857 perm = NULL; 01858 } 01859 } 01860 AST_RWLIST_WRLOCK(&cli_perms); 01861 AST_RWLIST_INSERT_TAIL(&cli_perms, user_group, list); 01862 AST_RWLIST_UNLOCK(&cli_perms); 01863 } 01864 01865 ast_config_destroy(cfg); 01866 ast_mutex_unlock(&permsconfiglock); 01867 return 0; 01868 }
int ast_data_init | ( | void | ) |
Provided by data.c
Definition at line 3277 of file data.c.
References ao2_container_alloc, ARRAY_LEN, ast_cli_register_multiple(), ast_manager_register_xml, ast_rwlock_init, AST_TEST_REGISTER, cli_data, data_provider_cmp(), data_provider_hash(), manager_data_get(), NUM_DATA_NODE_BUCKETS, and root_data.
Referenced by main().
03278 { 03279 int res = 0; 03280 03281 ast_rwlock_init(&root_data.lock); 03282 03283 if (!(root_data.container = ao2_container_alloc(NUM_DATA_NODE_BUCKETS, 03284 data_provider_hash, data_provider_cmp))) { 03285 return -1; 03286 } 03287 03288 res |= ast_cli_register_multiple(cli_data, ARRAY_LEN(cli_data)); 03289 03290 res |= ast_manager_register_xml("DataGet", 0, manager_data_get); 03291 03292 #ifdef TEST_FRAMEWORK 03293 AST_TEST_REGISTER(test_data_get); 03294 #endif 03295 03296 return res; 03297 }
int ast_device_state_engine_init | ( | void | ) |
Initialize the device state engine in separate thread.
Provided by devicestate.c
Definition at line 721 of file devicestate.c.
References ast_cond_init, ast_log(), ast_pthread_create_background, change_thread, do_devstate_changes(), and LOG_ERROR.
Referenced by main().
00722 { 00723 ast_cond_init(&change_pending, NULL); 00724 if (ast_pthread_create_background(&change_thread, NULL, do_devstate_changes, NULL) < 0) { 00725 ast_log(LOG_ERROR, "Unable to start device state change thread.\n"); 00726 return -1; 00727 } 00728 00729 return 0; 00730 }
int ast_event_init | ( | void | ) |
Provided by event.c
Definition at line 1744 of file event.c.
References ao2_container_alloc, ARRAY_LEN, ast_cli_register_multiple(), ast_event_cache, ast_event_cmp(), ast_event_hash(), ast_event_subs, AST_RWDLLIST_HEAD_INIT, ast_taskprocessor_get(), container, event_cli, event_dispatcher, hash_fn, and NUM_CACHE_BUCKETS.
Referenced by main().
01745 { 01746 int i; 01747 01748 for (i = 0; i < AST_EVENT_TOTAL; i++) { 01749 AST_RWDLLIST_HEAD_INIT(&ast_event_subs[i]); 01750 } 01751 01752 for (i = 0; i < AST_EVENT_TOTAL; i++) { 01753 if (!ast_event_cache[i].hash_fn) { 01754 /* This event type is not cached. */ 01755 continue; 01756 } 01757 01758 if (!(ast_event_cache[i].container = ao2_container_alloc(NUM_CACHE_BUCKETS, 01759 ast_event_hash, ast_event_cmp))) { 01760 return -1; 01761 } 01762 } 01763 01764 if (!(event_dispatcher = ast_taskprocessor_get("core_event_dispatcher", 0))) { 01765 return -1; 01766 } 01767 01768 ast_cli_register_multiple(event_cli, ARRAY_LEN(event_cli)); 01769 01770 return 0; 01771 }
int ast_features_init | ( | void | ) |
Provided by features.c
Definition at line 8076 of file features.c.
References action_bridge(), ao2_container_alloc, ARRAY_LEN, ast_cli_register_multiple(), ast_devstate_prov_add(), ast_manager_register_xml, ast_pthread_create, ast_register_application2(), AST_TEST_REGISTER, bridge_exec(), cli_features, do_parking_thread(), EVENT_FLAG_CALL, load_config(), manager_park(), manager_parking_status(), metermaidstate(), park_call_exec(), parkcall, parked_call_exec(), parking_thread, parkinglot_cmp_cb(), parkinglot_hash_cb(), and parkinglots.
Referenced by main().
08077 { 08078 int res; 08079 08080 parkinglots = ao2_container_alloc(7, parkinglot_hash_cb, parkinglot_cmp_cb); 08081 if (!parkinglots) { 08082 return -1; 08083 } 08084 08085 res = load_config(0); 08086 if (res) { 08087 return res; 08088 } 08089 ast_cli_register_multiple(cli_features, ARRAY_LEN(cli_features)); 08090 ast_pthread_create(&parking_thread, NULL, do_parking_thread, NULL); 08091 ast_register_application2(app_bridge, bridge_exec, NULL, NULL, NULL); 08092 res = ast_register_application2(parkedcall, parked_call_exec, NULL, NULL, NULL); 08093 if (!res) 08094 res = ast_register_application2(parkcall, park_call_exec, NULL, NULL, NULL); 08095 if (!res) { 08096 ast_manager_register_xml("ParkedCalls", 0, manager_parking_status); 08097 ast_manager_register_xml("Park", EVENT_FLAG_CALL, manager_park); 08098 ast_manager_register_xml("Bridge", EVENT_FLAG_CALL, action_bridge); 08099 } 08100 08101 res |= ast_devstate_prov_add("Park", metermaidstate); 08102 #if defined(TEST_FRAMEWORK) 08103 res |= AST_TEST_REGISTER(features_test); 08104 #endif /* defined(TEST_FRAMEWORK) */ 08105 08106 return res; 08107 }
int ast_file_init | ( | void | ) |
int ast_http_init | ( | void | ) |
Provided by http.c
Definition at line 1200 of file http.c.
References __ast_http_load(), ARRAY_LEN, ast_cli_register_multiple(), ast_http_uri_link(), cli_http, staticuri, and statusuri.
Referenced by main().
01201 { 01202 ast_http_uri_link(&statusuri); 01203 ast_http_uri_link(&staticuri); 01204 ast_cli_register_multiple(cli_http, ARRAY_LEN(cli_http)); 01205 01206 return __ast_http_load(0); 01207 }
int ast_http_reload | ( | void | ) |
Provided by http.c
Definition at line 1191 of file http.c.
References __ast_http_load().
01192 { 01193 return __ast_http_load(1); 01194 }
int ast_indications_init | ( | void | ) |
Load indications module.
Provided by indications.c
Definition at line 1149 of file indications.c.
References ao2_container_alloc, ARRAY_LEN, ast_cli_register_multiple(), ast_tone_zone_cmp(), ast_tone_zone_hash(), ast_tone_zones, cli_indications, load_indications(), and NUM_TONE_ZONE_BUCKETS.
Referenced by main().
01150 { 01151 if (!(ast_tone_zones = ao2_container_alloc(NUM_TONE_ZONE_BUCKETS, 01152 ast_tone_zone_hash, ast_tone_zone_cmp))) { 01153 return -1; 01154 } 01155 01156 if (load_indications(0)) { 01157 return -1; 01158 } 01159 01160 ast_cli_register_multiple(cli_indications, ARRAY_LEN(cli_indications)); 01161 01162 return 0; 01163 }
int ast_indications_reload | ( | void | ) |
Reload indications module.
Provided by indications.c
Definition at line 1166 of file indications.c.
References load_indications().
01167 { 01168 return load_indications(1); 01169 }
int ast_module_reload | ( | const char * | name | ) |
Reload asterisk modules.
name | the name of the module to reload |
1 | if the module was found but cannot be reloaded. | |
-1 | if a reload operation is already in progress. | |
2 | if the specfied module was found and reloaded. |
Definition at line 669 of file loader.c.
References ast_config_AST_CONFIG_DIR, ast_fully_booted, ast_lastreloadtime, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_lock_path(), AST_LOCK_SUCCESS, AST_LOCK_TIMEOUT, ast_log(), ast_mutex_trylock, ast_mutex_unlock, ast_opt_lock_confdir, ast_tvnow(), ast_unlock_path(), ast_verb, ast_verbose, ast_module::declined, ast_module_info::description, ast_module_user::entry, ast_module::flags, ast_module::info, LOG_NOTICE, LOG_WARNING, queue_reload_request(), ast_module_info::reload, ast_module::resource, resource_name_match(), and ast_module::running.
Referenced by action_reload(), action_updateconfig(), ast_process_pending_reloads(), handle_core_reload(), handle_reload(), manager_moduleload(), and monitor_sig_flags().
00670 { 00671 struct ast_module *cur; 00672 int res = 0; /* return value. 0 = not found, others, see below */ 00673 int i; 00674 00675 /* If we aren't fully booted, we just pretend we reloaded but we queue this 00676 up to run once we are booted up. */ 00677 if (!ast_fully_booted) { 00678 queue_reload_request(name); 00679 return 0; 00680 } 00681 00682 if (ast_mutex_trylock(&reloadlock)) { 00683 ast_verbose("The previous reload command didn't finish yet\n"); 00684 return -1; /* reload already in progress */ 00685 } 00686 ast_lastreloadtime = ast_tvnow(); 00687 00688 if (ast_opt_lock_confdir) { 00689 int try; 00690 int res; 00691 for (try = 1, res = AST_LOCK_TIMEOUT; try < 6 && (res == AST_LOCK_TIMEOUT); try++) { 00692 res = ast_lock_path(ast_config_AST_CONFIG_DIR); 00693 if (res == AST_LOCK_TIMEOUT) { 00694 ast_log(LOG_WARNING, "Failed to grab lock on %s, try %d\n", ast_config_AST_CONFIG_DIR, try); 00695 } 00696 } 00697 if (res != AST_LOCK_SUCCESS) { 00698 ast_verbose("Cannot grab lock on %s\n", ast_config_AST_CONFIG_DIR); 00699 ast_mutex_unlock(&reloadlock); 00700 return -1; 00701 } 00702 } 00703 00704 /* Call "predefined" reload here first */ 00705 for (i = 0; reload_classes[i].name; i++) { 00706 if (!name || !strcasecmp(name, reload_classes[i].name)) { 00707 reload_classes[i].reload_fn(); /* XXX should check error ? */ 00708 res = 2; /* found and reloaded */ 00709 } 00710 } 00711 00712 if (name && res) { 00713 if (ast_opt_lock_confdir) { 00714 ast_unlock_path(ast_config_AST_CONFIG_DIR); 00715 } 00716 ast_mutex_unlock(&reloadlock); 00717 return res; 00718 } 00719 00720 AST_LIST_LOCK(&module_list); 00721 AST_LIST_TRAVERSE(&module_list, cur, entry) { 00722 const struct ast_module_info *info = cur->info; 00723 00724 if (name && resource_name_match(name, cur->resource)) 00725 continue; 00726 00727 if (!cur->flags.running || cur->flags.declined) { 00728 if (!name) 00729 continue; 00730 ast_log(LOG_NOTICE, "The module '%s' was not properly initialized. " 00731 "Before reloading the module, you must run \"module load %s\" " 00732 "and fix whatever is preventing the module from being initialized.\n", 00733 name, name); 00734 res = 2; /* Don't report that the module was not found */ 00735 break; 00736 } 00737 00738 if (!info->reload) { /* cannot be reloaded */ 00739 if (res < 1) /* store result if possible */ 00740 res = 1; /* 1 = no reload() method */ 00741 continue; 00742 } 00743 00744 res = 2; 00745 ast_verb(3, "Reloading module '%s' (%s)\n", cur->resource, info->description); 00746 info->reload(); 00747 } 00748 AST_LIST_UNLOCK(&module_list); 00749 00750 if (ast_opt_lock_confdir) { 00751 ast_unlock_path(ast_config_AST_CONFIG_DIR); 00752 } 00753 ast_mutex_unlock(&reloadlock); 00754 00755 return res; 00756 }
int ast_plc_reload | ( | void | ) |
Reload genericplc configuration value from codecs.conf.
Implementation is in main/channel.c
Definition at line 7815 of file channel.c.
References ast_config_load, AST_OPT_FLAG_GENERIC_PLC, ast_options, ast_set2_flag, ast_true(), ast_variable_browse(), config_flags, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEMISSING, CONFIG_STATUS_FILEUNCHANGED, and var.
Referenced by ast_channels_init().
07816 { 07817 struct ast_variable *var; 07818 struct ast_flags config_flags = { 0 }; 07819 struct ast_config *cfg = ast_config_load("codecs.conf", config_flags); 07820 if (cfg == CONFIG_STATUS_FILEMISSING || cfg == CONFIG_STATUS_FILEUNCHANGED || cfg == CONFIG_STATUS_FILEINVALID) 07821 return 0; 07822 for (var = ast_variable_browse(cfg, "plc"); var; var = var->next) { 07823 if (!strcasecmp(var->name, "genericplc")) { 07824 ast_set2_flag(&ast_options, ast_true(var->value), AST_OPT_FLAG_GENERIC_PLC); 07825 } 07826 } 07827 ast_config_destroy(cfg); 07828 return 0; 07829 }
void ast_process_pending_reloads | ( | void | ) |
Process reload requests received during startup.
This function requests that the loader execute the pending reload requests that were queued during server startup.
Definition at line 604 of file loader.c.
References ast_free, ast_fully_booted, AST_LIST_LOCK, AST_LIST_REMOVE_HEAD, AST_LIST_UNLOCK, ast_log(), ast_module_reload(), do_full_reload, ast_module_user::entry, LOG_NOTICE, and reload_queue_item::module.
Referenced by main().
00605 { 00606 struct reload_queue_item *item; 00607 00608 if (!ast_fully_booted) { 00609 return; 00610 } 00611 00612 AST_LIST_LOCK(&reload_queue); 00613 00614 if (do_full_reload) { 00615 do_full_reload = 0; 00616 AST_LIST_UNLOCK(&reload_queue); 00617 ast_log(LOG_NOTICE, "Executing deferred reload request.\n"); 00618 ast_module_reload(NULL); 00619 return; 00620 } 00621 00622 while ((item = AST_LIST_REMOVE_HEAD(&reload_queue, entry))) { 00623 ast_log(LOG_NOTICE, "Executing deferred reload request for module '%s'.\n", item->module); 00624 ast_module_reload(item->module); 00625 ast_free(item); 00626 } 00627 00628 AST_LIST_UNLOCK(&reload_queue); 00629 }
int ast_ssl_init | ( | void | ) |
Provided by ssl.c
Definition at line 73 of file ssl.c.
References ast_calloc, ast_mutex_init, ssl_lock(), ssl_locks, and ssl_threadid().
Referenced by main().
00074 { 00075 #ifdef HAVE_OPENSSL 00076 unsigned int i; 00077 00078 SSL_library_init(); 00079 SSL_load_error_strings(); 00080 ERR_load_crypto_strings(); 00081 ERR_load_BIO_strings(); 00082 OpenSSL_add_all_algorithms(); 00083 00084 /* Make OpenSSL thread-safe. */ 00085 00086 CRYPTO_set_id_callback(ssl_threadid); 00087 00088 ssl_num_locks = CRYPTO_num_locks(); 00089 if (!(ssl_locks = ast_calloc(ssl_num_locks, sizeof(ssl_locks[0])))) { 00090 return -1; 00091 } 00092 for (i = 0; i < ssl_num_locks; i++) { 00093 ast_mutex_init(&ssl_locks[i]); 00094 } 00095 CRYPTO_set_locking_callback(ssl_lock); 00096 00097 #endif /* HAVE_OPENSSL */ 00098 return 0; 00099 }
void ast_stun_init | ( | void | ) |
Initialize the STUN system in Asterisk.
Provided by stun.c
Definition at line 499 of file stun.c.
References ast_cli_register_multiple(), and cli_stun.
Referenced by main().
00500 { 00501 ast_cli_register_multiple(cli_stun, sizeof(cli_stun) / sizeof(struct ast_cli_entry)); 00502 }
int ast_term_init | ( | void | ) |
Provided by term.c
Definition at line 83 of file term.c.
References ast_opt_console, ast_opt_force_black_background, ast_opt_light_background, ast_opt_no_color, ATTR_BRIGHT, ATTR_RESET, COLOR_BLACK, COLOR_BROWN, COLOR_WHITE, convshort(), and ESC.
Referenced by main().
00084 { 00085 char *term = getenv("TERM"); 00086 char termfile[256] = ""; 00087 char buffer[512] = ""; 00088 int termfd = -1, parseokay = 0, i; 00089 00090 if (ast_opt_no_color) { 00091 return 0; 00092 } 00093 00094 if (!ast_opt_console) { 00095 /* If any remote console is not compatible, we'll strip the color codes at that point */ 00096 vt100compat = 1; 00097 goto end; 00098 } 00099 00100 if (!term) { 00101 return 0; 00102 } 00103 00104 for (i = 0;; i++) { 00105 if (termpath[i] == NULL) { 00106 break; 00107 } 00108 snprintf(termfile, sizeof(termfile), "%s/%c/%s", termpath[i], *term, term); 00109 termfd = open(termfile, O_RDONLY); 00110 if (termfd > -1) { 00111 break; 00112 } 00113 } 00114 if (termfd > -1) { 00115 int actsize = read(termfd, buffer, sizeof(buffer) - 1); 00116 short sz_names = convshort(buffer + 2); 00117 short sz_bools = convshort(buffer + 4); 00118 short n_nums = convshort(buffer + 6); 00119 00120 /* if ((sz_names + sz_bools) & 1) 00121 sz_bools++; */ 00122 00123 if (sz_names + sz_bools + n_nums < actsize) { 00124 /* Offset 13 is defined in /usr/include/term.h, though we do not 00125 * include it here, as it conflicts with include/asterisk/term.h */ 00126 short max_colors = convshort(buffer + 12 + sz_names + sz_bools + 13 * 2); 00127 if (max_colors > 0) { 00128 vt100compat = 1; 00129 } 00130 parseokay = 1; 00131 } 00132 close(termfd); 00133 } 00134 00135 if (!parseokay) { 00136 /* These comparisons should not be substrings nor case-insensitive, as 00137 * terminal types are very particular about how they treat suffixes and 00138 * capitalization. For example, terminal type 'linux-m' does NOT 00139 * support color, while 'linux' does. Not even all vt100* terminals 00140 * support color, either (e.g. 'vt100+fnkeys'). */ 00141 if (!strcmp(term, "linux")) { 00142 vt100compat = 1; 00143 } else if (!strcmp(term, "xterm")) { 00144 vt100compat = 1; 00145 } else if (!strcmp(term, "xterm-color")) { 00146 vt100compat = 1; 00147 } else if (!strcmp(term, "xterm-256color")) { 00148 vt100compat = 1; 00149 } else if (!strncmp(term, "Eterm", 5)) { 00150 /* Both entries which start with Eterm support color */ 00151 vt100compat = 1; 00152 } else if (!strcmp(term, "vt100")) { 00153 vt100compat = 1; 00154 } else if (!strncmp(term, "crt", 3)) { 00155 /* Both crt terminals support color */ 00156 vt100compat = 1; 00157 } 00158 } 00159 00160 end: 00161 if (vt100compat) { 00162 /* Make commands show up in nice colors */ 00163 if (ast_opt_light_background) { 00164 snprintf(prepdata, sizeof(prepdata), "%c[%dm", ESC, COLOR_BROWN); 00165 snprintf(enddata, sizeof(enddata), "%c[%dm", ESC, COLOR_BLACK); 00166 snprintf(quitdata, sizeof(quitdata), "%c[0m", ESC); 00167 } else if (ast_opt_force_black_background) { 00168 snprintf(prepdata, sizeof(prepdata), "%c[%d;%d;%dm", ESC, ATTR_BRIGHT, COLOR_BROWN, COLOR_BLACK + 10); 00169 snprintf(enddata, sizeof(enddata), "%c[%d;%d;%dm", ESC, ATTR_RESET, COLOR_WHITE, COLOR_BLACK + 10); 00170 snprintf(quitdata, sizeof(quitdata), "%c[0m", ESC); 00171 } else { 00172 snprintf(prepdata, sizeof(prepdata), "%c[%d;%dm", ESC, ATTR_BRIGHT, COLOR_BROWN); 00173 snprintf(enddata, sizeof(enddata), "%c[%d;%dm", ESC, ATTR_RESET, COLOR_WHITE); 00174 snprintf(quitdata, sizeof(quitdata), "%c[0m", ESC); 00175 } 00176 } 00177 return 0; 00178 }
int ast_test_init | ( | void | ) |
Provided by test.c
Definition at line 932 of file test.c.
References ARRAY_LEN, and ast_cli_register_multiple().
Referenced by main().
00933 { 00934 #ifdef TEST_FRAMEWORK 00935 /* Register cli commands */ 00936 ast_cli_register_multiple(test_cli, ARRAY_LEN(test_cli)); 00937 #endif 00938 00939 return 0; 00940 }
int ast_timing_init | ( | void | ) |
Provided by timing.c
Definition at line 288 of file timing.c.
References ARRAY_LEN, ast_cli_register_multiple(), ast_heap_create(), cli_timing, timing_holder_cmp(), and timing_interfaces.
Referenced by main().
00289 { 00290 if (!(timing_interfaces = ast_heap_create(2, timing_holder_cmp, 0))) { 00291 return -1; 00292 } 00293 00294 return ast_cli_register_multiple(cli_timing, ARRAY_LEN(cli_timing)); 00295 }
int ast_tps_init | ( | void | ) |
Provided by taskprocessor.c
Definition at line 122 of file taskprocessor.c.
References ao2_container_alloc, ARRAY_LEN, ast_cli_register_multiple(), ast_cond_init, ast_log(), cli_ping_cond, LOG_ERROR, taskprocessor_clis, tps_cmp_cb(), tps_hash_cb(), TPS_MAX_BUCKETS, and tps_singletons.
Referenced by main().
00123 { 00124 if (!(tps_singletons = ao2_container_alloc(TPS_MAX_BUCKETS, tps_hash_cb, tps_cmp_cb))) { 00125 ast_log(LOG_ERROR, "taskprocessor container failed to initialize!\n"); 00126 return -1; 00127 } 00128 00129 ast_cond_init(&cli_ping_cond, NULL); 00130 00131 ast_cli_register_multiple(taskprocessor_clis, ARRAY_LEN(taskprocessor_clis)); 00132 return 0; 00133 }
int ast_xmldoc_load_documentation | ( | void | ) |
int astdb_init | ( | void | ) |
Provided by db.c
Definition at line 772 of file db.c.
References ARRAY_LEN, ast_cli_register_multiple(), ast_cond_init, ast_manager_register_xml, ast_pthread_create_background, cli_database, db_sync_thread(), dbinit(), EVENT_FLAG_REPORTING, EVENT_FLAG_SYSTEM, manager_dbdel(), manager_dbdeltree(), manager_dbget(), and manager_dbput().
Referenced by main().
00773 { 00774 pthread_t dont_care; 00775 00776 ast_cond_init(&dbcond, NULL); 00777 if (ast_pthread_create_background(&dont_care, NULL, db_sync_thread, NULL)) { 00778 return -1; 00779 } 00780 00781 dbinit(); 00782 ast_cli_register_multiple(cli_database, ARRAY_LEN(cli_database)); 00783 ast_manager_register_xml("DBGet", EVENT_FLAG_SYSTEM | EVENT_FLAG_REPORTING, manager_dbget); 00784 ast_manager_register_xml("DBPut", EVENT_FLAG_SYSTEM, manager_dbput); 00785 ast_manager_register_xml("DBDel", EVENT_FLAG_SYSTEM, manager_dbdel); 00786 ast_manager_register_xml("DBDelTree", EVENT_FLAG_SYSTEM, manager_dbdeltree); 00787 return 0; 00788 }
int astobj2_init | ( | void | ) |
Provided by astobj2.c
Definition at line 1125 of file astobj2.c.
References ARRAY_LEN, and ast_cli_register_multiple().
Referenced by main().
01126 { 01127 #ifdef AO2_DEBUG 01128 ast_cli_register_multiple(cli_astobj2, ARRAY_LEN(cli_astobj2)); 01129 #endif 01130 01131 return 0; 01132 }
void close_logger | ( | void | ) |
Provided by logger.c
Definition at line 1150 of file logger.c.
References ast_cond_signal, AST_LIST_LOCK, AST_LIST_UNLOCK, AST_PTHREADT_NULL, AST_RWLIST_TRAVERSE, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, close_logger_thread, f, logchannel::list, logcond, logthread, and qlog.
Referenced by really_quit().
01151 { 01152 struct logchannel *f = NULL; 01153 01154 logger_initialized = 0; 01155 01156 /* Stop logger thread */ 01157 AST_LIST_LOCK(&logmsgs); 01158 close_logger_thread = 1; 01159 ast_cond_signal(&logcond); 01160 AST_LIST_UNLOCK(&logmsgs); 01161 01162 if (logthread != AST_PTHREADT_NULL) 01163 pthread_join(logthread, NULL); 01164 01165 AST_RWLIST_WRLOCK(&logchannels); 01166 01167 if (qlog) { 01168 fclose(qlog); 01169 qlog = NULL; 01170 } 01171 01172 AST_RWLIST_TRAVERSE(&logchannels, f, list) { 01173 if (f->fileptr && (f->fileptr != stdout) && (f->fileptr != stderr)) { 01174 fclose(f->fileptr); 01175 f->fileptr = NULL; 01176 } 01177 } 01178 01179 closelog(); /* syslog */ 01180 01181 AST_RWLIST_UNLOCK(&logchannels); 01182 01183 return; 01184 }
int dnsmgr_init | ( | void | ) |
Provided by dnsmgr.c
Definition at line 393 of file dnsmgr.c.
References ast_cli_register(), ast_log(), cli_refresh, cli_reload, cli_status, do_reload(), LOG_ERROR, sched, and sched_context_create().
Referenced by main().
00394 { 00395 if (!(sched = sched_context_create())) { 00396 ast_log(LOG_ERROR, "Unable to create schedule context.\n"); 00397 return -1; 00398 } 00399 ast_cli_register(&cli_reload); 00400 ast_cli_register(&cli_status); 00401 ast_cli_register(&cli_refresh); 00402 return do_reload(1); 00403 }
int dnsmgr_reload | ( | void | ) |
Provided by dnsmgr.c
Definition at line 405 of file dnsmgr.c.
References do_reload().
00406 { 00407 return do_reload(0); 00408 }
void dnsmgr_start_refresh | ( | void | ) |
Provided by dnsmgr.c
Definition at line 287 of file dnsmgr.c.
References ast_sched_add_variable(), AST_SCHED_DEL, master_refresh_info, refresh_list(), and sched.
Referenced by main().
00288 { 00289 if (refresh_sched > -1) { 00290 AST_SCHED_DEL(sched, refresh_sched); 00291 refresh_sched = ast_sched_add_variable(sched, 100, refresh_list, &master_refresh_info, 1); 00292 } 00293 }
int init_framer | ( | void | ) |
Provided by frame.c
Definition at line 981 of file frame.c.
References ARRAY_LEN, ast_cli_register_multiple(), and my_clis.
Referenced by main().
00982 { 00983 ast_cli_register_multiple(my_clis, ARRAY_LEN(my_clis)); 00984 return 0; 00985 }
int init_logger | ( | void | ) |
Provided by logger.c
Definition at line 1126 of file logger.c.
References ARRAY_LEN, ast_cli_register_multiple(), ast_cond_destroy, ast_cond_init, ast_config_AST_LOG_DIR, ast_mkdir(), ast_pthread_create, cli_logger, init_logger_chain(), logcond, logger_thread(), and logthread.
Referenced by main().
01127 { 01128 /* auto rotate if sig SIGXFSZ comes a-knockin */ 01129 sigaction(SIGXFSZ, &handle_SIGXFSZ, NULL); 01130 01131 /* start logger thread */ 01132 ast_cond_init(&logcond, NULL); 01133 if (ast_pthread_create(&logthread, NULL, logger_thread, NULL) < 0) { 01134 ast_cond_destroy(&logcond); 01135 return -1; 01136 } 01137 01138 /* register the logger cli commands */ 01139 ast_cli_register_multiple(cli_logger, ARRAY_LEN(cli_logger)); 01140 01141 ast_mkdir(ast_config_AST_LOG_DIR, 0777); 01142 01143 /* create log channels */ 01144 init_logger_chain(0 /* locked */); 01145 logger_initialized = 1; 01146 01147 return 0; 01148 }
int load_modules | ( | unsigned | int | ) |
Provided by loader.c
Definition at line 1005 of file loader.c.
References add_to_load_order(), ast_config_load2(), ast_debug, AST_LIST_HEAD_INIT_NOLOCK, AST_LIST_LOCK, ast_log(), AST_MODULE_CONFIG, ast_variable_browse(), ast_verb, config_flags, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEMISSING, embedded_module_list, embedding, module_list::first, module_list::last, LOG_WARNING, ast_variable::name, ast_variable::next, and ast_variable::value.
Referenced by main().
01006 { 01007 struct ast_config *cfg; 01008 struct ast_module *mod; 01009 struct load_order_entry *order; 01010 struct ast_variable *v; 01011 unsigned int load_count; 01012 struct load_order load_order; 01013 int res = 0; 01014 struct ast_flags config_flags = { 0 }; 01015 int modulecount = 0; 01016 01017 #ifdef LOADABLE_MODULES 01018 struct dirent *dirent; 01019 DIR *dir; 01020 #endif 01021 01022 /* all embedded modules have registered themselves by now */ 01023 embedding = 0; 01024 01025 ast_verb(1, "Asterisk Dynamic Loader Starting:\n"); 01026 01027 AST_LIST_HEAD_INIT_NOLOCK(&load_order); 01028 01029 AST_LIST_LOCK(&module_list); 01030 01031 if (embedded_module_list.first) { 01032 module_list.first = embedded_module_list.first; 01033 module_list.last = embedded_module_list.last; 01034 embedded_module_list.first = NULL; 01035 } 01036 01037 cfg = ast_config_load2(AST_MODULE_CONFIG, "" /* core, can't reload */, config_flags); 01038 if (cfg == CONFIG_STATUS_FILEMISSING || cfg == CONFIG_STATUS_FILEINVALID) { 01039 ast_log(LOG_WARNING, "No '%s' found, no modules will be loaded.\n", AST_MODULE_CONFIG); 01040 goto done; 01041 } 01042 01043 /* first, find all the modules we have been explicitly requested to load */ 01044 for (v = ast_variable_browse(cfg, "modules"); v; v = v->next) { 01045 if (!strcasecmp(v->name, preload_only ? "preload" : "load")) { 01046 add_to_load_order(v->value, &load_order, 0); 01047 } 01048 if (!strcasecmp(v->name, preload_only ? "preload-require" : "require")) { 01049 /* Add the module to the list and make sure it's required */ 01050 add_to_load_order(v->value, &load_order, 1); 01051 ast_debug(2, "Adding module to required list: %s (%s)\n", v->value, v->name); 01052 } 01053 01054 } 01055 01056 /* check if 'autoload' is on */ 01057 if (!preload_only && ast_true(ast_variable_retrieve(cfg, "modules", "autoload"))) { 01058 /* if so, first add all the embedded modules that are not already running to the load order */ 01059 AST_LIST_TRAVERSE(&module_list, mod, entry) { 01060 /* if it's not embedded, skip it */ 01061 if (mod->lib) 01062 continue; 01063 01064 if (mod->flags.running) 01065 continue; 01066 01067 order = add_to_load_order(mod->resource, &load_order, 0); 01068 } 01069 01070 #ifdef LOADABLE_MODULES 01071 /* if we are allowed to load dynamic modules, scan the directory for 01072 for all available modules and add them as well */ 01073 if ((dir = opendir(ast_config_AST_MODULE_DIR))) { 01074 while ((dirent = readdir(dir))) { 01075 int ld = strlen(dirent->d_name); 01076 01077 /* Must end in .so to load it. */ 01078 01079 if (ld < 4) 01080 continue; 01081 01082 if (strcasecmp(dirent->d_name + ld - 3, ".so")) 01083 continue; 01084 01085 /* if there is already a module by this name in the module_list, 01086 skip this file */ 01087 if (find_resource(dirent->d_name, 0)) 01088 continue; 01089 01090 add_to_load_order(dirent->d_name, &load_order, 0); 01091 } 01092 01093 closedir(dir); 01094 } else { 01095 if (!ast_opt_quiet) 01096 ast_log(LOG_WARNING, "Unable to open modules directory '%s'.\n", 01097 ast_config_AST_MODULE_DIR); 01098 } 01099 #endif 01100 } 01101 01102 /* now scan the config for any modules we are prohibited from loading and 01103 remove them from the load order */ 01104 for (v = ast_variable_browse(cfg, "modules"); v; v = v->next) { 01105 if (strcasecmp(v->name, "noload")) 01106 continue; 01107 01108 AST_LIST_TRAVERSE_SAFE_BEGIN(&load_order, order, entry) { 01109 if (!resource_name_match(order->resource, v->value)) { 01110 AST_LIST_REMOVE_CURRENT(entry); 01111 ast_free(order->resource); 01112 ast_free(order); 01113 } 01114 } 01115 AST_LIST_TRAVERSE_SAFE_END; 01116 } 01117 01118 /* we are done with the config now, all the information we need is in the 01119 load_order list */ 01120 ast_config_destroy(cfg); 01121 01122 load_count = 0; 01123 AST_LIST_TRAVERSE(&load_order, order, entry) 01124 load_count++; 01125 01126 if (load_count) 01127 ast_log(LOG_NOTICE, "%d modules will be loaded.\n", load_count); 01128 01129 /* first, load only modules that provide global symbols */ 01130 if ((res = load_resource_list(&load_order, 1, &modulecount)) < 0) { 01131 goto done; 01132 } 01133 01134 /* now load everything else */ 01135 if ((res = load_resource_list(&load_order, 0, &modulecount)) < 0) { 01136 goto done; 01137 } 01138 01139 done: 01140 while ((order = AST_LIST_REMOVE_HEAD(&load_order, entry))) { 01141 ast_free(order->resource); 01142 ast_free(order); 01143 } 01144 01145 AST_LIST_UNLOCK(&module_list); 01146 01147 /* Tell manager clients that are aggressive at logging in that we're done 01148 loading modules. If there's a DNS problem in chan_sip, we might not 01149 even reach this */ 01150 manager_event(EVENT_FLAG_SYSTEM, "ModuleLoadReport", "ModuleLoadStatus: Done\r\nModuleSelection: %s\r\nModuleCount: %d\r\n", preload_only ? "Preload" : "All", modulecount); 01151 01152 return res; 01153 }
int load_pbx | ( | void | ) |
Provided by pbx.c
Definition at line 10279 of file pbx.c.
References __ast_custom_function_register(), ARRAY_LEN, ast_cli_register_multiple(), ast_data_register_multiple_core, AST_EVENT_DEVICE_STATE, AST_EVENT_IE_END, ast_event_subscribe(), ast_log(), ast_manager_register_xml, ast_register_application2(), ast_taskprocessor_get(), ast_verb, builtins, device_state_cb(), device_state_sub, device_state_tps, EVENT_FLAG_CONFIG, EVENT_FLAG_REPORTING, exception_function, LOG_ERROR, LOG_WARNING, manager_show_dialplan(), pbx_cli, pbx_data_providers, and testtime_function.
Referenced by main().
10280 { 10281 int x; 10282 10283 /* Initialize the PBX */ 10284 ast_verb(1, "Asterisk PBX Core Initializing\n"); 10285 if (!(device_state_tps = ast_taskprocessor_get("pbx-core", 0))) { 10286 ast_log(LOG_WARNING, "failed to create pbx-core taskprocessor\n"); 10287 } 10288 10289 ast_verb(1, "Registering builtin applications:\n"); 10290 ast_cli_register_multiple(pbx_cli, ARRAY_LEN(pbx_cli)); 10291 ast_data_register_multiple_core(pbx_data_providers, ARRAY_LEN(pbx_data_providers)); 10292 __ast_custom_function_register(&exception_function, NULL); 10293 __ast_custom_function_register(&testtime_function, NULL); 10294 10295 /* Register builtin applications */ 10296 for (x = 0; x < ARRAY_LEN(builtins); x++) { 10297 ast_verb(1, "[%s]\n", builtins[x].name); 10298 if (ast_register_application2(builtins[x].name, builtins[x].execute, NULL, NULL, NULL)) { 10299 ast_log(LOG_ERROR, "Unable to register builtin application '%s'\n", builtins[x].name); 10300 return -1; 10301 } 10302 } 10303 10304 /* Register manager application */ 10305 ast_manager_register_xml("ShowDialPlan", EVENT_FLAG_CONFIG | EVENT_FLAG_REPORTING, manager_show_dialplan); 10306 10307 if (!(device_state_sub = ast_event_subscribe(AST_EVENT_DEVICE_STATE, device_state_cb, "pbx Device State Change", NULL, 10308 AST_EVENT_IE_END))) { 10309 return -1; 10310 } 10311 10312 return 0; 10313 }
void threadstorage_init | ( | void | ) |