asterisk.c

Go to the documentation of this file.

/*
 * Asterisk -- An open source telephony toolkit.
 *
 * Copyright (C) 1999 - 2010, 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 -- An Open Source Telephony Toolkit
 *
 * \par Developer Documentation for Asterisk
 * This is the main developer documentation for Asterisk. It is 
 * generated by running "make progdocs".
 * \par Additional documentation
 * \arg \ref Licensing
 * \arg \ref DevDoc 
 * \arg \ref ConfigFiles
 *
 * \section copyright Copyright and author
 *
 * Copyright (C) 1999 - 2009, Digium, Inc.
 * Asterisk is a trademark registered by Digium, Inc.
 *
 * \author Mark Spencer <markster@digium.com>
 * Also see \ref AstCREDITS
 *
 * 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.
 */

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

#include "asterisk.h"

ASTERISK_FILE_VERSION(__FILE__, "$Revision: 312285 $")

#undef sched_setscheduler
#undef setpriority
#include <unistd.h>
#include <stdlib.h>
#include <sys/time.h>
#include <fcntl.h>
#include <stdio.h>
#include <signal.h>
#include <sched.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <sys/wait.h>
#include <string.h>
#include <errno.h>
#include <ctype.h>
#include <sys/resource.h>
#include <grp.h>
#include <pwd.h>
#include <sys/stat.h>

#if defined(HAVE_ZAPTEL) || defined (HAVE_DAHDI)
#include <sys/ioctl.h>
#include "asterisk/dahdi_compat.h"
#endif

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

#if  defined(__FreeBSD__) || defined( __NetBSD__ ) || defined(SOLARIS)
#include <netdb.h>
#if defined(SOLARIS)
int daemon(int, int);  /* defined in libresolv of all places */
#endif
#endif

#include "asterisk/logger.h"
#include "asterisk/options.h"
#include "asterisk/cli.h"
#include "asterisk/channel.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/pbx.h"
#include "asterisk/enum.h"
#include "asterisk/rtp.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 "asterisk/lock.h"
#include "editline/histedit.h"
#include "asterisk/config.h"
#include "asterisk/version.h"
#include "asterisk/linkedlists.h"
#include "asterisk/devicestate.h"
#include "asterisk/module.h"
#include "asterisk/poll-compat.h"

#include "asterisk/doxyref.h"    /* Doxygen documentation */

#include "../defaults.h"

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

#define AST_MAX_CONNECTS 128
#define NUM_MSGS 64

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

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

struct ast_flags ast_options = { AST_DEFAULT_OPTIONS };

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 */
/*! @} */

char record_cache_dir[AST_CACHE_DIR_LEN] = AST_TMP_DIR;
char debug_filename[AST_FILENAME_MAX] = "";
#ifdef HAVE_ZAPTEL
static char _dahdi_chan_name[AST_CHANNEL_NAME] = "Zap";
static size_t _dahdi_chan_name_len = 3;
static enum dahdi_chan_modes _dahdi_chan_mode = CHAN_ZAP_MODE;
#else
static char _dahdi_chan_name[AST_CHANNEL_NAME] = "DAHDI";
static size_t _dahdi_chan_name_len = 5;
static enum dahdi_chan_modes _dahdi_chan_mode = CHAN_DAHDI_PLUS_ZAP_MODE;
#endif
const char *dahdi_chan_name;
const size_t *dahdi_chan_name_len;
const enum dahdi_chan_modes *dahdi_chan_mode;

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 */
};

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

static AST_LIST_HEAD_STATIC(atexits, ast_atexit);

time_t ast_startuptime;
time_t 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 *);

char ast_config_AST_CONFIG_DIR[PATH_MAX];
char ast_config_AST_CONFIG_FILE[PATH_MAX];
char ast_config_AST_MODULE_DIR[PATH_MAX];
char ast_config_AST_SPOOL_DIR[PATH_MAX];
char ast_config_AST_MONITOR_DIR[PATH_MAX];
char ast_config_AST_VAR_DIR[PATH_MAX];
char ast_config_AST_DATA_DIR[PATH_MAX];
char ast_config_AST_LOG_DIR[PATH_MAX];
char ast_config_AST_AGI_DIR[PATH_MAX];
char ast_config_AST_DB[PATH_MAX];
char ast_config_AST_KEY_DIR[PATH_MAX];
char ast_config_AST_PID[PATH_MAX];
char ast_config_AST_SOCKET[PATH_MAX];
char ast_config_AST_RUN_DIR[PATH_MAX];
char ast_config_AST_RUN_USER[PATH_MAX];
char ast_config_AST_RUN_GROUP[PATH_MAX];
char ast_config_AST_CTL_PERMISSIONS[PATH_MAX];
char ast_config_AST_CTL_OWNER[PATH_MAX] = "\0";
char ast_config_AST_CTL_GROUP[PATH_MAX] = "\0";
char ast_config_AST_CTL[PATH_MAX] = "asterisk.ctl";
char ast_config_AST_SYSTEM_NAME[20] = "";

extern const char *ast_build_hostname;
extern const char *ast_build_kernel;
extern const char *ast_build_machine;
extern const char *ast_build_os;
extern const char *ast_build_date;
extern const char *ast_build_user;

unsigned int ast_FD_SETSIZE = FD_SETSIZE;

static char *_argv[256];
static int shuttingdown;
static int restartnow;
static pthread_t consolethread = AST_PTHREADT_NULL;
static pthread_t mon_sig_flags;

static char randompool[256];

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

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

#ifndef AST_MUTEX_INIT_W_CONSTRUCTORS
static AST_LIST_HEAD_STATIC(file_versions, file_version);
#else
static AST_LIST_HEAD(file_versions, file_version) file_versions;
static pthread_once_t file_versions_once = PTHREAD_ONCE_INIT;
static void file_versions_init(void)
{
   AST_LIST_HEAD_INIT(&file_versions);
}
#endif

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);
#ifdef AST_MUTEX_INIT_W_CONSTRUCTORS
   pthread_once(&file_versions_once, file_versions_init);
#endif
   AST_LIST_LOCK(&file_versions);
   AST_LIST_INSERT_HEAD(&file_versions, new, list);
   AST_LIST_UNLOCK(&file_versions);
}

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

   AST_LIST_LOCK(&file_versions);
   AST_LIST_TRAVERSE_SAFE_BEGIN(&file_versions, find, list) {
      if (!strcasecmp(find->file, file)) {
         AST_LIST_REMOVE_CURRENT(&file_versions, list);
         break;
      }
   }
   AST_LIST_TRAVERSE_SAFE_END;
   AST_LIST_UNLOCK(&file_versions);
   if (find)
      free(find);
}

struct thread_list_t {
   AST_LIST_ENTRY(thread_list_t) list;
   char *name;
   pthread_t id;
};

static AST_LIST_HEAD_STATIC(thread_list, thread_list_t);

static char show_threads_help[] =
"Usage: core show threads\n"
"       List threads currently active in the system.\n";

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

   if (!new)
      return;
   new->id = pthread_self();
   new->name = name; /* steal the allocated memory for the thread name */
   AST_LIST_LOCK(&thread_list);
   AST_LIST_INSERT_HEAD(&thread_list, new, list);
   AST_LIST_UNLOCK(&thread_list);
}

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

   AST_LIST_LOCK(&thread_list);
   AST_LIST_TRAVERSE_SAFE_BEGIN(&thread_list, x, list) {
      if ((void *) x->id == id) {
         AST_LIST_REMOVE_CURRENT(&thread_list, list);
         break;
      }
   }
   AST_LIST_TRAVERSE_SAFE_END;
   AST_LIST_UNLOCK(&thread_list);
   if (x) {
      free(x->name);
      free(x);
   }
}

static int handle_show_threads(int fd, int argc, char *argv[])
{
   int count = 0;
   struct thread_list_t *cur;

   AST_LIST_LOCK(&thread_list);
   AST_LIST_TRAVERSE(&thread_list, cur, list) {
      ast_cli(fd, "%p %s\n", (void *)cur->id, cur->name);
      count++;
   }
        AST_LIST_UNLOCK(&thread_list);
   ast_cli(fd, "%d threads listed.\n", count);
   return 0;
}

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;
}

static int handle_show_profile_deprecated(int fd, int argc, char *argv[])
{
   int i, min, max;
   char *search = NULL;

   if (prof_data == NULL)
      return 0;

   min = 0;
   max = prof_data->entries;
   if  (argc >= 3) { /* specific entries */
      if (isdigit(argv[2][0])) {
         min = atoi(argv[2]);
         if (argc == 4 && strcmp(argv[3], "-"))
            max = atoi(argv[3]);
      } else
         search = argv[2];
   }
   if (max > prof_data->entries)
      max = prof_data->entries;
   if (!strcmp(argv[0], "clear")) {
      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 0;
   }
   ast_cli(fd, "profile values (%d, allocated %d)\n-------------------\n",
      prof_data->entries, prof_data->max_size);
   ast_cli(fd, "%6s   %8s  %10s %12s %12s  %s\n", "ID", "Scale", "Events",
         "Value", "Average", "Name");
   for (i = min; i < max; i++) {
      struct profile_entry *e = &prof_data->e[i];
      if (!search || strstr(prof_data->e[i].name, search))
          ast_cli(fd, "%6d: [%8ld] %10ld %12lld %12lld  %s\n",
         i,
         (long)e->scale,
         (long)e->events, (long long)e->value,
         (long long)(e->events ? e->value / e->events : e->value),
         e->name);
   }
   return 0;
}

static int handle_show_profile(int fd, int argc, char *argv[])
{
   int i, min, max;
   char *search = NULL;

   if (prof_data == NULL)
      return 0;

   min = 0;
   max = prof_data->entries;
   if  (argc > 3) { /* specific entries */
      if (isdigit(argv[3][0])) {
         min = atoi(argv[3]);
         if (argc == 5 && strcmp(argv[4], "-"))
            max = atoi(argv[4]);
      } else
         search = argv[3];
   }
   if (max > prof_data->entries)
      max = prof_data->entries;
   if (!strcmp(argv[1], "clear")) {
      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 0;
   }
   ast_cli(fd, "profile values (%d, allocated %d)\n-------------------\n",
      prof_data->entries, prof_data->max_size);
   ast_cli(fd, "%6s   %8s  %10s %12s %12s  %s\n", "ID", "Scale", "Events",
         "Value", "Average", "Name");
   for (i = min; i < max; i++) {
      struct profile_entry *e = &prof_data->e[i];
      if (!search || strstr(prof_data->e[i].name, search))
          ast_cli(fd, "%6d: [%8ld] %10ld %12lld %12lld  %s\n",
         i,
         (long)e->scale,
         (long)e->events, (long long)e->value,
         (long long)(e->events ? e->value / e->events : e->value),
         e->name);
   }
   return 0;
}

static char show_version_files_help[] = 
"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";

/*! \brief CLI command to list module versions */
static int handle_show_version_files_deprecated(int fd, int argc, char *argv[])
{
#define FORMAT "%-25.25s %-40.40s\n"
   struct file_version *iterator;
   regex_t regexbuf;
   int havepattern = 0;
   int havename = 0;
   int count_files = 0;

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

   ast_cli(fd, FORMAT, "File", "Revision");
   ast_cli(fd, FORMAT, "----", "--------");
   AST_LIST_LOCK(&file_versions);
   AST_LIST_TRAVERSE(&file_versions, iterator, list) {
      if (havename && strcasecmp(iterator->file, argv[3]))
         continue;

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

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

   if (havepattern)
      regfree(&regexbuf);

   return RESULT_SUCCESS;
#undef FORMAT
}

static int handle_show_version_files(int fd, int argc, char *argv[])
{
#define FORMAT "%-25.25s %-40.40s\n"
   struct file_version *iterator;
   regex_t regexbuf;
   int havepattern = 0;
   int havename = 0;
   int count_files = 0;

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

   ast_cli(fd, FORMAT, "File", "Revision");
   ast_cli(fd, FORMAT, "----", "--------");
   AST_LIST_LOCK(&file_versions);
   AST_LIST_TRAVERSE(&file_versions, iterator, list) {
      if (havename && strcasecmp(iterator->file, argv[4]))
         continue;
      
      if (havepattern && regexec(&regexbuf, iterator->file, 0, NULL, 0))
         continue;

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

   if (havepattern)
      regfree(&regexbuf);

   return RESULT_SUCCESS;
#undef FORMAT
}

static char *complete_show_version_files_deprecated(const char *line, const char *word, int pos, int state)
{
   struct file_version *find;
   int which = 0;
   char *ret = NULL;
   int matchlen = strlen(word);

   if (pos != 3)
      return NULL;

   AST_LIST_LOCK(&file_versions);
   AST_LIST_TRAVERSE(&file_versions, find, list) {
      if (!strncasecmp(word, find->file, matchlen) && ++which > state) {
         ret = ast_strdup(find->file);
         break;
      }
   }
   AST_LIST_UNLOCK(&file_versions);

   return ret;
}

static char *complete_show_version_files(const char *line, const char *word, int pos, int state)
{
   struct file_version *find;
   int which = 0;
   char *ret = NULL;
   int matchlen = strlen(word);
   
   if (pos != 4)
      return NULL;

   AST_LIST_LOCK(&file_versions);
   AST_LIST_TRAVERSE(&file_versions, find, list) {
      if (!strncasecmp(word, find->file, matchlen) && ++which > state) {
         ret = ast_strdup(find->file);
         break;
      }
   }
   AST_LIST_UNLOCK(&file_versions);

   return ret;
}

#endif /* ! LOW_MEMORY */

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

   if (!(ae = ast_calloc(1, sizeof(*ae))))
      return -1;

   ae->func = func;

   ast_unregister_atexit(func);  

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

   return 0;
}

void ast_unregister_atexit(void (*func)(void))
{
   struct ast_atexit *ae = NULL;

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

   if (ae)
      free(ae);
}

/* 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 signal)
{

}

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

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;
#ifdef HAVE_WORKING_FORK
   int x;
#endif
   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 */
      for (x = STDERR_FILENO + 1; x < 4096; x++)
         close(x);
#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 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 x;
   for (x = 0;x < AST_MAX_CONNECTS; x++) {
      if (consoles[x].mute)
         continue;
      if (consoles[x].fd > -1) 
         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)
{
   fputs(string, stdout);
   fflush(stdout);
   ast_network_puts_mutable(string);
}

/*!
 * \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);
   }
}

/*!
 * 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);
}

static pthread_t lthread;

static void *netconsole(void *vconsole)
{
   struct console *con = vconsole;
   char hostname[MAXHOSTNAMELEN] = "";
   char tmp[512];
   int res;
   struct pollfd fds[2];
   
   if (gethostname(hostname, sizeof(hostname)-1))
      ast_copy_string(hostname, "<Unknown>", sizeof(hostname));
   snprintf(tmp, sizeof(tmp), "%s/%ld/%s\n", hostname, (long)ast_mainpid, ASTERISK_VERSION);
   fdprint(con->fd, tmp);
   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) {
         res = read(con->fd, tmp, sizeof(tmp) - 1);
         if (res < 1) {
            break;
         }
         tmp[res] = 0;
         ast_cli_command_multiple(con->fd, res, tmp);
      }
      if (fds[1].revents) {
         res = read(con->p[0], tmp, sizeof(tmp));
         if (res < 1) {
            ast_log(LOG_ERROR, "read returned %d\n", res);
            break;
         }
         res = write(con->fd, tmp, res);
         if (res < 1)
            break;
      }
   }
   if (option_verbose > 2) 
      ast_verbose(VERBOSE_PREFIX_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];
   pthread_attr_t attr;
   pthread_attr_init(&attr);
   pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
   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 {
         for (x = 0; x < AST_MAX_CONNECTS; x++) {
            if (consoles[x].fd < 0) {
               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 */
               if (ast_pthread_create_background(&consoles[x].t, &attr, 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) {
            if (option_verbose > 2) 
               ast_verbose(VERBOSE_PREFIX_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;
   }
   ast_register_verbose(network_verboser);
   ast_pthread_create_background(&lthread, NULL, listener, NULL);

   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) {
      ast_log(LOG_WARNING, "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, (char *)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;
   if (option_verbose > 1) 
      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));
      }
   }
}

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;

   /*
    * 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");
}

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

/*! \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
         if (option_verbose)
            ast_verbose("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
         if (option_verbose)
            ast_verbose("Set to high priority\n");
   } else {
      /* According to the manpage, these parameters can never fail. */
      setpriority(PRIO_PROCESS, 0, 0);
   }
#endif
   return 0;
}

static void ast_run_atexits(void)
{
   struct ast_atexit *ae;
   AST_LIST_LOCK(&atexits);
   AST_LIST_TRAVERSE(&atexits, ae, list) {
      if (ae->func) 
         ae->func();
   }
   AST_LIST_UNLOCK(&atexits);
}

static void quit_handler(int num, int nice, int safeshutdown, int restart)
{
   char filename[80] = "";
   time_t s,e;
   int x;
   /* Try to get as many CDRs as possible submitted to the backend engines (if in batch mode) */
   ast_cdr_engine_term();
   if (safeshutdown) {
      shuttingdown = 1;
      if (!nice) {
         /* 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)
               break;
            if (!ast_active_channels())
               break;
            if (!shuttingdown)
               break;
            /* Sleep 1/10 of a second */
            usleep(100000);
         }
      } else {
         if (nice < 2)
            ast_begin_shutdown(0);
         if (option_verbose && ast_opt_console)
            ast_verbose("Waiting for inactivity to perform %s...\n", restart ? "restart" : "halt");
         for (;;) {
            if (!ast_active_channels())
               break;
            if (!shuttingdown)
               break;
            sleep(1);
         }
      }

      if (!shuttingdown) {
         if (option_verbose && ast_opt_console)
            ast_verbose("Asterisk %s cancelled.\n", restart ? "restart" : "shutdown");
         return;
      }

      if (nice)
         ast_module_shutdown();
   }
   if (ast_opt_console || ast_opt_remote) {
      pthread_t thisthread = pthread_self();
      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 == thisthread || mon_sig_flags == thisthread) {
         /* Only end if we are the consolethread or signal handler, otherwise there's a race with that thread. */
         if (el != NULL) {
            el_end(el);
         }
         if (el_hist != NULL) {
            history_end(el_hist);
         }
      }
   }
   if (option_verbose)
      ast_verbose("Executing last minute cleanups\n");
   ast_run_atexits();
   /* Called on exit */
   if (option_verbose && ast_opt_console)
      ast_verbose("Asterisk %s ending (%d).\n", ast_active_channels() ? "uncleanly" : "cleanly", num);
   if (option_debug)
      ast_log(LOG_DEBUG, "Asterisk ending (%d).\n", num);
   manager_event(EVENT_FLAG_SYSTEM, "Shutdown", "Shutdown: %s\r\nRestart: %s\r\n", ast_active_channels() ? "Uncleanly" : "Cleanly", restart ? "True" : "False");
   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) {
      if (option_verbose || ast_opt_console)
         ast_verbose("Preparing for Asterisk restart...\n");
      /* Mark all FD's for closing on exec */
      for (x=3; x < 32768; x++) {
         fcntl(x, F_SETFD, FD_CLOEXEC);
      }
      if (option_verbose || ast_opt_console)
         ast_verbose("Asterisk is now restarting...\n");
      restartnow = 1;

      /* close logger */
      close_logger();

      /* 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();
   }
   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;

   /* Check for verboser preamble */
   if (*s == 127) {
      s++;
   }

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

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

   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 {
      if (*s == 127) {
         s++;
      }
      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;
   }
   if ((strncasecmp(s, "quit", 4) == 0 || strncasecmp(s, "exit", 4) == 0) &&
       (s[4] == '\0' || isspace(s[4]))) {
      quit_handler(0, 0, 0, 0);
      ret = 1;
   }

   return ret;
}

static char abort_halt_help[] = 
"Usage: abort shutdown\n"
"       Causes Asterisk to abort an executing shutdown or restart, and resume normal\n"
"       call operations.\n";

static char shutdown_now_help[] = 
"Usage: stop now\n"
"       Shuts down a running Asterisk immediately, hanging up all active calls .\n";

static char shutdown_gracefully_help[] = 
"Usage: stop gracefully\n"
"       Causes Asterisk to not accept new calls, and exit when all\n"
"       active calls have terminated normally.\n";

static char shutdown_when_convenient_help[] = 
"Usage: stop when convenient\n"
"       Causes Asterisk to perform a shutdown when all active calls have ended.\n";

static char restart_now_help[] = 
"Usage: restart now\n"
"       Causes Asterisk to hangup all calls and exec() itself performing a cold\n"
"       restart.\n";

static char restart_gracefully_help[] = 
"Usage: 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";

static char restart_when_convenient_help[] = 
"Usage: restart when convenient\n"
"       Causes Asterisk to perform a cold restart when all active calls have ended.\n";

static char bang_help[] =
"Usage: !<command>\n"
"       Executes a given shell command\n";

static char show_warranty_help[] =
"Usage: core show warranty\n"
"  Shows the warranty (if any) for this copy of Asterisk.\n";

static char show_license_help[] =
"Usage: core show license\n"
"  Shows the license(s) for this copy of Asterisk.\n";

static char version_help[] =
"Usage: core show version\n"
"       Shows Asterisk version information.\n";

static int handle_version_deprecated(int fd, int argc, char *argv[])
{
   if (argc != 2)
      return RESULT_SHOWUSAGE;
   ast_cli(fd, "Asterisk %s built by %s @ %s on a %s running %s on %s\n",
      ASTERISK_VERSION, ast_build_user, ast_build_hostname,
      ast_build_machine, ast_build_os, ast_build_date);
   return RESULT_SUCCESS;
}

static int handle_version(int fd, int argc, char *argv[])
{
   if (argc != 3)
      return RESULT_SHOWUSAGE;
   ast_cli(fd, "Asterisk %s built by %s @ %s on a %s running %s on %s\n",
      ASTERISK_VERSION, ast_build_user, ast_build_hostname,
      ast_build_machine, ast_build_os, ast_build_date);
   return RESULT_SUCCESS;
}

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

static int handle_shutdown_now(int fd, int argc, char *argv[])
{
   if (argc != 2)
      return RESULT_SHOWUSAGE;
   quit_handler(0, 0 /* Not nice */, 1 /* safely */, 0 /* not restart */);
   return RESULT_SUCCESS;
}

static int handle_shutdown_gracefully(int fd, int argc, char *argv[])
{
   if (argc != 2)
      return RESULT_SHOWUSAGE;
   quit_handler(0, 1 /* nicely */, 1 /* safely */, 0 /* no restart */);
   return RESULT_SUCCESS;
}

static int handle_shutdown_when_convenient(int fd, int argc, char *argv[])
{
   if (argc != 3)
      return RESULT_SHOWUSAGE;
   ast_cli(fd, "Waiting for inactivity to perform halt\n");
   quit_handler(0, 2 /* really nicely */, 1 /* safely */, 0 /* don't restart */);
   return RESULT_SUCCESS;
}

static int handle_restart_now(int fd, int argc, char *argv[])
{
   if (argc != 2)
      return RESULT_SHOWUSAGE;
   quit_handler(0, 0 /* not nicely */, 1 /* safely */, 1 /* restart */);
   return RESULT_SUCCESS;
}

static int handle_restart_gracefully(int fd, int argc, char *argv[])
{
   if (argc != 2)
      return RESULT_SHOWUSAGE;
   quit_handler(0, 1 /* nicely */, 1 /* safely */, 1 /* restart */);
   return RESULT_SUCCESS;
}

static int handle_restart_when_convenient(int fd, int argc, char *argv[])
{
   if (argc != 3)
      return RESULT_SHOWUSAGE;
   ast_cli(fd, "Waiting for inactivity to perform restart\n");
   quit_handler(0, 2 /* really nicely */, 1 /* safely */, 1 /* restart */);
   return RESULT_SUCCESS;
}

static int handle_abort_halt(int fd, int argc, char *argv[])
{
   if (argc != 2)
      return RESULT_SHOWUSAGE;
   ast_cancel_shutdown();
   shuttingdown = 0;
   return RESULT_SUCCESS;
}

static int handle_bang(int fd, int argc, char *argv[])
{
   return RESULT_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 int show_warranty(int fd, int argc, char *argv[])
{
   int x;

   for (x = 0; x < ARRAY_LEN(warranty_lines); x++)
      ast_cli(fd, "%s", (char *) warranty_lines[x]);

   return RESULT_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 int show_license(int fd, int argc, char *argv[])
{
   int x;

   for (x = 0; x < ARRAY_LEN(license_lines); x++)
      ast_cli(fd, "%s", (char *) license_lines[x]);

   return RESULT_SUCCESS;
}

#define ASTERISK_PROMPT "*CLI> "

#define ASTERISK_PROMPT2 "%s*CLI> "

static struct ast_cli_entry cli_show_version_deprecated = {
   { "show", "version", NULL },
   handle_version_deprecated, "Display version info",
   version_help };

#if !defined(LOW_MEMORY)
static struct ast_cli_entry cli_show_version_files_deprecated = {
   { "show", "version", "files", NULL },
   handle_show_version_files_deprecated, NULL,
   NULL, complete_show_version_files_deprecated };

static struct ast_cli_entry cli_show_profile_deprecated = {
   { "show", "profile", NULL },
   handle_show_profile_deprecated, NULL,
   NULL };

static struct ast_cli_entry cli_clear_profile_deprecated = {
   { "clear", "profile", NULL },
   handle_show_profile_deprecated, NULL,
   NULL };
#endif /* ! LOW_MEMORY */

static struct ast_cli_entry cli_asterisk[] = {
   { { "abort", "halt", NULL },
   handle_abort_halt, "Cancel a running halt",
   abort_halt_help },

   { { "stop", "now", NULL },
   handle_shutdown_now, "Shut down Asterisk immediately",
   shutdown_now_help },

   { { "stop", "gracefully", NULL },
   handle_shutdown_gracefully, "Gracefully shut down Asterisk",
   shutdown_gracefully_help },

   { { "stop", "when", "convenient", NULL },
   handle_shutdown_when_convenient, "Shut down Asterisk at empty call volume",
   shutdown_when_convenient_help },

   { { "restart", "now", NULL },
   handle_restart_now, "Restart Asterisk immediately", restart_now_help },

   { { "restart", "gracefully", NULL },
   handle_restart_gracefully, "Restart Asterisk gracefully",
   restart_gracefully_help },

   { { "restart", "when", "convenient", NULL },
   handle_restart_when_convenient, "Restart Asterisk at empty call volume",
   restart_when_convenient_help },

   { { "core", "show", "warranty", NULL },
   show_warranty, "Show the warranty (if any) for this copy of Asterisk",
   show_warranty_help },

   { { "core", "show", "license", NULL },
   show_license, "Show the license(s) for this copy of Asterisk",
   show_license_help },

   { { "core", "show", "version", NULL },
   handle_version, "Display version info",
   version_help, NULL, &cli_show_version_deprecated },

   { { "!", NULL },
   handle_bang, "Execute a shell command",
   bang_help },

#if !defined(LOW_MEMORY)
   { { "core", "show", "file", "version", NULL },
   handle_show_version_files, "List versions of files used to build Asterisk",
   show_version_files_help, complete_show_version_files, &cli_show_version_files_deprecated },

   { { "core", "show", "threads", NULL },
   handle_show_threads, "Show running threads",
   show_threads_help },

   { { "core", "show", "profile", NULL },
   handle_show_profile, "Display profiling info",
   NULL, NULL, &cli_show_profile_deprecated },

   { { "core", "clear", "profile", NULL },
   handle_show_profile, "Clear profiling info",
   NULL, NULL, &cli_clear_profile_deprecated },
#endif /* ! LOW_MEMORY */
};

static int ast_el_read_char(EditLine *el, 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];

   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)
            break;
         if (errno == EINTR)
            continue;
         ast_log(LOG_ERROR, "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 *tmp;
         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, 0, 0, 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, 0, 0, 0);
               }
            }
         }

         buf[res] = '\0';

         /* Strip preamble from asynchronous events, too */
         for (tmp = buf; *tmp; tmp++) {
            if (*tmp == 127) {
               memmove(tmp, tmp + 1, strlen(tmp));
               tmp--;
               res--;
            }
         }

         /* Write over the CLI prompt */
         if (!ast_opt_exec && !lastpos) {
            if (write(STDOUT_FILENO, "\r", 5) < 0) {
            }
         }
         if (write(STDOUT_FILENO, buf, res) < 0) {
         }
         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 char *cli_prompt(EditLine *el)
{
   static char prompt[200];
   char *pfmt;
   int color_used = 0;
   char term_code[20];

   if ((pfmt = getenv("ASTERISK_PROMPT"))) {
      char *t = pfmt, *p = prompt;
      memset(prompt, 0, sizeof(prompt));
      while (*t != '\0' && *p < sizeof(prompt)) {
         if (*t == '%') {
            char hostname[MAXHOSTNAMELEN]="";
            int i;
            time_t ts;
            struct tm tm;
#ifdef linux
            FILE *LOADAVG;
#endif
            int fgcolor = COLOR_WHITE, bgcolor = COLOR_BLACK;

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

               /* If the color has been reset correctly, then there's no need to reset it later */
               if ((fgcolor == COLOR_WHITE) && (bgcolor == COLOR_BLACK)) {
                  color_used = 0;
               } else {
                  color_used = 1;
               }
               break;
            case 'd': /* date */
               memset(&tm, 0, sizeof(tm));
               time(&ts);
               if (ast_localtime(&ts, &tm, NULL)) {
                  strftime(p, sizeof(prompt) - strlen(prompt), "%Y-%m-%d", &tm);
               }
               break;
            case 'h': /* hostname */
               if (!gethostname(hostname, sizeof(hostname) - 1)) {
                  strncat(p, hostname, sizeof(prompt) - strlen(prompt) - 1);
               } else {
                  strncat(p, "localhost", sizeof(prompt) - strlen(prompt) - 1);
               }
               break;
            case 'H': /* short hostname */
               if (!gethostname(hostname, sizeof(hostname) - 1)) {
                  for (i = 0; i < sizeof(hostname); i++) {
                     if (hostname[i] == '.') {
                        hostname[i] = '\0';
                        break;
                     }
                  }
                  strncat(p, hostname, sizeof(prompt) - strlen(prompt) - 1);
               } else {
                  strncat(p, "localhost", sizeof(prompt) - strlen(prompt) - 1);
               }
               break;
#ifdef linux
            case 'l': /* load avg */
               t++;
               if ((LOADAVG = fopen("/proc/loadavg", "r"))) {
                  float avg1, avg2, avg3;
                  int actproc, totproc, npid, which;

                  if (fscanf(LOADAVG, "%30f %30f %30f %30d/%30d %30d",
                        &avg1, &avg2, &avg3, &actproc, &totproc, &npid) != 6) {
                     ast_log(LOG_WARNING, "parsing /proc/loadavg failed\n");
                     fclose(LOADAVG);
                     break;
                  }
                  if (sscanf(t, "%30d", &which) == 1) {
                     switch (which) {
                     case 1:
                        snprintf(p, sizeof(prompt) - strlen(prompt), "%.2f", avg1);
                        break;
                     case 2:
                        snprintf(p, sizeof(prompt) - strlen(prompt), "%.2f", avg2);
                        break;
                     case 3:
                        snprintf(p, sizeof(prompt) - strlen(prompt), "%.2f", avg3);
                        break;
                     case 4:
                        snprintf(p, sizeof(prompt) - strlen(prompt), "%d/%d", actproc, totproc);
                        break;
                     case 5:
                        snprintf(p, sizeof(prompt) - strlen(prompt), "%d", npid);
                        break;
                     }
                  }
                  fclose(LOADAVG);
               }
               break;
#endif
            case 's': /* Asterisk system name (from asterisk.conf) */
               strncat(p, ast_config_AST_SYSTEM_NAME, sizeof(prompt) - strlen(prompt) - 1);
               break;
            case 't': /* time */
               memset(&tm, 0, sizeof(tm));
               time(&ts);
               if (ast_localtime(&ts, &tm, NULL)) {
                  strftime(p, sizeof(prompt) - strlen(prompt), "%H:%M:%S", &tm);
               }
               break;
            case '#': /* process console or remote? */
               if (!ast_opt_remote) {
                  strncat(p, "#", sizeof(prompt) - strlen(prompt) - 1);
               } else {
                  strncat(p, ">", sizeof(prompt) - strlen(prompt) - 1);
               }
               break;
            case '%': /* literal % */
               strncat(p, "%", sizeof(prompt) - strlen(prompt) - 1);
               break;
            case '\0': /* % is last character - prevent bug */
               t--;
               break;
            }
            while (*p != '\0') {
               p++;
            }
            t++;
         } else {
            *p = *t;
            p++;
            t++;
         }
      }
      if (color_used) {
         /* Force colors back to normal at end */
         term_color_code(term_code, COLOR_WHITE, COLOR_BLACK, sizeof(term_code));
         if (strlen(term_code) > sizeof(prompt) - strlen(prompt) - 1) {
            ast_copy_string(prompt + sizeof(prompt) - strlen(term_code) - 1, term_code, strlen(term_code) + 1);
         } else {
            /* This looks wrong, but we've already checked the length of term_code to ensure it's safe */
            strncat(p, term_code, sizeof(term_code));
         }
      }
   } else if (remotehostname)
      snprintf(prompt, sizeof(prompt), ASTERISK_PROMPT2, remotehostname);
   else
      snprintf(prompt, sizeof(prompt), ASTERISK_PROMPT);

   return(prompt);   
}

static char **ast_el_strtoarr(char *buf)
{
   char **match_list = NULL, *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 = ast_realloc(match_list, match_list_len * sizeof(char *)))) {
            /* TODO: Handle memory allocation failure */
         }
      }

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

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

   if (matches >= match_list_len) {
      if (!(match_list = ast_realloc(match_list, (match_list_len + 1) * sizeof(char *)))) {
         /* TODO: Handle memory allocation failure */
      }
   }

   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--;
            free(matches[idx]);
            matches[idx] = NULL;
            continue;
         }

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

   return numoutput;
}


static char *cli_complete(EditLine *el, 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(el);

   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);
      res = read(ast_consock, buf, sizeof(buf) - 1);
      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))) {
            lf->cursor[0] = 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))) {
                  lf->cursor[0] = 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);
         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(el, (int) len);
         el_insertstr(el, matches[0]);
         retval = CC_REFRESH;
      }

      if (nummatches == 1) {
         /* Found an exact match */
         el_insertstr(el, " ");
         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(el," ");
            retval = CC_REFRESH;
         }
      }
      for (i = 0; matches[i]; i++)
         free(matches[i]);
      free(matches);
   }

   lf->cursor[0] = savechr;

   return (char *)(long)retval;
}

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

   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 ? editor : "emacs");     
   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);

   return 0;
}

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

   if (el_hist == NULL || el == NULL)
      ast_el_initialize();
   if (strlen(buf) > 256)
      return 0;
   return (history(el_hist, &ev, H_ENTER, 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)
{
   char buf[256];
   FILE *f;
   int ret = -1;

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

   if ((f = fopen(filename, "r")) == NULL)
      return ret;

   while (!feof(f)) {
      if (!fgets(buf, sizeof(buf), f)) {
         continue;
      }
      if (!strcmp(buf, "_HiStOrY_V2_\n"))
         continue;
      if (ast_all_zeros(buf))
         continue;
      if ((ret = ast_el_add_history(buf)) == -1)
         break;
   }
   fclose(f);

   return ret;
}

static void ast_remotecontrol(char *data)
{
   char buf[80];
   int res;
   char filename[80] = "";
   char *hostname;
   char *cpid;
   char *version;
   int pid;
   char tmp[80];
   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) {
      if (write(ast_consock, data, strlen(data) + 1) < 0) {
         ast_log(LOG_ERROR, "write() failed: %s\n", strerror(errno));
         if (sig_flags.need_quit == 1) {
            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) {
      snprintf(tmp, sizeof(tmp), "core set verbose atleast %d", option_verbose);
      fdsend(ast_consock, tmp);
      snprintf(tmp, sizeof(tmp), "core set debug atleast %d", option_debug);
      fdsend(ast_consock, tmp);
      if (!ast_opt_mute)
         fdsend(ast_consock, "logger mute silent");
      else 
         printf("log and verbose output currently muted ('logger mute' to unmute)\n");
   }
   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);

   if (ast_opt_exec && data) {  /* hack to print output then exit if asterisk -rx is used */
      struct pollfd fds;
      fds.fd = ast_consock;
      fds.events = POLLIN;
      fds.revents = 0;
      while (ast_poll(&fds, 1, 500) > 0) {
         char buf[512] = "", *curline = buf, *nextline;
         int not_written = 1;

         if (sig_flags.need_quit == 1) {
            break;
         }

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

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

            /* Skip verbose lines */
            if (*curline != 127) {
               not_written = 0;
               if (write(STDOUT_FILENO, curline, nextline - curline) < 0) {
                  ast_log(LOG_WARNING, "write() failed: %s\n", strerror(errno));
               }
            }
            curline = nextline;
         } while (!ast_strlen_zero(curline));

         /* No non-verbose output in 500ms */
         if (not_written) {
            break;
         }
      }
      return;
   }
   for (;;) {
      ebuf = (char *)el_gets(el, &num);

      if (sig_flags.need_quit == 1) {
         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)) {
            /* Strip preamble from output */
            char *tmp;
            for (tmp = ebuf; *tmp; tmp++) {
               if (*tmp == 127) {
                  memmove(tmp, tmp + 1, strlen(tmp));
                  tmp--;
               }
            }
            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 " ASTERISK_VERSION "\n");
   return 0;
}

static int show_cli_help(void) {
   printf("Asterisk " ASTERISK_VERSION ", Copyright (C) 1999 - 2010, Digium, Inc. and others.\n");
   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 %s timer is available\n", dahdi_chan_name);
   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("   -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> (only valid with -r)\n");
   printf("\n");
   return 0;
}

static void ast_readconfig(void) 
{
   struct ast_config *cfg;
   struct ast_variable *v;
   char *config = AST_CONFIG_FILE;

   if (ast_opt_override_config) {
      cfg = ast_config_load(ast_config_AST_CONFIG_FILE);
      if (!cfg)
         ast_log(LOG_WARNING, "Unable to open specified master config file '%s', using built-in defaults\n", ast_config_AST_CONFIG_FILE);
   } else {
      cfg = ast_config_load(config);
   }

   /* init with buildtime config */
   ast_copy_string(ast_config_AST_CONFIG_DIR, AST_CONFIG_DIR, sizeof(ast_config_AST_CONFIG_DIR));
   ast_copy_string(ast_config_AST_SPOOL_DIR, AST_SPOOL_DIR, sizeof(ast_config_AST_SPOOL_DIR));
   ast_copy_string(ast_config_AST_MODULE_DIR, AST_MODULE_DIR, sizeof(ast_config_AST_MODULE_DIR));
   snprintf(ast_config_AST_MONITOR_DIR, sizeof(ast_config_AST_MONITOR_DIR) - 1, "%s/monitor", ast_config_AST_SPOOL_DIR);
   ast_copy_string(ast_config_AST_VAR_DIR, AST_VAR_DIR, sizeof(ast_config_AST_VAR_DIR));
   ast_copy_string(ast_config_AST_DATA_DIR, AST_DATA_DIR, sizeof(ast_config_AST_DATA_DIR));
   ast_copy_string(ast_config_AST_LOG_DIR, AST_LOG_DIR, sizeof(ast_config_AST_LOG_DIR));
   ast_copy_string(ast_config_AST_AGI_DIR, AST_AGI_DIR, sizeof(ast_config_AST_AGI_DIR));
   ast_copy_string(ast_config_AST_DB, AST_DB, sizeof(ast_config_AST_DB));
   ast_copy_string(ast_config_AST_KEY_DIR, AST_KEY_DIR, sizeof(ast_config_AST_KEY_DIR));
   ast_copy_string(ast_config_AST_PID, AST_PID, sizeof(ast_config_AST_PID));
   ast_copy_string(ast_config_AST_SOCKET, AST_SOCKET, sizeof(ast_config_AST_SOCKET));
   ast_copy_string(ast_config_AST_RUN_DIR, AST_RUN_DIR, sizeof(ast_config_AST_RUN_DIR));

   /* no asterisk.conf? no problem, use buildtime config! */
   if (!cfg) {
      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(ast_config_AST_CONFIG_DIR, v->value, sizeof(ast_config_AST_CONFIG_DIR));
      } else if (!strcasecmp(v->name, "astspooldir")) {
         ast_copy_string(ast_config_AST_SPOOL_DIR, v->value, sizeof(ast_config_AST_SPOOL_DIR));
         snprintf(ast_config_AST_MONITOR_DIR, sizeof(ast_config_AST_MONITOR_DIR) - 1, "%s/monitor", v->value);
      } else if (!strcasecmp(v->name, "astvarlibdir")) {
         ast_copy_string(ast_config_AST_VAR_DIR, v->value, sizeof(ast_config_AST_VAR_DIR));
         snprintf(ast_config_AST_DB, sizeof(ast_config_AST_DB), "%s/astdb", v->value);
      } else if (!strcasecmp(v->name, "astdatadir")) {
         ast_copy_string(ast_config_AST_DATA_DIR, v->value, sizeof(ast_config_AST_DATA_DIR));
         snprintf(ast_config_AST_KEY_DIR, sizeof(ast_config_AST_KEY_DIR), "%s/keys", v->value);
      } else if (!strcasecmp(v->name, "astlogdir")) {
         ast_copy_string(ast_config_AST_LOG_DIR, v->value, sizeof(ast_config_AST_LOG_DIR));
      } else if (!strcasecmp(v->name, "astagidir")) {
         ast_copy_string(ast_config_AST_AGI_DIR, v->value, sizeof(ast_config_AST_AGI_DIR));
      } else if (!strcasecmp(v->name, "astrundir")) {
         snprintf(ast_config_AST_PID, sizeof(ast_config_AST_PID), "%s/%s", v->value, "asterisk.pid");
         snprintf(ast_config_AST_SOCKET, sizeof(ast_config_AST_SOCKET), "%s/%s", v->value, ast_config_AST_CTL);
         ast_copy_string(ast_config_AST_RUN_DIR, v->value, sizeof(ast_config_AST_RUN_DIR));
      } else if (!strcasecmp(v->name, "astmoddir")) {
         ast_copy_string(ast_config_AST_MODULE_DIR, v->value, sizeof(ast_config_AST_MODULE_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, "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;
         }
      /* What user to run as */
      } else if (!strcasecmp(v->name, "runuser")) {
         ast_copy_string(ast_config_AST_RUN_USER, v->value, sizeof(ast_config_AST_RUN_USER));
      /* What group to run as */
      } else if (!strcasecmp(v->name, "rungroup")) {
         ast_copy_string(ast_config_AST_RUN_GROUP, v->value, sizeof(ast_config_AST_RUN_GROUP));
      } else if (!strcasecmp(v->name, "systemname")) {
         ast_copy_string(ast_config_AST_SYSTEM_NAME, v->value, sizeof(ast_config_AST_SYSTEM_NAME));
      } else if (!strcasecmp(v->name, "languageprefix")) {
         ast_language_is_prefix = ast_true(v->value);
      } else if (!strcasecmp(v->name, "dahdichanname")) {
#ifdef HAVE_ZAPTEL
         if (ast_true(v->value)) {
            strcpy(_dahdi_chan_name, "DAHDI");
            _dahdi_chan_name_len = 5;
            _dahdi_chan_mode = CHAN_DAHDI_PLUS_ZAP_MODE;
         }
#else
         if (ast_false(v->value)) {
            strcpy(_dahdi_chan_name, "Zap");
            _dahdi_chan_name_len = 3;
            _dahdi_chan_mode = CHAN_ZAP_MODE;
         }
#endif
      } else if (!strcasecmp(v->name, "sendfullybooted")) {
         ast_set2_flag(&ast_options, ast_true(v->value), AST_OPT_FLAG_SEND_FULLYBOOTED);
      }
   }
   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;
         quit_handler(0, 0, 1, 0);
      }
      if (read(sig_alert_pipe[0], &a, sizeof(a)) != sizeof(a)) {
      }
   }

   return NULL;
}

int main(int argc, char *argv[])
{
   int c;
   char filename[80] = "";
   char hostname[MAXHOSTNAMELEN] = "";
   char tmp[80];
   char * xarg = NULL;
   int x;
   FILE *f;
   sigset_t sigs;
   int num;
   int isroot = 1, rundir_exists = 0;
   char *buf;
   char *runuser = NULL, *rungroup = NULL;
   struct rlimit l;

   /* Remember original args for restart */
   if (argc > sizeof(_argv) / sizeof(_argv[0]) - 1) {
      fprintf(stderr, "Truncating argument size to %d\n", (int)(sizeof(_argv) / sizeof(_argv[0])) - 1);
      argc = sizeof(_argv) / sizeof(_argv[0]) - 1;
   }
   for (x=0; x<argc; x++)
      _argv[x] = argv[x];
   _argv[x] = NULL;

   if (geteuid() != 0)
      isroot = 0;

   /* if the progname is rasterisk consider it a remote console */
   if (argv[0] && (strstr(argv[0], "rasterisk")) != NULL) {
      ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_REMOTE);
   }
   if (gethostname(hostname, sizeof(hostname)-1))
      ast_copy_string(hostname, "<Unknown>", sizeof(hostname));
   ast_mainpid = getpid();
   ast_ulaw_init();
   ast_alaw_init();
   callerid_init();
   ast_builtins_init();
   ast_utils_init();
   tdd_init();
   ast_fd_init();
   ast_pbx_init();

   if (getenv("HOME")) 
      snprintf(filename, sizeof(filename), "%s/.asterisk_history", getenv("HOME"));
   /* Check for options */
   while ((c = getopt(argc, argv, "mtThfFdvVqprRgciInx:U:G:C:L:M:")) != -1) {
      switch (c) {
#if HAVE_WORKING_FORK
      case 'F':
         ast_set_flag(&ast_options, AST_OPT_FLAG_ALWAYS_FORK);
         break;
      case 'f':
         ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK);
         break;
#endif
      case 'd':
         option_debug++;
         ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK);
         break;
      case 'c':
         ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_CONSOLE);
         break;
      case 'n':
         ast_set_flag(&ast_options, AST_OPT_FLAG_NO_COLOR);
         break;
      case 'r':
         ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_REMOTE);
         break;
      case 'R':
         ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK | AST_OPT_FLAG_REMOTE | AST_OPT_FLAG_RECONNECT);
         break;
      case 'p':
         ast_set_flag(&ast_options, AST_OPT_FLAG_HIGH_PRIORITY);
         break;
      case 'v':
         option_verbose++;
         ast_set_flag(&ast_options, AST_OPT_FLAG_NO_FORK);
         break;
      case 'm':
         ast_set_flag(&ast_options, AST_OPT_FLAG_MUTE);
         break;
      case 'M':
         if ((sscanf(optarg, "%30d", &option_maxcalls) != 1) || (option_maxcalls < 0))
            option_maxcalls = 0;
         break;
      case 'L':
         if ((sscanf(optarg, "%30lf", &option_maxload) != 1) || (option_maxload < 0.0))
            option_maxload = 0.0;
         break;
      case 'q':
         ast_set_flag(&ast_options, AST_OPT_FLAG_QUIET);
         break;
      case 't':
         ast_set_flag(&ast_options, AST_OPT_FLAG_CACHE_RECORD_FILES);
         break;
      case 'T':
         ast_set_flag(&ast_options, AST_OPT_FLAG_TIMESTAMP);
         break;
      case 'x':
         ast_set_flag(&ast_options, AST_OPT_FLAG_EXEC | AST_OPT_FLAG_NO_COLOR);
         xarg = ast_strdupa(optarg);
         break;
      case 'C':
         ast_copy_string(ast_config_AST_CONFIG_FILE, optarg, sizeof(ast_config_AST_CONFIG_FILE));
         ast_set_flag(&ast_options, AST_OPT_FLAG_OVERRIDE_CONFIG);
         break;
      case 'I':
         ast_set_flag(&ast_options, AST_OPT_FLAG_INTERNAL_TIMING);
         break;
      case 'i':
         ast_set_flag(&ast_options, AST_OPT_FLAG_INIT_KEYS);
         break;
      case 'g':
         ast_set_flag(&ast_options, AST_OPT_FLAG_DUMP_CORE);
         break;
      case 'h':
         show_cli_help();
         exit(0);
      case 'V':
         show_version();
         exit(0);
      case 'U':
         runuser = ast_strdupa(optarg);
         break;
      case 'G':
         rungroup = ast_strdupa(optarg);
         break;
      case '?':
         exit(1);
      }
   }

   if (ast_opt_console || option_verbose || (ast_opt_remote && !ast_opt_exec)) {
      ast_register_verbose(console_verboser);
      WELCOME_MESSAGE;
   }

   if (ast_opt_console && !option_verbose) 
      ast_verbose("[ Booting...\n");

   /* For remote connections, change the name of the remote connection.
    * We do this for the benefit of init scripts (which need to know if/when
    * the main asterisk process has died yet). */
   if (ast_opt_remote) {
      strcpy(argv[0], "rasterisk");
      for (x = 1; x < argc; x++) {
         argv[x] = argv[0] + 10;
      }
   }

   if (ast_opt_console && !option_verbose) {
      ast_verbose("[ Reading Master Configuration ]\n");
   }

   ast_readconfig();

   if (ast_opt_always_fork && (ast_opt_remote || ast_opt_console)) {
      ast_log(LOG_WARNING, "'alwaysfork' is not compatible with console or remote console mode; ignored\n");
      ast_clear_flag(&ast_options, AST_OPT_FLAG_ALWAYS_FORK);
   }

   if (ast_opt_dump_core) {
      memset(&l, 0, sizeof(l));
      l.rlim_cur = RLIM_INFINITY;
      l.rlim_max = RLIM_INFINITY;
      if (setrlimit(RLIMIT_CORE, &l)) {
         ast_log(LOG_WARNING, "Unable to disable core size resource limit: %s\n", strerror(errno));
      }
   }

   if (getrlimit(RLIMIT_NOFILE, &l)) {
      ast_log(LOG_WARNING, "Unable to check file descriptor limit: %s\n", strerror(errno));
   }

#if !defined(CONFIGURE_RAN_AS_ROOT)
   /* Check if select(2) will run with more file descriptors */
   do {
      int fd, fd2;
      ast_fdset readers;
      struct timeval tv = { 0, };

      if (l.rlim_cur <= FD_SETSIZE) {
         /* The limit of select()able FDs is irrelevant, because we'll never
          * open one that high. */
         break;
      }

      if (!(fd = open("/dev/null", O_RDONLY))) {
         ast_log(LOG_ERROR, "Cannot open a file descriptor at boot? %s\n", strerror(errno));
         break; /* XXX Should we exit() here? XXX */
      }

      fd2 = (l.rlim_cur > sizeof(readers) * 8 ? sizeof(readers) * 8 : l.rlim_cur) - 1;
      if (dup2(fd, fd2) < 0) {
         ast_log(LOG_WARNING, "Cannot open maximum file descriptor %d at boot? %s\n", fd2, strerror(errno));
         close(fd);
         break;
      }

      FD_ZERO(&readers);
      FD_SET(fd2, &readers);
      if (ast_select(fd2 + 1, &readers, NULL, NULL, &tv) < 0) {
         ast_log(LOG_WARNING, "Maximum select()able file descriptor is %d\n", FD_SETSIZE);
      }
      ast_FD_SETSIZE = l.rlim_cur > ast_FDMAX ? ast_FDMAX : l.rlim_cur;
      close(fd);
      close(fd2);
   } while (0);
#elif defined(HAVE_VARIABLE_FDSET)
   ast_FD_SETSIZE = l.rlim_cur > ast_FDMAX ? ast_FDMAX : l.rlim_cur;
#endif /* !defined(CONFIGURE_RAN_AS_ROOT) */

   if ((!rungroup) && !ast_strlen_zero(ast_config_AST_RUN_GROUP))
      rungroup = ast_config_AST_RUN_GROUP;
   if ((!runuser) && !ast_strlen_zero(ast_config_AST_RUN_USER))
      runuser = ast_config_AST_RUN_USER;

   /* It's common on some platforms to clear /var/run at boot.  Create the
    * socket file directory before we drop privileges. */
   if (mkdir(ast_config_AST_RUN_DIR, 0755)) {
      if (errno == EEXIST) {
         rundir_exists = 1;
      } else {
         ast_log(LOG_WARNING, "Unable to create socket file directory.  Remote consoles will not be able to connect! (%s)\n", strerror(x));
      }
   }

#ifndef __CYGWIN__

   if (isroot) 
      ast_set_priority(ast_opt_high_priority);

   if (isroot && rungroup) {
      struct group *gr;
      gr = getgrnam(rungroup);
      if (!gr) {
         ast_log(LOG_WARNING, "No such group '%s'!\n", rungroup);
         exit(1);
      }
      if (!rundir_exists && chown(ast_config_AST_RUN_DIR, -1, gr->gr_gid)) {
         ast_log(LOG_WARNING, "Unable to chgrp run directory to %d (%s)\n", (int) gr->gr_gid, rungroup);
      }
      if (setgid(gr->gr_gid)) {
         ast_log(LOG_WARNING, "Unable to setgid to %d (%s)\n", (int)gr->gr_gid, rungroup);
         exit(1);
      }
      if (setgroups(0, NULL)) {
         ast_log(LOG_WARNING, "Unable to drop unneeded groups\n");
         exit(1);
      }
      if (option_verbose)
         ast_verbose("Running as group '%s'\n", rungroup);
   }

   if (runuser && !ast_test_flag(&ast_options, AST_OPT_FLAG_REMOTE)) {
#ifdef HAVE_CAP
      int has_cap = 1;
#endif /* HAVE_CAP */
      struct passwd *pw;
      pw = getpwnam(runuser);
      if (!pw) {
         ast_log(LOG_WARNING, "No such user '%s'!\n", runuser);
         exit(1);
      }
      if (chown(ast_config_AST_RUN_DIR, pw->pw_uid, -1)) {
         ast_log(LOG_WARNING, "Unable to chown run directory to %d (%s)\n", (int) pw->pw_uid, runuser);
      }
#ifdef HAVE_CAP
      if (prctl(PR_SET_KEEPCAPS, 1, 0, 0, 0)) {
         ast_log(LOG_WARNING, "Unable to keep capabilities.\n");
         has_cap = 0;
      }
#endif /* HAVE_CAP */
      if (!isroot && pw->pw_uid != geteuid()) {
         ast_log(LOG_ERROR, "Asterisk started as nonroot, but runuser '%s' requested.\n", runuser);
         exit(1);
      }
      if (!rungroup) {
         if (setgid(pw->pw_gid)) {
            ast_log(LOG_WARNING, "Unable to setgid to %d!\n", (int)pw->pw_gid);
            exit(1);
         }
         if (isroot && initgroups(pw->pw_name, pw->pw_gid)) {
            ast_log(LOG_WARNING, "Unable to init groups for '%s'\n", runuser);
            exit(1);
         }
      }
      if (setuid(pw->pw_uid)) {
         ast_log(LOG_WARNING, "Unable to setuid to %d (%s)\n", (int)pw->pw_uid, runuser);
         exit(1);
      }
      if (option_verbose)
         ast_verbose("Running as user '%s'\n", runuser);
#ifdef HAVE_CAP
      if (has_cap) {
         cap_t cap;

         cap = cap_from_text("cap_net_admin=eip");

         if (cap_set_proc(cap))
            ast_log(LOG_WARNING, "Unable to install capabilities.\n");

         if (cap_free(cap))
            ast_log(LOG_WARNING, "Unable to drop capabilities.\n");
      }
#endif /* HAVE_CAP */
   }

#endif /* __CYGWIN__ */

#ifdef linux
   if (geteuid() && ast_opt_dump_core) {
      if (prctl(PR_SET_DUMPABLE, 1, 0, 0, 0) < 0) {
         ast_log(LOG_WARNING, "Unable to set the process for core dumps after changing to a non-root user. %s\n", strerror(errno));
      }  
   }
#endif

   ast_term_init();
   printf("%s", term_end());
   fflush(stdout);

   if (ast_opt_console && !option_verbose) 
      ast_verbose("[ Initializing Custom Configuration Options ]\n");
   /* custom config setup */
   register_config_cli();
   read_config_maps();
   
   if (ast_opt_console) {
      if (el_hist == NULL || el == NULL)
         ast_el_initialize();

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

   if (ast_tryconnect()) {
      /* One is already running */
      if (ast_opt_remote) {
         if (ast_opt_exec) {
            ast_remotecontrol(xarg);
            quit_handler(0, 0, 0, 0);
            exit(0);
         }
         printf("%s", term_quit());
         ast_remotecontrol(NULL);
         quit_handler(0, 0, 0, 0);
         exit(0);
      } else {
         ast_log(LOG_ERROR, "Asterisk already running on %s.  Use 'asterisk -r' to connect.\n", ast_config_AST_SOCKET);
         printf("%s", term_quit());
         exit(1);
      }
   } else if (ast_opt_remote || ast_opt_exec) {
      ast_log(LOG_ERROR, "Unable to connect to remote asterisk (does %s exist?)\n", ast_config_AST_SOCKET);
      printf("%s", term_quit());
      exit(1);
   }
   /* Blindly write pid file since we couldn't connect */
   unlink(ast_config_AST_PID);
   f = fopen(ast_config_AST_PID, "w");
   if (f) {
      fprintf(f, "%ld\n", (long)getpid());
      fclose(f);
   } else
      ast_log(LOG_WARNING, "Unable to open pid file '%s': %s\n", ast_config_AST_PID, strerror(errno));

#if HAVE_WORKING_FORK
   if (ast_opt_always_fork || !ast_opt_no_fork) {
#ifndef HAVE_SBIN_LAUNCHD
      if (daemon(1, 0) < 0) {
         ast_log(LOG_ERROR, "daemon() failed: %s\n", strerror(errno));
      }
      ast_mainpid = getpid();
      /* Blindly re-write pid file since we are forking */
      unlink(ast_config_AST_PID);
      f = fopen(ast_config_AST_PID, "w");
      if (f) {
         fprintf(f, "%ld\n", (long)ast_mainpid);
         fclose(f);
      } else
         ast_log(LOG_WARNING, "Unable to open pid file '%s': %s\n", ast_config_AST_PID, strerror(errno));
#else
      ast_log(LOG_WARNING, "Mac OS X detected.  Use 'launchctl load /Library/LaunchDaemon/org.asterisk.asterisk.plist'.\n");
#endif
   }
#endif

#ifdef TEST_FRAMEWORK
   if (ast_test_init()) {
      printf("%s", term_quit());
      exit(1);
   }
#endif

   ast_makesocket();
   sigemptyset(&sigs);
   sigaddset(&sigs, SIGHUP);
   sigaddset(&sigs, SIGTERM);
   sigaddset(&sigs, SIGINT);
   sigaddset(&sigs, SIGPIPE);
   sigaddset(&sigs, SIGWINCH);
   pthread_sigmask(SIG_BLOCK, &sigs, NULL);
   sigaction(SIGURG, &urg_handler, NULL);
   signal(SIGINT, __quit_handler);
   signal(SIGTERM, __quit_handler);
   sigaction(SIGHUP, &hup_handler, NULL);
   sigaction(SIGCHLD, &child_handler, NULL);
   signal(SIGPIPE, SIG_IGN);

   /* ensure that the random number generators are seeded with a different value every time
      Asterisk is started
   */
   srand((unsigned int) getpid() + (unsigned int) time(NULL));
   initstate((unsigned int) getpid() * 65536 + (unsigned int) time(NULL), randompool, sizeof(randompool));

   if (init_logger()) {
      printf("%s", term_quit());
      exit(1);
   }

   dahdi_chan_name = _dahdi_chan_name;
   dahdi_chan_name_len = &_dahdi_chan_name_len;
   dahdi_chan_mode = &_dahdi_chan_mode;

#ifdef HAVE_DAHDI
   {
      int fd;
      int x = 160;
      fd = open(DAHDI_FILE_TIMER, O_RDWR);
      if (fd >= 0) {
         if (ioctl(fd, DAHDI_TIMERCONFIG, &x)) {
            ast_log(LOG_ERROR, "You have " DAHDI_NAME
                  " built and drivers loaded, but the "
                  DAHDI_NAME " timer test failed to set DAHDI_TIMERCONFIG to %d.\n", x);
            exit(1);
         }
         if ((x = ast_wait_for_input(fd, 300)) < 0) {
            ast_log(LOG_ERROR, "You have " DAHDI_NAME 
                  "built and drivers loaded, but the " 
                  DAHDI_NAME " timer could not be polled during the " 
                  DAHDI_NAME " timer test.\n");
            exit(1);
         }
         if (!x) {
            const char dahdi_timer_error[] = {
               "Asterisk has detected a problem with your " DAHDI_NAME 
                  " configuration and will shutdown for your protection.  You have options:"
               "\n\t1. You only have to compile " DAHDI_NAME 
                  " support into Asterisk if you need it.  One option is to recompile without " 
                  DAHDI_NAME " support."
               "\n\t2. You only have to load " DAHDI_NAME " drivers if you want to take advantage of " 
                  DAHDI_NAME " services.  One option is to unload " 
                  DAHDI_NAME " modules if you don't need them."
               "\n\t3. If you need Zaptel services, you must correctly configure " DAHDI_NAME "."
            };
            ast_log(LOG_ERROR, "%s\n", dahdi_timer_error);
            exit(1);
         }
         close(fd);
      }
   }
#endif
   threadstorage_init();

   astobj2_init();

   ast_autoservice_init();

   if (load_modules(1)) {
      printf("%s", term_quit());
      exit(1);
   }

   if (dnsmgr_init()) {
      printf("%s", term_quit());
      exit(1);
   }

   ast_http_init();

   ast_channels_init();

   if (init_manager()) {
      printf("%s", term_quit());
      exit(1);
   }

   if (ast_cdr_engine_init()) {
      printf("%s", term_quit());
      exit(1);
   }

   if (ast_device_state_engine_init()) {
      printf("%s", term_quit());
      exit(1);
   }

   ast_rtp_init();

   ast_udptl_init();

   if (ast_image_init()) {
      printf("%s", term_quit());
      exit(1);
   }

   if (ast_file_init()) {
      printf("%s", term_quit());
      exit(1);
   }

   if (load_pbx()) {
      printf("%s", term_quit());
      exit(1);
   }

   if (init_framer()) {
      printf("%s", term_quit());
      exit(1);
   }

   if (astdb_init()) {
      printf("%s", term_quit());
      exit(1);
   }

   if (ast_enum_init()) {
      printf("%s", term_quit());
      exit(1);
   }

   if (load_modules(0)) {
      printf("%s", term_quit());
      exit(1);
   }

   dnsmgr_start_refresh();

   /* We might have the option of showing a console, but for now just
      do nothing... */
   if (ast_opt_console && !option_verbose)
      ast_verbose(" ]\n");
   if (option_verbose || ast_opt_console)
      ast_verbose("%s", term_color(tmp, "Asterisk Ready.\n", COLOR_BRWHITE, COLOR_BLACK, sizeof(tmp)));
   if (ast_opt_no_fork)
      consolethread = pthread_self();

   if (pipe(sig_alert_pipe))
      sig_alert_pipe[0] = sig_alert_pipe[1] = -1;

   ast_set_flag(&ast_options, AST_OPT_FLAG_FULLY_BOOTED);
   if (ast_opt_send_fullybooted) {
      manager_event(EVENT_FLAG_SYSTEM, "FullyBooted", "Status: Fully Booted\r\n");
   }

   ast_process_pending_reloads();

   pthread_sigmask(SIG_UNBLOCK, &sigs, NULL);

#ifdef __AST_DEBUG_MALLOC
   __ast_mm_init();
#endif   

   time(&ast_startuptime);
   ast_cli_register_multiple(cli_asterisk, sizeof(cli_asterisk) / sizeof(struct ast_cli_entry));

   if (ast_opt_console) {
      /* Console stuff now... */
      /* Register our quit function */
      char title[256];
      pthread_attr_t attr;

      pthread_attr_init(&attr);
      pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
      ast_pthread_create(&mon_sig_flags, &attr, monitor_sig_flags, NULL);
      pthread_attr_destroy(&attr);

      set_icon("Asterisk");
      snprintf(title, sizeof(title), "Asterisk Console on '%s' (pid %ld)", hostname, (long)ast_mainpid);
      set_title(title);

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

         if (!buf && write(1, "", 1) < 0)
            goto lostterm;

         if (buf) {
            if (buf[strlen(buf)-1] == '\n')
               buf[strlen(buf)-1] = '\0';

            consolehandler((char *)buf);
         } else if (ast_opt_remote && (write(STDOUT_FILENO, "\nUse EXIT or QUIT to exit the asterisk console\n",
               strlen("\nUse EXIT or QUIT to exit the asterisk console\n")) < 0)) {
            /* Whoa, stdout disappeared from under us... Make /dev/null's */
            int fd;
            fd = open("/dev/null", O_RDWR);
            if (fd > -1) {
               dup2(fd, STDOUT_FILENO);
               dup2(fd, STDIN_FILENO);
            } else
               ast_log(LOG_WARNING, "Failed to open /dev/null to recover from dead console. Bad things will happen!\n");
            break;
         }
      }
   }

   monitor_sig_flags(NULL);

lostterm:
   return 0;
}