#include "asterisk/autoconfig.h"
#include "asterisk/compat.h"
#include "asterisk/paths.h"
Include dependency graph for asterisk.h:
This graph shows which files directly or indirectly include this file:
Go to the source code of this file.
Defines | |
#define | ASTERISK_FILE_VERSION(file, version) |
Register/unregister a source code file with the core. | |
#define | DEFAULT_LANGUAGE "en" |
#define | DEFAULT_SAMPLE_RATE 8000 |
#define | DEFAULT_SAMPLES_PER_MS ((DEFAULT_SAMPLE_RATE)/1000) |
#define | sched_setscheduler __PLEASE_USE_ast_set_priority_INSTEAD_OF_sched_setscheduler__ |
#define | setpriority __PLEASE_USE_ast_set_priority_INSTEAD_OF_setpriority__ |
Functions | |
int | ast_add_profile (const char *, uint64_t scale) |
support for event profiling | |
void | ast_builtins_init (void) |
initialize the _full_cmd string in * each of the builtins. | |
void | ast_channels_init (void) |
int64_t | ast_mark (int, int start1_stop0) |
int | ast_module_reload (const char *name) |
Reload asterisk modules. | |
int64_t | ast_profile (int, int64_t) |
int | ast_register_atexit (void(*func)(void)) |
Register a function to be executed before Asterisk exits. | |
void | ast_register_file_version (const char *file, const char *version) |
Register the version of a source code file with the core. | |
int | ast_set_priority (int) |
We set ourselves to a high priority, that we might pre-empt everything else. If your PBX has heavy activity on it, this is a good thing. | |
int | ast_term_init (void) |
void | ast_unregister_atexit (void(*func)(void)) |
Unregister a function registered with ast_register_atexit(). | |
void | ast_unregister_file_version (const char *file) |
Unregister a source code file from the core. | |
int | astdb_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) |
int | reload_logger (int) |
void | threadstorage_init (void) |
Variables | |
char | ast_config_AST_AGI_DIR [PATH_MAX] |
char | ast_config_AST_CONFIG_DIR [PATH_MAX] |
char | ast_config_AST_CONFIG_FILE [PATH_MAX] |
char | ast_config_AST_CTL [PATH_MAX] |
char | ast_config_AST_CTL_GROUP [PATH_MAX] |
char | ast_config_AST_CTL_OWNER [PATH_MAX] |
char | ast_config_AST_CTL_PERMISSIONS [PATH_MAX] |
char | ast_config_AST_DATA_DIR [PATH_MAX] |
char | ast_config_AST_DB [PATH_MAX] |
char | ast_config_AST_KEY_DIR [PATH_MAX] |
char | ast_config_AST_LOG_DIR [PATH_MAX] |
char | ast_config_AST_MODULE_DIR [PATH_MAX] |
char | ast_config_AST_MONITOR_DIR [PATH_MAX] |
char | ast_config_AST_PID [PATH_MAX] |
char | ast_config_AST_RUN_DIR [PATH_MAX] |
char | ast_config_AST_SOCKET [PATH_MAX] |
char | ast_config_AST_SPOOL_DIR [PATH_MAX] |
char | ast_config_AST_SYSTEM_NAME [20] |
char | ast_config_AST_VAR_DIR [PATH_MAX] |
Definition in file asterisk.h.
#define ASTERISK_FILE_VERSION | ( | file, | |||
version | ) |
Register/unregister a source code file with the core.
file | the source file name | |
version | the version string (typically a CVS revision keyword string) |
Example:
ASTERISK_FILE_VERSION(__FILE__, "\$Revision\$")
Definition at line 172 of file asterisk.h.
#define DEFAULT_LANGUAGE "en" |
Definition at line 34 of file asterisk.h.
#define DEFAULT_SAMPLE_RATE 8000 |
Definition at line 36 of file asterisk.h.
Referenced by check_header(), ogg_vorbis_rewrite(), setformat(), and write_header().
#define DEFAULT_SAMPLES_PER_MS ((DEFAULT_SAMPLE_RATE)/1000) |
Definition at line 37 of file asterisk.h.
Referenced by ast_stream_fastforward(), ast_stream_rewind(), and isAnsweringMachine().
#define sched_setscheduler __PLEASE_USE_ast_set_priority_INSTEAD_OF_sched_setscheduler__ |
#define setpriority __PLEASE_USE_ast_set_priority_INSTEAD_OF_setpriority__ |
int ast_add_profile | ( | const char * | name, | |
uint64_t | scale | |||
) |
support for event profiling
Definition at line 369 of file asterisk.c.
References ast_calloc, ast_realloc, ast_strdup, profile_data::e, profile_data::entries, profile_entry::events, profile_entry::mark, profile_data::max_size, profile_entry::name, prof_data, profile_entry::scale, and profile_entry::value.
Referenced by extension_match_core().
00370 { 00371 int l = sizeof(struct profile_data); 00372 int n = 10; /* default entries */ 00373 00374 if (prof_data == NULL) { 00375 prof_data = ast_calloc(1, l + n*sizeof(struct profile_entry)); 00376 if (prof_data == NULL) 00377 return -1; 00378 prof_data->entries = 0; 00379 prof_data->max_size = n; 00380 } 00381 if (prof_data->entries >= prof_data->max_size) { 00382 void *p; 00383 n = prof_data->max_size + 20; 00384 p = ast_realloc(prof_data, l + n*sizeof(struct profile_entry)); 00385 if (p == NULL) 00386 return -1; 00387 prof_data = p; 00388 prof_data->max_size = n; 00389 } 00390 n = prof_data->entries++; 00391 prof_data->e[n].name = ast_strdup(name); 00392 prof_data->e[n].value = 0; 00393 prof_data->e[n].events = 0; 00394 prof_data->e[n].mark = 0; 00395 prof_data->e[n].scale = scale; 00396 return n; 00397 }
void ast_builtins_init | ( | void | ) |
initialize the _full_cmd string in * each of the builtins.
Provided by cli.c
Definition at line 1496 of file cli.c.
References ast_cli_entry::_full_cmd, ast_cli_register_multiple(), ast_join(), ast_log(), builtins, cli_cli, ast_cli_entry::cmda, LOG_WARNING, and strdup.
Referenced by main().
01497 { 01498 struct ast_cli_entry *e; 01499 01500 for (e = builtins; e->cmda[0] != NULL; e++) { 01501 char buf[80]; 01502 ast_join(buf, sizeof(buf), e->cmda); 01503 e->_full_cmd = strdup(buf); 01504 if (!e->_full_cmd) 01505 ast_log(LOG_WARNING, "-- cannot allocate <%s>\n", buf); 01506 } 01507 01508 ast_cli_register_multiple(cli_cli, sizeof(cli_cli) / sizeof(struct ast_cli_entry)); 01509 }
void ast_channels_init | ( | void | ) |
Provided by channel.c
Definition at line 4473 of file channel.c.
References ast_cli_register_multiple(), and cli_channel.
Referenced by main().
04474 { 04475 ast_cli_register_multiple(cli_channel, sizeof(cli_channel) / sizeof(struct ast_cli_entry)); 04476 }
int64_t ast_mark | ( | int | , | |
int | start1_stop0 | |||
) |
Definition at line 431 of file asterisk.c.
References profile_data::e, profile_data::entries, profile_entry::events, profile_entry::mark, prof_data, rdtsc(), profile_entry::scale, and profile_entry::value.
Referenced by extension_match_core().
00432 { 00433 if (!prof_data || i < 0 || i > prof_data->entries) /* invalid index */ 00434 return 0; 00435 if (startstop == 1) 00436 prof_data->e[i].mark = rdtsc(); 00437 else { 00438 prof_data->e[i].mark = (rdtsc() - prof_data->e[i].mark); 00439 if (prof_data->e[i].scale > 1) 00440 prof_data->e[i].mark /= prof_data->e[i].scale; 00441 prof_data->e[i].value += prof_data->e[i].mark; 00442 prof_data->e[i].events++; 00443 } 00444 return prof_data->e[i].mark; 00445 }
int ast_module_reload | ( | const char * | name | ) |
Reload asterisk modules.
name | the name of the module to reload |
Definition at line 521 of file loader.c.
References ast_lastreloadtime, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_mutex_trylock(), ast_mutex_unlock(), ast_verbose(), ast_module::declined, ast_module_info::description, ast_module::flags, ast_module::info, option_verbose, ast_module_info::reload, resource_name_match(), ast_module::running, and VERBOSE_PREFIX_3.
Referenced by action_updateconfig(), handle_reload(), handle_reload_deprecated(), and monitor_sig_flags().
00522 { 00523 struct ast_module *cur; 00524 int res = 0; /* return value. 0 = not found, others, see below */ 00525 int i; 00526 00527 if (ast_mutex_trylock(&reloadlock)) { 00528 ast_verbose("The previous reload command didn't finish yet\n"); 00529 return -1; /* reload already in progress */ 00530 } 00531 ast_lastreloadtime = time(NULL); 00532 00533 /* Call "predefined" reload here first */ 00534 for (i = 0; reload_classes[i].name; i++) { 00535 if (!name || !strcasecmp(name, reload_classes[i].name)) { 00536 reload_classes[i].reload_fn(); /* XXX should check error ? */ 00537 res = 2; /* found and reloaded */ 00538 } 00539 } 00540 00541 if (name && res) { 00542 ast_mutex_unlock(&reloadlock); 00543 return res; 00544 } 00545 00546 AST_LIST_LOCK(&module_list); 00547 AST_LIST_TRAVERSE(&module_list, cur, entry) { 00548 const struct ast_module_info *info = cur->info; 00549 00550 if (name && resource_name_match(name, cur->resource)) 00551 continue; 00552 00553 if (!(cur->flags.running || cur->flags.declined)) 00554 continue; 00555 00556 if (!info->reload) { /* cannot be reloaded */ 00557 if (res < 1) /* store result if possible */ 00558 res = 1; /* 1 = no reload() method */ 00559 continue; 00560 } 00561 00562 res = 2; 00563 if (option_verbose > 2) 00564 ast_verbose(VERBOSE_PREFIX_3 "Reloading module '%s' (%s)\n", cur->resource, info->description); 00565 info->reload(); 00566 } 00567 AST_LIST_UNLOCK(&module_list); 00568 00569 ast_mutex_unlock(&reloadlock); 00570 00571 return res; 00572 }
int64_t ast_profile | ( | int | , | |
int64_t | ||||
) |
Definition at line 399 of file asterisk.c.
References profile_data::e, profile_data::entries, profile_entry::events, prof_data, profile_entry::scale, and profile_entry::value.
00400 { 00401 if (!prof_data || i < 0 || i > prof_data->entries) /* invalid index */ 00402 return 0; 00403 if (prof_data->e[i].scale > 1) 00404 delta /= prof_data->e[i].scale; 00405 prof_data->e[i].value += delta; 00406 prof_data->e[i].events++; 00407 return prof_data->e[i].value; 00408 }
int ast_register_atexit | ( | void(*)(void) | func | ) |
Register a function to be executed before Asterisk exits.
func | The callback function to use. |
Definition at line 699 of file asterisk.c.
References ast_calloc, AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_UNLOCK, and ast_unregister_atexit().
Referenced by do_reload(), and load_module().
00700 { 00701 int res = -1; 00702 struct ast_atexit *ae; 00703 ast_unregister_atexit(func); 00704 AST_LIST_LOCK(&atexits); 00705 if ((ae = ast_calloc(1, sizeof(*ae)))) { 00706 AST_LIST_INSERT_HEAD(&atexits, ae, list); 00707 ae->func = func; 00708 res = 0; 00709 } 00710 AST_LIST_UNLOCK(&atexits); 00711 return res; 00712 }
void ast_register_file_version | ( | const char * | file, | |
const char * | version | |||
) |
Register the version of a source code file with the core.
file | the source file name | |
version | the version string (typically a CVS revision keyword string) |
Definition at line 253 of file asterisk.c.
References ast_calloc, AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_UNLOCK, ast_strdupa, and ast_strip_quoted().
00254 { 00255 struct file_version *new; 00256 char *work; 00257 size_t version_length; 00258 00259 work = ast_strdupa(version); 00260 work = ast_strip(ast_strip_quoted(work, "$", "$")); 00261 version_length = strlen(work) + 1; 00262 00263 if (!(new = ast_calloc(1, sizeof(*new) + version_length))) 00264 return; 00265 00266 new->file = file; 00267 new->version = (char *) new + sizeof(*new); 00268 memcpy(new->version, work, version_length); 00269 AST_LIST_LOCK(&file_versions); 00270 AST_LIST_INSERT_HEAD(&file_versions, new, list); 00271 AST_LIST_UNLOCK(&file_versions); 00272 }
int ast_set_priority | ( | int | ) |
We set ourselves to a high priority, that we might pre-empt everything else. If your PBX has heavy activity on it, this is a good thing.
Provided by asterisk.c
Definition at line 1188 of file asterisk.c.
References ast_log(), ast_verbose(), LOG_WARNING, sched_setscheduler, and setpriority.
Referenced by app_exec(), ast_safe_system(), icesencode(), launch_script(), main(), mp3play(), NBScatplay(), send_waveform_to_fd(), spawn_mp3(), and spawn_ras().
01189 { 01190 struct sched_param sched; 01191 memset(&sched, 0, sizeof(sched)); 01192 #ifdef __linux__ 01193 if (pri) { 01194 sched.sched_priority = 10; 01195 if (sched_setscheduler(0, SCHED_RR, &sched)) { 01196 ast_log(LOG_WARNING, "Unable to set high priority\n"); 01197 return -1; 01198 } else 01199 if (option_verbose) 01200 ast_verbose("Set to realtime thread\n"); 01201 } else { 01202 sched.sched_priority = 0; 01203 /* According to the manpage, these parameters can never fail. */ 01204 sched_setscheduler(0, SCHED_OTHER, &sched); 01205 } 01206 #else 01207 if (pri) { 01208 if (setpriority(PRIO_PROCESS, 0, -10) == -1) { 01209 ast_log(LOG_WARNING, "Unable to set high priority\n"); 01210 return -1; 01211 } else 01212 if (option_verbose) 01213 ast_verbose("Set to high priority\n"); 01214 } else { 01215 /* According to the manpage, these parameters can never fail. */ 01216 setpriority(PRIO_PROCESS, 0, 0); 01217 } 01218 #endif 01219 return 0; 01220 }
int ast_term_init | ( | void | ) |
Provided by term.c
Definition at line 75 of file term.c.
References ast_opt_console, ast_opt_no_color, ast_opt_no_fork, ATTR_BRIGHT, ATTR_RESET, COLOR_BLACK, COLOR_BROWN, COLOR_WHITE, convshort(), and ESC.
Referenced by main().
00076 { 00077 char *term = getenv("TERM"); 00078 char termfile[256] = ""; 00079 char buffer[512] = ""; 00080 int termfd = -1, parseokay = 0, i; 00081 00082 if (!term) 00083 return 0; 00084 if (!ast_opt_console || ast_opt_no_color || !ast_opt_no_fork) 00085 return 0; 00086 00087 for (i=0 ;; i++) { 00088 if (termpath[i] == NULL) { 00089 break; 00090 } 00091 snprintf(termfile, sizeof(termfile), "%s/%c/%s", termpath[i], *term, term); 00092 termfd = open(termfile, O_RDONLY); 00093 if (termfd > -1) { 00094 break; 00095 } 00096 } 00097 if (termfd > -1) { 00098 int actsize = read(termfd, buffer, sizeof(buffer) - 1); 00099 short sz_names = convshort(buffer + 2); 00100 short sz_bools = convshort(buffer + 4); 00101 short n_nums = convshort(buffer + 6); 00102 00103 /* if ((sz_names + sz_bools) & 1) 00104 sz_bools++; */ 00105 00106 if (sz_names + sz_bools + n_nums < actsize) { 00107 /* Offset 13 is defined in /usr/include/term.h, though we do not 00108 * include it here, as it conflicts with include/asterisk/term.h */ 00109 short max_colors = convshort(buffer + 12 + sz_names + sz_bools + 13 * 2); 00110 if (max_colors > 0) { 00111 vt100compat = 1; 00112 } 00113 parseokay = 1; 00114 } 00115 close(termfd); 00116 } 00117 00118 if (!parseokay) { 00119 /* These comparisons should not be substrings nor case-insensitive, as 00120 * terminal types are very particular about how they treat suffixes and 00121 * capitalization. For example, terminal type 'linux-m' does NOT 00122 * support color, while 'linux' does. Not even all vt100* terminals 00123 * support color, either (e.g. 'vt100+fnkeys'). */ 00124 if (!strcmp(term, "linux")) { 00125 vt100compat = 1; 00126 } else if (!strcmp(term, "xterm")) { 00127 vt100compat = 1; 00128 } else if (!strcmp(term, "xterm-color")) { 00129 vt100compat = 1; 00130 } else if (!strncmp(term, "Eterm", 5)) { 00131 /* Both entries which start with Eterm support color */ 00132 vt100compat = 1; 00133 } else if (!strcmp(term, "vt100")) { 00134 vt100compat = 1; 00135 } else if (!strncmp(term, "crt", 3)) { 00136 /* Both crt terminals support color */ 00137 vt100compat = 1; 00138 } 00139 } 00140 00141 if (vt100compat) { 00142 /* Make commands show up in nice colors */ 00143 snprintf(prepdata, sizeof(prepdata), "%c[%d;%d;%dm", ESC, ATTR_BRIGHT, COLOR_BROWN, COLOR_BLACK + 10); 00144 snprintf(enddata, sizeof(enddata), "%c[%d;%d;%dm", ESC, ATTR_RESET, COLOR_WHITE, COLOR_BLACK + 10); 00145 snprintf(quitdata, sizeof(quitdata), "%c[0m", ESC); 00146 } 00147 return 0; 00148 }
void ast_unregister_atexit | ( | void(*)(void) | func | ) |
Unregister a function registered with ast_register_atexit().
func | The callback function to unregister. |
Definition at line 714 of file asterisk.c.
References AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, and ast_atexit::func.
Referenced by ast_register_atexit(), and do_reload().
00715 { 00716 struct ast_atexit *ae; 00717 AST_LIST_LOCK(&atexits); 00718 AST_LIST_TRAVERSE_SAFE_BEGIN(&atexits, ae, list) { 00719 if (ae->func == func) { 00720 AST_LIST_REMOVE_CURRENT(&atexits, list); 00721 break; 00722 } 00723 } 00724 AST_LIST_TRAVERSE_SAFE_END 00725 AST_LIST_UNLOCK(&atexits); 00726 }
void ast_unregister_file_version | ( | const char * | file | ) |
Unregister a source code file from the core.
file | the source file name |
Definition at line 274 of file asterisk.c.
References AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, and free.
00275 { 00276 struct file_version *find; 00277 00278 AST_LIST_LOCK(&file_versions); 00279 AST_LIST_TRAVERSE_SAFE_BEGIN(&file_versions, find, list) { 00280 if (!strcasecmp(find->file, file)) { 00281 AST_LIST_REMOVE_CURRENT(&file_versions, list); 00282 break; 00283 } 00284 } 00285 AST_LIST_TRAVERSE_SAFE_END; 00286 AST_LIST_UNLOCK(&file_versions); 00287 if (find) 00288 free(find); 00289 }
int astdb_init | ( | void | ) |
Provided by db.c
Definition at line 588 of file db.c.
References ast_cli_register_multiple(), ast_manager_register, cli_database, dbinit(), EVENT_FLAG_SYSTEM, manager_dbget(), and manager_dbput().
Referenced by main().
00589 { 00590 dbinit(); 00591 ast_cli_register_multiple(cli_database, sizeof(cli_database) / sizeof(struct ast_cli_entry)); 00592 ast_manager_register("DBGet", EVENT_FLAG_SYSTEM, manager_dbget, "Get DB Entry"); 00593 ast_manager_register("DBPut", EVENT_FLAG_SYSTEM, manager_dbput, "Put DB Entry"); 00594 return 0; 00595 }
void close_logger | ( | void | ) |
Provided by logger.c
Definition at line 620 of file logger.c.
References AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, eventlog, f, and qlog.
Referenced by quit_handler().
00621 { 00622 struct logchannel *f; 00623 00624 AST_LIST_LOCK(&logchannels); 00625 00626 if (eventlog) { 00627 fclose(eventlog); 00628 eventlog = NULL; 00629 } 00630 00631 if (qlog) { 00632 fclose(qlog); 00633 qlog = NULL; 00634 } 00635 00636 AST_LIST_TRAVERSE(&logchannels, f, list) { 00637 if (f->fileptr && (f->fileptr != stdout) && (f->fileptr != stderr)) { 00638 fclose(f->fileptr); 00639 f->fileptr = NULL; 00640 } 00641 } 00642 00643 closelog(); /* syslog */ 00644 00645 AST_LIST_UNLOCK(&logchannels); 00646 00647 return; 00648 }
int dnsmgr_init | ( | void | ) |
Provided by dnsmgr.c
Definition at line 336 of file dnsmgr.c.
References ast_cli_register(), ast_log(), cli_reload, cli_status, do_reload(), LOG_ERROR, sched, and sched_context_create().
Referenced by main().
00337 { 00338 if (!(sched = sched_context_create())) { 00339 ast_log(LOG_ERROR, "Unable to create schedule context.\n"); 00340 return -1; 00341 } 00342 ast_cli_register(&cli_reload); 00343 ast_cli_register(&cli_status); 00344 return do_reload(1); 00345 }
int dnsmgr_reload | ( | void | ) |
Provided by dnsmgr.c
Definition at line 347 of file dnsmgr.c.
References do_reload().
00348 { 00349 return do_reload(0); 00350 }
void dnsmgr_start_refresh | ( | void | ) |
Provided by dnsmgr.c
Definition at line 251 of file dnsmgr.c.
References ast_sched_add_variable(), ast_sched_del(), master_refresh_info, refresh_list(), and sched.
Referenced by main().
00252 { 00253 if (refresh_sched > -1) { 00254 ast_sched_del(sched, refresh_sched); 00255 refresh_sched = ast_sched_add_variable(sched, 100, refresh_list, &master_refresh_info, 1); 00256 } 00257 }
int init_framer | ( | void | ) |
Provided by frame.c
Definition at line 1036 of file frame.c.
References ast_cli_register_multiple(), and my_clis.
Referenced by main().
01037 { 01038 ast_cli_register_multiple(my_clis, sizeof(my_clis) / sizeof(struct ast_cli_entry)); 01039 return 0; 01040 }
int init_logger | ( | void | ) |
Provided by logger.c
Definition at line 581 of file logger.c.
References ast_cli_register_multiple(), ast_config_AST_LOG_DIR, ast_log(), ast_queue_log(), ast_verbose(), cli_logger, eventlog, EVENTLOG, handle_SIGXFSZ(), init_logger_chain(), LOG_ERROR, LOG_EVENT, logfiles, option_verbose, qlog, and QUEUELOG.
Referenced by main().
00582 { 00583 char tmp[256]; 00584 int res = 0; 00585 00586 /* auto rotate if sig SIGXFSZ comes a-knockin */ 00587 (void) signal(SIGXFSZ,(void *) handle_SIGXFSZ); 00588 00589 /* register the logger cli commands */ 00590 ast_cli_register_multiple(cli_logger, sizeof(cli_logger) / sizeof(struct ast_cli_entry)); 00591 00592 mkdir((char *)ast_config_AST_LOG_DIR, 0755); 00593 00594 /* create log channels */ 00595 init_logger_chain(); 00596 00597 /* create the eventlog */ 00598 if (logfiles.event_log) { 00599 mkdir((char *)ast_config_AST_LOG_DIR, 0755); 00600 snprintf(tmp, sizeof(tmp), "%s/%s", (char *)ast_config_AST_LOG_DIR, EVENTLOG); 00601 eventlog = fopen((char *)tmp, "a"); 00602 if (eventlog) { 00603 ast_log(LOG_EVENT, "Started Asterisk Event Logger\n"); 00604 if (option_verbose) 00605 ast_verbose("Asterisk Event Logger Started %s\n",(char *)tmp); 00606 } else { 00607 ast_log(LOG_ERROR, "Unable to create event log: %s\n", strerror(errno)); 00608 res = -1; 00609 } 00610 } 00611 00612 if (logfiles.queue_log) { 00613 snprintf(tmp, sizeof(tmp), "%s/%s", (char *)ast_config_AST_LOG_DIR, QUEUELOG); 00614 qlog = fopen(tmp, "a"); 00615 ast_queue_log("NONE", "NONE", "NONE", "QUEUESTART", "%s", ""); 00616 } 00617 return res; 00618 }
int load_modules | ( | unsigned | int | ) |
Provided by loader.c
Definition at line 700 of file loader.c.
References add_to_load_order(), ast_config_AST_MODULE_DIR, ast_config_load(), AST_LIST_HEAD_INIT_NOLOCK, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, ast_log(), AST_MODULE_CONFIG, ast_opt_quiet, ast_true(), ast_variable_browse(), ast_variable_retrieve(), ast_verbose(), embedding, find_resource(), ast_module::flags, free, ast_module::lib, ast_variable::name, ast_variable::next, option_verbose, load_order_entry::resource, resource_name_match(), ast_module::running, and ast_variable::value.
Referenced by main().
00701 { 00702 struct ast_config *cfg; 00703 struct ast_module *mod; 00704 struct load_order_entry *order; 00705 struct ast_variable *v; 00706 unsigned int load_count; 00707 struct load_order load_order; 00708 int res = 0; 00709 #if LOADABLE_MODULES 00710 struct dirent *dirent; 00711 DIR *dir; 00712 #endif 00713 00714 /* all embedded modules have registered themselves by now */ 00715 embedding = 0; 00716 00717 if (option_verbose) 00718 ast_verbose("Asterisk Dynamic Loader Starting:\n"); 00719 00720 AST_LIST_HEAD_INIT_NOLOCK(&load_order); 00721 00722 AST_LIST_LOCK(&module_list); 00723 00724 if (!(cfg = ast_config_load(AST_MODULE_CONFIG))) { 00725 ast_log(LOG_WARNING, "No '%s' found, no modules will be loaded.\n", AST_MODULE_CONFIG); 00726 goto done; 00727 } 00728 00729 /* first, find all the modules we have been explicitly requested to load */ 00730 for (v = ast_variable_browse(cfg, "modules"); v; v = v->next) { 00731 if (!strcasecmp(v->name, preload_only ? "preload" : "load")) 00732 add_to_load_order(v->value, &load_order); 00733 } 00734 00735 /* check if 'autoload' is on */ 00736 if (!preload_only && ast_true(ast_variable_retrieve(cfg, "modules", "autoload"))) { 00737 /* if so, first add all the embedded modules that are not already running to the load order */ 00738 AST_LIST_TRAVERSE(&module_list, mod, entry) { 00739 /* if it's not embedded, skip it */ 00740 if (mod->lib) 00741 continue; 00742 00743 if (mod->flags.running) 00744 continue; 00745 00746 order = add_to_load_order(mod->resource, &load_order); 00747 } 00748 00749 #if LOADABLE_MODULES 00750 /* if we are allowed to load dynamic modules, scan the directory for 00751 for all available modules and add them as well */ 00752 if ((dir = opendir(ast_config_AST_MODULE_DIR))) { 00753 while ((dirent = readdir(dir))) { 00754 int ld = strlen(dirent->d_name); 00755 00756 /* Must end in .so to load it. */ 00757 00758 if (ld < 4) 00759 continue; 00760 00761 if (strcasecmp(dirent->d_name + ld - 3, ".so")) 00762 continue; 00763 00764 /* if there is already a module by this name in the module_list, 00765 skip this file */ 00766 if (find_resource(dirent->d_name, 0)) 00767 continue; 00768 00769 add_to_load_order(dirent->d_name, &load_order); 00770 } 00771 00772 closedir(dir); 00773 } else { 00774 if (!ast_opt_quiet) 00775 ast_log(LOG_WARNING, "Unable to open modules directory '%s'.\n", 00776 ast_config_AST_MODULE_DIR); 00777 } 00778 #endif 00779 } 00780 00781 /* now scan the config for any modules we are prohibited from loading and 00782 remove them from the load order */ 00783 for (v = ast_variable_browse(cfg, "modules"); v; v = v->next) { 00784 if (strcasecmp(v->name, "noload")) 00785 continue; 00786 00787 AST_LIST_TRAVERSE_SAFE_BEGIN(&load_order, order, entry) { 00788 if (!resource_name_match(order->resource, v->value)) { 00789 AST_LIST_REMOVE_CURRENT(&load_order, entry); 00790 free(order->resource); 00791 free(order); 00792 } 00793 } 00794 AST_LIST_TRAVERSE_SAFE_END; 00795 } 00796 00797 /* we are done with the config now, all the information we need is in the 00798 load_order list */ 00799 ast_config_destroy(cfg); 00800 00801 load_count = 0; 00802 AST_LIST_TRAVERSE(&load_order, order, entry) 00803 load_count++; 00804 00805 if (load_count) 00806 ast_log(LOG_NOTICE, "%d modules will be loaded.\n", load_count); 00807 00808 /* first, load only modules that provide global symbols */ 00809 AST_LIST_TRAVERSE_SAFE_BEGIN(&load_order, order, entry) { 00810 switch (load_resource(order->resource, 1)) { 00811 case AST_MODULE_LOAD_SUCCESS: 00812 case AST_MODULE_LOAD_DECLINE: 00813 AST_LIST_REMOVE_CURRENT(&load_order, entry); 00814 free(order->resource); 00815 free(order); 00816 break; 00817 case AST_MODULE_LOAD_FAILURE: 00818 res = -1; 00819 goto done; 00820 case AST_MODULE_LOAD_SKIP: 00821 /* try again later */ 00822 break; 00823 } 00824 } 00825 AST_LIST_TRAVERSE_SAFE_END; 00826 00827 /* now load everything else */ 00828 AST_LIST_TRAVERSE_SAFE_BEGIN(&load_order, order, entry) { 00829 switch (load_resource(order->resource, 0)) { 00830 case AST_MODULE_LOAD_SUCCESS: 00831 case AST_MODULE_LOAD_DECLINE: 00832 AST_LIST_REMOVE_CURRENT(&load_order, entry); 00833 free(order->resource); 00834 free(order); 00835 break; 00836 case AST_MODULE_LOAD_FAILURE: 00837 res = -1; 00838 goto done; 00839 case AST_MODULE_LOAD_SKIP: 00840 /* should not happen */ 00841 break; 00842 } 00843 } 00844 AST_LIST_TRAVERSE_SAFE_END; 00845 00846 done: 00847 while ((order = AST_LIST_REMOVE_HEAD(&load_order, entry))) { 00848 free(order->resource); 00849 free(order); 00850 } 00851 00852 AST_LIST_UNLOCK(&module_list); 00853 00854 return res; 00855 }
int load_pbx | ( | void | ) |
Provided by pbx.c
Definition at line 6059 of file pbx.c.
References ast_cli_register_multiple(), ast_log(), ast_register_application(), ast_verbose(), builtins, LOG_ERROR, option_verbose, pbx_cli, and VERBOSE_PREFIX_1.
Referenced by main().
06060 { 06061 int x; 06062 06063 /* Initialize the PBX */ 06064 if (option_verbose) { 06065 ast_verbose( "Asterisk PBX Core Initializing\n"); 06066 ast_verbose( "Registering builtin applications:\n"); 06067 } 06068 ast_cli_register_multiple(pbx_cli, sizeof(pbx_cli) / sizeof(struct ast_cli_entry)); 06069 06070 /* Register builtin applications */ 06071 for (x=0; x<sizeof(builtins) / sizeof(struct pbx_builtin); x++) { 06072 if (option_verbose) 06073 ast_verbose( VERBOSE_PREFIX_1 "[%s]\n", builtins[x].name); 06074 if (ast_register_application(builtins[x].name, builtins[x].execute, builtins[x].synopsis, builtins[x].description)) { 06075 ast_log(LOG_ERROR, "Unable to register builtin application '%s'\n", builtins[x].name); 06076 return -1; 06077 } 06078 } 06079 return 0; 06080 }
int reload_logger | ( | int | ) |
Provided by logger.c
Definition at line 368 of file logger.c.
References ast_config_AST_LOG_DIR, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log(), ast_queue_log(), ast_verbose(), EVENT_FLAG_SYSTEM, EVENTLOG, eventlog, f, init_logger_chain(), LOG_ERROR, LOG_EVENT, logfiles, manager_event(), option_verbose, qlog, and QUEUELOG.
Referenced by ast_log(), handle_logger_reload(), and handle_logger_rotate().
00369 { 00370 char old[PATH_MAX] = ""; 00371 char new[PATH_MAX]; 00372 int event_rotate = rotate, queue_rotate = rotate; 00373 struct logchannel *f; 00374 FILE *myf; 00375 int x, res = 0; 00376 00377 AST_LIST_LOCK(&logchannels); 00378 00379 if (eventlog) 00380 fclose(eventlog); 00381 else 00382 event_rotate = 0; 00383 eventlog = NULL; 00384 00385 if (qlog) 00386 fclose(qlog); 00387 else 00388 queue_rotate = 0; 00389 qlog = NULL; 00390 00391 mkdir((char *)ast_config_AST_LOG_DIR, 0755); 00392 00393 AST_LIST_TRAVERSE(&logchannels, f, list) { 00394 if (f->disabled) { 00395 f->disabled = 0; /* Re-enable logging at reload */ 00396 manager_event(EVENT_FLAG_SYSTEM, "LogChannel", "Channel: %s\r\nEnabled: Yes\r\n", f->filename); 00397 } 00398 if (f->fileptr && (f->fileptr != stdout) && (f->fileptr != stderr)) { 00399 fclose(f->fileptr); /* Close file */ 00400 f->fileptr = NULL; 00401 if (rotate) { 00402 ast_copy_string(old, f->filename, sizeof(old)); 00403 00404 for (x = 0; ; x++) { 00405 snprintf(new, sizeof(new), "%s.%d", f->filename, x); 00406 myf = fopen((char *)new, "r"); 00407 if (myf) 00408 fclose(myf); 00409 else 00410 break; 00411 } 00412 00413 /* do it */ 00414 if (rename(old,new)) 00415 fprintf(stderr, "Unable to rename file '%s' to '%s'\n", old, new); 00416 } 00417 } 00418 } 00419 00420 filesize_reload_needed = 0; 00421 00422 init_logger_chain(); 00423 00424 if (logfiles.event_log) { 00425 snprintf(old, sizeof(old), "%s/%s", (char *)ast_config_AST_LOG_DIR, EVENTLOG); 00426 if (event_rotate) { 00427 for (x=0;;x++) { 00428 snprintf(new, sizeof(new), "%s/%s.%d", (char *)ast_config_AST_LOG_DIR, EVENTLOG,x); 00429 myf = fopen((char *)new, "r"); 00430 if (myf) /* File exists */ 00431 fclose(myf); 00432 else 00433 break; 00434 } 00435 00436 /* do it */ 00437 if (rename(old,new)) 00438 ast_log(LOG_ERROR, "Unable to rename file '%s' to '%s'\n", old, new); 00439 } 00440 00441 eventlog = fopen(old, "a"); 00442 if (eventlog) { 00443 ast_log(LOG_EVENT, "Restarted Asterisk Event Logger\n"); 00444 if (option_verbose) 00445 ast_verbose("Asterisk Event Logger restarted\n"); 00446 } else { 00447 ast_log(LOG_ERROR, "Unable to create event log: %s\n", strerror(errno)); 00448 res = -1; 00449 } 00450 } 00451 00452 if (logfiles.queue_log) { 00453 snprintf(old, sizeof(old), "%s/%s", (char *)ast_config_AST_LOG_DIR, QUEUELOG); 00454 if (queue_rotate) { 00455 for (x = 0; ; x++) { 00456 snprintf(new, sizeof(new), "%s/%s.%d", (char *)ast_config_AST_LOG_DIR, QUEUELOG, x); 00457 myf = fopen((char *)new, "r"); 00458 if (myf) /* File exists */ 00459 fclose(myf); 00460 else 00461 break; 00462 } 00463 00464 /* do it */ 00465 if (rename(old, new)) 00466 ast_log(LOG_ERROR, "Unable to rename file '%s' to '%s'\n", old, new); 00467 } 00468 00469 qlog = fopen(old, "a"); 00470 if (qlog) { 00471 ast_queue_log("NONE", "NONE", "NONE", "CONFIGRELOAD", "%s", ""); 00472 ast_log(LOG_EVENT, "Restarted Asterisk Queue Logger\n"); 00473 if (option_verbose) 00474 ast_verbose("Asterisk Queue Logger restarted\n"); 00475 } else { 00476 ast_log(LOG_ERROR, "Unable to create queue log: %s\n", strerror(errno)); 00477 res = -1; 00478 } 00479 } 00480 00481 AST_LIST_UNLOCK(&logchannels); 00482 00483 return res; 00484 }
void threadstorage_init | ( | void | ) |
char ast_config_AST_AGI_DIR[PATH_MAX] |
Definition at line 210 of file asterisk.c.
char ast_config_AST_CONFIG_DIR[PATH_MAX] |
Definition at line 202 of file asterisk.c.
char ast_config_AST_CONFIG_FILE[PATH_MAX] |
Definition at line 203 of file asterisk.c.
char ast_config_AST_CTL[PATH_MAX] |
Definition at line 221 of file asterisk.c.
char ast_config_AST_CTL_GROUP[PATH_MAX] |
Definition at line 220 of file asterisk.c.
char ast_config_AST_CTL_OWNER[PATH_MAX] |
Definition at line 219 of file asterisk.c.
char ast_config_AST_CTL_PERMISSIONS[PATH_MAX] |
Definition at line 218 of file asterisk.c.
char ast_config_AST_DATA_DIR[PATH_MAX] |
Definition at line 208 of file asterisk.c.
char ast_config_AST_DB[PATH_MAX] |
Definition at line 211 of file asterisk.c.
char ast_config_AST_KEY_DIR[PATH_MAX] |
Definition at line 212 of file asterisk.c.
char ast_config_AST_LOG_DIR[PATH_MAX] |
Definition at line 209 of file asterisk.c.
char ast_config_AST_MODULE_DIR[PATH_MAX] |
Definition at line 204 of file asterisk.c.
char ast_config_AST_MONITOR_DIR[PATH_MAX] |
Definition at line 206 of file asterisk.c.
char ast_config_AST_PID[PATH_MAX] |
Definition at line 213 of file asterisk.c.
char ast_config_AST_RUN_DIR[PATH_MAX] |
Definition at line 215 of file asterisk.c.
char ast_config_AST_SOCKET[PATH_MAX] |
Definition at line 214 of file asterisk.c.
char ast_config_AST_SPOOL_DIR[PATH_MAX] |
Definition at line 205 of file asterisk.c.
char ast_config_AST_SYSTEM_NAME[20] |
Definition at line 222 of file asterisk.c.
char ast_config_AST_VAR_DIR[PATH_MAX] |
Definition at line 207 of file asterisk.c.