Mon Mar 19 11:30:31 2012

Asterisk developer's documentation


_private.h File Reference

Prototypes for public functions only of internal interest,. More...

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)


Detailed Description

Prototypes for public functions only of internal interest,.

Definition in file _private.h.


Function Documentation

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().

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   ) 

Provided by file.c

Definition at line 1489 of file file.c.

Referenced by main().

01490 {
01491    ast_cli_register_multiple(cli_file, ARRAY_LEN(cli_file));
01492    return 0;
01493 }

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().

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.

Parameters:
name the name of the module to reload
This function reloads the specified module, or if no modules are specified, it will reload all loaded modules.

Note:
Modules are reloaded using their reload() functions, not unloading them and loading them again.
Returns:
0 if the specified module was not found.
Return values:
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.

Note:
This function will do nothing if the server has not completely started up. Once called, the reload queue is emptied, and further invocations will have no affect.

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   ) 

Load XML documentation. Provided by xmldoc.c.

Return values:
1 on error.
0 on success.

Referenced by main().

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   ) 

Provided by threadstorage.c

Definition at line 31 of file threadstorage.c.

Referenced by main().

00032 {
00033 }


Generated on Mon Mar 19 11:30:31 2012 for Asterisk - The Open Source Telephony Project by  doxygen 1.4.7