154#undef sched_setscheduler
163#include <sys/resource.h>
167#if defined(HAVE_SYSINFO)
168#include <sys/sysinfo.h>
169#elif defined(HAVE_SYSCTL)
170#include <sys/param.h>
171#include <sys/sysctl.h>
172#include <sys/vmmeter.h>
173#if defined(__FreeBSD__) || defined(__DragonFly__)
174#include <vm/vm_param.h>
176#if defined(HAVE_SWAPCTL)
185#include <sys/loadavg.h>
189#include <sys/prctl.h>
191#include <sys/capability.h>
247#include "../defaults.h"
292#define AF_LOCAL AF_UNIX
293#define PF_LOCAL PF_UNIX
296#define AST_MAX_CONNECTS 128
300#define COPYRIGHT_TAG "Copyright (C) 1999 - 2022, Sangoma Technologies Corporation and others."
303#define WELCOME_MESSAGE \
304 ast_verbose("Asterisk %s, " COPYRIGHT_TAG "\n" \
305 "Created by Mark Spencer <markster@digium.com>\n" \
306 "Asterisk comes with ABSOLUTELY NO WARRANTY; type 'core show warranty' for details.\n" \
307 "This is free software, with components licensed under the GNU General Public\n" \
308 "License version 2 and other licenses; you are welcome to redistribute it under\n" \
309 "certain conditions. Type 'core show license' for details.\n" \
310 "=========================================================================\n", ast_get_version()) \
352static void asterisk_daemon(
int isroot,
const char *runuser,
const char *rungroup);
393static cap_t child_cap;
404#if !defined(LOW_MEMORY)
422 new->id = pthread_self();
436 if ((
void *) x->id ==
id) {
454 if (!(f = fopen(filename,
"r"))) {
458 while ((
c = fgetc(f)) != EOF) {
474#if defined(HAVE_EACCESS) || defined(HAVE_EUIDACCESS)
480 e->
command =
"core show settings";
481 e->
usage =
"Usage: core show settings\n"
482 " Show core misc settings";
491 ast_cli(
a->fd,
"\nPBX Core settings\n");
492 ast_cli(
a->fd,
"-----------------\n");
499 ast_cli(
a->fd,
" Maximum calls: Not set\n");
501 if (getrlimit(RLIMIT_NOFILE, &
limits)) {
502 ast_cli(
a->fd,
" Maximum open file handles: Error because of %s\n", strerror(
errno));
503 }
else if (
limits.rlim_cur == RLIM_INFINITY) {
504 ast_cli(
a->fd,
" Maximum open file handles: Unlimited\n");
508 ast_cli(
a->fd,
" Maximum open file handles: %d\n", (
int)
limits.rlim_cur);
516 print_file(
a->fd,
" Core dump file: ",
"/proc/sys/kernel/core_pattern");
518#if defined(HAVE_SYSINFO)
531 ast_cli(
a->fd,
" Entity ID: %s\n", eid_str);
532 ast_cli(
a->fd,
" PBX UUID: %s\n", pbx_uuid);
536#if defined(HAVE_EACCESS) || defined(HAVE_EUIDACCESS)
537#if defined(HAVE_EUIDACCESS) && !defined(HAVE_EACCESS)
538#define eaccess euidaccess
540 if (!getcwd(dir,
sizeof(dir))) {
541 if (eaccess(dir, R_OK | X_OK | F_OK)) {
542 ast_cli(
a->fd,
" Running directory: %s\n",
"Unable to access");
544 ast_cli(
a->fd,
" Running directory: %s (%s)\n", dir,
"Unable to access");
547 ast_cli(
a->fd,
" Running directory: %s\n", dir);
558#if !defined(LOW_MEMORY)
564 ast_cli(
a->fd,
" RTP dynamic payload types: %u,%u-%u\n",
568 ast_cli(
a->fd,
" RTP dynamic payload types: %u-%u,%u-%u\n",
572 ast_cli(
a->fd,
" RTP dynamic payload types: %u-%u\n",
585 ast_cli(
a->fd,
"\n* Directories\n");
609 e->
command =
"core show threads";
611 "Usage: core show threads\n"
612 " List threads currently active in the system.\n";
620 ast_cli(
a->fd,
"%p %d %s\n", (
void *)cur->id, cur->lwp, cur->name);
624 ast_cli(
a->fd,
"%d threads listed.\n", count);
628#if defined (HAVE_SYSCTL) && defined(HAVE_SWAPCTL)
633static int swapmode(
int *used,
int *
total)
635 struct swapent *swdev;
636 int nswap, rnswap, i;
638 nswap = swapctl(SWAP_NSWAP, 0, 0);
646 rnswap = swapctl(SWAP_STATS, swdev, nswap);
656 for (i = 0; i < nswap; i++) {
657 if (swdev[i].se_flags & SWF_ENABLE) {
658 *used += (swdev[i].se_inuse / (1024 / DEV_BSIZE));
659 *
total += (swdev[i].se_nblks / (1024 / DEV_BSIZE));
667#if defined(HAVE_SYSINFO) || defined(HAVE_SYSCTL)
671 uint64_t physmem, freeram;
672#if defined(HAVE_SYSINFO) || defined(HAVE_SWAPCTL)
674 uint64_t freeswap = 0;
678#if defined(HAVE_SYSINFO)
679 struct sysinfo sys_info;
680#elif defined(HAVE_SYSCTL)
681 static int pageshift;
682 struct vmtotal vmtotal;
683 struct timeval boottime;
685 int mib[2], pagesize;
686#if defined(HAVE_SWAPCTL)
694 e->
command =
"core show sysinfo";
696 "Usage: core show sysinfo\n"
697 " List current system information.\n";
703#if defined(HAVE_SYSINFO)
705 uptime = sys_info.uptime / 3600;
706 physmem = sys_info.totalram * sys_info.mem_unit;
707 freeram = (sys_info.freeram * sys_info.mem_unit) / 1024;
708 totalswap = (sys_info.totalswap * sys_info.mem_unit) / 1024;
709 freeswap = (sys_info.freeswap * sys_info.mem_unit) / 1024;
710 nprocs = sys_info.procs;
711#elif defined(HAVE_SYSCTL)
715 mib[1] = KERN_BOOTTIME;
716 len =
sizeof(boottime);
717 if (sysctl(mib, 2, &boottime, &
len,
NULL, 0) != -1) {
718 uptime = now - boottime.tv_sec;
720 uptime = uptime/3600;
723#if defined(HW_PHYSMEM64)
724 mib[1] = HW_PHYSMEM64;
728 len =
sizeof(physmem);
729 sysctl(mib, 2, &physmem, &
len,
NULL, 0);
731 pagesize = getpagesize();
733 while (pagesize > 1) {
744 len =
sizeof(vmtotal);
745 sysctl(mib, 2, &vmtotal, &
len,
NULL, 0);
746 freeram = (vmtotal.t_free << pageshift);
748#if defined(HAVE_SWAPCTL)
749 swapmode(&usedswap, &totalswap);
750 freeswap = (totalswap - usedswap);
753#if defined(__OpenBSD__)
755 mib[1] = KERN_NPROCS;
756 len =
sizeof(nprocs);
757 sysctl(mib, 2, &nprocs, &
len,
NULL, 0);
761 ast_cli(
a->fd,
"\nSystem Statistics\n");
762 ast_cli(
a->fd,
"-----------------\n");
763 ast_cli(
a->fd,
" System Uptime: %ld hours\n", uptime);
764 ast_cli(
a->fd,
" Total RAM: %" PRIu64
" KiB\n", physmem / 1024);
765 ast_cli(
a->fd,
" Free RAM: %" PRIu64
" KiB\n", freeram);
766#if defined(HAVE_SYSINFO)
767 ast_cli(
a->fd,
" Buffer RAM: %" PRIu64
" KiB\n", ((uint64_t) sys_info.bufferram * sys_info.mem_unit) / 1024);
769#if defined(HAVE_SYSINFO) || defined(HAVE_SWAPCTL)
770 ast_cli(
a->fd,
" Total Swap Space: %d KiB\n", totalswap);
771 ast_cli(
a->fd,
" Free Swap Space: %" PRIu64
" KiB\n\n", freeswap);
773 ast_cli(
a->fd,
" Number of Processes: %d \n\n", nprocs);
800#if !defined(LOW_MEMORY)
834#if !defined(LOW_MEMORY)
847#if !defined(LOW_MEMORY)
851#if defined ( __i686__) && (defined(__FreeBSD__) || defined(__NetBSD__) || defined(linux))
852#if defined(__FreeBSD__)
853#include <machine/cpufunc.h>
854#elif defined(__NetBSD__) || defined(linux)
855static __inline uint64_t
860 __asm __volatile(
".byte 0x0f, 0x31" :
"=A" (rv));
865static __inline uint64_t
875#if !defined(LOW_MEMORY)
893#if !defined(LOW_MEMORY)
894#define DEFINE_PROFILE_MIN_MAX_VALUES min = 0; \
895 max = prof_data->entries;\
897 if (isdigit(a->argv[3][0])) { \
898 min = atoi(a->argv[3]); \
899 if (a->argc == 5 && strcmp(a->argv[4], "-")) \
900 max = atoi(a->argv[4]); \
902 search = a->argv[3]; \
904 if (max > prof_data->entries) \
905 max = prof_data->entries;
910 const char *search =
NULL;
913 e->command =
"core show profile";
914 e->usage =
"Usage: core show profile\n"
915 " show profile information";
925 ast_cli(
a->fd,
"profile values (%d, allocated %d)\n-------------------\n",
927 ast_cli(
a->fd,
"%6s %8s %10s %12s %12s %s\n",
"ID",
"Scale",
"Events",
928 "Value",
"Average",
"Name");
929 for (i =
min; i <
max; i++) {
931 if (!search || strstr(
entry->name, search))
932 ast_cli(
a->fd,
"%6d: [%8ld] %10ld %12lld %12lld %s\n",
945 const char *search =
NULL;
948 e->
command =
"core clear profile";
949 e->
usage =
"Usage: core clear profile\n"
950 " clear profile information";
960 for (i=
min; i <
max; i++) {
968#undef DEFINE_PROFILE_MIN_MAX_VALUES
974 return ast_db_get(
"pbx",
"UUID", pbx_uuid, length);
981 int lastreloaded = 0;
987 uptime = (int)
tmp.tv_sec;
992 lastreloaded = (int)
tmp.tv_sec;
996 "Status",
"Fully Booted",
998 "LastReload", lastreloaded);
1070 return write(fd, s, strlen(s) + 1);
1076 return write(fd, s, strlen(s));
1086 .sa_flags = SA_RESTART,
1090 .sa_handler = SIG_IGN,
1135#if defined(HAVE_WORKING_FORK) || defined(HAVE_WORKING_VFORK)
1138#ifdef HAVE_WORKING_FORK
1146 cap_set_proc(child_cap);
1148#ifdef HAVE_WORKING_FORK
1156#ifdef HAVE_WORKING_FORK
1196#if defined(HAVE_WORKING_FORK) || defined(HAVE_WORKING_VFORK)
1201 res = waitpid(pid, &
status, 0);
1206 if (
errno != EINTR) {
1236 execl(
"/bin/sh",
"/bin/sh",
"-c", s, (
char *)
NULL);
1278 ast_cli(fd,
"Console is not muted anymore.\n");
1282 ast_cli(fd,
"Console is muted.\n");
1287 ast_cli(fd,
"Couldn't find remote console.\n");
1355 fputs(
string, stdout);
1376#if defined(SO_PEERCRED)
1377#ifdef HAVE_STRUCT_SOCKPEERCRED_UID
1378#define HAVE_STRUCT_UCRED_UID
1379 struct sockpeercred cred;
1383 socklen_t
len =
sizeof(cred);
1385#if defined(HAVE_GETPEEREID)
1393 result = read(fd, buffer, size);
1398#if defined(SO_PEERCRED) && (defined(HAVE_STRUCT_UCRED_UID) || defined(HAVE_STRUCT_UCRED_CR_UID))
1399 if (getsockopt(fd, SOL_SOCKET, SO_PEERCRED, &cred, &
len)) {
1402#if defined(HAVE_STRUCT_UCRED_UID)
1410#elif defined(HAVE_GETPEEREID)
1411 if (getpeereid(fd, &uid, &gid)) {
1426 struct console *con = vconsole;
1430 const char *
const end_buf =
inbuf +
sizeof(
inbuf);
1431 char *start_read =
inbuf;
1433 struct pollfd fds[2];
1441 fds[0].fd = con->
fd;
1442 fds[0].events = POLLIN;
1444 fds[1].fd = con->
p[0];
1445 fds[1].events = POLLIN;
1454 if (fds[0].revents) {
1455 int cmds_read, bytes_read;
1456 if ((bytes_read =
read_credentials(con->
fd, start_read, end_buf - start_read, con)) < 1) {
1460 if (strncmp(
inbuf,
"cli quit after ", 15) == 0) {
1469 if (start_read + bytes_read < end_buf) {
1470 start_read += bytes_read;
1477 if (start_read[bytes_read - 1] ==
'\0') {
1485 while (cmds_read-- && (start_read = strchr(start_read,
'\0'))) {
1488 memmove(
inbuf, start_read, end_buf - start_read);
1489 start_read = end_buf - start_read +
inbuf;
1491 if (fds[1].revents) {
1497 res = write(con->
fd, outbuf, res);
1504 ast_verb(3,
"Remote UNIX connection disconnected\n");
1516 struct sockaddr_un sunaddr;
1521 struct pollfd fds[1];
1528 fds[0].events = POLLIN;
1529 poll_result =
ast_poll(fds, 1, -1);
1530 pthread_testcancel();
1531 if (poll_result < 0) {
1532 if (
errno != EINTR) {
1537 len =
sizeof(sunaddr);
1543#if defined(SO_PASSCRED)
1546 if (setsockopt(s, SOL_SOCKET, SO_PASSCRED, &sckopt,
sizeof(sckopt)) < 0) {
1558 fdprint(s,
"Server failed to create pipe\n");
1576 fdprint(s,
"Server failed to spawn thread\n");
1582 fdprint(s,
"No more connections allowed\n");
1586 ast_verb(3,
"Remote UNIX connection\n");
1596 struct sockaddr_un sunaddr;
1618 memset(&sunaddr, 0,
sizeof(sunaddr));
1621 res = bind(
ast_socket, (
struct sockaddr *)&sunaddr,
sizeof(sunaddr));
1682 struct sockaddr_un sunaddr;
1686 fprintf(stderr,
"Unable to create socket: %s\n", strerror(
errno));
1689 memset(&sunaddr, 0,
sizeof(sunaddr));
1692 res = connect(
ast_consock, (
struct sockaddr *)&sunaddr,
sizeof(sunaddr));
1718 int save_errno =
errno;
1727 printf(
"Received HUP signal -- Reloading configs\n");
1730 fprintf(stderr,
"hup_handler: write() failed: %s\n", strerror(
errno));
1737 .sa_flags = SA_RESTART,
1748 for (n = 0; waitpid(-1, &
status, WNOHANG) > 0; n++)
1751 printf(
"Huh? Child handler, but nobody there?\n");
1757 .sa_flags = SA_RESTART,
1763 if (getenv(
"TERM") && strstr(getenv(
"TERM"),
"xterm"))
1764 fprintf(stdout,
"\033]2;%s\007",
text);
1769 if (getenv(
"TERM") && strstr(getenv(
"TERM"),
"xterm"))
1770 fprintf(stdout,
"\033]1;%s\007",
text);
1781 return sched_getscheduler(0);
1789 return (getpriority(PRIO_PROCESS, 0) < 0);
1796#if !defined(__linux__)
1799#elif defined(LOW_MEMORY)
1804 struct sched_param
sched;
1805 char const *policy_str;
1811 policy_str =
"realtime";
1812 sched.sched_priority = 10;
1814 policy = SCHED_OTHER;
1815 policy_str =
"regular";
1816 sched.sched_priority = 0;
1819 ast_log(
LOG_WARNING,
"Unable to set %s thread priority on main thread\n", policy_str);
1822 ast_verb(1,
"Setting %s thread priority on all threads\n", policy_str);
1839 struct sched_param
sched;
1843 sched.sched_priority = 10;
1848 sched.sched_priority = 0;
1858 ast_verb(1,
"Set to high priority\n");
1879 int shutdown_aborted = 0;
1885 shutdown_aborted = 1;
1888 return shutdown_aborted;
1916#define SHUTDOWN_TIMEOUT 15
1947 if (seconds < (now - start)) {
1968 ast_verbose(
"Ignoring asterisk %s request, already in progress.\n", restart ?
"restart" :
"shutdown");
1991 ast_verb(0,
"Beginning asterisk %s....\n", restart ?
"restart" :
"shutdown");
2000 ast_verb(0,
"Waiting for inactivity to perform %s...\n", restart ?
"restart" :
"halt");
2011 ast_verb(0,
"Asterisk %s cancelled.\n", restart ?
"restart" :
"shutdown");
2044 int active_channels;
2049 ast_verb(0,
"Some modules could not be unloaded, switching to fast shutdown\n");
2066 }
else if (!restart) {
2077 "Shutdown", active_channels ?
"Uncleanly" :
"Cleanly",
2078 "Restart", restart ?
"True" :
"False");
2083 ast_verb(0,
"Asterisk %s ending (%d).\n",
2084 active_channels ?
"uncleanly" :
"cleanly", num);
2086 ast_verb(0,
"Executing last minute cleanups\n");
2089 ast_debug(1,
"Asterisk ending (%d).\n", num);
2097 pthread_kill(
lthread, SIGURG);
2108 ast_verb(0,
"Preparing for Asterisk restart...\n");
2110 for (i = 3; i < 32768; i++) {
2111 fcntl(i, F_SETFD, FD_CLOEXEC);
2113 ast_verb(0,
"Asterisk is now restarting...\n");
2142 fprintf(stderr,
"quit_handler: write() failed: %s\n", strerror(
errno));
2178 snprintf(outbuf, maxout,
"%s%s%s%s%s%s",
2194 state->verbose_line_level = 0;
2208 unsigned int newline;
2227 if ((s = strchr(
c,
'\n'))) {
2231 s = strchr(
c,
'\0');
2247 if (fwrite(
c,
sizeof(
char), num, stdout) < num) {
2261 state->verbose_line_level = 0;
2308 while (isspace(*s)) {
2319 }
else if ((strncasecmp(s,
"quit", 4) == 0 || strncasecmp(s,
"exit", 4) == 0) &&
2320 (s[4] ==
'\0' || isspace(s[4]))) {
2332 e->
command =
"core show version";
2334 "Usage: core show version\n"
2335 " Shows Asterisk version information.\n";
2343 ast_cli(
a->fd,
"Asterisk %s built by %s @ %s on a %s running %s on %s\n",
2355 "Usage: core stop now\n"
2356 " Shuts down a running Asterisk immediately, hanging up all active calls .\n";
2363 if (
a->argc != e->
args)
2373 e->
command =
"core stop gracefully";
2375 "Usage: core stop gracefully\n"
2376 " Causes Asterisk to not accept new calls, and exit when all\n"
2377 " active calls have terminated normally.\n";
2384 if (
a->argc != e->
args)
2394 e->
command =
"core stop when convenient";
2396 "Usage: core stop when convenient\n"
2397 " Causes Asterisk to perform a shutdown when all active calls have ended.\n";
2404 if (
a->argc != e->
args)
2406 ast_cli(
a->fd,
"Waiting for inactivity to perform halt\n");
2415 e->
command =
"core restart now";
2417 "Usage: core restart now\n"
2418 " Causes Asterisk to hangup all calls and exec() itself performing a cold\n"
2426 if (
a->argc != e->
args)
2436 e->
command =
"core restart gracefully";
2438 "Usage: core restart gracefully\n"
2439 " Causes Asterisk to stop accepting new calls and exec() itself performing a cold\n"
2440 " restart when all active calls have ended.\n";
2447 if (
a->argc != e->
args)
2457 e->
command =
"core restart when convenient";
2459 "Usage: core restart when convenient\n"
2460 " Causes Asterisk to perform a cold restart when all active calls have ended.\n";
2467 if (
a->argc != e->
args)
2469 ast_cli(
a->fd,
"Waiting for inactivity to perform restart\n");
2478 e->
command =
"core abort shutdown";
2480 "Usage: core abort shutdown\n"
2481 " Causes Asterisk to abort an executing shutdown or restart, and resume normal\n"
2482 " call operations.\n";
2489 if (
a->argc != e->
args)
2503 "Usage: !<command>\n"
2504 " Executes a given shell command\n";
2516 "BECAUSE THE PROGRAM IS LICENSED FREE OF CHARGE, THERE IS NO WARRANTY\n"
2517 "FOR THE PROGRAM, TO THE EXTENT PERMITTED BY APPLICABLE LAW. EXCEPT WHEN\n"
2518 "OTHERWISE STATED IN WRITING THE COPYRIGHT HOLDERS AND/OR OTHER PARTIES\n"
2519 "PROVIDE THE PROGRAM \"AS IS\" WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED\n"
2520 "OR IMPLIED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF\n"
2521 "MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. THE ENTIRE RISK AS\n"
2522 "TO THE QUALITY AND PERFORMANCE OF THE PROGRAM IS WITH YOU. SHOULD THE\n"
2523 "PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF ALL NECESSARY SERVICING,\n"
2524 "REPAIR OR CORRECTION.\n"
2526 "IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING\n"
2527 "WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MAY MODIFY AND/OR\n"
2528 "REDISTRIBUTE THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES,\n"
2529 "INCLUDING ANY GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING\n"
2530 "OUT OF THE USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED\n"
2531 "TO LOSS OF DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY\n"
2532 "YOU OR THIRD PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER\n"
2533 "PROGRAMS), EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE\n"
2534 "POSSIBILITY OF SUCH DAMAGES.\n"
2541 e->
command =
"core show warranty";
2543 "Usage: core show warranty\n"
2544 " Shows the warranty (if any) for this copy of Asterisk.\n";
2557 "This program is free software; you can redistribute it and/or modify\n"
2558 "it under the terms of the GNU General Public License version 2 as\n"
2559 "published by the Free Software Foundation.\n"
2561 "This program also contains components licensed under other licenses.\n"
2564 "This program is distributed in the hope that it will be useful,\n"
2565 "but WITHOUT ANY WARRANTY; without even the implied warranty of\n"
2566 "MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the\n"
2567 "GNU General Public License for more details.\n"
2569 "You should have received a copy of the GNU General Public License\n"
2570 "along with this program; if not, write to the Free Software\n"
2571 "Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA\n"
2578 e->
command =
"core show license";
2580 "Usage: core show license\n"
2581 " Shows the license(s) for this copy of Asterisk.\n";
2592#define ASTERISK_PROMPT "*CLI> "
2617#if !defined(LOW_MEMORY)
2619#if defined(HAVE_SYSINFO) || defined(HAVE_SYSCTL)
2652 printf(
"log and verbose output currently muted ('logger mute' to unmute)\n");
2656#ifdef HAVE_LIBEDIT_IS_UNICODE
2657#define CHAR_T_LIBEDIT wchar_t
2658#define CHAR_TO_LIBEDIT(c) btowc(c)
2660#define CHAR_T_LIBEDIT char
2661#define CHAR_TO_LIBEDIT(c) c
2668 struct pollfd fds[2];
2671#define EL_BUF_SIZE 512
2677 fds[0].events = POLLIN;
2679 fds[1].fd = STDIN_FILENO;
2680 fds[1].events = POLLIN;
2688 if (
errno == EINTR) {
2691 fprintf(stderr,
"poll failed: %s\n", strerror(
errno));
2698 num_read = read(STDIN_FILENO, &
c, 1);
2708 if (fds[0].revents) {
2712 fprintf(stderr,
"\nDisconnected from Asterisk server\n");
2717 int reconnects_per_second = 20;
2719 fprintf(stderr,
"Attempting to reconnect for 30 seconds\n");
2720 for (tries = 0; tries < 30 * reconnects_per_second; tries++) {
2722 fprintf(stderr,
"Reconnect succeeded after %.3f seconds\n", 1.0 / reconnects_per_second * tries);
2729 usleep(1000000 / reconnects_per_second);
2731 if (tries >= 30 * reconnects_per_second) {
2732 fprintf(stderr,
"Failed to reconnect for 30 seconds. Quitting.\n");
2743 if (write(STDOUT_FILENO,
"\r␛[0K", 5) < 0) {
2749 if ((res <
EL_BUF_SIZE - 1) && ((
buf[res-1] ==
'\n') || (res >= 2 &&
buf[res-2] ==
'\n'))) {
2770 static int cli_prompt_changes = 0;
2776 }
else if (!cli_prompt_changes) {
2782 if ((pfmt = getenv(
"ASTERISK_PROMPT"))) {
2785 while (*t !=
'\0') {
2789 struct ast_tm tm = { 0, };
2796 if (sscanf(t,
"%30d;%30d%n", &fgcolor, &bgcolor, &i) == 2) {
2799 }
else if (sscanf(t,
"%30d%n", &fgcolor, &i) == 1) {
2811 cli_prompt_changes++;
2815 if ((gr = getgrgid(getgid()))) {
2829 if ((dotptr = strchr(
hostname,
'.'))) {
2837#ifdef HAVE_GETLOADAVG
2840 if (sscanf(t,
"%30d", &which) == 1 && which > 0 && which <= 3) {
2844 cli_prompt_changes++;
2855 cli_prompt_changes++;
2859 if ((pw = getpwuid(getuid()))) {
2908 goto vector_cleanup;
2913 goto vector_cleanup;
2938 for (numoutputline = 0; numoutputline < limit && idx <
AST_VECTOR_SIZE(matches); idx++) {
2943 if (!numoutputline) {
2947 fprintf(stdout,
"\n");
2961 LineInfo *lf = (LineInfo *)el_line(editline);
2963 savechr = *(
char *)lf->cursor;
2964 *(
char *)lf->cursor =
'\0';
2965 ptr = (
char *)lf->cursor;
2967 while (ptr > lf->buffer) {
2968 if (isspace(*ptr)) {
2976 len = lf->cursor - ptr;
2979#define CMD_MATCHESARRAY "_COMMAND MATCHESARRAY \"%s\" \"%s\""
2985 if (maxmbuf == -1) {
2986 *((
char *) lf->cursor) = savechr;
2988 return (
char *)(CC_ERROR);
2997 if (mlen + 1024 > maxmbuf) {
2999 maxmbuf = mlen + 1024;
3003 *((
char *) lf->cursor) = savechr;
3005 return (
char *)(CC_ERROR);
3012 if (!strncmp(mbuf,
"Usage:", 6)) {
3043 int maxlen, match_len;
3047 el_deletestr(editline, (
int)
len);
3048 el_insertstr(editline, best_match);
3054 el_insertstr(editline,
" ");
3060 if (match_len > maxlen) {
3065 fprintf(stdout,
"\n");
3073 *((
char *) lf->cursor) = savechr;
3075 return (
char *)(long)
retval;
3081 char *editor, *editrc = getenv(
"EDITRC");
3083 if (!(editor = getenv(
"AST_EDITMODE"))) {
3084 if (!(editor = getenv(
"AST_EDITOR"))) {
3094 el = el_init(
"asterisk", stdin, stdout, stderr);
3097 el_set(
el, EL_EDITMODE, 1);
3098 el_set(
el, EL_EDITOR, editor);
3104 history(
el_hist, &ev, H_SETSIZE, 100);
3108 el_set(
el, EL_ADDFN,
"ed-complete",
"Complete argument",
cli_complete);
3110 el_set(
el, EL_BIND,
"^I",
"ed-complete",
NULL);
3112 el_set(
el, EL_BIND,
"?",
"ed-complete",
NULL);
3114 el_set(
el, EL_BIND,
"^D",
"ed-redisplay",
NULL);
3116 el_set(
el, EL_BIND,
"\\e[3~",
"ed-delete-next-char",
NULL);
3118 el_set(
el, EL_BIND,
"\\e[1~",
"ed-move-to-beg",
NULL);
3119 el_set(
el, EL_BIND,
"\\e[4~",
"ed-move-to-end",
NULL);
3121 el_set(
el, EL_BIND,
"\\eOC",
"vi-next-word",
NULL);
3122 el_set(
el, EL_BIND,
"\\eOD",
"vi-prev-word",
NULL);
3125 el_source(
el, editrc);
3131#define MAX_HISTORY_COMMAND_LENGTH 256
3148 if (!history(
el_hist, &ev, H_FIRST) && strcmp(ev.str, stripped_buf) == 0) {
3152 return history(
el_hist, &ev, H_ENTER, stripped_buf);
3162 return (history(
el_hist, &ev, H_SAVE, filename));
3173 return history(
el_hist, &ev, H_LOAD, filename);
3178 struct passwd *pw = getpwuid(geteuid());
3183 ast_log(
LOG_ERROR,
"Unable to determine home directory. History read/write disabled.\n");
3189 ast_log(
LOG_ERROR,
"Unable to create history file name. History read/write disabled.\n");
3193 ret = readwrite(
name);
3221 char *stringp =
NULL;
3240 char prefix[] =
"cli quit after ";
3252 cpid =
strsep(&stringp,
"/");
3255 version =
"<Version Unknown>";
3267 int linefull = 1, prev_linefull = 1, prev_line_verbose = 0;
3270 fds.events = POLLIN;
3273 while (
ast_poll(&fds, 1, 60000) > 0) {
3274 char buffer[512] =
"", *curline = buffer, *nextline;
3275 int not_written = 1;
3281 if (read(
ast_consock, buffer,
sizeof(buffer) - 1) <= 0) {
3286 prev_linefull = linefull;
3287 if ((nextline = strchr(curline,
'\n'))) {
3292 nextline = strchr(curline,
'\0');
3306 if ((!prev_linefull && !prev_line_verbose) || (prev_linefull && *curline > 0)) {
3307 prev_line_verbose = 0;
3309 if (write(STDOUT_FILENO, curline, nextline - curline) < 0) {
3313 prev_line_verbose = 1;
3337 ebuf = (
char *)el_gets(
el, &num);
3343 if (!ebuf && write(1,
"", 1) < 0)
3347 if (ebuf[strlen(ebuf)-1] ==
'\n')
3348 ebuf[strlen(ebuf)-1] =
'\0';
3358 printf(
"\nDisconnected from Asterisk server\n");
3370 printf(
"Usage: asterisk [OPTIONS]\n");
3371 printf(
"Valid Options:\n");
3372 printf(
" -V Display version number and exit\n");
3373 printf(
" -C <configfile> Use an alternate configuration file\n");
3374 printf(
" -G <group> Run as a group other than the caller\n");
3375 printf(
" -U <user> Run as a user other than the caller\n");
3376 printf(
" -c Provide console CLI\n");
3377 printf(
" -d Increase debugging (multiple d's = more debugging)\n");
3378#if HAVE_WORKING_FORK
3379 printf(
" -f Do not fork\n");
3380 printf(
" -F Always fork\n");
3382 printf(
" -g Dump core in case of a crash\n");
3383 printf(
" -h This help screen\n");
3384 printf(
" -i Initialize crypto keys at startup\n");
3385 printf(
" -L <load> Limit the maximum load average before rejecting new calls\n");
3386 printf(
" -M <value> Limit the maximum number of calls to the specified value\n");
3387 printf(
" -m Mute debugging and console output on the console\n");
3388 printf(
" -n Disable console colorization. Can be used only at startup.\n");
3389 printf(
" -p Run as pseudo-realtime thread\n");
3390 printf(
" -q Quiet mode (suppress output)\n");
3391 printf(
" -r Connect to Asterisk on this machine\n");
3392 printf(
" -R Same as -r, except attempt to reconnect if disconnected\n");
3393 printf(
" -s <socket> Connect to Asterisk via socket <socket> (only valid with -r)\n");
3394 printf(
" -t Record soundfiles in /var/tmp and move them where they\n");
3395 printf(
" belong after they are done\n");
3396 printf(
" -T Display the time in [Mmm dd hh:mm:ss] format for each line\n");
3397 printf(
" of output to the CLI. Cannot be used with remote console mode.\n\n");
3398 printf(
" -v Increase verbosity (multiple v's = more verbose)\n");
3399 printf(
" -x <cmd> Execute command <cmd> (implies -r)\n");
3400 printf(
" -X Enable use of #exec in asterisk.conf\n");
3401 printf(
" -W Adjust terminal colors to compensate for a light background\n");
3424 if (!strcasecmp(v->
name,
"log_level")) {
3432 }
else if (!strcasecmp(v->
name,
"cache_pools")) {
3467 struct stat canary_stat;
3475 if (stat(
canary_filename, &canary_stat) || now.tv_sec > canary_stat.st_mtime + 60) {
3477 "The canary is no more. He has ceased to be! "
3478 "He's expired and gone to meet his maker! "
3479 "He's a stiff! Bereft of life, he rests in peace. "
3480 "His metabolic processes are now history! He's off the twig! "
3481 "He's kicked the bucket. He's shuffled off his mortal coil, "
3482 "run down the curtain, and joined the bleeding choir invisible!! "
3483 "THIS is an EX-CANARY. (Reducing priority)\n");
3517 fd = open(
"/dev/null", O_RDWR);
3552 ast_verbose(
"Running under group '%s'\n", rungroup);
3566 int isroot = 1, rundir_exists = 0;
3571 static const char *getopt_settings =
"BC:cde:FfG:ghIiL:M:mnpqRrs:TtU:VvWXx:";
3575 fprintf(stderr,
"Truncating argument size to %d\n", (
int)
ARRAY_LEN(
_argv) - 1);
3578 for (x = 0; x < argc; x++)
3586 if (argv[0] && (strstr(argv[0],
"rasterisk")) !=
NULL) {
3592 while ((
c = getopt(argc, argv, getopt_settings)) != -1) {
3637 while ((
c = getopt(argc, argv, getopt_settings)) != -1) {
3658#if defined(HAVE_SYSINFO)
3665#if HAVE_WORKING_FORK
3684 "NOTICE: The -I option is no longer needed.\n"
3685 " It will always be enabled if you have a timing module loaded.\n");
3758 while ((
c = getopt(argc, argv, getopt_settings)) != -1) {
3795 fprintf(stderr,
"'%c' option is not compatible with remote console mode and has no effect.\n",
c);
3800 fprintf(stderr,
"\n");
3808 strcpy(argv[0],
"rasterisk");
3809 for (x = 1; x < argc; x++) {
3810 argv[x] = argv[0] + 10;
3815 fprintf(stderr,
"The 'languageprefix' option in asterisk.conf is deprecated; in a future release it will be removed, and your sound files will need to be organized in the 'new style' language layout.\n");
3819 fprintf(stderr,
"'alwaysfork' is not compatible with console or remote console mode; ignored\n");
3824 memset(&l, 0,
sizeof(l));
3825 l.rlim_cur = RLIM_INFINITY;
3826 l.rlim_max = RLIM_INFINITY;
3827 if (setrlimit(RLIMIT_CORE, &l)) {
3828 fprintf(stderr,
"Unable to disable core size resource limit: %s\n", strerror(
errno));
3832 if (getrlimit(RLIMIT_NOFILE, &l)) {
3833 fprintf(stderr,
"Unable to check file descriptor limit: %s\n", strerror(
errno));
3836#if !defined(CONFIGURE_RAN_AS_ROOT)
3841 struct timeval tv = { 0, };
3843 if (l.rlim_cur <= FD_SETSIZE) {
3849 if (!(fd = open(
"/dev/null", O_RDONLY))) {
3850 fprintf(stderr,
"Cannot open a file descriptor at boot? %s\n", strerror(
errno));
3854 fd2 = ((l.rlim_cur >
sizeof(readers) * 8) ?
sizeof(readers) * 8 : l.rlim_cur) - 1;
3855 if (dup2(fd, fd2) < 0) {
3856 fprintf(stderr,
"Cannot open maximum file descriptor %d at boot? %s\n", fd2, strerror(
errno));
3864 fprintf(stderr,
"Maximum select()able file descriptor is %d\n", FD_SETSIZE);
3870#elif defined(HAVE_VARIABLE_FDSET)
3887 if (
errno == EEXIST) {
3890 fprintf(stderr,
"Unable to create socket file directory. Remote consoles will not be able to connect! (%s)\n", strerror(x));
3900 if (isroot && rungroup) {
3902 gr = getgrnam(rungroup);
3904 fprintf(stderr,
"No such group '%s'!\n", rungroup);
3908 fprintf(stderr,
"Unable to chgrp run directory to %d (%s)\n", (
int) gr->gr_gid, rungroup);
3910 if (setgid(gr->gr_gid)) {
3911 fprintf(stderr,
"Unable to setgid to %d (%s)\n", (
int)gr->gr_gid, rungroup);
3914 if (setgroups(0,
NULL)) {
3915 fprintf(stderr,
"Unable to drop unneeded groups\n");
3925 pw = getpwnam(runuser);
3927 fprintf(stderr,
"No such user '%s'!\n", runuser);
3931 fprintf(stderr,
"Unable to chown run directory to %d (%s)\n", (
int) pw->pw_uid, runuser);
3934 if (prctl(PR_SET_KEEPCAPS, 1, 0, 0, 0)) {
3939 if (!isroot && pw->pw_uid != geteuid()) {
3940 fprintf(stderr,
"Asterisk started as nonroot, but runuser '%s' requested.\n", runuser);
3944 if (setgid(pw->pw_gid)) {
3945 fprintf(stderr,
"Unable to setgid to %d!\n", (
int)pw->pw_gid);
3948 if (isroot && initgroups(pw->pw_name, pw->pw_gid)) {
3949 fprintf(stderr,
"Unable to init groups for '%s'\n", runuser);
3953 if (setuid(pw->pw_uid)) {
3954 fprintf(stderr,
"Unable to setuid to %d (%s)\n", (
int)pw->pw_uid, runuser);
3961 cap = cap_from_text(
"cap_net_admin=eip");
3963 if (cap_set_proc(cap)) {
3964 fprintf(stderr,
"Unable to install capabilities.\n");
3966 if (cap_free(cap)) {
3967 fprintf(stderr,
"Unable to drop capabilities.\n");
3977 if (prctl(PR_SET_DUMPABLE, 1, 0, 0, 0) < 0) {
3978 fprintf(stderr,
"Unable to set the process for core dumps after changing to a non-root user. %s\n", strerror(
errno));
3984#if defined(HAVE_EACCESS) || defined(HAVE_EUIDACCESS)
3986 if (!getcwd(dir,
sizeof(dir)) || eaccess(dir, R_OK | X_OK | F_OK)) {
3987 fprintf(stderr,
"Unable to access the running directory (%s). Changing to '/' for compatibility.\n", strerror(
errno));
3992 fprintf(stderr,
"chdir(\"/\") failed?!! %s\n", strerror(
errno));
3999 fprintf(stderr,
"Unable to chdir(\"/\") ?!! %s\n", strerror(
errno));
4031 fprintf(stderr,
"Asterisk already running on %s. Use 'asterisk -r' to connect.\n",
ast_config_AST_SOCKET);
4042 child_cap = cap_from_text(
"cap_net_admin-eip");
4047 cap_free(child_cap);
4058 fprintf(stderr,
"%s initialization failed. ASTERISK EXITING!\n%s",
name,
term_quit());
4061 exit(init_result == -2 ? 2 : 1);
4081#if HAVE_WORKING_FORK
4083#ifndef HAVE_SBIN_LAUNCHD
4084 if (daemon(1, 0) < 0) {
4085 fprintf(stderr,
"daemon() failed: %s\n", strerror(
errno));
4090 fprintf(stderr,
"Mac OS X detected. Use 'launchctl load /Library/LaunchDaemon/org.asterisk.asterisk.plist'.\n");
4119 char canary_binary[
PATH_MAX], ppid[12];
4122 signal(SIGCHLD, SIG_DFL);
4123 signal(SIGPIPE, SIG_DFL);
4127 snprintf(ppid,
sizeof(ppid),
"%d", (
int)
ast_mainpid);
4136 pthread_t dont_care;
4187 ast_verb(0,
"PBX UUID: %s\n", pbx_uuid);
4203#ifdef TEST_FRAMEWORK
4222 (void) sigemptyset(&sigs);
4223 (void) sigaddset(&sigs, SIGHUP);
4224 (void) sigaddset(&sigs, SIGTERM);
4225 (void) sigaddset(&sigs, SIGINT);
4226 (void) sigaddset(&sigs, SIGPIPE);
4227 (void) sigaddset(&sigs, SIGWINCH);
4228 pthread_sigmask(SIG_BLOCK, &sigs,
NULL);
4238 srand((
unsigned int) getpid() + (
unsigned int) time(
NULL));
4307 pthread_sigmask(SIG_UNBLOCK, &sigs,
NULL);
4335 snprintf(title,
sizeof(title),
"Asterisk Console on '%s' (pid %ld)",
hostname, (
long)
ast_mainpid);
4351 buf = (
char *) el_gets(
el, &num);
4353 if (!
buf && write(1,
"", 1) < 0)
4357 if (
buf[strlen(
buf)-1] ==
'\n')
4358 buf[strlen(
buf)-1] =
'\0';
Prototypes for public functions only of internal interest,.
int load_pbx_variables(void)
void threadstorage_init(void)
void ast_process_pending_reloads(void)
Process reload requests received during startup.
int modules_shutdown(void)
int ast_bridging_init(void)
Initialize the bridging system.
void dnsmgr_start_refresh(void)
int ast_timing_init(void)
int ast_device_state_engine_init(void)
Initialize the device state engine in separate thread.
void ast_cli_channels_init(void)
void ast_msg_shutdown(void)
void logger_queue_start(void)
Start the ast_queue_log() logger.
void load_asterisk_conf(void)
void ast_stun_init(void)
Initialize the STUN system in Asterisk.
void set_asterisk_conf_path(const char *path)
int load_pbx_functions_cli(void)
void load_astmm_phase_2(void)
Initialize malloc debug phase 2.
int load_pbx_hangup_handler(void)
int ast_local_init(void)
Initialize the local proxy channel.
int load_pbx_builtins(void)
int load_pbx_switch(void)
int ast_rtp_engine_init(void)
initializes the rtp engine arrays
int ast_xmldoc_load_documentation(void)
Load XML documentation. Provided by xmldoc.c.
int ast_named_locks_init(void)
int ast_channels_init(void)
void clean_time_zones(void)
void load_astmm_phase_1(void)
Initialize malloc debug phase 1.
void ast_builtins_init(void)
initialize the _full_cmd string in * each of the builtins.
void ast_autoservice_init(void)
int ast_endpoint_init(void)
Endpoint support initialization.
int ast_dns_system_resolver_init(void)
Initializes the resolver.
int ast_cli_perms_init(int reload)
void set_socket_path(const char *path)
int ast_parking_stasis_init(void)
initializes the rtp engine arrays
Access Control of various sorts.
A-Law to Signed linear conversion.
void ast_alaw_init(void)
To init the alaw to slinear conversion stuff, this needs to be run.
void ast_alertpipe_close(int alert_pipe[2])
Close an alert pipe.
ssize_t ast_alertpipe_write(int alert_pipe[2])
Write an event to an alert pipe.
int ast_alertpipe_init(int alert_pipe[2])
Initialize an alert pipe.
ast_alert_status_t ast_alertpipe_read(int alert_pipe[2])
Read an event from an alert pipe.
Generic Advice of Charge encode and decode routines.
int ast_aoc_cli_init(void)
enable aoc cli options
Asterisk version information.
const char * ast_get_build_opts(void)
const char * ast_get_version(void)
Retrieve the Asterisk version string.
const char * ast_get_build_opts_all(void)
Persistent data storage (akin to *doze registry)
int ast_db_put(const char *family, const char *key, const char *value)
Store value addressed by family/key.
int ast_db_get(const char *family, const char *key, char *value, int valuelen)
Get key value specified by family/key.
static int ast_el_add_history(const char *)
static char * remotehostname
static char * handle_stop_gracefully(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static void __ast_unregister_atexit(void(*func)(void))
static char * cli_complete(EditLine *editline, int ch)
int64_t ast_mark(int i, int startstop)
int main(int argc, char *argv[])
static int ast_socket_is_sd
int ast_shutdown_final(void)
static void canary_exit(void)
static shutdown_nice_t shuttingdown
static void check_init(int init_result, const char *name)
static void __remote_quit_handler(int num)
static void _urg_handler(int num)
Urgent handler.
static char * show_license(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char * handle_show_threads(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static void ast_run_atexits(int run_cleanups)
static int console_state_init(void *ptr)
static struct profile_data * prof_data
static char * handle_stop_when_convenient(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static int remoteconsolehandler(const char *s)
static struct ast_str * prompt
static void publish_fully_booted(void)
static int show_version(void)
static void main_atexit(void)
static int safe_exec_wait(pid_t pid)
wait for spawned application to complete and unreplace sigchld
int ast_add_profile(const char *name, uint64_t scale)
allocates a counter with a given name and scale.
static void ast_cli_display_match_list(struct ast_vector_string *matches, int max)
static void _hup_handler(int num)
static char * handle_version(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static unsigned int safe_system_level
Keep track of how many threads are currently trying to wait*() on a child process.
static void ast_network_puts_mutable(const char *string, int level, int sublevel)
log the string to all attached network console clients
static char randompool[256]
static char * handle_show_sysinfo(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
Give an overview of system statistics.
#define WELCOME_MESSAGE
Welcome message when starting a CLI interface.
int ast_safe_execvp(int dualfork, const char *file, char *const argv[])
Safely spawn an external program while closing file descriptors.
int ast_register_cleanup(void(*func)(void))
Register a function to be executed before Asterisk gracefully exits.
static void set_header(char *outbuf, int maxout, char level)
static int ast_el_read_char(EditLine *editline, CHAR_T_LIBEDIT *cp)
static char * handle_stop_now(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char canary_filename[128]
static __inline uint64_t rdtsc(void)
static struct sigaction child_handler
int ast_set_priority(int pri)
We set ourselves to a high priority, that we might pre-empt everything else. If your PBX has heavy ac...
static void asterisk_daemon(int isroot, const char *runuser, const char *rungroup)
void ast_console_toggle_loglevel(int fd, int level, int state)
enable or disable a logging level to a specified console
static char * handle_show_settings(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
Give an overview of core settings.
static int has_priority(void)
Check whether we were set to high(er) priority.
void ast_console_toggle_mute(int fd, int silent)
mute or unmute a console from logging
static void send_rasterisk_connect_commands(void)
static struct sigaction safe_system_prev_handler
static char * handle_bang(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static struct sigaction hup_handler
static pthread_t mon_sig_flags
static int fdprint(int fd, const char *s)
static pthread_t consolethread
static void * netconsole(void *vconsole)
static int ast_el_initialize(void)
static int set_priority_all(int pri)
Set priority on all known threads.
static void ast_begin_shutdown(void)
static char * handle_restart_now(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char * handle_restart_when_convenient(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static int ast_el_read_history(const char *)
static char * handle_abort_shutdown(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
int ast_shutting_down(void)
static void _child_handler(int sig)
void ast_console_puts_mutable(const char *string, int level)
log the string to the root console, and all attached network console clients
int ast_pbx_uuid_get(char *pbx_uuid, int length)
Retrieve the PBX UUID.
void ast_replace_sigchld(void)
Replace the SIGCHLD handler.
int ast_cancel_shutdown(void)
Cancel an existing shutdown and return to normal operation.
static void ast_network_puts(const char *string)
write the string to all attached console clients
static int read_credentials(int fd, char *buffer, size_t size, struct console *con)
read() function supporting the reception of user credentials.
#define CHAR_TO_LIBEDIT(c)
static int shutdown_pending
static void _null_sig_handler(int sig)
NULL handler so we can collect the child exit status.
static void process_histfile(int(*readwrite)(const char *filename))
static struct @297 sig_flags
static int sig_alert_pipe[2]
struct timeval ast_lastreloadtime
static const char warranty_lines[]
void ast_console_puts(const char *string)
write the string to the root console, and all attached network console clients
void ast_unregister_atexit(void(*func)(void))
Unregister a function registered with ast_register_atexit().
static int console_print(const char *s)
static void quit_handler(int num, shutdown_nice_t niceness, int restart)
static char * handle_restart_gracefully(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static void * monitor_sig_flags(void *unused)
static char * show_warranty(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
#define MAX_HISTORY_COMMAND_LENGTH
void ast_register_thread(char *name)
static void ast_remotecontrol(char *data)
static int print_file(int fd, char *desc, const char *filename)
Print the contents of a file.
void ast_unregister_thread(void *id)
static void consolehandler(const char *s)
static struct ast_cli_entry cli_asterisk_shutdown[]
Shutdown Asterisk CLI commands.
int ast_register_atexit(void(*func)(void))
Register a function to be executed before Asterisk exits.
static ast_mutex_t safe_system_lock
static pid_t safe_exec_prep(int dualfork)
fork and perform other preparations for spawning applications
int ast_safe_system(const char *s)
Safely spawn an OS shell command while closing file descriptors.
static int ast_all_zeros(const char *s)
static int can_safely_quit(shutdown_nice_t niceness, int restart)
static char * cli_prompt(EditLine *editline)
static void set_title(char *text)
Set an X-term or screen title.
static int register_atexit(void(*func)(void), int is_cleanup)
static char * handle_clear_profile(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static int wait_for_channels_to_die(shutdown_nice_t niceness, int seconds)
static struct ast_threadstorage console_state
static int ast_makesocket(void)
#define DEFINE_PROFILE_MIN_MAX_VALUES
unsigned int need_quit_handler
static int ast_tryconnect(void)
static void * canary_thread(void *unused)
static void * listener(void *unused)
static struct ast_cli_entry cli_asterisk[]
static int fdsend(int fd, const char *s)
static int ast_el_write_history(const char *)
static void run_startup_commands(void)
static int show_cli_help(void)
static void ast_el_read_default_histfile(void)
static char * handle_show_profile(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static void env_init(void)
struct timeval ast_startuptime
static void read_pjproject_startup_options(void)
static const char license_lines[]
void ast_unreplace_sigchld(void)
Restore the SIGCHLD handler.
static void really_quit(int num, shutdown_nice_t niceness, int restart)
static void ast_el_write_default_histfile(void)
static int multi_thread_safe
static struct ast_vector_string * ast_el_strtoarr(char *buf)
static void __quit_handler(int num)
void ast_console_puts_mutable_full(const char *message, int level, int sublevel)
log the string to the console, and all attached console clients
static void set_icon(char *text)
static void print_intro_message(const char *runuser, const char *rungroup)
static struct sigaction ignore_sig_handler
static struct sigaction null_sig_handler
struct console consoles[AST_MAX_CONNECTS]
int64_t ast_profile(int i, int64_t delta)
static struct sigaction urg_handler
Asterisk main include file. File version handling, generic pbx functions.
#define sched_setscheduler
#define ast_alloca(size)
call __builtin_alloca to ensure we get gcc builtin semantics
#define ast_realloc(p, len)
A wrapper for realloc()
#define ast_strdup(str)
A wrapper for strdup()
#define ast_strdupa(s)
duplicate a string in memory from the stack
void ast_free_ptr(void *ptr)
free() wrapper
#define ast_asprintf(ret, fmt,...)
A wrapper for asprintf()
#define ast_calloc(num, len)
A wrapper for calloc()
int ast_bucket_init(void)
Initialize bucket support.
const char * ast_build_os
const char * ast_build_machine
const char * ast_build_hostname
const char * ast_build_user
const char * ast_build_date
const char * ast_build_kernel
CallerID (and other GR30) management and generation Includes code and algorithms from the Zapata libr...
void callerid_init(void)
CallerID Initialization.
int ast_cdr_is_enabled(void)
Return TRUE if CDR subsystem is enabled.
void ast_cdr_engine_term(void)
static char version[AST_MAX_EXTENSION]
General Asterisk PBX channel definitions.
void ast_softhangup_all(void)
Soft hangup all active channels.
int ast_undestroyed_channels(void)
int ast_active_channels(void)
returns number of active/allocated channels
Standard Command Line Interface.
#define AST_CLI_COMPLETE_EOF
int ast_cli_unregister_multiple(struct ast_cli_entry *e, int len)
Unregister multiple commands.
#define AST_CLI_DEFINE(fn, txt,...)
void ast_cli(int fd, const char *fmt,...)
int ast_cli_allow_at_shutdown(struct ast_cli_entry *e)
Allow a CLI command to be executed while Asterisk is shutting down.
int ast_cli_command_multiple_full(int uid, int gid, int fd, size_t size, const char *s)
Executes multiple CLI commands Interpret strings separated by NULL and execute each one,...
ast_cli_command
calling arguments for new-style handlers.
struct ast_vector_string * ast_cli_completion_vector(const char *text, const char *word)
Generates a vector of strings for CLI completion.
#define ast_cli_register_multiple(e, len)
Register multiple commands.
int ast_codec_init(void)
Initialize codec support within the core.
int ast_codec_builtin_init(void)
Initialize built-in codecs within the core.
int devstate_init(void)
Initialize the device state core.
void ast_verbose(const char *fmt,...)
Generic File Format Support. Should be included by clients of the file handling routines....
static int len(struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t buflen)
int ast_manager_check_enabled(void)
Check if AMI is enabled.
int ast_webmanager_check_enabled(void)
Check if AMI/HTTP is enabled.
void ast_manager_publish_event(const char *type, int class_type, struct ast_json *obj)
Publish an event to AMI.
void ast_init_logger_for_socket_console(void)
load logger.conf configuration for console socket connections
int ast_option_rtpusedynamic
int ast_option_pjproject_log_level
double ast_option_maxload
unsigned int ast_option_rtpptdynamic
struct ast_flags ast_options
unsigned int option_dtmfminduration
int ast_option_pjproject_cache_pools
@ AST_OPT_FLAG_HIGH_PRIORITY
@ AST_OPT_FLAG_GENERIC_PLC
@ AST_OPT_FLAG_TRANSCODE_VIA_SLIN
@ AST_OPT_FLAG_EXEC_INCLUDES
@ AST_OPT_FLAG_TRANSMIT_SILENCE
@ AST_OPT_FLAG_ALWAYS_FORK
@ AST_OPT_FLAG_GENERIC_PLC_ON_EQUAL_CODECS
@ AST_OPT_FLAG_CACHE_RECORD_FILES
@ AST_OPT_FLAG_FULLY_BOOTED
@ AST_OPT_FLAG_FORCE_BLACK_BACKGROUND
@ AST_OPT_FLAG_LIGHT_BACKGROUND
static char prefix[MAX_PREFIX]
General Asterisk channel definitions for image handling.
int ast_image_init(void)
Initialize image stuff Initializes all the various image stuff. Basically just registers the cli stuf...
Application convenience functions, designed to give consistent look and feel to Asterisk apps.
int app_init(void)
Initialize the application core.
void ast_close_fds_above_n(int n)
Common routine for child processes, to close all fds prior to exec(2)
int setenv(const char *name, const char *value, int overwrite)
int getloadavg(double *list, int nelem)
char * strsep(char **str, const char *delims)
Configuration File Parser.
struct ast_config * ast_config_load2(const char *filename, const char *who_asked, struct ast_flags flags)
Load a config file.
#define CONFIG_STATUS_FILEMISSING
int ast_realtime_enabled(void)
Check if there's any realtime engines loaded.
#define CONFIG_STATUS_FILEUNCHANGED
#define CONFIG_STATUS_FILEINVALID
void ast_config_destroy(struct ast_config *cfg)
Destroys a config.
struct ast_variable * ast_variable_browse(const struct ast_config *config, const char *category_name)
int register_config_cli(void)
Exposed initialization method for core process.
void ast_verb_console_unregister(void)
Unregister this thread's console verbosity level.
void ast_verb_console_register(int *level)
Register this thread's console verbosity level pointer.
#define ast_debug(level,...)
Log a DEBUG message.
int ast_is_logger_initialized(void)
Test if logger is initialized.
#define ast_verb(level,...)
int ast_verb_console_get(void)
Get this thread's console verbosity level.
const char * ast_logger_get_dateformat(void)
Get the logger configured date format.
#define VERBOSE_MAGIC2LEVEL(x)
#define VERBOSE_HASMAGIC(x)
I/O Management (derived from Cheops-NG)
int ast_get_termcols(int fd)
Columns of Terminal.
int ast_sd_notify(const char *state)
a wrapper for sd_notify(): notify systemd of any state changes.
int ast_sd_get_fd_un(int type, const char *path)
Find a listening AF_LOCAL file descriptor provided by socket activation.
Asterisk JSON abstraction layer.
void ast_json_unref(struct ast_json *value)
Decrease refcount on value. If refcount reaches zero, value is freed.
struct ast_json * ast_json_pack(char const *format,...)
Helper for creating complex JSON values.
int ast_json_init(void)
Initialize the JSON library.
A set of macros to manage forward-linked lists.
#define AST_RWLIST_REMOVE_CURRENT
#define AST_RWLIST_RDLOCK(head)
Read locks a list.
#define AST_LIST_HEAD_STATIC(name, type)
Defines a structure to be used to hold a list of specified type, statically initialized.
#define AST_RWLIST_TRAVERSE_SAFE_BEGIN
#define AST_RWLIST_WRLOCK(head)
Write locks a list.
#define AST_RWLIST_UNLOCK(head)
Attempts to unlock a read/write based list.
#define AST_RWLIST_HEAD_STATIC(name, type)
Defines a structure to be used to hold a read/write list of specified type, statically initialized.
#define AST_LIST_ENTRY(type)
Declare a forward link structure inside a list entry.
#define AST_RWLIST_TRAVERSE_SAFE_END
#define AST_LIST_TRAVERSE_SAFE_END
Closes a safe loop traversal block.
#define AST_LIST_LOCK(head)
Locks a list.
#define AST_RWLIST_TRAVERSE
#define AST_LIST_INSERT_HEAD(head, elm, field)
Inserts a list entry at the head of a list.
#define AST_LIST_TRAVERSE_SAFE_BEGIN(head, var, field)
Loops safely over (traverses) the entries in a list.
#define AST_LIST_REMOVE_CURRENT(field)
Removes the current entry from a list during a traversal.
#define AST_RWLIST_INSERT_HEAD
#define AST_LIST_REMOVE_HEAD(head, field)
Removes and returns the head entry from a list.
#define AST_LIST_UNLOCK(head)
Attempts to unlock a list.
struct ast_tm * ast_localtime(const struct timeval *timep, struct ast_tm *p_tm, const char *zone)
Timezone-independent version of localtime_r(3).
int ast_strftime(char *buf, size_t len, const char *format, const struct ast_tm *tm)
Special version of strftime(3) that handles fractions of a second. Takes the same arguments as strfti...
Asterisk locking-related definitions:
#define AST_PTHREADT_NULL
#define ast_mutex_unlock(a)
#define ast_mutex_lock(a)
#define AST_MUTEX_DEFINE_STATIC(mutex)
static char * levels[NUMLOGLEVELS]
Logging channels used in the Asterisk logging system.
static char hostname[MAXHOSTNAMELEN]
#define WEXITSTATUS(status)
#define WIFEXITED(status)
The AMI - Asterisk Manager Interface - is a TCP protocol created to manage Asterisk with third-party ...
#define EVENT_FLAG_SYSTEM
Asterisk module definitions.
enum ast_module_reload_result ast_module_reload(const char *name)
Reload asterisk modules.
int mwi_init(void)
Initialize the mwi core.
Wrapper for network related headers, masking differences between various operating systems....
Options provided by main asterisk program.
#define ast_opt_dump_core
int ast_language_is_prefix
The following variable controls the layout of localized sound files. If 0, use the historical layout ...
#define MAX_PJ_LOG_MAX_LEVEL
#define ast_opt_reconnect
#define DEFAULT_PJPROJECT_CACHE_POOLS
#define ast_opt_hide_connect
#define ast_opt_high_priority
#define ast_opt_timestamp
#define ast_opt_always_fork
#define ast_opt_hide_messaging_ami_events
#define ast_opt_sounds_search_custom
#define DEFAULT_PJ_LOG_MAX_LEVEL
#define ast_opt_cache_media_frames
char ast_defaultlanguage[]
Asterisk file paths, configured in asterisk.conf.
const char * ast_config_AST_KEY_DIR
const char * ast_config_AST_RUN_GROUP
const char * ast_config_AST_SOCKET
const char * ast_config_AST_RUN_USER
const char * ast_config_AST_CTL_PERMISSIONS
const char * ast_config_AST_CTL_GROUP
const char * ast_config_AST_MODULE_DIR
const char * ast_config_AST_PID
const char * ast_config_AST_RUN_DIR
const char * ast_config_AST_DATA_DIR
const char * ast_config_AST_CONFIG_DIR
const char * ast_config_AST_SPOOL_DIR
const char * ast_config_AST_AGI_DIR
const char * ast_config_AST_VAR_DIR
const char * ast_config_AST_SYSTEM_NAME
const char * ast_config_AST_SBIN_DIR
const char * ast_config_AST_CONFIG_FILE
const char * ast_config_AST_LOG_DIR
const char * ast_config_AST_CTL_OWNER
const char * ast_config_AST_DB
Core PBX routines and definitions.
int ast_pickup_init(void)
Initialize pickup.
#define ast_poll(a, b, c)
Presence state management.
int ast_presence_state_engine_init(void)
Pluggable RTP Architecture.
#define AST_RTP_PT_LAST_REASSIGN
#define AST_RTP_PT_FIRST_DYNAMIC
Scheduler Routines (derived from cheops)
Security Event Reporting API.
int ast_security_stasis_init(void)
initializes stasis topic/event types for ast_security_topic and ast_security_event_type
unsigned int ast_FD_SETSIZE
static int ast_select(int nfds, ast_fdset *rfds, ast_fdset *wfds, ast_fdset *efds, struct timeval *tvp)
Waits for activity on a group of channels.
Sorcery Data Access Layer API.
int ast_sorcery_init(void)
Initialize the sorcery API.
Stasis Message Bus API. See Stasis Message Bus API for detailed documentation.
int stasis_init(void)
Initialize the Stasis subsystem.
int ast_endpoint_stasis_init(void)
Initialization function for endpoint stasis support.
int ast_stasis_system_init(void)
Initialize the stasis system topic and message types.
int ast_str_append(struct ast_str **buf, ssize_t max_len, const char *fmt,...)
Append to a thread local dynamic string.
char * ast_str_buffer(const struct ast_str *buf)
Returns the string buffer within the ast_str buf.
#define S_OR(a, b)
returns the equivalent of logic or for strings: first one if not empty, otherwise second one.
int attribute_pure ast_true(const char *val)
Make sure something is true. Determine if a string containing a boolean value is "true"....
static force_inline int attribute_pure ast_strlen_zero(const char *s)
int attribute_pure ast_false(const char *val)
Make sure something is false. Determine if a string containing a boolean value is "false"....
void ast_str_reset(struct ast_str *buf)
Reset the content of a dynamic string. Useful before a series of ast_str_append.
#define ast_str_create(init_len)
Create a malloc'ed dynamic length string.
int ast_str_set(struct ast_str **buf, ssize_t max_len, const char *fmt,...)
Set a dynamic string using variable arguments.
void ast_copy_string(char *dst, const char *src, size_t size)
Size-limited null-terminating string copy.
char * ast_strip(char *s)
Strip leading/trailing whitespace from a string.
struct ast_atexit::@298 list
descriptor for a cli entry.
int args
This gets set in ast_cli_register()
Structure used to handle boolean flags.
Abstract JSON element (object, array, string, int, ...).
Support for dynamic strings.
Structure for variables, used for configurations and for channel variables.
struct ast_variable * next
String vector definitions.
struct profile_entry e[0]
TTY/TDD Generation support.
Handy terminal functions for vt* terms.
const char * term_quit(void)
int ast_term_color_code(struct ast_str **str, int fgcolor, int bgcolor)
Append a color sequence to an ast_str.
const char * ast_term_reset(void)
Returns the terminal reset code.
const char * ast_term_color(int fgcolor, int bgcolor)
Return a color sequence string.
const char * term_end(void)
#define COLORIZE(fg, bg, str)
#define COLORIZE_FMT
Shortcut macros for coloring a set of text.
#define AST_THREADSTORAGE_CUSTOM(a, b, c)
Define a thread storage variable, with custom initialization and cleanup.
void * ast_threadstorage_get(struct ast_threadstorage *ts, size_t init_size)
Retrieve thread storage.
struct timeval ast_tvsub(struct timeval a, struct timeval b)
Returns the difference of two timevals a - b.
struct timeval ast_tvnow(void)
Returns current timeval. Meant to replace calls to gettimeofday().
Support for translation of data formats. translate.c.
int ast_translate_init(void)
Initialize the translation matrix and index to format conversion table.
u-Law to Signed linear conversion
void ast_ulaw_init(void)
Set up mu-law conversion table.
UTF-8 information and validation functions.
int ast_utf8_init(void)
Register UTF-8 tests.
static int inbuf(struct baseio *bio, FILE *fi)
utility used by inchar(), for base_encode()
#define ast_test_flag(p, flag)
#define RAII_VAR(vartype, varname, initval, dtor)
Declare a variable that will call a destructor function when it goes out of scope.
#define ast_pthread_create_background(a, b, c, d)
char * ast_eid_to_str(char *s, int maxlen, struct ast_eid *eid)
Convert an EID to a string.
int ast_get_tid(void)
Get current thread ID.
#define ast_clear_flag(p, flag)
#define ast_pthread_create_detached(a, b, c, d)
#define ast_fd_set_flags(fd, flags)
Set flags on the given file descriptor.
#define ast_pthread_create_detached_background(a, b, c, d)
#define ast_set_flag(p, flag)
struct ast_eid ast_eid_default
Global EID.
Universally unique identifier support.
void ast_uuid_init(void)
Initialize the UUID system.
char * ast_uuid_generate_str(char *buf, size_t size)
Generate a UUID string.
#define AST_VECTOR_SIZE(vec)
Get the number of elements in a vector.
#define AST_VECTOR_PTR_FREE(vec)
Deallocates this vector pointer.
#define AST_VECTOR_APPEND(vec, elem)
Append an element to a vector, growing the vector if needed.
#define AST_VECTOR_CALLBACK_VOID(vec, callback,...)
Execute a callback on every element in a vector disregarding callback return.
#define AST_VECTOR_GET(vec, idx)
Get an element from a vector.
Asterisk XML Documentation API.