[asterisk/asterisk.git] / main / asterisk.c

/*
 * Asterisk -- An open source telephony toolkit.
 *
 * Copyright (C) 1999 - 2012, Digium, Inc.
 *
 * Mark Spencer <markster@digium.com>
 *
 * See http://www.asterisk.org for more information about
 * the Asterisk project. Please do not directly contact
 * any of the maintainers of this project for assistance;
 * the project provides a web site, mailing lists and IRC
 * channels for your use.
 *
 * This program is free software, distributed under the terms of
 * the GNU General Public License Version 2. See the LICENSE file
 * at the top of the source tree.
 */


/* Doxygenified Copyright Header */
/*!
 * \mainpage Asterisk -- The Open Source Telephony Project
 *
 * \par Welcome
 *
 * This documentation created by the Doxygen project clearly explains the
 * internals of the Asterisk software. This documentation contains basic
 * examples, developer documentation, support information, and information
 * for upgrading.
 * 
 * \section community Community
 * Asterisk is a big project and has a busy community. Look at the
 * resources for questions and stick around to help answer questions.
 * \li \ref asterisk_community_resources
 *
 * \par Developer Documentation for Asterisk
 *
 * This is the main developer documentation for Asterisk. It is
 * generated by running "make progdocs" from the Asterisk source tree.
 *
 * In addition to the information available on the Asterisk source code,
 * please see the appendices for information on coding guidelines,
 * release management, commit policies, and more.
 *
 * \arg \ref AsteriskArchitecture
 *
 * \par Additional documentation
 * \arg \ref Licensing
 * \arg \ref DevDoc
 * \arg \ref configuration_file
 * \arg \ref channel_drivers
 * \arg \ref applications
 *
 * \section copyright Copyright and Author
 *
 * Copyright (C) 1999 - 2012, Digium, Inc.
 * Asterisk is a <a href="http://www.digium.com/en/company/view-policy.php?id=Trademark-Policy">registered trademark</a>
 * of <a href="http://www.digium.com">Digium, Inc</a>.
 *
 * \author Mark Spencer <markster@digium.com>
 *
 * See http://www.asterisk.org for more information about
 * the Asterisk project. Please do not directly contact
 * any of the maintainers of this project for assistance;
 * the project provides a web site, mailing lists, and IRC
 * channels for your use.
 *
 */

/*!
 * \page asterisk_community_resources Asterisk Community Resources
 * \par Websites
 * \li http://www.asterisk.org Asterisk Homepage
 * \li http://wiki.asterisk.org Asterisk Wiki
 *
 * \par Mailing Lists
 * \par
 * All lists: http://lists.digium.com/mailman/listinfo
 * \li aadk-commits     SVN commits to the AADK repository
 * \li asterisk-addons-commits  SVN commits to the Asterisk addons project
 * \li asterisk-announce        [no description available]
 * \li asterisk-biz     Commercial and Business-Oriented Asterisk Discussion
 * \li Asterisk-BSD     Asterisk on BSD discussion
 * \li asterisk-bugs    [no description available]
 * \li asterisk-commits SVN commits to the Asterisk project
 * \li asterisk-dev     Asterisk Developers Mailing List
 * \li asterisk-doc     Discussions regarding The Asterisk Documentation Project
 * \li asterisk-embedded        Asterisk Embedded Development
 * \li asterisk-gui     Asterisk GUI project discussion
 * \li asterisk-gui-commits     SVN commits to the Asterisk-GUI project
 * \li asterisk-ha-clustering   Asterisk High Availability and Clustering List - Non-Commercial Discussion
 * \li Asterisk-i18n    Discussion of Asterisk internationalization
 * \li asterisk-r2      [no description available]
 * \li asterisk-scf-commits     Commits to the Asterisk SCF project code repositories
 * \li asterisk-scf-committee   Asterisk SCF Steering Committee discussions
 * \li asterisk-scf-dev Asterisk SCF Developers Mailing List
 * \li asterisk-scf-wiki-changes        Changes to the Asterisk SCF space on wiki.asterisk.org
 * \li asterisk-security        Asterisk Security Discussion
 * \li asterisk-speech-rec      Use of speech recognition in Asterisk
 * \li asterisk-ss7     [no description available]
 * \li asterisk-users   Asterisk Users Mailing List - Non-Commercial Discussion
 * \li asterisk-video   Development discussion of video media support in Asterisk
 * \li asterisk-wiki-changes    Changes to the Asterisk space on wiki.asterisk.org
 * \li asterisknow      AsteriskNOW Discussion
 * \li dahdi-commits    SVN commits to the DAHDI project
 * \li digium-announce  Digium Product Announcements
 * \li Dundi    Distributed Universal Number Discovery
 * \li libiax2-commits  SVN commits to the libiax2 project
 * \li libpri-commits   SVN commits to the libpri project
 * \li libss7-commits   SVN commits to the libss7 project
 * \li svn-commits      SVN commits to the Digium repositories
 * \li Test-results     Results from automated testing
 * \li thirdparty-commits       SVN commits to the Digium third-party software repository
 * \li zaptel-commits   SVN commits to the Zaptel project
 *
 * \par Forums
 * \li Forums are located at http://forums.asterisk.org/
 *
 * \par IRC
 * \par
 * Use http://www.freenode.net IRC server to connect with Asterisk
 * developers and users in realtime.
 * 
 * \li \verbatim #asterisk \endverbatim Asterisk Users Room
 * \li \verbatim #asterisk-dev \endverbatim Asterisk Developers Room
 *
 * \par More
 * \par
 * If you would like to add a resource to this list please create an issue
 * on the issue tracker with a patch.
 */

/*! \file
 * \brief Top level source file for Asterisk - the Open Source PBX.
 *      Implementation of PBX core functions and CLI interface.
 */

/*! \li \ref asterisk.c uses the configuration file \ref asterisk.conf
 * \addtogroup configuration_file
 */

/*! \page asterisk.conf asterisk.conf
 * \verbinclude asterisk.conf.sample
 */

/*** MODULEINFO
        <support_level>core</support_level>
 ***/

#include "asterisk.h"

ASTERISK_FILE_VERSION(__FILE__, "$Revision$")

#include "asterisk/_private.h"

#undef sched_setscheduler
#undef setpriority
#include <sys/time.h>
#include <fcntl.h>
#include <signal.h>
#include <sched.h>
#include <sys/un.h>
#include <sys/wait.h>
#include <ctype.h>
#include <sys/resource.h>
#include <grp.h>
#include <pwd.h>
#include <sys/stat.h>
#if defined(HAVE_SYSINFO)
#include <sys/sysinfo.h>
#elif defined(HAVE_SYSCTL)
#include <sys/param.h>
#include <sys/sysctl.h>
#if !defined(__OpenBSD__)
#include <sys/vmmeter.h>
#if defined(__FreeBSD__)
#include <vm/vm_param.h>
#endif
#endif
#if defined(HAVE_SWAPCTL)
#include <sys/swap.h>
#endif
#endif
#include <regex.h>
#include <histedit.h>

#if defined(SOLARIS)
int daemon(int, int);  /* defined in libresolv of all places */
#include <sys/loadavg.h>
#endif

#ifdef linux
#include <sys/prctl.h>
#ifdef HAVE_CAP
#include <sys/capability.h>
#endif /* HAVE_CAP */
#endif /* linux */

/* we define here the variables so to better agree on the prototype */
#include "asterisk/paths.h"
#include "asterisk/network.h"
#include "asterisk/cli.h"
#include "asterisk/channel.h"
#include "asterisk/translate.h"
#include "asterisk/features.h"
#include "asterisk/acl.h"
#include "asterisk/ulaw.h"
#include "asterisk/alaw.h"
#include "asterisk/callerid.h"
#include "asterisk/image.h"
#include "asterisk/tdd.h"
#include "asterisk/term.h"
#include "asterisk/manager.h"
#include "asterisk/cdr.h"
#include "asterisk/cel.h"
#include "asterisk/pbx.h"
#include "asterisk/enum.h"
#include "asterisk/http.h"
#include "asterisk/udptl.h"
#include "asterisk/app.h"
#include "asterisk/lock.h"
#include "asterisk/utils.h"
#include "asterisk/file.h"
#include "asterisk/io.h"
#include "editline/histedit.h"
#include "asterisk/config.h"
#include "asterisk/ast_version.h"
#include "asterisk/linkedlists.h"
#include "asterisk/devicestate.h"
#include "asterisk/presencestate.h"
#include "asterisk/module.h"
#include "asterisk/dsp.h"
#include "asterisk/buildinfo.h"
#include "asterisk/xmldoc.h"
#include "asterisk/poll-compat.h"
#include "asterisk/ccss.h"
#include "asterisk/test.h"
#include "asterisk/rtp_engine.h"
#include "asterisk/format.h"
#include "asterisk/aoc.h"
#include "asterisk/uuid.h"
#include "asterisk/sorcery.h"
#include "asterisk/stasis.h"
#include "asterisk/json.h"
#include "asterisk/stasis_endpoints.h"
#include "asterisk/security_events.h"

#include "../defaults.h"

/*** DOCUMENTATION
        <managerEvent language="en_US" name="FullyBooted">
                <managerEventInstance class="EVENT_FLAG_SYSTEM">
                        <synopsis>Raised when all Asterisk initialization procedures have finished.</synopsis>
                        <syntax>
                                <parameter name="Status">
                                        <para>Informational message</para>
                                </parameter>
                        </syntax>
                </managerEventInstance>
        </managerEvent>
        <managerEvent language="en_US" name="Shutdown">
                <managerEventInstance class="EVENT_FLAG_SYSTEM">
                        <synopsis>Raised when Asterisk is shutdown or restarted.</synopsis>
                        <syntax>
                                <parameter name="Shutdown">
                                        <para>Whether the shutdown is proceeding cleanly (all channels
                                        were hungup successfully) or uncleanly (channels will be
                                        terminated)</para>
                                        <enumlist>
                                                <enum name="Uncleanly"/>
                                                <enum name="Cleanly"/>
                                        </enumlist>
                                </parameter>
                                <parameter name="Restart">
                                        <para>Whether or not a restart will occur.</para>
                                        <enumlist>
                                                <enum name="True"/>
                                                <enum name="False"/>
                                        </enumlist>
                                </parameter>
                        </syntax>
                </managerEventInstance>
        </managerEvent>
 ***/

#ifndef AF_LOCAL
#define AF_LOCAL AF_UNIX
#define PF_LOCAL PF_UNIX
#endif

#define AST_MAX_CONNECTS 128
#define NUM_MSGS 64

/*! Default minimum DTMF digit length - 80ms */
#define AST_MIN_DTMF_DURATION 80


/*! \brief Welcome message when starting a CLI interface */
#define WELCOME_MESSAGE \
    ast_verbose("Asterisk %s, Copyright (C) 1999 - 2012 Digium, Inc. and others.\n" \
                "Created by Mark Spencer <markster@digium.com>\n" \
                "Asterisk comes with ABSOLUTELY NO WARRANTY; type 'core show warranty' for details.\n" \
                "This is free software, with components licensed under the GNU General Public\n" \
                "License version 2 and other licenses; you are welcome to redistribute it under\n" \
                "certain conditions. Type 'core show license' for details.\n" \
                "=========================================================================\n", ast_get_version()) \

/*! \defgroup main_options Main Configuration Options
 * \brief Main configuration options from asterisk.conf or OS command line on starting Asterisk.
 * \arg \ref Config_ast "asterisk.conf"
 * \note Some of them can be changed in the CLI
 */
/*! @{ */

struct ast_flags ast_options = { AST_DEFAULT_OPTIONS };
struct ast_flags ast_compat = { 0 };

int option_verbose;                             /*!< Verbosity level */
int option_debug;                               /*!< Debug level */
double option_maxload;                          /*!< Max load avg on system */
int option_maxcalls;                            /*!< Max number of active calls */
int option_maxfiles;                            /*!< Max number of open file handles (files, sockets) */
unsigned int option_dtmfminduration;            /*!< Minimum duration of DTMF. */
#if defined(HAVE_SYSINFO)
long option_minmemfree;                         /*!< Minimum amount of free system memory - stop accepting calls if free memory falls below this watermark */
#endif

/*! @} */

struct ast_eid ast_eid_default;

/* XXX tmpdir is a subdir of the spool directory, and no way to remap it */
char record_cache_dir[AST_CACHE_DIR_LEN] = DEFAULT_TMP_DIR;

static int ast_socket = -1;             /*!< UNIX Socket for allowing remote control */
static int ast_consock = -1;            /*!< UNIX Socket for controlling another asterisk */
pid_t ast_mainpid;
struct console {
        int fd;                         /*!< File descriptor */
        int p[2];                       /*!< Pipe */
        pthread_t t;                    /*!< Thread of handler */
        int mute;                       /*!< Is the console muted for logs */
        int uid;                        /*!< Remote user ID. */
        int gid;                        /*!< Remote group ID. */
        int levels[NUMLOGLEVELS];       /*!< Which log levels are enabled for the console */
};

struct ast_atexit {
        void (*func)(void);
        AST_LIST_ENTRY(ast_atexit) list;
};

static AST_LIST_HEAD_STATIC(atexits, ast_atexit);

struct timeval ast_startuptime;
struct timeval ast_lastreloadtime;

static History *el_hist;
static EditLine *el;
static char *remotehostname;

struct console consoles[AST_MAX_CONNECTS];

char defaultlanguage[MAX_LANGUAGE] = DEFAULT_LANGUAGE;

static int ast_el_add_history(char *);
static int ast_el_read_history(char *);
static int ast_el_write_history(char *);

struct _cfg_paths {
        char config_dir[PATH_MAX];
        char module_dir[PATH_MAX];
        char spool_dir[PATH_MAX];
        char monitor_dir[PATH_MAX];
        char var_dir[PATH_MAX];
        char data_dir[PATH_MAX];
        char log_dir[PATH_MAX];
        char agi_dir[PATH_MAX];
        char run_dir[PATH_MAX];
        char key_dir[PATH_MAX];

        char config_file[PATH_MAX];
        char db_path[PATH_MAX];
        char sbin_dir[PATH_MAX];
        char pid_path[PATH_MAX];
        char socket_path[PATH_MAX];
        char run_user[PATH_MAX];
        char run_group[PATH_MAX];
        char system_name[128];
};

static struct _cfg_paths cfg_paths;

const char *ast_config_AST_CONFIG_DIR   = cfg_paths.config_dir;
const char *ast_config_AST_CONFIG_FILE  = cfg_paths.config_file;
const char *ast_config_AST_MODULE_DIR   = cfg_paths.module_dir;
const char *ast_config_AST_SPOOL_DIR    = cfg_paths.spool_dir;
const char *ast_config_AST_MONITOR_DIR  = cfg_paths.monitor_dir;
const char *ast_config_AST_VAR_DIR      = cfg_paths.var_dir;
const char *ast_config_AST_DATA_DIR     = cfg_paths.data_dir;
const char *ast_config_AST_LOG_DIR      = cfg_paths.log_dir;
const char *ast_config_AST_AGI_DIR      = cfg_paths.agi_dir;
const char *ast_config_AST_KEY_DIR      = cfg_paths.key_dir;
const char *ast_config_AST_RUN_DIR      = cfg_paths.run_dir;
const char *ast_config_AST_SBIN_DIR = cfg_paths.sbin_dir;

const char *ast_config_AST_DB           = cfg_paths.db_path;
const char *ast_config_AST_PID          = cfg_paths.pid_path;
const char *ast_config_AST_SOCKET       = cfg_paths.socket_path;
const char *ast_config_AST_RUN_USER     = cfg_paths.run_user;
const char *ast_config_AST_RUN_GROUP    = cfg_paths.run_group;
const char *ast_config_AST_SYSTEM_NAME  = cfg_paths.system_name;

static char ast_config_AST_CTL_PERMISSIONS[PATH_MAX];
static char ast_config_AST_CTL_OWNER[PATH_MAX] = "\0";
static char ast_config_AST_CTL_GROUP[PATH_MAX] = "\0";
static char ast_config_AST_CTL[PATH_MAX] = "asterisk.ctl";

extern unsigned int ast_FD_SETSIZE;

static char *_argv[256];
typedef enum {
        NOT_SHUTTING_DOWN = -2,
        SHUTTING_DOWN = -1,
        /* Valid values for quit_handler niceness below: */
        SHUTDOWN_FAST,
        SHUTDOWN_NORMAL,
        SHUTDOWN_NICE,
        SHUTDOWN_REALLY_NICE
} shutdown_nice_t;
static shutdown_nice_t shuttingdown = NOT_SHUTTING_DOWN;
static int restartnow;
static pthread_t consolethread = AST_PTHREADT_NULL;
static pthread_t mon_sig_flags;
static int canary_pid = 0;
static char canary_filename[128];
static int multi_thread_safe;

static char randompool[256];

static int sig_alert_pipe[2] = { -1, -1 };
static struct {
         unsigned int need_reload:1;
         unsigned int need_quit:1;
         unsigned int need_quit_handler:1;
} sig_flags;

/*! \brief The \ref stasis topic for system level changes */
static struct stasis_topic *system_topic;

/*!\ brief The \ref stasis_message_type for network changes */
STASIS_MESSAGE_TYPE_DEFN(ast_network_change_type);

#if !defined(LOW_MEMORY)
struct file_version {
        AST_RWLIST_ENTRY(file_version) list;
        const char *file;
        char *version;
};

/*! \brief The \ref stasis topic for system level changes */
static struct stasis_topic *system_topic;

static AST_RWLIST_HEAD_STATIC(file_versions, file_version);

void ast_register_file_version(const char *file, const char *version)
{
        struct file_version *new;
        char *work;
        size_t version_length;

        work = ast_strdupa(version);
        work = ast_strip(ast_strip_quoted(work, "$", "$"));
        version_length = strlen(work) + 1;

        if (!(new = ast_calloc(1, sizeof(*new) + version_length)))
                return;

        new->file = file;
        new->version = (char *) new + sizeof(*new);
        memcpy(new->version, work, version_length);
        AST_RWLIST_WRLOCK(&file_versions);
        AST_RWLIST_INSERT_HEAD(&file_versions, new, list);
        AST_RWLIST_UNLOCK(&file_versions);
}

void ast_unregister_file_version(const char *file)
{
        struct file_version *find;

        AST_RWLIST_WRLOCK(&file_versions);
        AST_RWLIST_TRAVERSE_SAFE_BEGIN(&file_versions, find, list) {
                if (!strcasecmp(find->file, file)) {
                        AST_RWLIST_REMOVE_CURRENT(list);
                        break;
                }
        }
        AST_RWLIST_TRAVERSE_SAFE_END;
        AST_RWLIST_UNLOCK(&file_versions);

        if (find)
                ast_free(find);
}

char *ast_complete_source_filename(const char *partial, int n)
{
        struct file_version *find;
        size_t len = strlen(partial);
        int count = 0;
        char *res = NULL;

        AST_RWLIST_RDLOCK(&file_versions);
        AST_RWLIST_TRAVERSE(&file_versions, find, list) {
                if (!strncasecmp(find->file, partial, len) && ++count > n) {
                        res = ast_strdup(find->file);
                        break;
                }
        }
        AST_RWLIST_UNLOCK(&file_versions);
        return res;
}

/*! \brief Find version for given module name */
const char *ast_file_version_find(const char *file)
{
        struct file_version *iterator;

        AST_RWLIST_WRLOCK(&file_versions);
        AST_RWLIST_TRAVERSE(&file_versions, iterator, list) {
                if (!strcasecmp(iterator->file, file))
                        break;
        }
        AST_RWLIST_UNLOCK(&file_versions);
        if (iterator)
                return iterator->version;
        return NULL;
}

struct thread_list_t {
        AST_RWLIST_ENTRY(thread_list_t) list;
        char *name;
        pthread_t id;
        int lwp;
};

static AST_RWLIST_HEAD_STATIC(thread_list, thread_list_t);

void ast_register_thread(char *name)
{
        struct thread_list_t *new = ast_calloc(1, sizeof(*new));

        if (!new)
                return;

        ast_assert(multi_thread_safe);
        new->id = pthread_self();
        new->lwp = ast_get_tid();
        new->name = name; /* steal the allocated memory for the thread name */
        AST_RWLIST_WRLOCK(&thread_list);
        AST_RWLIST_INSERT_HEAD(&thread_list, new, list);
        AST_RWLIST_UNLOCK(&thread_list);
}

void ast_unregister_thread(void *id)
{
        struct thread_list_t *x;

        AST_RWLIST_WRLOCK(&thread_list);
        AST_RWLIST_TRAVERSE_SAFE_BEGIN(&thread_list, x, list) {
                if ((void *) x->id == id) {
                        AST_RWLIST_REMOVE_CURRENT(list);
                        break;
                }
        }
        AST_RWLIST_TRAVERSE_SAFE_END;
        AST_RWLIST_UNLOCK(&thread_list);
        if (x) {
                ast_free(x->name);
                ast_free(x);
        }
}

/*! \brief Give an overview of core settings */
static char *handle_show_settings(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        char buf[BUFSIZ];
        struct ast_tm tm;
        char eid_str[128];

        switch (cmd) {
        case CLI_INIT:
                e->command = "core show settings";
                e->usage = "Usage: core show settings\n"
                           "       Show core misc settings";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        ast_eid_to_str(eid_str, sizeof(eid_str), &ast_eid_default);

        ast_cli(a->fd, "\nPBX Core settings\n");
        ast_cli(a->fd, "-----------------\n");
        ast_cli(a->fd, "  Version:                     %s\n", ast_get_version());
        ast_cli(a->fd, "  Build Options:               %s\n", S_OR(AST_BUILDOPTS, "(none)"));
        if (option_maxcalls)
                ast_cli(a->fd, "  Maximum calls:               %d (Current %d)\n", option_maxcalls, ast_active_channels());
        else
                ast_cli(a->fd, "  Maximum calls:               Not set\n");
        if (option_maxfiles)
                ast_cli(a->fd, "  Maximum open file handles:   %d\n", option_maxfiles);
        else
                ast_cli(a->fd, "  Maximum open file handles:   Not set\n");
        ast_cli(a->fd, "  Verbosity:                   %d\n", option_verbose);
        ast_cli(a->fd, "  Debug level:                 %d\n", option_debug);
        ast_cli(a->fd, "  Maximum load average:        %lf\n", option_maxload);
#if defined(HAVE_SYSINFO)
        ast_cli(a->fd, "  Minimum free memory:         %ld MB\n", option_minmemfree);
#endif
        if (ast_localtime(&ast_startuptime, &tm, NULL)) {
                ast_strftime(buf, sizeof(buf), "%H:%M:%S", &tm);
                ast_cli(a->fd, "  Startup time:                %s\n", buf);
        }
        if (ast_localtime(&ast_lastreloadtime, &tm, NULL)) {
                ast_strftime(buf, sizeof(buf), "%H:%M:%S", &tm);
                ast_cli(a->fd, "  Last reload time:            %s\n", buf);
        }
        ast_cli(a->fd, "  System:                      %s/%s built by %s on %s %s\n", ast_build_os, ast_build_kernel, ast_build_user, ast_build_machine, ast_build_date);
        ast_cli(a->fd, "  System name:                 %s\n", ast_config_AST_SYSTEM_NAME);
        ast_cli(a->fd, "  Entity ID:                   %s\n", eid_str);
        ast_cli(a->fd, "  Default language:            %s\n", defaultlanguage);
        ast_cli(a->fd, "  Language prefix:             %s\n", ast_language_is_prefix ? "Enabled" : "Disabled");
        ast_cli(a->fd, "  User name and group:         %s/%s\n", ast_config_AST_RUN_USER, ast_config_AST_RUN_GROUP);
        ast_cli(a->fd, "  Executable includes:         %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_EXEC_INCLUDES) ? "Enabled" : "Disabled");
        ast_cli(a->fd, "  Transcode via SLIN:          %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_TRANSCODE_VIA_SLIN) ? "Enabled" : "Disabled");
        ast_cli(a->fd, "  Internal timing:             %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_INTERNAL_TIMING) ? "Enabled" : "Disabled");
        ast_cli(a->fd, "  Transmit silence during rec: %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_TRANSMIT_SILENCE) ? "Enabled" : "Disabled");
        ast_cli(a->fd, "  Generic PLC:                 %s\n", ast_test_flag(&ast_options, AST_OPT_FLAG_GENERIC_PLC) ? "Enabled" : "Disabled");
        ast_cli(a->fd, "  Min DTMF duration::          %u\n", option_dtmfminduration);

        ast_cli(a->fd, "\n* Subsystems\n");
        ast_cli(a->fd, "  -------------\n");
        ast_cli(a->fd, "  Manager (AMI):               %s\n", check_manager_enabled() ? "Enabled" : "Disabled");
        ast_cli(a->fd, "  Web Manager (AMI/HTTP):      %s\n", check_webmanager_enabled() ? "Enabled" : "Disabled");
        ast_cli(a->fd, "  Call data records:           %s\n", check_cdr_enabled() ? "Enabled" : "Disabled");
        ast_cli(a->fd, "  Realtime Architecture (ARA): %s\n", ast_realtime_enabled() ? "Enabled" : "Disabled");

        /*! \todo we could check musiconhold, voicemail, smdi, adsi, queues  */

        ast_cli(a->fd, "\n* Directories\n");
        ast_cli(a->fd, "  -------------\n");
        ast_cli(a->fd, "  Configuration file:          %s\n", ast_config_AST_CONFIG_FILE);
        ast_cli(a->fd, "  Configuration directory:     %s\n", ast_config_AST_CONFIG_DIR);
        ast_cli(a->fd, "  Module directory:            %s\n", ast_config_AST_MODULE_DIR);
        ast_cli(a->fd, "  Spool directory:             %s\n", ast_config_AST_SPOOL_DIR);
        ast_cli(a->fd, "  Log directory:               %s\n", ast_config_AST_LOG_DIR);
        ast_cli(a->fd, "  Run/Sockets directory:       %s\n", ast_config_AST_RUN_DIR);
        ast_cli(a->fd, "  PID file:                    %s\n", ast_config_AST_PID);
        ast_cli(a->fd, "  VarLib directory:            %s\n", ast_config_AST_VAR_DIR);
        ast_cli(a->fd, "  Data directory:              %s\n", ast_config_AST_DATA_DIR);
        ast_cli(a->fd, "  ASTDB:                       %s\n", ast_config_AST_DB);
        ast_cli(a->fd, "  IAX2 Keys directory:         %s\n", ast_config_AST_KEY_DIR);
        ast_cli(a->fd, "  AGI Scripts directory:       %s\n", ast_config_AST_AGI_DIR);
        ast_cli(a->fd, "\n\n");
        return CLI_SUCCESS;
}

static char *handle_show_threads(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        int count = 0;
        struct thread_list_t *cur;
        switch (cmd) {
        case CLI_INIT:
                e->command = "core show threads";
                e->usage =
                        "Usage: core show threads\n"
                        "       List threads currently active in the system.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        AST_RWLIST_RDLOCK(&thread_list);
        AST_RWLIST_TRAVERSE(&thread_list, cur, list) {
                ast_cli(a->fd, "%p %d %s\n", (void *)cur->id, cur->lwp, cur->name);
                count++;
        }
        AST_RWLIST_UNLOCK(&thread_list);
        ast_cli(a->fd, "%d threads listed.\n", count);
        return CLI_SUCCESS;
}

#if defined (HAVE_SYSCTL) && defined(HAVE_SWAPCTL)
/*
 * swapmode is rewritten by Tobias Weingartner <weingart@openbsd.org>
 * to be based on the new swapctl(2) system call.
 */
static int swapmode(int *used, int *total)
{
        struct swapent *swdev;
        int nswap, rnswap, i;

        nswap = swapctl(SWAP_NSWAP, 0, 0);
        if (nswap == 0)
                return 0;

        swdev = ast_calloc(nswap, sizeof(*swdev));
        if (swdev == NULL)
                return 0;

        rnswap = swapctl(SWAP_STATS, swdev, nswap);
        if (rnswap == -1) {
                ast_free(swdev);
                return 0;
        }

        /* if rnswap != nswap, then what? */

        /* Total things up */
        *total = *used = 0;
        for (i = 0; i < nswap; i++) {
                if (swdev[i].se_flags & SWF_ENABLE) {
                        *used += (swdev[i].se_inuse / (1024 / DEV_BSIZE));
                        *total += (swdev[i].se_nblks / (1024 / DEV_BSIZE));
                }
        }
        ast_free(swdev);
        return 1;
}
#elif defined(HAVE_SYSCTL) && !defined(HAVE_SYSINFO)
static int swapmode(int *used, int *total)
{
        *used = *total = 0;
        return 1;
}
#endif

#if defined(HAVE_SYSINFO) || defined(HAVE_SYSCTL)
/*! \brief Give an overview of system statistics */
static char *handle_show_sysinfo(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        uint64_t physmem, freeram;
        uint64_t freeswap = 0;
        int nprocs = 0;
        long uptime = 0;
        int totalswap = 0;
#if defined(HAVE_SYSINFO)
        struct sysinfo sys_info;
        sysinfo(&sys_info);
        uptime = sys_info.uptime / 3600;
        physmem = sys_info.totalram * sys_info.mem_unit;
        freeram = (sys_info.freeram * sys_info.mem_unit) / 1024;
        totalswap = (sys_info.totalswap * sys_info.mem_unit) / 1024;
        freeswap = (sys_info.freeswap * sys_info.mem_unit) / 1024;
        nprocs = sys_info.procs;
#elif defined(HAVE_SYSCTL)
        static int pageshift;
        struct vmtotal vmtotal;
        struct timeval  boottime;
        time_t  now;
        int mib[2], pagesize, usedswap = 0;
        size_t len;
        /* calculate the uptime by looking at boottime */
        time(&now);
        mib[0] = CTL_KERN;
        mib[1] = KERN_BOOTTIME;
        len = sizeof(boottime);
        if (sysctl(mib, 2, &boottime, &len, NULL, 0) != -1) {
                uptime = now - boottime.tv_sec;
        }
        uptime = uptime/3600;
        /* grab total physical memory  */
        mib[0] = CTL_HW;
#if defined(HW_PHYSMEM64)
        mib[1] = HW_PHYSMEM64;
#else
        mib[1] = HW_PHYSMEM;
#endif
        len = sizeof(physmem);
        sysctl(mib, 2, &physmem, &len, NULL, 0);

        pagesize = getpagesize();
        pageshift = 0;
        while (pagesize > 1) {
                pageshift++;
                pagesize >>= 1;
        }

        /* we only need the amount of log(2)1024 for our conversion */
        pageshift -= 10;

        /* grab vm totals */
        mib[0] = CTL_VM;
        mib[1] = VM_METER;
        len = sizeof(vmtotal);
        sysctl(mib, 2, &vmtotal, &len, NULL, 0);
        freeram = (vmtotal.t_free << pageshift);
        /* generate swap usage and totals */
        swapmode(&usedswap, &totalswap);
        freeswap = (totalswap - usedswap);
        /* grab number of processes */
#if defined(__OpenBSD__)
        mib[0] = CTL_KERN;
        mib[1] = KERN_NPROCS;
        len = sizeof(nprocs);
        sysctl(mib, 2, &nprocs, &len, NULL, 0);
#endif
#endif

        switch (cmd) {
        case CLI_INIT:
                e->command = "core show sysinfo";
                e->usage =
                        "Usage: core show sysinfo\n"
                        "       List current system information.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        ast_cli(a->fd, "\nSystem Statistics\n");
        ast_cli(a->fd, "-----------------\n");
        ast_cli(a->fd, "  System Uptime:             %lu hours\n", uptime);
        ast_cli(a->fd, "  Total RAM:                 %" PRIu64 " KiB\n", physmem / 1024);
        ast_cli(a->fd, "  Free RAM:                  %" PRIu64 " KiB\n", freeram);
#if defined(HAVE_SYSINFO)
        ast_cli(a->fd, "  Buffer RAM:                %" PRIu64 " KiB\n", ((uint64_t) sys_info.bufferram * sys_info.mem_unit) / 1024);
#endif
#if defined (HAVE_SYSCTL) || defined(HAVE_SWAPCTL)
        ast_cli(a->fd, "  Total Swap Space:          %u KiB\n", totalswap);
        ast_cli(a->fd, "  Free Swap Space:           %" PRIu64 " KiB\n\n", freeswap);
#endif
        ast_cli(a->fd, "  Number of Processes:       %d \n\n", nprocs);
        return CLI_SUCCESS;
}
#endif

struct profile_entry {
        const char *name;
        uint64_t        scale;  /* if non-zero, values are scaled by this */
        int64_t mark;
        int64_t value;
        int64_t events;
};

struct profile_data {
        int entries;
        int max_size;
        struct profile_entry e[0];
};

static struct profile_data *prof_data;

/*! \brief allocates a counter with a given name and scale.
 * \return Returns the identifier of the counter.
 */
int ast_add_profile(const char *name, uint64_t scale)
{
        int l = sizeof(struct profile_data);
        int n = 10;     /* default entries */

        if (prof_data == NULL) {
                prof_data = ast_calloc(1, l + n*sizeof(struct profile_entry));
                if (prof_data == NULL)
                        return -1;
                prof_data->entries = 0;
                prof_data->max_size = n;
        }
        if (prof_data->entries >= prof_data->max_size) {
                void *p;
                n = prof_data->max_size + 20;
                p = ast_realloc(prof_data, l + n*sizeof(struct profile_entry));
                if (p == NULL)
                        return -1;
                prof_data = p;
                prof_data->max_size = n;
        }
        n = prof_data->entries++;
        prof_data->e[n].name = ast_strdup(name);
        prof_data->e[n].value = 0;
        prof_data->e[n].events = 0;
        prof_data->e[n].mark = 0;
        prof_data->e[n].scale = scale;
        return n;
}

int64_t ast_profile(int i, int64_t delta)
{
        if (!prof_data || i < 0 || i > prof_data->entries)      /* invalid index */
                return 0;
        if (prof_data->e[i].scale > 1)
                delta /= prof_data->e[i].scale;
        prof_data->e[i].value += delta;
        prof_data->e[i].events++;
        return prof_data->e[i].value;
}

/* The RDTSC instruction was introduced on the Pentium processor and is not
 * implemented on certain clones, like the Cyrix 586. Hence, the previous
 * expectation of __i386__ was in error. */
#if defined ( __i686__) && (defined(__FreeBSD__) || defined(linux))
#if defined(__FreeBSD__)
#include <machine/cpufunc.h>
#elif defined(linux)
static __inline uint64_t
rdtsc(void)
{
        uint64_t rv;

        __asm __volatile(".byte 0x0f, 0x31" : "=A" (rv));
        return (rv);
}
#endif
#else   /* supply a dummy function on other platforms */
static __inline uint64_t
rdtsc(void)
{
        return 0;
}
#endif

int64_t ast_mark(int i, int startstop)
{
        if (!prof_data || i < 0 || i > prof_data->entries) /* invalid index */
                return 0;
        if (startstop == 1)
                prof_data->e[i].mark = rdtsc();
        else {
                prof_data->e[i].mark = (rdtsc() - prof_data->e[i].mark);
                if (prof_data->e[i].scale > 1)
                        prof_data->e[i].mark /= prof_data->e[i].scale;
                prof_data->e[i].value += prof_data->e[i].mark;
                prof_data->e[i].events++;
        }
        return prof_data->e[i].mark;
}

#define DEFINE_PROFILE_MIN_MAX_VALUES min = 0; \
        max = prof_data->entries;\
        if  (a->argc > 3) { /* specific entries */ \
                if (isdigit(a->argv[3][0])) { \
                        min = atoi(a->argv[3]); \
                        if (a->argc == 5 && strcmp(a->argv[4], "-")) \
                                max = atoi(a->argv[4]); \
                } else \
                        search = a->argv[3]; \
        } \
        if (max > prof_data->entries) \
                max = prof_data->entries;

static char *handle_show_profile(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        int i, min, max;
        const char *search = NULL;
        switch (cmd) {
        case CLI_INIT:
                e->command = "core show profile";
                e->usage = "Usage: core show profile\n"
                           "       show profile information";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (prof_data == NULL)
                return 0;

        DEFINE_PROFILE_MIN_MAX_VALUES;
        ast_cli(a->fd, "profile values (%d, allocated %d)\n-------------------\n",
                prof_data->entries, prof_data->max_size);
        ast_cli(a->fd, "%6s   %8s  %10s %12s %12s  %s\n", "ID", "Scale", "Events",
                        "Value", "Average", "Name");
        for (i = min; i < max; i++) {
                struct profile_entry *entry = &prof_data->e[i];
                if (!search || strstr(entry->name, search))
                    ast_cli(a->fd, "%6d: [%8ld] %10ld %12lld %12lld  %s\n",
                        i,
                        (long)entry->scale,
                        (long)entry->events, (long long)entry->value,
                        (long long)(entry->events ? entry->value / entry->events : entry->value),
                        entry->name);
        }
        return CLI_SUCCESS;
}

static char *handle_clear_profile(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        int i, min, max;
        const char *search = NULL;
        switch (cmd) {
        case CLI_INIT:
                e->command = "core clear profile";
                e->usage = "Usage: core clear profile\n"
                           "       clear profile information";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (prof_data == NULL)
                return 0;

        DEFINE_PROFILE_MIN_MAX_VALUES;
        for (i= min; i < max; i++) {
                if (!search || strstr(prof_data->e[i].name, search)) {
                        prof_data->e[i].value = 0;
                        prof_data->e[i].events = 0;
                }
        }
        return CLI_SUCCESS;
}
#undef DEFINE_PROFILE_MIN_MAX_VALUES

/*! \brief CLI command to list module versions */
static char *handle_show_version_files(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
#define FORMAT "%-25.25s %-40.40s\n"
        struct file_version *iterator;
        regex_t regexbuf;
        int havepattern = 0;
        int havename = 0;
        int count_files = 0;
        char *ret = NULL;
        int matchlen, which = 0;
        struct file_version *find;

        switch (cmd) {
        case CLI_INIT:
                e->command = "core show file version [like]";
                e->usage =
                        "Usage: core show file version [like <pattern>]\n"
                        "       Lists the revision numbers of the files used to build this copy of Asterisk.\n"
                        "       Optional regular expression pattern is used to filter the file list.\n";
                return NULL;
        case CLI_GENERATE:
                matchlen = strlen(a->word);
                if (a->pos != 3)
                        return NULL;
                AST_RWLIST_RDLOCK(&file_versions);
                AST_RWLIST_TRAVERSE(&file_versions, find, list) {
                        if (!strncasecmp(a->word, find->file, matchlen) && ++which > a->n) {
                                ret = ast_strdup(find->file);
                                break;
                        }
                }
                AST_RWLIST_UNLOCK(&file_versions);
                return ret;
        }


        switch (a->argc) {
        case 6:
                if (!strcasecmp(a->argv[4], "like")) {
                        if (regcomp(&regexbuf, a->argv[5], REG_EXTENDED | REG_NOSUB))
                                return CLI_SHOWUSAGE;
                        havepattern = 1;
                } else
                        return CLI_SHOWUSAGE;
                break;
        case 5:
                havename = 1;
                break;
        case 4:
                break;
        default:
                return CLI_SHOWUSAGE;
        }

        ast_cli(a->fd, FORMAT, "File", "Revision");
        ast_cli(a->fd, FORMAT, "----", "--------");
        AST_RWLIST_RDLOCK(&file_versions);
        AST_RWLIST_TRAVERSE(&file_versions, iterator, list) {
                if (havename && strcasecmp(iterator->file, a->argv[4]))
                        continue;

                if (havepattern && regexec(&regexbuf, iterator->file, 0, NULL, 0))
                        continue;

                ast_cli(a->fd, FORMAT, iterator->file, iterator->version);
                count_files++;
                if (havename)
                        break;
        }
        AST_RWLIST_UNLOCK(&file_versions);
        if (!havename) {
                ast_cli(a->fd, "%d files listed.\n", count_files);
        }

        if (havepattern)
                regfree(&regexbuf);

        return CLI_SUCCESS;
#undef FORMAT
}

#endif /* ! LOW_MEMORY */

struct stasis_topic *ast_system_topic(void)
{
        return system_topic;
}

/*! \brief Cleanup the \ref stasis system level items */
static void stasis_system_topic_cleanup(void)
{
        ao2_cleanup(system_topic);
        system_topic = NULL;
        STASIS_MESSAGE_TYPE_CLEANUP(ast_network_change_type);
}

/*! \brief Initialize the system level items for \ref stasis */
static int stasis_system_topic_init(void)
{
        ast_register_atexit(stasis_system_topic_cleanup);

        system_topic = stasis_topic_create("ast_system");
        if (!system_topic) {
                return 1;
        }

        if (STASIS_MESSAGE_TYPE_INIT(ast_network_change_type) != 0) {
                return -1;
        }

        return 0;
}

/*!
 * \brief Publish a \ref system_status_type message over \ref stasis
 *
 * \param payload The JSON payload to send with the message
 */
static void publish_system_message(const char *message_type, struct ast_json *obj)
{
        RAII_VAR(struct stasis_message *, message, NULL, ao2_cleanup);
        RAII_VAR(struct ast_json_payload *, payload, NULL, ao2_cleanup);
        RAII_VAR(struct ast_json *, event_info, NULL, ast_json_unref);

        if (!obj) {
                return;
        }

        event_info = ast_json_pack("{s: s, s: i, s: o}",
                        "type", message_type,
                        "class_type", EVENT_FLAG_SYSTEM,
                        "event", obj);
        if (!event_info) {
                return;
        }

        payload = ast_json_payload_create(event_info);
        if (!payload) {
                return;
        }

        message = stasis_message_create(ast_manager_get_generic_type(), payload);
        if (!message) {
                return;
        }
        stasis_publish(ast_manager_get_topic(), message);
}

static void publish_fully_booted(void)
{
        RAII_VAR(struct ast_json *, json_object, NULL, ast_json_unref);

        json_object = ast_json_pack("{s: s}",
                        "Status", "Fully Booted");
        publish_system_message("FullyBooted", json_object);
}

static void ast_run_atexits(void)
{
        struct ast_atexit *ae;

        AST_LIST_LOCK(&atexits);
        while ((ae = AST_LIST_REMOVE_HEAD(&atexits, list))) {
                if (ae->func) {
                        ae->func();
                }
                ast_free(ae);
        }
        AST_LIST_UNLOCK(&atexits);
}

static void __ast_unregister_atexit(void (*func)(void))
{
        struct ast_atexit *ae;

        AST_LIST_TRAVERSE_SAFE_BEGIN(&atexits, ae, list) {
                if (ae->func == func) {
                        AST_LIST_REMOVE_CURRENT(list);
                        ast_free(ae);
                        break;
                }
        }
        AST_LIST_TRAVERSE_SAFE_END;
}

int ast_register_atexit(void (*func)(void))
{
        struct ast_atexit *ae;

        ae = ast_calloc(1, sizeof(*ae));
        if (!ae) {
                return -1;
        }
        ae->func = func;

        AST_LIST_LOCK(&atexits);
        __ast_unregister_atexit(func);
        AST_LIST_INSERT_HEAD(&atexits, ae, list);
        AST_LIST_UNLOCK(&atexits);

        return 0;
}

void ast_unregister_atexit(void (*func)(void))
{
        AST_LIST_LOCK(&atexits);
        __ast_unregister_atexit(func);
        AST_LIST_UNLOCK(&atexits);
}

/* Sending commands from consoles back to the daemon requires a terminating NULL */
static int fdsend(int fd, const char *s)
{
        return write(fd, s, strlen(s) + 1);
}

/* Sending messages from the daemon back to the display requires _excluding_ the terminating NULL */
static int fdprint(int fd, const char *s)
{
        return write(fd, s, strlen(s));
}

/*! \brief NULL handler so we can collect the child exit status */
static void _null_sig_handler(int sig)
{
}

static struct sigaction null_sig_handler = {
        .sa_handler = _null_sig_handler,
        .sa_flags = SA_RESTART,
};

static struct sigaction ignore_sig_handler = {
        .sa_handler = SIG_IGN,
};

AST_MUTEX_DEFINE_STATIC(safe_system_lock);
/*! \brief Keep track of how many threads are currently trying to wait*() on
 *  a child process
 */
static unsigned int safe_system_level = 0;
static struct sigaction safe_system_prev_handler;

void ast_replace_sigchld(void)
{
        unsigned int level;

        ast_mutex_lock(&safe_system_lock);
        level = safe_system_level++;

        /* only replace the handler if it has not already been done */
        if (level == 0) {
                sigaction(SIGCHLD, &null_sig_handler, &safe_system_prev_handler);
        }

        ast_mutex_unlock(&safe_system_lock);
}

void ast_unreplace_sigchld(void)
{
        unsigned int level;

        ast_mutex_lock(&safe_system_lock);
        level = --safe_system_level;

        /* only restore the handler if we are the last one */
        if (level == 0) {
                sigaction(SIGCHLD, &safe_system_prev_handler, NULL);
        }

        ast_mutex_unlock(&safe_system_lock);
}

int ast_safe_system(const char *s)
{
        pid_t pid;
        int res;
        struct rusage rusage;
        int status;

#if defined(HAVE_WORKING_FORK) || defined(HAVE_WORKING_VFORK)
        ast_replace_sigchld();

#ifdef HAVE_WORKING_FORK
        pid = fork();
#else
        pid = vfork();
#endif

        if (pid == 0) {
#ifdef HAVE_CAP
                cap_t cap = cap_from_text("cap_net_admin-eip");

                if (cap_set_proc(cap)) {
                        /* Careful with order! Logging cannot happen after we close FDs */
                        ast_log(LOG_WARNING, "Unable to remove capabilities.\n");
                }
                cap_free(cap);
#endif
#ifdef HAVE_WORKING_FORK
                if (ast_opt_high_priority)
                        ast_set_priority(0);
                /* Close file descriptors and launch system command */
                ast_close_fds_above_n(STDERR_FILENO);
#endif
                execl("/bin/sh", "/bin/sh", "-c", s, (char *) NULL);
                _exit(1);
        } else if (pid > 0) {
                for (;;) {
                        res = wait4(pid, &status, 0, &rusage);
                        if (res > -1) {
                                res = WIFEXITED(status) ? WEXITSTATUS(status) : -1;
                                break;
                        } else if (errno != EINTR)
                                break;
                }
        } else {
                ast_log(LOG_WARNING, "Fork failed: %s\n", strerror(errno));
                res = -1;
        }

        ast_unreplace_sigchld();
#else /* !defined(HAVE_WORKING_FORK) && !defined(HAVE_WORKING_VFORK) */
        res = -1;
#endif

        return res;
}

/*!
 * \brief enable or disable a logging level to a specified console
 */
void ast_console_toggle_loglevel(int fd, int level, int state)
{
        int x;

        if (level >= NUMLOGLEVELS) {
                level = NUMLOGLEVELS - 1;
        }

        for (x = 0;x < AST_MAX_CONNECTS; x++) {
                if (fd == consoles[x].fd) {
                        /*
                         * Since the logging occurs when levels are false, set to
                         * flipped iinput because this function accepts 0 as off and 1 as on
                         */
                        consoles[x].levels[level] = state ? 0 : 1;
                        return;
                }
        }
}

/*!
 * \brief mute or unmute a console from logging
 */
void ast_console_toggle_mute(int fd, int silent)
{
        int x;
        for (x = 0;x < AST_MAX_CONNECTS; x++) {
                if (fd == consoles[x].fd) {
                        if (consoles[x].mute) {
                                consoles[x].mute = 0;
                                if (!silent)
                                        ast_cli(fd, "Console is not muted anymore.\n");
                        } else {
                                consoles[x].mute = 1;
                                if (!silent)
                                        ast_cli(fd, "Console is muted.\n");
                        }
                        return;
                }
        }
        ast_cli(fd, "Couldn't find remote console.\n");
}

/*!
 * \brief log the string to all attached console clients
 */
static void ast_network_puts_mutable(const char *string, int level)
{
        int x;
        for (x = 0;x < AST_MAX_CONNECTS; x++) {
                if (consoles[x].mute)
                        continue;
                if (consoles[x].fd > -1) {
                        if (!consoles[x].levels[level])
                                fdprint(consoles[x].p[1], string);
                }
        }
}

/*!
 * \brief log the string to the console, and all attached
 * console clients
 */
void ast_console_puts_mutable(const char *string, int level)
{
        fputs(string, stdout);
        fflush(stdout);
        ast_network_puts_mutable(string, level);
}

/*!
 * \brief write the string to all attached console clients
 */
static void ast_network_puts(const char *string)
{
        int x;
        for (x = 0; x < AST_MAX_CONNECTS; x++) {
                if (consoles[x].fd > -1)
                        fdprint(consoles[x].p[1], string);
        }
}

/*!
 * \brief write the string to the console, and all attached
 * console clients
 */
void ast_console_puts(const char *string)
{
        fputs(string, stdout);
        fflush(stdout);
        ast_network_puts(string);
}

static void network_verboser(const char *s)
{
        ast_network_puts_mutable(s, __LOG_VERBOSE);
}

static pthread_t lthread;

/*!
 * \brief read() function supporting the reception of user credentials.
 *
 * \param fd Socket file descriptor.
 * \param buffer Receive buffer.
 * \param size 'buffer' size.
 * \param con Console structure to set received credentials
 * \retval -1 on error
 * \retval the number of bytes received on success.
 */
static int read_credentials(int fd, char *buffer, size_t size, struct console *con)
{
#if defined(SO_PEERCRED)
#ifdef HAVE_STRUCT_SOCKPEERCRED_UID
#define HAVE_STRUCT_UCRED_UID
        struct sockpeercred cred;
#else
        struct ucred cred;
#endif
        socklen_t len = sizeof(cred);
#endif
#if defined(HAVE_GETPEEREID)
        uid_t uid;
        gid_t gid;
#else
        int uid, gid;
#endif
        int result;

        result = read(fd, buffer, size);
        if (result < 0) {
                return result;
        }

#if defined(SO_PEERCRED) && (defined(HAVE_STRUCT_UCRED_UID) || defined(HAVE_STRUCT_UCRED_CR_UID))
        if (getsockopt(fd, SOL_SOCKET, SO_PEERCRED, &cred, &len)) {
                return result;
        }
#if defined(HAVE_STRUCT_UCRED_UID)
        uid = cred.uid;
        gid = cred.gid;
#else /* defined(HAVE_STRUCT_UCRED_CR_UID) */
        uid = cred.cr_uid;
        gid = cred.cr_gid;
#endif /* defined(HAVE_STRUCT_UCRED_UID) */

#elif defined(HAVE_GETPEEREID)
        if (getpeereid(fd, &uid, &gid)) {
                return result;
        }
#else
        return result;
#endif
        con->uid = uid;
        con->gid = gid;

        return result;
}

static void *netconsole(void *vconsole)
{
        struct console *con = vconsole;
        char hostname[MAXHOSTNAMELEN] = "";
        char inbuf[512];
        char outbuf[512];
        const char * const end_buf = inbuf + sizeof(inbuf);
        char *start_read = inbuf;
        int res;
        struct pollfd fds[2];

        if (gethostname(hostname, sizeof(hostname)-1))
                ast_copy_string(hostname, "<Unknown>", sizeof(hostname));
        snprintf(outbuf, sizeof(outbuf), "%s/%ld/%s\n", hostname, (long)ast_mainpid, ast_get_version());
        fdprint(con->fd, outbuf);
        for (;;) {
                fds[0].fd = con->fd;
                fds[0].events = POLLIN;
                fds[0].revents = 0;
                fds[1].fd = con->p[0];
                fds[1].events = POLLIN;
                fds[1].revents = 0;

                res = ast_poll(fds, 2, -1);
                if (res < 0) {
                        if (errno != EINTR)
                                ast_log(LOG_WARNING, "poll returned < 0: %s\n", strerror(errno));
                        continue;
                }
                if (fds[0].revents) {
                        int cmds_read, bytes_read;
                        if ((bytes_read = read_credentials(con->fd, start_read, end_buf - start_read, con)) < 1) {
                                break;
                        }
                        /* XXX This will only work if it is the first command, and I'm not sure fixing it is worth the effort. */
                        if (strncmp(inbuf, "cli quit after ", 15) == 0) {
                                ast_cli_command_multiple_full(con->uid, con->gid, con->fd, bytes_read - 15, inbuf + 15);
                                break;
                        }
                        /* ast_cli_command_multiple_full will only process individual commands terminated by a
                         * NULL and not trailing partial commands. */
                        if (!(cmds_read = ast_cli_command_multiple_full(con->uid, con->gid, con->fd, bytes_read + start_read - inbuf, inbuf))) {
                                /* No commands were read. We either have a short read on the first command
                                 * with space left, or a command that is too long */
                                if (start_read + bytes_read < end_buf) {
                                        start_read += bytes_read;
                                } else {
                                        ast_log(LOG_ERROR, "Command too long! Skipping\n");
                                        start_read = inbuf;
                                }
                                continue;
                        }
                        if (start_read[bytes_read - 1] == '\0') {
                                /* The read ended on a command boundary, start reading again at the head of inbuf */
                                start_read = inbuf;
                                continue;
                        }
                        /* If we get this far, we have left over characters that have not been processed.
                         * Advance to the character after the last command read by ast_cli_command_multiple_full.
                         * We are guaranteed to have at least cmds_read NULLs */
                        while (cmds_read-- && (start_read = strchr(start_read, '\0'))) {
                                start_read++;
                        }
                        memmove(inbuf, start_read, end_buf - start_read);
                        start_read = end_buf - start_read + inbuf;
                }
                if (fds[1].revents) {
                        res = read_credentials(con->p[0], outbuf, sizeof(outbuf), con);
                        if (res < 1) {
                                ast_log(LOG_ERROR, "read returned %d\n", res);
                                break;
                        }
                        res = write(con->fd, outbuf, res);
                        if (res < 1)
                                break;
                }
        }
        if (!ast_opt_hide_connect) {
                ast_verb(3, "Remote UNIX connection disconnected\n");
        }
        close(con->fd);
        close(con->p[0]);
        close(con->p[1]);
        con->fd = -1;

        return NULL;
}

static void *listener(void *unused)
{
        struct sockaddr_un sunaddr;
        int s;
        socklen_t len;
        int x;
        int flags;
        struct pollfd fds[1];
        for (;;) {
                if (ast_socket < 0)
                        return NULL;
                fds[0].fd = ast_socket;
                fds[0].events = POLLIN;
                s = ast_poll(fds, 1, -1);
                pthread_testcancel();
                if (s < 0) {
                        if (errno != EINTR)
                                ast_log(LOG_WARNING, "poll returned error: %s\n", strerror(errno));
                        continue;
                }
                len = sizeof(sunaddr);
                s = accept(ast_socket, (struct sockaddr *)&sunaddr, &len);
                if (s < 0) {
                        if (errno != EINTR)
                                ast_log(LOG_WARNING, "Accept returned %d: %s\n", s, strerror(errno));
                } else {
#if !defined(SO_PASSCRED)
                        {
#else
                        int sckopt = 1;
                        /* turn on socket credentials passing. */
                        if (setsockopt(s, SOL_SOCKET, SO_PASSCRED, &sckopt, sizeof(sckopt)) < 0) {
                                ast_log(LOG_WARNING, "Unable to turn on socket credentials passing\n");
                        } else {
#endif
                                for (x = 0; x < AST_MAX_CONNECTS; x++) {
                                        if (consoles[x].fd >= 0) {
                                                continue;
                                        }
                                        if (socketpair(AF_LOCAL, SOCK_STREAM, 0, consoles[x].p)) {
                                                ast_log(LOG_ERROR, "Unable to create pipe: %s\n", strerror(errno));
                                                consoles[x].fd = -1;
                                                fdprint(s, "Server failed to create pipe\n");
                                                close(s);
                                                break;
                                        }
                                        flags = fcntl(consoles[x].p[1], F_GETFL);
                                        fcntl(consoles[x].p[1], F_SETFL, flags | O_NONBLOCK);
                                        consoles[x].fd = s;
                                        consoles[x].mute = 1; /* Default is muted, we will un-mute if necessary */
                                        /* Default uid and gid to -2, so then in cli.c/cli_has_permissions() we will be able
                                           to know if the user didn't send the credentials. */
                                        consoles[x].uid = -2;
                                        consoles[x].gid = -2;
                                        if (ast_pthread_create_detached_background(&consoles[x].t, NULL, netconsole, &consoles[x])) {
                                                ast_log(LOG_ERROR, "Unable to spawn thread to handle connection: %s\n", strerror(errno));
                                                close(consoles[x].p[0]);
                                                close(consoles[x].p[1]);
                                                consoles[x].fd = -1;
                                                fdprint(s, "Server failed to spawn thread\n");
                                                close(s);
                                        }
                                        break;
                                }
                                if (x >= AST_MAX_CONNECTS) {
                                        fdprint(s, "No more connections allowed\n");
                                        ast_log(LOG_WARNING, "No more connections allowed\n");
                                        close(s);
                                } else if ((consoles[x].fd > -1) && (!ast_opt_hide_connect)) {
                                        ast_verb(3, "Remote UNIX connection\n");
                                }
                        }
                }
        }
        return NULL;
}

static int ast_makesocket(void)
{
        struct sockaddr_un sunaddr;
        int res;
        int x;
        uid_t uid = -1;
        gid_t gid = -1;

        for (x = 0; x < AST_MAX_CONNECTS; x++)
                consoles[x].fd = -1;
        unlink(ast_config_AST_SOCKET);
        ast_socket = socket(PF_LOCAL, SOCK_STREAM, 0);
        if (ast_socket < 0) {
                ast_log(LOG_WARNING, "Unable to create control socket: %s\n", strerror(errno));
                return -1;
        }
        memset(&sunaddr, 0, sizeof(sunaddr));
        sunaddr.sun_family = AF_LOCAL;
        ast_copy_string(sunaddr.sun_path, ast_config_AST_SOCKET, sizeof(sunaddr.sun_path));
        res = bind(ast_socket, (struct sockaddr *)&sunaddr, sizeof(sunaddr));
        if (res) {
                ast_log(LOG_WARNING, "Unable to bind socket to %s: %s\n", ast_config_AST_SOCKET, strerror(errno));
                close(ast_socket);
                ast_socket = -1;
                return -1;
        }
        res = listen(ast_socket, 2);
        if (res < 0) {
                ast_log(LOG_WARNING, "Unable to listen on socket %s: %s\n", ast_config_AST_SOCKET, strerror(errno));
                close(ast_socket);
                ast_socket = -1;
                return -1;
        }
        if (ast_register_verbose(network_verboser)) {
                ast_log(LOG_WARNING, "Unable to register network verboser?\n");
        }

        if (ast_pthread_create_background(&lthread, NULL, listener, NULL)) {
                ast_log(LOG_WARNING, "Unable to create listener thread.\n");
                close(ast_socket);
                return -1;
        }

        if (!ast_strlen_zero(ast_config_AST_CTL_OWNER)) {
                struct passwd *pw;
                if ((pw = getpwnam(ast_config_AST_CTL_OWNER)) == NULL)
                        ast_log(LOG_WARNING, "Unable to find uid of user %s\n", ast_config_AST_CTL_OWNER);
                else
                        uid = pw->pw_uid;
        }

        if (!ast_strlen_zero(ast_config_AST_CTL_GROUP)) {
                struct group *grp;
                if ((grp = getgrnam(ast_config_AST_CTL_GROUP)) == NULL)
                        ast_log(LOG_WARNING, "Unable to find gid of group %s\n", ast_config_AST_CTL_GROUP);
                else
                        gid = grp->gr_gid;
        }

        if (chown(ast_config_AST_SOCKET, uid, gid) < 0)
                ast_log(LOG_WARNING, "Unable to change ownership of %s: %s\n", ast_config_AST_SOCKET, strerror(errno));

        if (!ast_strlen_zero(ast_config_AST_CTL_PERMISSIONS)) {
                int p1;
                mode_t p;
                sscanf(ast_config_AST_CTL_PERMISSIONS, "%30o", &p1);
                p = p1;
                if ((chmod(ast_config_AST_SOCKET, p)) < 0)
                        ast_log(LOG_WARNING, "Unable to change file permissions of %s: %s\n", ast_config_AST_SOCKET, strerror(errno));
        }

        return 0;
}

static int ast_tryconnect(void)
{
        struct sockaddr_un sunaddr;
        int res;
        ast_consock = socket(PF_LOCAL, SOCK_STREAM, 0);
        if (ast_consock < 0) {
                fprintf(stderr, "Unable to create socket: %s\n", strerror(errno));
                return 0;
        }
        memset(&sunaddr, 0, sizeof(sunaddr));
        sunaddr.sun_family = AF_LOCAL;
        ast_copy_string(sunaddr.sun_path, ast_config_AST_SOCKET, sizeof(sunaddr.sun_path));
        res = connect(ast_consock, (struct sockaddr *)&sunaddr, sizeof(sunaddr));
        if (res) {
                close(ast_consock);
                ast_consock = -1;
                return 0;
        } else
                return 1;
}

/*! \brief Urgent handler
 *
 * Called by soft_hangup to interrupt the poll, read, or other
 * system call.  We don't actually need to do anything though.
 * Remember: Cannot EVER ast_log from within a signal handler
 */
static void _urg_handler(int num)
{
        return;
}

static struct sigaction urg_handler = {
        .sa_handler = _urg_handler,
        .sa_flags = SA_RESTART,
};

static void _hup_handler(int num)
{
        int a = 0, save_errno = errno;
        printf("Received HUP signal -- Reloading configs\n");
        if (restartnow)
                execvp(_argv[0], _argv);
        sig_flags.need_reload = 1;
        if (sig_alert_pipe[1] != -1) {
                if (write(sig_alert_pipe[1], &a, sizeof(a)) < 0) {
                        fprintf(stderr, "hup_handler: write() failed: %s\n", strerror(errno));
                }
        }
        errno = save_errno;
}

static struct sigaction hup_handler = {
        .sa_handler = _hup_handler,
        .sa_flags = SA_RESTART,
};

static void _child_handler(int sig)
{
        /* Must not ever ast_log or ast_verbose within signal handler */
        int n, status, save_errno = errno;

        /*
         * Reap all dead children -- not just one
         */
        for (n = 0; wait4(-1, &status, WNOHANG, NULL) > 0; n++)
                ;
        if (n == 0 && option_debug)
                printf("Huh?  Child handler, but nobody there?\n");
        errno = save_errno;
}

static struct sigaction child_handler = {
        .sa_handler = _child_handler,
        .sa_flags = SA_RESTART,
};

/*! \brief Set maximum open files */
static void set_ulimit(int value)
{
        struct rlimit l = {0, 0};

        if (value <= 0) {
                ast_log(LOG_WARNING, "Unable to change max files open to invalid value %i\n",value);
                return;
        }

        l.rlim_cur = value;
        l.rlim_max = value;

        if (setrlimit(RLIMIT_NOFILE, &l)) {
                ast_log(LOG_WARNING, "Unable to disable core size resource limit: %s\n",strerror(errno));
                return;
        }

        ast_log(LOG_NOTICE, "Setting max files open to %d\n",value);

        return;
}

/*! \brief Set an X-term or screen title */
static void set_title(char *text)
{
        if (getenv("TERM") && strstr(getenv("TERM"), "xterm"))
                fprintf(stdout, "\033]2;%s\007", text);
}

static void set_icon(char *text)
{
        if (getenv("TERM") && strstr(getenv("TERM"), "xterm"))
                fprintf(stdout, "\033]1;%s\007", text);
}

/*! \brief 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_set_priority(int pri)
{
        struct sched_param sched;
        memset(&sched, 0, sizeof(sched));
#ifdef __linux__
        if (pri) {
                sched.sched_priority = 10;
                if (sched_setscheduler(0, SCHED_RR, &sched)) {
                        ast_log(LOG_WARNING, "Unable to set high priority\n");
                        return -1;
                } else
                        ast_verb(1, "Set to realtime thread\n");
        } else {
                sched.sched_priority = 0;
                /* According to the manpage, these parameters can never fail. */
                sched_setscheduler(0, SCHED_OTHER, &sched);
        }
#else
        if (pri) {
                if (setpriority(PRIO_PROCESS, 0, -10) == -1) {
                        ast_log(LOG_WARNING, "Unable to set high priority\n");
                        return -1;
                } else
                        ast_verb(1, "Set to high priority\n");
        } else {
                /* According to the manpage, these parameters can never fail. */
                setpriority(PRIO_PROCESS, 0, 0);
        }
#endif
        return 0;
}

static int can_safely_quit(shutdown_nice_t niceness, int restart);
static void really_quit(int num, shutdown_nice_t niceness, int restart);

static void quit_handler(int num, shutdown_nice_t niceness, int restart)
{
        if (can_safely_quit(niceness, restart)) {
                really_quit(num, niceness, restart);
                /* No one gets here. */
        }
        /* It wasn't our time. */
}

static int can_safely_quit(shutdown_nice_t niceness, int restart)
{
        /* Check if someone else isn't already doing this. */
        ast_mutex_lock(&safe_system_lock);
        if (shuttingdown != NOT_SHUTTING_DOWN && niceness >= shuttingdown) {
                /* Already in progress and other request was less nice. */
                ast_mutex_unlock(&safe_system_lock);
                ast_verbose("Ignoring asterisk %s request, already in progress.\n", restart ? "restart" : "shutdown");
                return 0;
        }
        shuttingdown = niceness;
        ast_mutex_unlock(&safe_system_lock);

        /* Try to get as many CDRs as possible submitted to the backend engines
         * (if in batch mode). really_quit happens to call it again when running
         * the atexit handlers, otherwise this would be a bit early. */
        ast_cdr_engine_term();

        /* Shutdown the message queue for the technology agnostic message channel.
         * This has to occur before we pause shutdown pending ast_undestroyed_channels. */
        ast_msg_shutdown();

        if (niceness == SHUTDOWN_NORMAL) {
                time_t s, e;
                /* Begin shutdown routine, hanging up active channels */
                ast_begin_shutdown(1);
                if (option_verbose && ast_opt_console) {
                        ast_verbose("Beginning asterisk %s....\n", restart ? "restart" : "shutdown");
                }
                time(&s);
                for (;;) {
                        time(&e);
                        /* Wait up to 15 seconds for all channels to go away */
                        if ((e - s) > 15 || !ast_undestroyed_channels() || shuttingdown != niceness) {
                                break;
                        }
                        /* Sleep 1/10 of a second */
                        usleep(100000);
                }
        } else if (niceness >= SHUTDOWN_NICE) {
                if (niceness != SHUTDOWN_REALLY_NICE) {
                        ast_begin_shutdown(0);
                }
                if (option_verbose && ast_opt_console) {
                        ast_verb(0, "Waiting for inactivity to perform %s...\n", restart ? "restart" : "halt");
                }
                for (;;) {
                        if (!ast_undestroyed_channels() || shuttingdown != niceness) {
                                break;
                        }
                        sleep(1);
                }
        }

        /* Re-acquire lock and check if someone changed the niceness, in which
         * case someone else has taken over the shutdown.
         */
        ast_mutex_lock(&safe_system_lock);
        if (shuttingdown != niceness) {
                if (shuttingdown == NOT_SHUTTING_DOWN && option_verbose && ast_opt_console) {
                        ast_verb(0, "Asterisk %s cancelled.\n", restart ? "restart" : "shutdown");
                }
                ast_mutex_unlock(&safe_system_lock);
                return 0;
        }
        shuttingdown = SHUTTING_DOWN;
        ast_mutex_unlock(&safe_system_lock);

        return 1;
}

/*! Called when exiting is certain. */
static void really_quit(int num, shutdown_nice_t niceness, int restart)
{
        int active_channels;
        RAII_VAR(struct ast_json *, json_object, NULL, ast_json_unref);

        if (niceness >= SHUTDOWN_NICE) {
                ast_module_shutdown();
        }

        if (ast_opt_console || (ast_opt_remote && !ast_opt_exec)) {
                char filename[80] = "";
                if (getenv("HOME")) {
                        snprintf(filename, sizeof(filename), "%s/.asterisk_history", getenv("HOME"));
                }
                if (!ast_strlen_zero(filename)) {
                        ast_el_write_history(filename);
                }
                if (consolethread == AST_PTHREADT_NULL || consolethread == pthread_self()) {
                        /* Only end if we are the consolethread, otherwise there's a race with that thread. */
                        if (el != NULL) {
                                el_end(el);
                        }
                        if (el_hist != NULL) {
                                history_end(el_hist);
                        }
                } else if (mon_sig_flags == pthread_self()) {
                        if (consolethread != AST_PTHREADT_NULL) {
                                pthread_kill(consolethread, SIGURG);
                        }
                }
        }
        active_channels = ast_active_channels();
        json_object = ast_json_pack("{s: s, s: s}",
                        "Shutdown", active_channels ? "Uncleanly" : "Cleanly",
                        "Restart", restart ? "True" : "False");
        publish_system_message("Shutdown", json_object);
        ast_verb(0, "Asterisk %s ending (%d).\n",
                active_channels ? "uncleanly" : "cleanly", num);

        ast_verb(0, "Executing last minute cleanups\n");
        ast_run_atexits();

        ast_debug(1, "Asterisk ending (%d).\n", num);
        if (ast_socket > -1) {
                pthread_cancel(lthread);
                close(ast_socket);
                ast_socket = -1;
                unlink(ast_config_AST_SOCKET);
        }
        if (ast_consock > -1)
                close(ast_consock);
        if (!ast_opt_remote)
                unlink(ast_config_AST_PID);
        printf("%s", term_quit());
        if (restart) {
                int i;
                ast_verb(0, "Preparing for Asterisk restart...\n");
                /* Mark all FD's for closing on exec */
                for (i = 3; i < 32768; i++) {
                        fcntl(i, F_SETFD, FD_CLOEXEC);
                }
                ast_verb(0, "Asterisk is now restarting...\n");
                restartnow = 1;

                /* close logger */
                close_logger();
                clean_time_zones();

                /* If there is a consolethread running send it a SIGHUP
                   so it can execvp, otherwise we can do it ourselves */
                if ((consolethread != AST_PTHREADT_NULL) && (consolethread != pthread_self())) {
                        pthread_kill(consolethread, SIGHUP);
                        /* Give the signal handler some time to complete */
                        sleep(2);
                } else
                        execvp(_argv[0], _argv);

        } else {
                /* close logger */
                close_logger();
                clean_time_zones();
        }

        exit(0);
}

static void __quit_handler(int num)
{
        int a = 0;
        sig_flags.need_quit = 1;
        if (sig_alert_pipe[1] != -1) {
                if (write(sig_alert_pipe[1], &a, sizeof(a)) < 0) {
                        fprintf(stderr, "quit_handler: write() failed: %s\n", strerror(errno));
                }
        }
        /* There is no need to restore the signal handler here, since the app
         * is going to exit */
}

static void __remote_quit_handler(int num)
{
        sig_flags.need_quit = 1;
}

static const char *fix_header(char *outbuf, int maxout, const char *s, char *cmp)
{
        const char *c;

        if (!strncmp(s, cmp, strlen(cmp))) {
                c = s + strlen(cmp);
                term_color(outbuf, cmp, COLOR_GRAY, 0, maxout);
                return c;
        }
        return NULL;
}

/* These gymnastics are due to platforms which designate char as unsigned by
 * default. Level is the negative character -- offset by 1, because \0 is the
 * EOS delimiter. */
#define VERBOSE_MAGIC2LEVEL(x) (((char) -*(signed char *) (x)) - 1)
#define VERBOSE_HASMAGIC(x)     (*(signed char *) (x) < 0)

static void console_verboser(const char *s)
{
        char tmp[80];
        const char *c = NULL;
        char level = 0;

        if (VERBOSE_HASMAGIC(s)) {
                level = VERBOSE_MAGIC2LEVEL(s);
                s++;
                if (level > option_verbose) {
                        return;
                }
        }

        if ((c = fix_header(tmp, sizeof(tmp), s, VERBOSE_PREFIX_4)) ||
            (c = fix_header(tmp, sizeof(tmp), s, VERBOSE_PREFIX_3)) ||
            (c = fix_header(tmp, sizeof(tmp), s, VERBOSE_PREFIX_2)) ||
            (c = fix_header(tmp, sizeof(tmp), s, VERBOSE_PREFIX_1))) {
                fputs(tmp, stdout);
                fputs(c, stdout);
        } else {
                fputs(s, stdout);
        }

        fflush(stdout);

        /* Wake up a poll()ing console */
        if (ast_opt_console && consolethread != AST_PTHREADT_NULL) {
                pthread_kill(consolethread, SIGURG);
        }
}

static int ast_all_zeros(char *s)
{
        while (*s) {
                if (*s > 32)
                        return 0;
                s++;
        }
        return 1;
}

static void consolehandler(char *s)
{
        printf("%s", term_end());
        fflush(stdout);

        /* Called when readline data is available */
        if (!ast_all_zeros(s))
                ast_el_add_history(s);
        /* The real handler for bang */
        if (s[0] == '!') {
                if (s[1])
                        ast_safe_system(s+1);
                else
                        ast_safe_system(getenv("SHELL") ? getenv("SHELL") : "/bin/sh");
        } else
                ast_cli_command(STDOUT_FILENO, s);
}

static int remoteconsolehandler(char *s)
{
        int ret = 0;

        /* Called when readline data is available */
        if (!ast_all_zeros(s))
                ast_el_add_history(s);
        /* The real handler for bang */
        if (s[0] == '!') {
                if (s[1])
                        ast_safe_system(s+1);
                else
                        ast_safe_system(getenv("SHELL") ? getenv("SHELL") : "/bin/sh");
                ret = 1;
        } else if (strncasecmp(s, "core set verbose ", 17) == 0) {
                int old_verbose = option_verbose;
                if (strncasecmp(s + 17, "atleast ", 8) == 0) {
                        int tmp;
                        if (sscanf(s + 25, "%d", &tmp) != 1) {
                                fprintf(stderr, "Usage: core set verbose [atleast] <level>\n");
                        } else {
                                if (tmp > option_verbose) {
                                        option_verbose = tmp;
                                }
                                if (old_verbose != option_verbose) {
                                        fprintf(stdout, "Set remote console verbosity from %d to %d\n", old_verbose, option_verbose);
                                } else {
                                        fprintf(stdout, "Verbosity level unchanged.\n");
                                }
                        }
                } else {
                        if (sscanf(s + 17, "%d", &option_verbose) != 1) {
                                fprintf(stderr, "Usage: core set verbose [atleast] <level>\n");
                        } else {
                                if (old_verbose != option_verbose) {
                                        fprintf(stdout, "Set remote console verbosity to %d\n", option_verbose);
                                } else {
                                        fprintf(stdout, "Verbosity level unchanged.\n");
                                }
                        }
                }
                ret = 1;
        } else if ((strncasecmp(s, "quit", 4) == 0 || strncasecmp(s, "exit", 4) == 0) &&
            (s[4] == '\0' || isspace(s[4]))) {
                quit_handler(0, SHUTDOWN_FAST, 0);
                ret = 1;
        }

        return ret;
}

static char *handle_version(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "core show version";
                e->usage =
                        "Usage: core show version\n"
                        "       Shows Asterisk version information.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (a->argc != 3)
                return CLI_SHOWUSAGE;
        ast_cli(a->fd, "Asterisk %s built by %s @ %s on a %s running %s on %s\n",
                ast_get_version(), ast_build_user, ast_build_hostname,
                ast_build_machine, ast_build_os, ast_build_date);
        return CLI_SUCCESS;
}

#if 0
static int handle_quit(int fd, int argc, char *argv[])
{
        if (argc != 1)
                return RESULT_SHOWUSAGE;
        quit_handler(0, SHUTDOWN_NORMAL, 0);
        return RESULT_SUCCESS;
}
#endif

static char *handle_stop_now(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "core stop now";
                e->usage =
                        "Usage: core stop now\n"
                        "       Shuts down a running Asterisk immediately, hanging up all active calls .\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (a->argc != e->args)
                return CLI_SHOWUSAGE;
        quit_handler(0, SHUTDOWN_NORMAL, 0 /* not restart */);
        return CLI_SUCCESS;
}

static char *handle_stop_gracefully(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "core stop gracefully";
                e->usage =
                        "Usage: core stop gracefully\n"
                        "       Causes Asterisk to not accept new calls, and exit when all\n"
                        "       active calls have terminated normally.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (a->argc != e->args)
                return CLI_SHOWUSAGE;
        quit_handler(0, SHUTDOWN_NICE, 0 /* no restart */);
        return CLI_SUCCESS;
}

static char *handle_stop_when_convenient(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "core stop when convenient";
                e->usage =
                        "Usage: core stop when convenient\n"
                        "       Causes Asterisk to perform a shutdown when all active calls have ended.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (a->argc != e->args)
                return CLI_SHOWUSAGE;
        ast_cli(a->fd, "Waiting for inactivity to perform halt\n");
        quit_handler(0, SHUTDOWN_REALLY_NICE, 0 /* don't restart */);
        return CLI_SUCCESS;
}

static char *handle_restart_now(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "core restart now";
                e->usage =
                        "Usage: core restart now\n"
                        "       Causes Asterisk to hangup all calls and exec() itself performing a cold\n"
                        "       restart.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (a->argc != e->args)
                return CLI_SHOWUSAGE;
        quit_handler(0, SHUTDOWN_NORMAL, 1 /* restart */);
        return CLI_SUCCESS;
}

static char *handle_restart_gracefully(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "core restart gracefully";
                e->usage =
                        "Usage: core restart gracefully\n"
                        "       Causes Asterisk to stop accepting new calls and exec() itself performing a cold\n"
                        "       restart when all active calls have ended.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (a->argc != e->args)
                return CLI_SHOWUSAGE;
        quit_handler(0, SHUTDOWN_NICE, 1 /* restart */);
        return CLI_SUCCESS;
}

static char *handle_restart_when_convenient(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "core restart when convenient";
                e->usage =
                        "Usage: core restart when convenient\n"
                        "       Causes Asterisk to perform a cold restart when all active calls have ended.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (a->argc != e->args)
                return CLI_SHOWUSAGE;
        ast_cli(a->fd, "Waiting for inactivity to perform restart\n");
        quit_handler(0, SHUTDOWN_REALLY_NICE, 1 /* restart */);
        return CLI_SUCCESS;
}

static char *handle_abort_shutdown(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        int aborting_shutdown = 0;

        switch (cmd) {
        case CLI_INIT:
                e->command = "core abort shutdown";
                e->usage =
                        "Usage: core abort shutdown\n"
                        "       Causes Asterisk to abort an executing shutdown or restart, and resume normal\n"
                        "       call operations.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        if (a->argc != e->args)
                return CLI_SHOWUSAGE;

        ast_mutex_lock(&safe_system_lock);
        if (shuttingdown >= SHUTDOWN_FAST) {
                aborting_shutdown = 1;
                shuttingdown = NOT_SHUTTING_DOWN;
        }
        ast_mutex_unlock(&safe_system_lock);

        if (aborting_shutdown) {
                ast_cancel_shutdown();
        }
        return CLI_SUCCESS;
}

static char *handle_bang(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "!";
                e->usage =
                        "Usage: !<command>\n"
                        "       Executes a given shell command\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        return CLI_SUCCESS;
}
static const char warranty_lines[] = {
        "\n"
        "                           NO WARRANTY\n"
        "\n"
        "BECAUSE THE PROGRAM IS LICENSED FREE OF CHARGE, THERE IS NO WARRANTY\n"
        "FOR THE PROGRAM, TO THE EXTENT PERMITTED BY APPLICABLE LAW.  EXCEPT WHEN\n"
        "OTHERWISE STATED IN WRITING THE COPYRIGHT HOLDERS AND/OR OTHER PARTIES\n"
        "PROVIDE THE PROGRAM \"AS IS\" WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED\n"
        "OR IMPLIED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF\n"
        "MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.  THE ENTIRE RISK AS\n"
        "TO THE QUALITY AND PERFORMANCE OF THE PROGRAM IS WITH YOU.  SHOULD THE\n"
        "PROGRAM PROVE DEFECTIVE, YOU ASSUME THE COST OF ALL NECESSARY SERVICING,\n"
        "REPAIR OR CORRECTION.\n"
        "\n"
        "IN NO EVENT UNLESS REQUIRED BY APPLICABLE LAW OR AGREED TO IN WRITING\n"
        "WILL ANY COPYRIGHT HOLDER, OR ANY OTHER PARTY WHO MAY MODIFY AND/OR\n"
        "REDISTRIBUTE THE PROGRAM AS PERMITTED ABOVE, BE LIABLE TO YOU FOR DAMAGES,\n"
        "INCLUDING ANY GENERAL, SPECIAL, INCIDENTAL OR CONSEQUENTIAL DAMAGES ARISING\n"
        "OUT OF THE USE OR INABILITY TO USE THE PROGRAM (INCLUDING BUT NOT LIMITED\n"
        "TO LOSS OF DATA OR DATA BEING RENDERED INACCURATE OR LOSSES SUSTAINED BY\n"
        "YOU OR THIRD PARTIES OR A FAILURE OF THE PROGRAM TO OPERATE WITH ANY OTHER\n"
        "PROGRAMS), EVEN IF SUCH HOLDER OR OTHER PARTY HAS BEEN ADVISED OF THE\n"
        "POSSIBILITY OF SUCH DAMAGES.\n"
};

static char *show_warranty(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "core show warranty";
                e->usage =
                        "Usage: core show warranty\n"
                        "       Shows the warranty (if any) for this copy of Asterisk.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        ast_cli(a->fd, "%s", warranty_lines);

        return CLI_SUCCESS;
}

static const char license_lines[] = {
        "\n"
        "This program is free software; you can redistribute it and/or modify\n"
        "it under the terms of the GNU General Public License version 2 as\n"
        "published by the Free Software Foundation.\n"
        "\n"
        "This program also contains components licensed under other licenses.\n"
        "They include:\n"
        "\n"
        "This program is distributed in the hope that it will be useful,\n"
        "but WITHOUT ANY WARRANTY; without even the implied warranty of\n"
        "MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the\n"
        "GNU General Public License for more details.\n"
        "\n"
        "You should have received a copy of the GNU General Public License\n"
        "along with this program; if not, write to the Free Software\n"
        "Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA\n"
};

static char *show_license(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
{
        switch (cmd) {
        case CLI_INIT:
                e->command = "core show license";
                e->usage =
                        "Usage: core show license\n"
                        "       Shows the license(s) for this copy of Asterisk.\n";
                return NULL;
        case CLI_GENERATE:
                return NULL;
        }

        ast_cli(a->fd, "%s", license_lines);

        return CLI_SUCCESS;
}

#define ASTERISK_PROMPT "*CLI> "

#define ASTERISK_PROMPT2 "%s*CLI> "

/*!
 * \brief Shutdown Asterisk CLI commands.
 *
 * \note These CLI commands cannot be unregistered at shutdown
 * because one of them is likely the reason for the shutdown.
 * The CLI generates a warning if a command is in-use when it is
 * unregistered.
 */
static struct ast_cli_entry cli_asterisk_shutdown[] = {
        AST_CLI_DEFINE(handle_stop_now, "Shut down Asterisk immediately"),
        AST_CLI_DEFINE(handle_stop_gracefully, "Gracefully shut down Asterisk"),
        AST_CLI_DEFINE(handle_stop_when_convenient, "Shut down Asterisk at empty call volume"),
        AST_CLI_DEFINE(handle_restart_now, "Restart Asterisk immediately"),
        AST_CLI_DEFINE(handle_restart_gracefully, "Restart Asterisk gracefully"),
        AST_CLI_DEFINE(handle_restart_when_convenient, "Restart Asterisk at empty call volume"),
};

static struct ast_cli_entry cli_asterisk[] = {
        AST_CLI_DEFINE(handle_abort_shutdown, "Cancel a running shutdown"),
        AST_CLI_DEFINE(show_warranty, "Show the warranty (if any) for this copy of Asterisk"),
        AST_CLI_DEFINE(show_license, "Show the license(s) for this copy of Asterisk"),
        AST_CLI_DEFINE(handle_version, "Display version info"),
        AST_CLI_DEFINE(handle_bang, "Execute a shell command"),
#if !defined(LOW_MEMORY)
        AST_CLI_DEFINE(handle_show_version_files, "List versions of files used to build Asterisk"),
        AST_CLI_DEFINE(handle_show_threads, "Show running threads"),
#if defined(HAVE_SYSINFO) || defined(HAVE_SYSCTL)
        AST_CLI_DEFINE(handle_show_sysinfo, "Show System Information"),
#endif
        AST_CLI_DEFINE(handle_show_profile, "Display profiling info"),
        AST_CLI_DEFINE(handle_show_settings, "Show some core settings"),
        AST_CLI_DEFINE(handle_clear_profile, "Clear profiling info"),
#endif /* ! LOW_MEMORY */
};

struct el_read_char_state_struct {
        unsigned int line_full:1;
        unsigned int prev_line_full:1;
        char prev_line_verbosity;
};

static int el_read_char_state_init(void *ptr)
{
        struct el_read_char_state_struct *state = ptr;
        state->line_full = 1;
        state->prev_line_full = 1;
        state->prev_line_verbosity = 0;
        return 0;
}

AST_THREADSTORAGE_CUSTOM(el_read_char_state, el_read_char_state_init, ast_free_ptr);

static int ast_el_read_char(EditLine *editline, char *cp)
{
        int num_read = 0;
        int lastpos = 0;
        struct pollfd fds[2];
        int res;
        int max;
#define EL_BUF_SIZE 512
        char buf[EL_BUF_SIZE];
        struct el_read_char_state_struct *state = ast_threadstorage_get(&el_read_char_state, sizeof(*state));

        for (;;) {
                max = 1;
                fds[0].fd = ast_consock;
                fds[0].events = POLLIN;
                if (!ast_opt_exec) {
                        fds[1].fd = STDIN_FILENO;
                        fds[1].events = POLLIN;
                        max++;
                }
                res = ast_poll(fds, max, -1);
                if (res < 0) {
                        if (sig_flags.need_quit || sig_flags.need_quit_handler)
                                break;
                        if (errno == EINTR)
                                continue;
                        fprintf(stderr, "poll failed: %s\n", strerror(errno));
                        break;
                }

                if (!ast_opt_exec && fds[1].revents) {
                        num_read = read(STDIN_FILENO, cp, 1);
                        if (num_read < 1) {
                                break;
                        } else {
                                return (num_read);
                        }
                }
                if (fds[0].revents) {
                        char level = 0;
                        char *curline = buf, *nextline;
                        res = read(ast_consock, buf, sizeof(buf) - 1);
                        /* if the remote side disappears exit */
                        if (res < 1) {
                                fprintf(stderr, "\nDisconnected from Asterisk server\n");
                                if (!ast_opt_reconnect) {
                                        quit_handler(0, SHUTDOWN_FAST, 0);
                                } else {
                                        int tries;
                                        int reconnects_per_second = 20;
                                        fprintf(stderr, "Attempting to reconnect for 30 seconds\n");
                                        for (tries = 0; tries < 30 * reconnects_per_second; tries++) {
                                                if (ast_tryconnect()) {
                                                        fprintf(stderr, "Reconnect succeeded after %.3f seconds\n", 1.0 / reconnects_per_second * tries);
                                                        printf("%s", term_quit());
                                                        WELCOME_MESSAGE;
                                                        if (!ast_opt_mute)
                                                                fdsend(ast_consock, "logger mute silent");
                                                        else
                                                                printf("log and verbose output currently muted ('logger mute' to unmute)\n");
                                                        break;
                                                } else
                                                        usleep(1000000 / reconnects_per_second);
                                        }
                                        if (tries >= 30 * reconnects_per_second) {
                                                fprintf(stderr, "Failed to reconnect for 30 seconds.  Quitting.\n");
                                                quit_handler(0, SHUTDOWN_FAST, 0);
                                        }
                                }
                                continue;
                        }

                        buf[res] = '\0';

                        /* Write over the CLI prompt */
                        if (!ast_opt_exec && !lastpos) {
                                if (write(STDOUT_FILENO, "\r\e[0K", 5) < 0) {
                                }
                        }

                        do {
                                state->prev_line_full = state->line_full;
                                if ((nextline = strchr(curline, '\n'))) {
                                        state->line_full = 1;
                                        nextline++;
                                } else {
                                        state->line_full = 0;
                                        nextline = strchr(curline, '\0');
                                }

                                if (state->prev_line_full && VERBOSE_HASMAGIC(curline)) {
                                        level = VERBOSE_MAGIC2LEVEL(curline);
                                        curline++;
                                } else if (state->prev_line_full && !VERBOSE_HASMAGIC(curline)) {
                                        /* Non-verbose output */
                                        level = 0;
                                } else {
                                        level = state->prev_line_verbosity;
                                }
                                if ((!state->prev_line_full && state->prev_line_verbosity <= option_verbose) || (state->prev_line_full && level <= option_verbose)) {
                                        if (write(STDOUT_FILENO, curline, nextline - curline) < 0) {
                                        }
                                }

                                state->prev_line_verbosity = level;
                                curline = nextline;
                        } while (!ast_strlen_zero(curline));

                        if ((res < EL_BUF_SIZE - 1) && ((buf[res-1] == '\n') || (buf[res-2] == '\n'))) {
                                *cp = CC_REFRESH;
                                return(1);
                        } else
                                lastpos = 1;
                }
        }

        *cp = '\0';
        return (0);
}

static struct ast_str *prompt = NULL;

static char *cli_prompt(EditLine *editline)
{
        char tmp[100];
        char *pfmt;
        int color_used = 0;
        static int cli_prompt_changes = 0;
        struct passwd *pw;
        struct group *gr;

        if (prompt == NULL) {
                prompt = ast_str_create(100);
        } else if (!cli_prompt_changes) {
                return ast_str_buffer(prompt);
        } else {
                ast_str_reset(prompt);
        }

        if ((pfmt = getenv("ASTERISK_PROMPT"))) {
                char *t = pfmt;
                struct timeval ts = ast_tvnow();
                while (*t != '\0') {
                        if (*t == '%') {
                                char hostname[MAXHOSTNAMELEN] = "";
                                int i, which;
                                struct ast_tm tm = { 0, };
                                int fgcolor = COLOR_WHITE, bgcolor = COLOR_BLACK;

                                t++;
                                switch (*t) {
                                case 'C': /* color */
                                        t++;
                                        if (sscanf(t, "%30d;%30d%n", &fgcolor, &bgcolor, &i) == 2) {
                                                ast_term_color_code(&prompt, fgcolor, bgcolor);
                                                t += i - 1;
                                        } else if (sscanf(t, "%30d%n", &fgcolor, &i) == 1) {
                                                ast_term_color_code(&prompt, fgcolor, 0);
                                                t += i - 1;
                                        }

                                        /* If the color has been reset correctly, then there's no need to reset it later */
                                        color_used = ((fgcolor == COLOR_WHITE) && (bgcolor == COLOR_BLACK)) ? 0 : 1;
                                        break;
                                case 'd': /* date */
                                        if (ast_localtime(&ts, &tm, NULL)) {
                                                ast_strftime(tmp, sizeof(tmp), "%Y-%m-%d", &tm);
                                                ast_str_append(&prompt, 0, "%s", tmp);
                                                cli_prompt_changes++;
                                        }
                                        break;
                                case 'g': /* group */
                                        if ((gr = getgrgid(getgid()))) {
                                                ast_str_append(&prompt, 0, "%s", gr->gr_name);
                                        }
                                        break;
                                case 'h': /* hostname */
                                        if (!gethostname(hostname, sizeof(hostname) - 1)) {
                                                ast_str_append(&prompt, 0, "%s", hostname);
                                        } else {
                                                ast_str_append(&prompt, 0, "%s", "localhost");
                                        }
                                        break;
                                case 'H': /* short hostname */
                                        if (!gethostname(hostname, sizeof(hostname) - 1)) {
                                                char *dotptr;
                                                if ((dotptr = strchr(hostname, '.'))) {
                                                        *dotptr = '\0';
                                                }
                                                ast_str_append(&prompt, 0, "%s", hostname);
                                        } else {
                                                ast_str_append(&prompt, 0, "%s", "localhost");
                                        }
                                        break;
#ifdef HAVE_GETLOADAVG
                                case 'l': /* load avg */
                                        t++;
                                        if (sscanf(t, "%30d", &which) == 1 && which > 0 && which <= 3) {
                                                double list[3];
                                                getloadavg(list, 3);
                                                ast_str_append(&prompt, 0, "%.2f", list[which - 1]);
                                                cli_prompt_changes++;
                                        }
                                        break;
#endif
                                case 's': /* Asterisk system name (from asterisk.conf) */
                                        ast_str_append(&prompt, 0, "%s", ast_config_AST_SYSTEM_NAME);
                                        break;
                                case 't': /* time */
                                        if (ast_localtime(&ts, &tm, NULL)) {
                                                ast_strftime(tmp, sizeof(tmp), "%H:%M:%S", &tm);
                                                ast_str_append(&prompt, 0, "%s", tmp);
                                                cli_prompt_changes++;
                                        }
                                        break;
                                case 'u': /* username */
                                        if ((pw = getpwuid(getuid()))) {
                                                ast_str_append(&prompt, 0, "%s", pw->pw_name);
                                        }
                                        break;
                                case '#': /* process console or remote? */
                                        ast_str_append(&prompt, 0, "%c", ast_opt_remote ? '>' : '#');
                                        break;
                                case '%': /* literal % */
                                        ast_str_append(&prompt, 0, "%c", '%');
                                        break;
                                case '\0': /* % is last character - prevent bug */
                                        t--;
                                        break;
                                }
                        } else {
                                ast_str_append(&prompt, 0, "%c", *t);
                        }
                        t++;
                }
                if (color_used) {
                        /* Force colors back to normal at end */
                        ast_term_color_code(&prompt, 0, 0);
                }
        } else if (remotehostname) {
                ast_str_set(&prompt, 0, ASTERISK_PROMPT2, remotehostname);
        } else {
                ast_str_set(&prompt, 0, "%s", ASTERISK_PROMPT);
        }

        return ast_str_buffer(prompt);
}

static char **ast_el_strtoarr(char *buf)
{
        char **match_list = NULL, **match_list_tmp, *retstr;
        size_t match_list_len;
        int matches = 0;

        match_list_len = 1;
        while ( (retstr = strsep(&buf, " ")) != NULL) {

                if (!strcmp(retstr, AST_CLI_COMPLETE_EOF))
                        break;
                if (matches + 1 >= match_list_len) {
                        match_list_len <<= 1;
                        if ((match_list_tmp = ast_realloc(match_list, match_list_len * sizeof(char *)))) {
                                match_list = match_list_tmp;
                        } else {
                                if (match_list)
                                        ast_free(match_list);
                                return (char **) NULL;
                        }
                }

                match_list[matches++] = ast_strdup(retstr);
        }

        if (!match_list)
                return (char **) NULL;

        if (matches >= match_list_len) {
                if ((match_list_tmp = ast_realloc(match_list, (match_list_len + 1) * sizeof(char *)))) {
                        match_list = match_list_tmp;
                } else {
                        if (match_list)
                                ast_free(match_list);
                        return (char **) NULL;
                }
        }

        match_list[matches] = (char *) NULL;

        return match_list;
}

static int ast_el_sort_compare(const void *i1, const void *i2)
{
        char *s1, *s2;

        s1 = ((char **)i1)[0];
        s2 = ((char **)i2)[0];

        return strcasecmp(s1, s2);
}

static int ast_cli_display_match_list(char **matches, int len, int max)
{
        int i, idx, limit, count;
        int screenwidth = 0;
        int numoutput = 0, numoutputline = 0;

        screenwidth = ast_get_termcols(STDOUT_FILENO);

        /* find out how many entries can be put on one line, with two spaces between strings */
        limit = screenwidth / (max + 2);
        if (limit == 0)
                limit = 1;

        /* how many lines of output */
        count = len / limit;
        if (count * limit < len)
                count++;

        idx = 1;

        qsort(&matches[0], (size_t)(len), sizeof(char *), ast_el_sort_compare);

        for (; count > 0; count--) {
                numoutputline = 0;
                for (i = 0; i < limit && matches[idx]; i++, idx++) {

                        /* Don't print dupes */
                        if ( (matches[idx+1] != NULL && strcmp(matches[idx], matches[idx+1]) == 0 ) ) {
                                i--;
                                ast_free(matches[idx]);
                                matches[idx] = NULL;
                                continue;
                        }

                        numoutput++;
                        numoutputline++;
                        fprintf(stdout, "%-*s  ", max, matches[idx]);
                        ast_free(matches[idx]);
                        matches[idx] = NULL;
                }
                if (numoutputline > 0)
                        fprintf(stdout, "\n");
        }

        return numoutput;
}


static char *cli_complete(EditLine *editline, int ch)
{
        int len = 0;
        char *ptr;
        int nummatches = 0;
        char **matches;
        int retval = CC_ERROR;
        char buf[2048], savechr;
        int res;

        LineInfo *lf = (LineInfo *)el_line(editline);

        savechr = *(char *)lf->cursor;
        *(char *)lf->cursor = '\0';
        ptr = (char *)lf->cursor;
        if (ptr) {
                while (ptr > lf->buffer) {
                        if (isspace(*ptr)) {
                                ptr++;
                                break;
                        }
                        ptr--;
                }
        }

        len = lf->cursor - ptr;

        if (ast_opt_remote) {
                snprintf(buf, sizeof(buf), "_COMMAND NUMMATCHES \"%s\" \"%s\"", lf->buffer, ptr);
                fdsend(ast_consock, buf);
                if ((res = read(ast_consock, buf, sizeof(buf) - 1)) < 0) {
                        return (char*)(CC_ERROR);
                }
                buf[res] = '\0';
                nummatches = atoi(buf);

                if (nummatches > 0) {
                        char *mbuf;
                        int mlen = 0, maxmbuf = 2048;
                        /* Start with a 2048 byte buffer */
                        if (!(mbuf = ast_malloc(maxmbuf))) {
                                *((char *) lf->cursor) = savechr;
                                return (char *)(CC_ERROR);
                        }
                        snprintf(buf, sizeof(buf), "_COMMAND MATCHESARRAY \"%s\" \"%s\"", lf->buffer, ptr);
                        fdsend(ast_consock, buf);
                        res = 0;
                        mbuf[0] = '\0';
                        while (!strstr(mbuf, AST_CLI_COMPLETE_EOF) && res != -1) {
                                if (mlen + 1024 > maxmbuf) {
                                        /* Every step increment buffer 1024 bytes */
                                        maxmbuf += 1024;
                                        if (!(mbuf = ast_realloc(mbuf, maxmbuf))) {
                                                *((char *) lf->cursor) = savechr;
                                                return (char *)(CC_ERROR);
                                        }
                                }
                                /* Only read 1024 bytes at a time */
                                res = read(ast_consock, mbuf + mlen, 1024);
                                if (res > 0)
                                        mlen += res;
                        }
                        mbuf[mlen] = '\0';

                        matches = ast_el_strtoarr(mbuf);
                        ast_free(mbuf);
                } else
                        matches = (char **) NULL;
        } else {
                char **p, *oldbuf=NULL;
                nummatches = 0;
                matches = ast_cli_completion_matches((char *)lf->buffer,ptr);
                for (p = matches; p && *p; p++) {
                        if (!oldbuf || strcmp(*p,oldbuf))
                                nummatches++;
                        oldbuf = *p;
                }
        }

        if (matches) {
                int i;
                int matches_num, maxlen, match_len;

                if (matches[0][0] != '\0') {
                        el_deletestr(editline, (int) len);
                        el_insertstr(editline, matches[0]);
                        retval = CC_REFRESH;
                }

                if (nummatches == 1) {
                        /* Found an exact match */
                        el_insertstr(editline, " ");
                        retval = CC_REFRESH;
                } else {
                        /* Must be more than one match */
                        for (i = 1, maxlen = 0; matches[i]; i++) {
                                match_len = strlen(matches[i]);
                                if (match_len > maxlen)
                                        maxlen = match_len;
                        }
                        matches_num = i - 1;
                        if (matches_num >1) {
                                fprintf(stdout, "\n");
                                ast_cli_display_match_list(matches, nummatches, maxlen);
                                retval = CC_REDISPLAY;
                        } else {
                                el_insertstr(editline," ");
                                retval = CC_REFRESH;
                        }
                }
                for (i = 0; matches[i]; i++)
                        ast_free(matches[i]);
                ast_free(matches);
        }

        *((char *) lf->cursor) = savechr;

        return (char *)(long)retval;
}

static int ast_el_initialize(void)
{
        HistEvent ev;
        char *editor, *editrc = getenv("EDITRC");

        if (!(editor = getenv("AST_EDITMODE"))) {
                if (!(editor = getenv("AST_EDITOR"))) {
                        editor = "emacs";
                }
        }

        if (el != NULL)
                el_end(el);
        if (el_hist != NULL)
                history_end(el_hist);

        el = el_init("asterisk", stdin, stdout, stderr);
        el_set(el, EL_PROMPT, cli_prompt);

        el_set(el, EL_EDITMODE, 1);
        el_set(el, EL_EDITOR, editor);
        el_hist = history_init();
        if (!el || !el_hist)
                return -1;

        /* setup history with 100 entries */
        history(el_hist, &ev, H_SETSIZE, 100);

        el_set(el, EL_HIST, history, el_hist);

        el_set(el, EL_ADDFN, "ed-complete", "Complete argument", cli_complete);
        /* Bind <tab> to command completion */
        el_set(el, EL_BIND, "^I", "ed-complete", NULL);
        /* Bind ? to command completion */
        el_set(el, EL_BIND, "?", "ed-complete", NULL);
        /* Bind ^D to redisplay */
        el_set(el, EL_BIND, "^D", "ed-redisplay", NULL);
        /* Bind Delete to delete char left */
        el_set(el, EL_BIND, "\\e[3~", "ed-delete-next-char", NULL);
        /* Bind Home and End to move to line start and end */
        el_set(el, EL_BIND, "\\e[1~", "ed-move-to-beg", NULL);
        el_set(el, EL_BIND, "\\e[4~", "ed-move-to-end", NULL);
        /* Bind C-left and C-right to move by word (not all terminals) */
        el_set(el, EL_BIND, "\\eOC", "vi-next-word", NULL);
        el_set(el, EL_BIND, "\\eOD", "vi-prev-word", NULL);

        if (editrc) {
                el_source(el, editrc);
        }

        return 0;
}

#define MAX_HISTORY_COMMAND_LENGTH 256

static int ast_el_add_history(char *buf)
{
        HistEvent ev;

        if (el_hist == NULL || el == NULL)
                ast_el_initialize();
        if (strlen(buf) > (MAX_HISTORY_COMMAND_LENGTH - 1))
                return 0;
        return (history(el_hist, &ev, H_ENTER, ast_strip(ast_strdupa(buf))));
}

static int ast_el_write_history(char *filename)
{
        HistEvent ev;

        if (el_hist == NULL || el == NULL)
                ast_el_initialize();

        return (history(el_hist, &ev, H_SAVE, filename));
}

static int ast_el_read_history(char *filename)
{
        HistEvent ev;

        if (el_hist == NULL || el == NULL) {
                ast_el_initialize();
        }

        return history(el_hist, &ev, H_LOAD, filename);
}

static void ast_remotecontrol(char *data)
{
        char buf[80];
        int res;
        char filename[80] = "";
        char *hostname;
        char *cpid;
        char *version;
        int pid;
        char *stringp = NULL;

        char *ebuf;
        int num = 0;

        memset(&sig_flags, 0, sizeof(sig_flags));
        signal(SIGINT, __remote_quit_handler);
        signal(SIGTERM, __remote_quit_handler);
        signal(SIGHUP, __remote_quit_handler);

        if (read(ast_consock, buf, sizeof(buf)) < 0) {
                ast_log(LOG_ERROR, "read() failed: %s\n", strerror(errno));
                return;
        }
        if (data) {
                char prefix[] = "cli quit after ";
                char *tmp = ast_alloca(strlen(data) + strlen(prefix) + 1);
                sprintf(tmp, "%s%s", prefix, data);
                if (write(ast_consock, tmp, strlen(tmp) + 1) < 0) {
                        ast_log(LOG_ERROR, "write() failed: %s\n", strerror(errno));
                        if (sig_flags.need_quit || sig_flags.need_quit_handler) {
                                return;
                        }
                }
        }
        stringp = buf;
        hostname = strsep(&stringp, "/");
        cpid = strsep(&stringp, "/");
        version = strsep(&stringp, "\n");
        if (!version)
                version = "<Version Unknown>";
        stringp = hostname;
        strsep(&stringp, ".");
        if (cpid)
                pid = atoi(cpid);
        else
                pid = -1;
        if (!data) {
                if (!ast_opt_mute) {
                        fdsend(ast_consock, "logger mute silent");
                } else {
                        printf("log and verbose output currently muted ('logger mute' to unmute)\n");
                }
        }

        if (ast_opt_exec && data) {  /* hack to print output then exit if asterisk -rx is used */
                int linefull = 1, prev_linefull = 1, prev_line_verbose = 0;
                struct pollfd fds;
                fds.fd = ast_consock;
                fds.events = POLLIN;
                fds.revents = 0;

                while (ast_poll(&fds, 1, 60000) > 0) {
                        char buffer[512] = "", *curline = buffer, *nextline;
                        int not_written = 1;

                        if (sig_flags.need_quit || sig_flags.need_quit_handler) {
                                break;
                        }

                        if (read(ast_consock, buffer, sizeof(buffer) - 1) <= 0) {
                                break;
                        }

                        do {
                                prev_linefull = linefull;
                                if ((nextline = strchr(curline, '\n'))) {
                                        linefull = 1;
                                        nextline++;
                                } else {
                                        linefull = 0;
                                        nextline = strchr(curline, '\0');
                                }

                                /* Skip verbose lines */
                                /* Prev line full? | Line is verbose | Last line verbose? | Print
                                 * TRUE            | TRUE*           | TRUE               | FALSE
                                 * TRUE            | TRUE*           | FALSE              | FALSE
                                 * TRUE            | FALSE*          | TRUE               | TRUE
                                 * TRUE            | FALSE*          | FALSE              | TRUE
                                 * FALSE           | TRUE            | TRUE*              | FALSE
                                 * FALSE           | TRUE            | FALSE*             | TRUE
                                 * FALSE           | FALSE           | TRUE*              | FALSE
                                 * FALSE           | FALSE           | FALSE*             | TRUE
                                 */
                                if ((!prev_linefull && !prev_line_verbose) || (prev_linefull && *curline > 0)) {
                                        prev_line_verbose = 0;
                                        not_written = 0;
                                        if (write(STDOUT_FILENO, curline, nextline - curline) < 0) {
                                                ast_log(LOG_WARNING, "write() failed: %s\n", strerror(errno));
                                        }
                                } else {
                                        prev_line_verbose = 1;
                                }
                                curline = nextline;
                        } while (!ast_strlen_zero(curline));

                        /* No non-verbose output in 60 seconds. */
                        if (not_written) {
                                break;
                        }
                }
                return;
        }

        ast_verbose("Connected to Asterisk %s currently running on %s (pid = %d)\n", version, hostname, pid);
        remotehostname = hostname;
        if (getenv("HOME"))
                snprintf(filename, sizeof(filename), "%s/.asterisk_history", getenv("HOME"));
        if (el_hist == NULL || el == NULL)
                ast_el_initialize();

        el_set(el, EL_GETCFN, ast_el_read_char);

        if (!ast_strlen_zero(filename))
                ast_el_read_history(filename);

        for (;;) {
                ebuf = (char *)el_gets(el, &num);

                if (sig_flags.need_quit || sig_flags.need_quit_handler) {
                        break;
                }

                if (!ebuf && write(1, "", 1) < 0)
                        break;

                if (!ast_strlen_zero(ebuf)) {
                        if (ebuf[strlen(ebuf)-1] == '\n')
                                ebuf[strlen(ebuf)-1] = '\0';
                        if (!remoteconsolehandler(ebuf)) {
                                res = write(ast_consock, ebuf, strlen(ebuf) + 1);
                                if (res < 1) {
                                        ast_log(LOG_WARNING, "Unable to write: %s\n", strerror(errno));
                                        break;
                                }
                        }
                }
        }
        printf("\nDisconnected from Asterisk server\n");
}

static int show_version(void)
{
        printf("Asterisk %s\n", ast_get_version());
        return 0;
}

static int show_cli_help(void)
{
        printf("Asterisk %s, Copyright (C) 1999 - 2012, Digium, Inc. and others.\n", ast_get_version());
        printf("Usage: asterisk [OPTIONS]\n");
        printf("Valid Options:\n");
        printf("   -V              Display version number and exit\n");
        printf("   -C <configfile> Use an alternate configuration file\n");
        printf("   -G <group>      Run as a group other than the caller\n");
        printf("   -U <user>       Run as a user other than the caller\n");
        printf("   -c              Provide console CLI\n");
        printf("   -d              Enable extra debugging\n");
#if HAVE_WORKING_FORK
        printf("   -f              Do not fork\n");
        printf("   -F              Always fork\n");
#endif
        printf("   -g              Dump core in case of a crash\n");
        printf("   -h              This help screen\n");
        printf("   -i              Initialize crypto keys at startup\n");
        printf("   -I              Enable internal timing if DAHDI timer is available\n");
        printf("   -L <load>       Limit the maximum load average before rejecting new calls\n");
        printf("   -M <value>      Limit the maximum number of calls to the specified value\n");
        printf("   -m              Mute debugging and console output on the console\n");
        printf("   -n              Disable console colorization\n");
        printf("   -p              Run as pseudo-realtime thread\n");
        printf("   -q              Quiet mode (suppress output)\n");
        printf("   -r              Connect to Asterisk on this machine\n");
        printf("   -R              Same as -r, except attempt to reconnect if disconnected\n");
        printf("   -s <socket>     Connect to Asterisk via socket <socket> (only valid with -r)\n");
        printf("   -t              Record soundfiles in /var/tmp and move them where they\n");
        printf("                   belong after they are done\n");
        printf("   -T              Display the time in [Mmm dd hh:mm:ss] format for each line\n");
        printf("                   of output to the CLI\n");
        printf("   -v              Increase verbosity (multiple v's = more verbose)\n");
        printf("   -x <cmd>        Execute command <cmd> (implies -r)\n");
        printf("   -X              Execute includes by default (allows #exec in asterisk.conf)\n");
        printf("   -W              Adjust terminal colors to compensate for a light background\n");
        printf("\n");
        return 0;
}

static void ast_readconfig(void)
{
        struct ast_config *cfg;
        struct ast_variable *v;
        char *config = DEFAULT_CONFIG_FILE;
        char hostname[MAXHOSTNAMELEN] = "";
        struct ast_flags config_flags = { CONFIG_FLAG_NOREALTIME };
        struct {
                unsigned int dbdir:1;
                unsigned int keydir:1;
        } found = { 0, 0 };

        /* Set default value */
        option_dtmfminduration = AST_MIN_DTMF_DURATION;

        if (ast_opt_override_config) {
                cfg = ast_config_load2(ast_config_AST_CONFIG_FILE, "" /* core, can't reload */, config_flags);
                if (cfg == CONFIG_STATUS_FILEMISSING || cfg == CONFIG_STATUS_FILEUNCHANGED || cfg == CONFIG_STATUS_FILEINVALID) {
                        fprintf(stderr, "Unable to open specified master config file '%s', using built-in defaults\n", ast_config_AST_CONFIG_FILE);
                }
        } else {
                cfg = ast_config_load2(config, "" /* core, can't reload */, config_flags);
        }

        /* init with buildtime config */
        ast_copy_string(cfg_paths.config_dir, DEFAULT_CONFIG_DIR, sizeof(cfg_paths.config_dir));
        ast_copy_string(cfg_paths.spool_dir, DEFAULT_SPOOL_DIR, sizeof(cfg_paths.spool_dir));
        ast_copy_string(cfg_paths.module_dir, DEFAULT_MODULE_DIR, sizeof(cfg_paths.module_dir));
        snprintf(cfg_paths.monitor_dir, sizeof(cfg_paths.monitor_dir), "%s/monitor", cfg_paths.spool_dir);
        ast_copy_string(cfg_paths.var_dir, DEFAULT_VAR_DIR, sizeof(cfg_paths.var_dir));
        ast_copy_string(cfg_paths.data_dir, DEFAULT_DATA_DIR, sizeof(cfg_paths.data_dir));
        ast_copy_string(cfg_paths.log_dir, DEFAULT_LOG_DIR, sizeof(cfg_paths.log_dir));
        ast_copy_string(cfg_paths.agi_dir, DEFAULT_AGI_DIR, sizeof(cfg_paths.agi_dir));
        ast_copy_string(cfg_paths.db_path, DEFAULT_DB, sizeof(cfg_paths.db_path));
        ast_copy_string(cfg_paths.sbin_dir, DEFAULT_SBIN_DIR, sizeof(cfg_paths.sbin_dir));
        ast_copy_string(cfg_paths.key_dir, DEFAULT_KEY_DIR, sizeof(cfg_paths.key_dir));
        ast_copy_string(cfg_paths.pid_path, DEFAULT_PID, sizeof(cfg_paths.pid_path));
        ast_copy_string(cfg_paths.socket_path, DEFAULT_SOCKET, sizeof(cfg_paths.socket_path));
        ast_copy_string(cfg_paths.run_dir, DEFAULT_RUN_DIR, sizeof(cfg_paths.run_dir));

        ast_set_default_eid(&ast_eid_default);

        /* no asterisk.conf? no problem, use buildtime config! */
        if (cfg == CONFIG_STATUS_FILEMISSING || cfg == CONFIG_STATUS_FILEUNCHANGED || cfg == CONFIG_STATUS_FILEINVALID) {
                return;
        }

        for (v = ast_variable_browse(cfg, "files"); v; v = v->next) {
                if (!strcasecmp(v->name, "astctlpermissions"))
                        ast_copy_string(ast_config_AST_CTL_PERMISSIONS, v->value, sizeof(ast_config_AST_CTL_PERMISSIONS));
                else if (!strcasecmp(v->name, "astctlowner"))
                        ast_copy_string(ast_config_AST_CTL_OWNER, v->value, sizeof(ast_config_AST_CTL_OWNER));
                else if (!strcasecmp(v->name, "astctlgroup"))
                        ast_copy_string(ast_config_AST_CTL_GROUP, v->value, sizeof(ast_config_AST_CTL_GROUP));
                else if (!strcasecmp(v->name, "astctl"))
                        ast_copy_string(ast_config_AST_CTL, v->value, sizeof(ast_config_AST_CTL));
        }

        for (v = ast_variable_browse(cfg, "directories"); v; v = v->next) {
                if (!strcasecmp(v->name, "astetcdir")) {
                        ast_copy_string(cfg_paths.config_dir, v->value, sizeof(cfg_paths.config_dir));
                } else if (!strcasecmp(v->name, "astspooldir")) {
                        ast_copy_string(cfg_paths.spool_dir, v->value, sizeof(cfg_paths.spool_dir));
                        snprintf(cfg_paths.monitor_dir, sizeof(cfg_paths.monitor_dir), "%s/monitor", v->value);
                } else if (!strcasecmp(v->name, "astvarlibdir")) {
                        ast_copy_string(cfg_paths.var_dir, v->value, sizeof(cfg_paths.var_dir));
                        if (!found.dbdir)
                                snprintf(cfg_paths.db_path, sizeof(cfg_paths.db_path), "%s/astdb", v->value);
                } else if (!strcasecmp(v->name, "astdbdir")) {
                        snprintf(cfg_paths.db_path, sizeof(cfg_paths.db_path), "%s/astdb", v->value);
                        found.dbdir = 1;
                } else if (!strcasecmp(v->name, "astdatadir")) {
                        ast_copy_string(cfg_paths.data_dir, v->value, sizeof(cfg_paths.data_dir));
                        if (!found.keydir)
                                snprintf(cfg_paths.key_dir, sizeof(cfg_paths.key_dir), "%s/keys", v->value);
                } else if (!strcasecmp(v->name, "astkeydir")) {
                        snprintf(cfg_paths.key_dir, sizeof(cfg_paths.key_dir), "%s/keys", v->value);
                        found.keydir = 1;
                } else if (!strcasecmp(v->name, "astlogdir")) {
                        ast_copy_string(cfg_paths.log_dir, v->value, sizeof(cfg_paths.log_dir));
                } else if (!strcasecmp(v->name, "astagidir")) {
                        ast_copy_string(cfg_paths.agi_dir, v->value, sizeof(cfg_paths.agi_dir));
                } else if (!strcasecmp(v->name, "astrundir")) {
                        snprintf(cfg_paths.pid_path, sizeof(cfg_paths.pid_path), "%s/%s", v->value, "asterisk.pid");
                        snprintf(cfg_paths.socket_path, sizeof(cfg_paths.socket_path), "%s/%s", v->value, ast_config_AST_CTL);
                        ast_copy_string(cfg_paths.run_dir, v->value, sizeof(cfg_paths.run_dir));
                } else if (!strcasecmp(v->name, "astmoddir")) {
                        ast_copy_string(cfg_paths.module_dir, v->value, sizeof(cfg_paths.module_dir));
                } else if (!strcasecmp(v->name, "astsbindir")) {
                        ast_copy_string(cfg_paths.sbin_dir, v->value, sizeof(cfg_paths.sbin_dir));
                }
        }

        for (v = ast_variable_browse(cfg, "options"); v; v = v->next) {
                /* verbose level (-v at startup) */
                if (!strcasecmp(v->name, "verbose")) {
                        option_verbose = atoi(v->value);
                /* whether or not to force timestamping in CLI verbose output. (-T at startup) */
                } else if (!strcasecmp(v->name, "timestamp")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_TIMESTAMP);
                /* whether or not to support #exec in config files */
                } else if (!strcasecmp(v->name, "execincludes")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_EXEC_INCLUDES);
                /* debug level (-d at startup) */
                } else if (!strcasecmp(v->name, "debug")) {
                        option_debug = 0;
                        if (sscanf(v->value, "%30d", &option_debug) != 1) {
                                option_debug = ast_true(v->value);
                        }
#if HAVE_WORKING_FORK
                /* Disable forking (-f at startup) */
                } else if (!strcasecmp(v->name, "nofork")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_NO_FORK);
                /* Always fork, even if verbose or debug are enabled (-F at startup) */
                } else if (!strcasecmp(v->name, "alwaysfork")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_ALWAYS_FORK);
#endif
                /* Run quietly (-q at startup ) */
                } else if (!strcasecmp(v->name, "quiet")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_QUIET);
                /* Run as console (-c at startup, implies nofork) */
                } else if (!strcasecmp(v->name, "console")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_CONSOLE);
                /* Run with high priority if the O/S permits (-p at startup) */
                } else if (!strcasecmp(v->name, "highpriority")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_HIGH_PRIORITY);
                /* Initialize RSA auth keys (IAX2) (-i at startup) */
                } else if (!strcasecmp(v->name, "initcrypto")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_INIT_KEYS);
                /* Disable ANSI colors for console (-c at startup) */
                } else if (!strcasecmp(v->name, "nocolor")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_NO_COLOR);
                /* Disable some usage warnings for picky people :p */
                } else if (!strcasecmp(v->name, "dontwarn")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_DONT_WARN);
                /* Dump core in case of crash (-g) */
                } else if (!strcasecmp(v->name, "dumpcore")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_DUMP_CORE);
                /* Cache recorded sound files to another directory during recording */
                } else if (!strcasecmp(v->name, "cache_record_files")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_CACHE_RECORD_FILES);
                /* Specify cache directory */
                }  else if (!strcasecmp(v->name, "record_cache_dir")) {
                        ast_copy_string(record_cache_dir, v->value, AST_CACHE_DIR_LEN);
                /* Build transcode paths via SLINEAR, instead of directly */
                } else if (!strcasecmp(v->name, "transcode_via_sln")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_TRANSCODE_VIA_SLIN);
                /* Transmit SLINEAR silence while a channel is being recorded or DTMF is being generated on a channel */
                } else if (!strcasecmp(v->name, "transmit_silence_during_record") || !strcasecmp(v->name, "transmit_silence")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_TRANSMIT_SILENCE);
                /* Enable internal timing */
                } else if (!strcasecmp(v->name, "internal_timing")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_INTERNAL_TIMING);
                } else if (!strcasecmp(v->name, "mindtmfduration")) {
                        if (sscanf(v->value, "%30u", &option_dtmfminduration) != 1) {
                                option_dtmfminduration = AST_MIN_DTMF_DURATION;
                        }
                } else if (!strcasecmp(v->name, "maxcalls")) {
                        if ((sscanf(v->value, "%30d", &option_maxcalls) != 1) || (option_maxcalls < 0)) {
                                option_maxcalls = 0;
                        }
                } else if (!strcasecmp(v->name, "maxload")) {
                        double test[1];

                        if (getloadavg(test, 1) == -1) {
                                ast_log(LOG_ERROR, "Cannot obtain load average on this system. 'maxload' option disabled.\n");
                                option_maxload = 0.0;
                        } else if ((sscanf(v->value, "%30lf", &option_maxload) != 1) || (option_maxload < 0.0)) {
                                option_maxload = 0.0;
                        }
                /* Set the maximum amount of open files */
                } else if (!strcasecmp(v->name, "maxfiles")) {
                        option_maxfiles = atoi(v->value);
                        set_ulimit(option_maxfiles);
                /* What user to run as */
                } else if (!strcasecmp(v->name, "runuser")) {
                        ast_copy_string(cfg_paths.run_user, v->value, sizeof(cfg_paths.run_user));
                /* What group to run as */
                } else if (!strcasecmp(v->name, "rungroup")) {
                        ast_copy_string(cfg_paths.run_group, v->value, sizeof(cfg_paths.run_group));
                } else if (!strcasecmp(v->name, "systemname")) {
                        ast_copy_string(cfg_paths.system_name, v->value, sizeof(cfg_paths.system_name));
                } else if (!strcasecmp(v->name, "autosystemname")) {
                        if (ast_true(v->value)) {
                                if (!gethostname(hostname, sizeof(hostname) - 1))
                                        ast_copy_string(cfg_paths.system_name, hostname, sizeof(cfg_paths.system_name));
                                else {
                                        if (ast_strlen_zero(ast_config_AST_SYSTEM_NAME)){
                                                ast_copy_string(cfg_paths.system_name, "localhost", sizeof(cfg_paths.system_name));
                                        }
                                        ast_log(LOG_ERROR, "Cannot obtain hostname for this system.  Using '%s' instead.\n", ast_config_AST_SYSTEM_NAME);
                                }
                        }
                } else if (!strcasecmp(v->name, "languageprefix")) {
                        ast_language_is_prefix = ast_true(v->value);
                } else if (!strcasecmp(v->name, "defaultlanguage")) {
                        ast_copy_string(defaultlanguage, v->value, MAX_LANGUAGE);
                } else if (!strcasecmp(v->name, "lockmode")) {
                        if (!strcasecmp(v->value, "lockfile")) {
                                ast_set_lock_type(AST_LOCK_TYPE_LOCKFILE);
                        } else if (!strcasecmp(v->value, "flock")) {
                                ast_set_lock_type(AST_LOCK_TYPE_FLOCK);
                        } else {
                                ast_log(LOG_WARNING, "'%s' is not a valid setting for the lockmode option, "
                                        "defaulting to 'lockfile'\n", v->value);
                                ast_set_lock_type(AST_LOCK_TYPE_LOCKFILE);
                        }
#if defined(HAVE_SYSINFO)
                } else if (!strcasecmp(v->name, "minmemfree")) {
                        /* specify the minimum amount of free memory to retain.  Asterisk should stop accepting new calls
                         * if the amount of free memory falls below this watermark */
                        if ((sscanf(v->value, "%30ld", &option_minmemfree) != 1) || (option_minmemfree < 0)) {
                                option_minmemfree = 0;
                        }
#endif
                } else if (!strcasecmp(v->name, "entityid")) {
                        struct ast_eid tmp_eid;
                        if (!ast_str_to_eid(&tmp_eid, v->value)) {
                                ast_verbose("Successfully set global EID to '%s'\n", v->value);
                                ast_eid_default = tmp_eid;
                        } else
                                ast_verbose("Invalid Entity ID '%s' provided\n", v->value);
                } else if (!strcasecmp(v->name, "lightbackground")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_LIGHT_BACKGROUND);
                } else if (!strcasecmp(v->name, "forceblackbackground")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_FORCE_BLACK_BACKGROUND);
                } else if (!strcasecmp(v->name, "hideconnect")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_HIDE_CONSOLE_CONNECT);
                } else if (!strcasecmp(v->name, "lockconfdir")) {
                        ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_LOCK_CONFIG_DIR);
                } else if (!strcasecmp(v->name, "stdexten")) {
                        /* Choose how to invoke the extensions.conf stdexten */
                        if (!strcasecmp(v->value, "gosub")) {
                                ast_clear_flag(&ast_options, AST_OPT_FLAG_STDEXTEN_MACRO);
                        } else if (!strcasecmp(v->value, "macro")) {
                                ast_set_flag(&ast_options, AST_OPT_FLAG_STDEXTEN_MACRO);
                        } else {
                                ast_log(LOG_WARNING,
                                        "'%s' is not a valid setting for the stdexten option, defaulting to 'gosub'\n",
                                        v->value);
                                ast_clear_flag(&ast_options, AST_OPT_FLAG_STDEXTEN_MACRO);
                        }
                }
        }
        for (v = ast_variable_browse(cfg, "compat"); v; v = v->next) {
                float version;
                if (sscanf(v->value, "%30f", &version) != 1) {
                        fprintf(stderr, "Compatibility version for option '%s' is not a number: '%s'\n", v->name, v->value);
                        continue;
                }
                if (!strcasecmp(v->name, "app_set")) {
                        ast_set2_flag(&ast_compat, version < 1.5 ? 1 : 0, AST_COMPAT_APP_SET);
                } else if (!strcasecmp(v->name, "res_agi")) {
                        ast_set2_flag(&ast_compat, version < 1.5 ? 1 : 0, AST_COMPAT_DELIM_RES_AGI);
                } else if (!strcasecmp(v->name, "pbx_realtime")) {
                        ast_set2_flag(&ast_compat, version < 1.5 ? 1 : 0, AST_COMPAT_DELIM_PBX_REALTIME);
                }
        }
        ast_config_destroy(cfg);
}

static void *monitor_sig_flags(void *unused)
{
        for (;;) {
                struct pollfd p = { sig_alert_pipe[0], POLLIN, 0 };
                int a;
                ast_poll(&p, 1, -1);
                if (sig_flags.need_reload) {
                        sig_flags.need_reload = 0;
                        ast_module_reload(NULL);
                }
                if (sig_flags.need_quit) {
                        sig_flags.need_quit = 0;
                        if ((consolethread != AST_PTHREADT_NULL) && (consolethread != pthread_self())) {
                                sig_flags.need_quit_handler = 1;
                                pthread_kill(consolethread, SIGURG);
                        } else {
                                quit_handler(0, SHUTDOWN_NORMAL, 0);
                        }
                }
                if (read(sig_alert_pipe[0], &a, sizeof(a)) != sizeof(a)) {
                }
        }

        return NULL;
}

static void *canary_thread(void *unused)
{
        struct stat canary_stat;
        struct timeval now;

        /* Give the canary time to sing */
        sleep(120);

        for (;;) {
                now = ast_tvnow();
                if (stat(canary_filename, &canary_stat) || now.tv_sec > canary_stat.st_mtime + 60) {
                        ast_log(LOG_WARNING,
                                "The canary is no more.  He has ceased to be!  "
                                "He's expired and gone to meet his maker!  "
                                "He's a stiff!  Bereft of life, he rests in peace.  "
                                "His metabolic processes are now history!  He's off the twig!  "
                                "He's kicked the bucket.  He's shuffled off his mortal coil, "
                                "run down the curtain, and joined the bleeding choir invisible!!  "
                                "THIS is an EX-CANARY.  (Reducing priority)\n");
                        ast_set_priority(0);
&nb