Mon Apr 30 07:47:39 2007

Asterisk developer's documentation

---

AMI functions

callback to display queues status in manager More...

Data Structures
struct	ast_manager_user
struct	eventqent
struct	fast_originate_helper
struct	mansession
struct	permalias
Defines
#define	ASTMAN_APPEND_BUF_INITSIZE   256
#define	MANAGER_EVENT_BUF_INITSIZE   256
Functions
static void *	accept_thread (void *ignore)
static int	action_command (struct mansession *s, const struct message *m)
	action_command: Manager command "command" - execute CLI command
static int	action_events (struct mansession *s, const struct message *m)
static int	action_extensionstate (struct mansession *s, const struct message *m)
static int	action_getconfig (struct mansession *s, const struct message *m)
static int	action_getvar (struct mansession *s, const struct message *m)
static int	action_hangup (struct mansession *s, const struct message *m)
static int	action_listcommands (struct mansession *s, const struct message *m)
static int	action_logoff (struct mansession *s, const struct message *m)
static int	action_mailboxcount (struct mansession *s, const struct message *m)
static int	action_mailboxstatus (struct mansession *s, const struct message *m)
static int	action_originate (struct mansession *s, const struct message *m)
static int	action_ping (struct mansession *s, const struct message *m)
static int	action_redirect (struct mansession *s, const struct message *m)
	action_redirect: The redirect manager command
static int	action_setvar (struct mansession *s, const struct message *m)
static int	action_status (struct mansession *s, const struct message *m)
	Manager "status" command to show channels.
static int	action_timeout (struct mansession *s, const struct message *m)
static int	action_updateconfig (struct mansession *s, const struct message *m)
static int	action_userevent (struct mansession *s, const struct message *m)
static int	action_waitevent (struct mansession *s, const struct message *m)
static int	append_event (const char *str, int category)
static struct ast_manager_user *	ast_get_manager_by_name_locked (const char *name)
static int	ast_instring (const char *bigstr, const char *smallstr, char delim)
static int	ast_is_number (char *string)
static	AST_LIST_HEAD_STATIC (users, ast_manager_user)
static	AST_LIST_HEAD_STATIC (sessions, mansession)
int	ast_manager_register2 (const char *action, int auth, int(*func)(struct mansession *s, const struct message *m), const char *synopsis, const char *description)
	register a new command with manager, including online help. This is the preferred way to register a manager command
static int	ast_manager_register_struct (struct manager_action *act)
int	ast_manager_unregister (char *action)
	AST_RWLOCK_DEFINE_STATIC (actionlock)
	AST_THREADSTORAGE (astman_append_buf, astman_append_buf_init)
	AST_THREADSTORAGE (manager_event_buf, manager_event_buf_init)
void	astman_append (struct mansession *s, const char *fmt,...)
const char *	astman_get_header (const struct message *m, char *var)
ast_variable *	astman_get_variables (const struct message *m)
void	astman_send_ack (struct mansession *s, const struct message *m, char *msg)
void	astman_send_error (struct mansession *s, const struct message *m, char *error)
void	astman_send_response (struct mansession *s, const struct message *m, char *resp, char *msg)
static int	authenticate (struct mansession *s, const struct message *m)
static char *	authority_to_str (int authority, char *res, int reslen)
	Convert authority code to string with serveral options.
static char *	complete_show_mancmd (const char *line, const char *word, int pos, int state)
static void	destroy_session (struct mansession *s)
static int	do_message (struct mansession *s)
static void *	fast_originate (void *data)
static void	free_session (struct mansession *s)
static int	get_input (struct mansession *s, char *output)
static int	get_perm (const char *instr)
static int	handle_showmanager (int fd, int argc, char *argv[])
static int	handle_showmanagers (int fd, int argc, char *argv[])
static int	handle_showmancmd (int fd, int argc, char *argv[])
static int	handle_showmancmds (int fd, int argc, char *argv[])
	CLI command Should change to "manager show commands".
static int	handle_showmanconn (int fd, int argc, char *argv[])
	CLI command show manager connected.
static int	handle_showmaneventq (int fd, int argc, char *argv[])
	CLI command show manager connected.
static void	handle_updates (struct mansession *s, const struct message *m, struct ast_config *cfg)
static char *	html_translate (char *in)
int	manager_event (int category, const char *event, const char *fmt,...)
	manager_event: Send AMI event to client
static int	manager_state_cb (char *context, char *exten, int state, void *data)
static int	process_events (struct mansession *s)
static int	process_message (struct mansession *s, const struct message *m)
static void *	session_do (void *data)
static int	set_eventmask (struct mansession *s, const char *eventmask)
	Rather than braindead on,off this now can also accept a specific int mask value or a ',' delim list of mask strings (the same as manager.conf) -anthm.
static int	strings_to_mask (const char *string)
static void	unuse_eventqent (struct eventqent *e)
static void	xml_copy_escape (char **dst, size_t *maxlen, const char *src, int lower)
static char *	xml_translate (char *in, struct ast_variable *vars)
Variables
static int	asock = -1
static int	block_sockets
static struct ast_cli_entry	cli_manager []
static struct ast_cli_entry	cli_show_manager_command_deprecated
static struct ast_cli_entry	cli_show_manager_commands_deprecated
static struct ast_cli_entry	cli_show_manager_connected_deprecated
static struct ast_cli_entry	cli_show_manager_eventq_deprecated
static int	displayconnects = 1
static int	enabled
static struct manager_action *	first_action
static int	httptimeout = 60
static char	mandescr_command []
static char	mandescr_events []
static char	mandescr_extensionstate []
static char	mandescr_getconfig []
static char	mandescr_getvar []
static char	mandescr_hangup []
static char	mandescr_listcommands []
static char	mandescr_logoff []
static char	mandescr_mailboxcount []
static char	mandescr_mailboxstatus []
	Help text for manager command mailboxstatus.
static char	mandescr_originate []
static char	mandescr_ping []
	Manager PING.
static char	mandescr_redirect []
static char	mandescr_setvar []
static char	mandescr_timeout []
static char	mandescr_updateconfig []
static char	mandescr_userevent []
static char	mandescr_waitevent []
	Manager WAITEVENT.
eventqent *	master_eventq = NULL
static int	num_sessions
static struct permalias	perms []
static int	portno = DEFAULT_MANAGER_PORT
static char	showmanager_help []
static char	showmanagers_help []
static char	showmancmd_help []
static char	showmancmds_help []
static char	showmanconn_help []
static char	showmaneventq_help []
static pthread_t	t
static int	timestampevents

---

Detailed Description

callback to display queues status in manager

---

Define Documentation

#define ASTMAN_APPEND_BUF_INITSIZE   256

Definition at line 113 of file manager.c.

Referenced by astman_append().

#define MANAGER_EVENT_BUF_INITSIZE   256

Definition at line 110 of file manager.c.

Referenced by manager_event().

---

Function Documentation

static void* accept_thread

(

void *

ignore

)

[static]

Definition at line 2176 of file manager.c.

References asock, ast_calloc, ast_inet_ntoa(), AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_log(), ast_mutex_init(), ast_pthread_create_background, AST_PTHREADT_NULL, ast_verbose(), block_sockets, destroy_session(), displayconnects, pollfd::events, pollfd::fd, free, free_session(), LOG_WARNING, master_eventq, eventqent::next, num_sessions, option_verbose, poll(), POLLIN, s, session_do(), sessions, eventqent::usecount, and VERBOSE_PREFIX_2.

Referenced by init_manager(), and reload_config().

{
   int as;
   struct sockaddr_in sin;
   socklen_t sinlen;
   struct eventqent *eqe;
   struct mansession *s;
   struct protoent *p;
   int arg = 1;
   int flags;
   pthread_attr_t attr;
   time_t now;
   struct pollfd pfds[1];

   pthread_attr_init(&attr);
   pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);

   for (;;) {
      time(&now);
      AST_LIST_LOCK(&sessions);
      AST_LIST_TRAVERSE_SAFE_BEGIN(&sessions, s, list) {
         if (s->sessiontimeout && (now > s->sessiontimeout) && !s->inuse) {
            AST_LIST_REMOVE_CURRENT(&sessions, list);
            if (s->authenticated && (option_verbose > 1) && displayconnects) {
               ast_verbose(VERBOSE_PREFIX_2 "HTTP Manager '%s' timed out from %s\n",
                  s->username, ast_inet_ntoa(s->sin.sin_addr));
            }
            free_session(s);
            break;   
         }
      }
      AST_LIST_TRAVERSE_SAFE_END
      /* Purge master event queue of old, unused events, but make sure we
         always keep at least one in the queue */
      eqe = master_eventq;
      while (master_eventq->next && !master_eventq->usecount) {
         eqe = master_eventq;
         master_eventq = master_eventq->next;
         free(eqe);
      }
      AST_LIST_UNLOCK(&sessions);
      if (s)
         ast_atomic_fetchadd_int(&num_sessions, -1);

      sinlen = sizeof(sin);
      pfds[0].fd = asock;
      pfds[0].events = POLLIN;
      /* Wait for something to happen, but timeout every few seconds so
         we can ditch any old manager sessions */
      if (poll(pfds, 1, 5000) < 1)
         continue;
      as = accept(asock, (struct sockaddr *)&sin, &sinlen);
      if (as < 0) {
         ast_log(LOG_NOTICE, "Accept returned -1: %s\n", strerror(errno));
         continue;
      }
      p = getprotobyname("tcp");
      if (p) {
         if( setsockopt(as, p->p_proto, TCP_NODELAY, (char *)&arg, sizeof(arg) ) < 0 ) {
            ast_log(LOG_WARNING, "Failed to set manager tcp connection to TCP_NODELAY mode: %s\n", strerror(errno));
         }
      }
      if (!(s = ast_calloc(1, sizeof(*s))))
         continue;

      ast_atomic_fetchadd_int(&num_sessions, 1);
      
      memcpy(&s->sin, &sin, sizeof(sin));
      s->writetimeout = 100;
      s->waiting_thread = AST_PTHREADT_NULL;

      if (!block_sockets) {
         /* For safety, make sure socket is non-blocking */
         flags = fcntl(as, F_GETFL);
         fcntl(as, F_SETFL, flags | O_NONBLOCK);
      } else {
         flags = fcntl(as, F_GETFL);
         fcntl(as, F_SETFL, flags & ~O_NONBLOCK);
      }
      ast_mutex_init(&s->__lock);
      s->fd = as;
      s->send_events = -1;
      AST_LIST_LOCK(&sessions);
      AST_LIST_INSERT_HEAD(&sessions, s, list);
      /* Find the last place in the master event queue and hook ourselves
         in there */
      s->eventq = master_eventq;
      while(s->eventq->next)
         s->eventq = s->eventq->next;
      AST_LIST_UNLOCK(&sessions);
      ast_atomic_fetchadd_int(&s->eventq->usecount, 1);
      if (ast_pthread_create_background(&s->t, &attr, session_do, s))
         destroy_session(s);
   }
   pthread_attr_destroy(&attr);
   return NULL;
}

static int action_command	(	struct mansession *	s,
		const struct message *	m
	)			[static]

action_command: Manager command "command" - execute CLI command

Definition at line 1611 of file manager.c.

References ast_cli_command(), ast_strlen_zero(), astman_append(), astman_get_header(), and s.

Referenced by init_manager().

{
   const char *cmd = astman_get_header(m, "Command");
   const char *id = astman_get_header(m, "ActionID");
   astman_append(s, "Response: Follows\r\nPrivilege: Command\r\n");
   if (!ast_strlen_zero(id))
      astman_append(s, "ActionID: %s\r\n", id);
   /* FIXME: Wedge a ActionID response in here, waiting for later changes */
   ast_cli_command(s->fd, cmd);
   astman_append(s, "--END COMMAND--\r\n\r\n");
   return 0;
}

static int action_events	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1297 of file manager.c.

References astman_get_header(), astman_send_response(), s, and set_eventmask().

Referenced by init_manager().

{
   const char *mask = astman_get_header(m, "EventMask");
   int res;

   res = set_eventmask(s, mask);
   if (res > 0)
      astman_send_response(s, m, "Events On", NULL);
   else if (res == 0)
      astman_send_response(s, m, "Events Off", NULL);

   return 0;
}

static int action_extensionstate	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1874 of file manager.c.

References ast_extension_state(), ast_get_hint(), ast_strlen_zero(), astman_append(), astman_get_header(), astman_send_error(), context, exten, and s.

Referenced by init_manager().

{
   const char *exten = astman_get_header(m, "Exten");
   const char *context = astman_get_header(m, "Context");
   const char *id = astman_get_header(m,"ActionID");
   char idText[256] = "";
   char hint[256] = "";
   int status;
   if (ast_strlen_zero(exten)) {
      astman_send_error(s, m, "Extension not specified");
      return 0;
   }
   if (ast_strlen_zero(context))
      context = "default";
   status = ast_extension_state(NULL, context, exten);
   ast_get_hint(hint, sizeof(hint) - 1, NULL, 0, NULL, context, exten);
        if (!ast_strlen_zero(id)) {
                snprintf(idText, sizeof(idText), "ActionID: %s\r\n", id);
        }
   astman_append(s, "Response: Success\r\n"
                    "%s"
               "Message: Extension Status\r\n"
               "Exten: %s\r\n"
               "Context: %s\r\n"
               "Hint: %s\r\n"
               "Status: %d\r\n\r\n",
               idText,exten, context, hint, status);
   return 0;
}

static int action_getconfig	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1026 of file manager.c.

References ast_category_browse(), ast_config_destroy(), ast_config_load_with_comments(), ast_strlen_zero(), ast_variable_browse(), astman_append(), astman_get_header(), astman_send_error(), lineno, ast_variable::name, ast_variable::next, s, and ast_variable::value.

Referenced by init_manager().

{
   struct ast_config *cfg;
   const char *fn = astman_get_header(m, "Filename");
   int catcount = 0;
   int lineno = 0;
   char *category=NULL;
   struct ast_variable *v;
   char idText[256] = "";
   const char *id = astman_get_header(m, "ActionID");

   if (!ast_strlen_zero(id))
      snprintf(idText, sizeof(idText), "ActionID: %s\r\n", id);

   if (ast_strlen_zero(fn)) {
      astman_send_error(s, m, "Filename not specified");
      return 0;
   }
   if (!(cfg = ast_config_load_with_comments(fn))) {
      astman_send_error(s, m, "Config file not found");
      return 0;
   }
   astman_append(s, "Response: Success\r\n%s", idText);
   while ((category = ast_category_browse(cfg, category))) {
      lineno = 0;
      astman_append(s, "Category-%06d: %s\r\n", catcount, category);
      for (v = ast_variable_browse(cfg, category); v; v = v->next)
         astman_append(s, "Line-%06d-%06d: %s=%s\r\n", catcount, lineno++, v->name, v->value);
      catcount++;
   }
   ast_config_destroy(cfg);
   astman_append(s, "\r\n");

   return 0;
}

static int action_getvar	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1394 of file manager.c.

References ast_channel_unlock, ast_func_read(), ast_get_channel_by_name_locked(), ast_strdupa, ast_strlen_zero(), astman_append(), astman_get_header(), astman_send_error(), copy(), name, pbx_retrieve_variable(), and s.

Referenced by init_manager().

{
   struct ast_channel *c = NULL;
   const char *name = astman_get_header(m, "Channel");
   const char *varname = astman_get_header(m, "Variable");
   const char *id = astman_get_header(m,"ActionID");
   char *varval;
   char workspace[1024] = "";

   if (ast_strlen_zero(varname)) {
      astman_send_error(s, m, "No variable specified");
      return 0;
   }

   if (!ast_strlen_zero(name)) {
      c = ast_get_channel_by_name_locked(name);
      if (!c) {
         astman_send_error(s, m, "No such channel");
         return 0;
      }
   }

   if (varname[strlen(varname) - 1] == ')') {
      char *copy = ast_strdupa(varname);

      ast_func_read(c, copy, workspace, sizeof(workspace));
      varval = workspace;
   } else {
      pbx_retrieve_variable(c, varname, &varval, workspace, sizeof(workspace), NULL);
   }

   if (c)
      ast_channel_unlock(c);
   astman_append(s, "Response: Success\r\n"
      "Variable: %s\r\nValue: %s\r\n", varname, varval);
   if (!ast_strlen_zero(id))
      astman_append(s, "ActionID: %s\r\n",id);
   astman_append(s, "\r\n");

   return 0;
}

static int action_hangup	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1326 of file manager.c.

References ast_channel_unlock, ast_get_channel_by_name_locked(), ast_softhangup(), AST_SOFTHANGUP_EXPLICIT, ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), name, and s.

Referenced by init_manager().

{
   struct ast_channel *c = NULL;
   const char *name = astman_get_header(m, "Channel");
   if (ast_strlen_zero(name)) {
      astman_send_error(s, m, "No channel specified");
      return 0;
   }
   c = ast_get_channel_by_name_locked(name);
   if (!c) {
      astman_send_error(s, m, "No such channel");
      return 0;
   }
   ast_softhangup(c, AST_SOFTHANGUP_EXPLICIT);
   ast_channel_unlock(c);
   astman_send_ack(s, m, "Channel Hungup");
   return 0;
}

static int action_listcommands	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Note:

The actionlock is read-locked by the caller of this function

Definition at line 1270 of file manager.c.

References manager_action::action, ast_strlen_zero(), astman_append(), astman_get_header(), manager_action::authority, authority_to_str(), first_action, manager_action::next, s, and manager_action::synopsis.

Referenced by init_manager().

{
   struct manager_action *cur;
   char idText[256] = "";
   char temp[BUFSIZ];
   const char *id = astman_get_header(m,"ActionID");

   if (!ast_strlen_zero(id))
      snprintf(idText, sizeof(idText), "ActionID: %s\r\n", id);
   astman_append(s, "Response: Success\r\n%s", idText);
   for (cur = first_action; cur; cur = cur->next) {
      if ((s->writeperm & cur->authority) == cur->authority)
         astman_append(s, "%s: %s (Priv: %s)\r\n", cur->action, cur->synopsis, authority_to_str(cur->authority, temp, sizeof(temp)));
   }
   astman_append(s, "\r\n");

   return 0;
}

static int action_logoff	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1315 of file manager.c.

References astman_send_response(), and s.

Referenced by init_manager().

{
   astman_send_response(s, m, "Goodbye", "Thanks for all the fish.");
   return -1;
}

static int action_mailboxcount	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1838 of file manager.c.

References ast_app_inboxcount(), ast_strlen_zero(), astman_append(), astman_get_header(), astman_send_error(), mailbox, and s.

Referenced by init_manager().

{
   const char *mailbox = astman_get_header(m, "Mailbox");
   const char *id = astman_get_header(m,"ActionID");
   char idText[256] = "";
   int newmsgs = 0, oldmsgs = 0;
   if (ast_strlen_zero(mailbox)) {
      astman_send_error(s, m, "Mailbox not specified");
      return 0;
   }
   ast_app_inboxcount(mailbox, &newmsgs, &oldmsgs);
   if (!ast_strlen_zero(id)) {
      snprintf(idText, sizeof(idText), "ActionID: %s\r\n",id);
   }
   astman_append(s, "Response: Success\r\n"
               "%s"
               "Message: Mailbox Message Count\r\n"
               "Mailbox: %s\r\n"
               "NewMessages: %d\r\n"
               "OldMessages: %d\r\n" 
               "\r\n",
                idText,mailbox, newmsgs, oldmsgs);
   return 0;
}

static int action_mailboxstatus	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1806 of file manager.c.

References ast_app_has_voicemail(), ast_strlen_zero(), astman_append(), astman_get_header(), astman_send_error(), mailbox, and s.

Referenced by init_manager().

{
   const char *mailbox = astman_get_header(m, "Mailbox");
   const char *id = astman_get_header(m,"ActionID");
   char idText[256] = "";
   int ret;
   if (ast_strlen_zero(mailbox)) {
      astman_send_error(s, m, "Mailbox not specified");
      return 0;
   }
        if (!ast_strlen_zero(id))
                snprintf(idText, sizeof(idText), "ActionID: %s\r\n", id);
   ret = ast_app_has_voicemail(mailbox, NULL);
   astman_append(s, "Response: Success\r\n"
               "%s"
               "Message: Mailbox Status\r\n"
               "Mailbox: %s\r\n"
               "Waiting: %d\r\n\r\n", idText, mailbox, ret);
   return 0;
}

static int action_originate	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1688 of file manager.c.

References app, ast_callerid_parse(), ast_calloc, ast_findlabel_extension(), AST_FORMAT_SLINEAR, ast_pbx_outgoing_app(), ast_pbx_outgoing_exten(), ast_pthread_create, ast_shrink_phone_number(), ast_strlen_zero(), ast_true(), astman_get_header(), astman_get_variables(), astman_send_ack(), astman_send_error(), context, exten, fast_originate(), name, ast_channel::priority, s, timeout, and fast_originate_helper::vars.

Referenced by init_manager().

{
   const char *name = astman_get_header(m, "Channel");
   const char *exten = astman_get_header(m, "Exten");
   const char *context = astman_get_header(m, "Context");
   const char *priority = astman_get_header(m, "Priority");
   const char *timeout = astman_get_header(m, "Timeout");
   const char *callerid = astman_get_header(m, "CallerID");
   const char *account = astman_get_header(m, "Account");
   const char *app = astman_get_header(m, "Application");
   const char *appdata = astman_get_header(m, "Data");
   const char *async = astman_get_header(m, "Async");
   const char *id = astman_get_header(m, "ActionID");
   struct ast_variable *vars = astman_get_variables(m);
   char *tech, *data;
   char *l = NULL, *n = NULL;
   int pi = 0;
   int res;
   int to = 30000;
   int reason = 0;
   char tmp[256];
   char tmp2[256];
   
   pthread_t th;
   pthread_attr_t attr;
   if (!name) {
      astman_send_error(s, m, "Channel not specified");
      return 0;
   }
   if (!ast_strlen_zero(priority) && (sscanf(priority, "%d", &pi) != 1)) {
      if ((pi = ast_findlabel_extension(NULL, context, exten, priority, NULL)) < 1) {
         astman_send_error(s, m, "Invalid priority\n");
         return 0;
      }
   }
   if (!ast_strlen_zero(timeout) && (sscanf(timeout, "%d", &to) != 1)) {
      astman_send_error(s, m, "Invalid timeout\n");
      return 0;
   }
   ast_copy_string(tmp, name, sizeof(tmp));
   tech = tmp;
   data = strchr(tmp, '/');
   if (!data) {
      astman_send_error(s, m, "Invalid channel\n");
      return 0;
   }
   *data++ = '\0';
   ast_copy_string(tmp2, callerid, sizeof(tmp2));
   ast_callerid_parse(tmp2, &n, &l);
   if (n) {
      if (ast_strlen_zero(n))
         n = NULL;
   }
   if (l) {
      ast_shrink_phone_number(l);
      if (ast_strlen_zero(l))
         l = NULL;
   }
   if (ast_true(async)) {
      struct fast_originate_helper *fast = ast_calloc(1, sizeof(*fast));
      if (!fast) {
         res = -1;
      } else {
         if (!ast_strlen_zero(id))
            snprintf(fast->idtext, sizeof(fast->idtext), "ActionID: %s\r\n", id);
         ast_copy_string(fast->tech, tech, sizeof(fast->tech));
            ast_copy_string(fast->data, data, sizeof(fast->data));
         ast_copy_string(fast->app, app, sizeof(fast->app));
         ast_copy_string(fast->appdata, appdata, sizeof(fast->appdata));
         if (l)
            ast_copy_string(fast->cid_num, l, sizeof(fast->cid_num));
         if (n)
            ast_copy_string(fast->cid_name, n, sizeof(fast->cid_name));
         fast->vars = vars;   
         ast_copy_string(fast->context, context, sizeof(fast->context));
         ast_copy_string(fast->exten, exten, sizeof(fast->exten));
         ast_copy_string(fast->account, account, sizeof(fast->account));
         fast->timeout = to;
         fast->priority = pi;
         pthread_attr_init(&attr);
         pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
         if (ast_pthread_create(&th, &attr, fast_originate, fast)) {
            res = -1;
         } else {
            res = 0;
         }
         pthread_attr_destroy(&attr);
      }
   } else if (!ast_strlen_zero(app)) {
         res = ast_pbx_outgoing_app(tech, AST_FORMAT_SLINEAR, data, to, app, appdata, &reason, 1, l, n, vars, account, NULL);
      } else {
      if (exten && context && pi)
            res = ast_pbx_outgoing_exten(tech, AST_FORMAT_SLINEAR, data, to, context, exten, pi, &reason, 1, l, n, vars, account, NULL);
      else {
         astman_send_error(s, m, "Originate with 'Exten' requires 'Context' and 'Priority'");
         return 0;
      }
   }   
   if (!res)
      astman_send_ack(s, m, "Originate successfully queued");
   else
      astman_send_error(s, m, "Originate failed");
   return 0;
}

static int action_ping	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1014 of file manager.c.

References astman_send_response(), and s.

Referenced by init_manager().

{
   astman_send_response(s, m, "Pong", NULL);
   return 0;
}

static int action_redirect	(	struct mansession *	s,
		const struct message *	m
	)			[static]

action_redirect: The redirect manager command

Definition at line 1540 of file manager.c.

References ast_async_goto(), ast_channel_unlock, ast_check_hangup(), ast_findlabel_extension(), ast_get_channel_by_name_locked(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), context, exten, name, and s.

Referenced by init_manager().

{
   const char *name = astman_get_header(m, "Channel");
   const char *name2 = astman_get_header(m, "ExtraChannel");
   const char *exten = astman_get_header(m, "Exten");
   const char *context = astman_get_header(m, "Context");
   const char *priority = astman_get_header(m, "Priority");
   struct ast_channel *chan, *chan2 = NULL;
   int pi = 0;
   int res;

   if (ast_strlen_zero(name)) {
      astman_send_error(s, m, "Channel not specified");
      return 0;
   }
   if (!ast_strlen_zero(priority) && (sscanf(priority, "%d", &pi) != 1)) {
      if ((pi = ast_findlabel_extension(NULL, context, exten, priority, NULL)) < 1) {
         astman_send_error(s, m, "Invalid priority\n");
         return 0;
      }
   }
   /* XXX watch out, possible deadlock!!! */
   chan = ast_get_channel_by_name_locked(name);
   if (!chan) {
      char buf[BUFSIZ];
      snprintf(buf, sizeof(buf), "Channel does not exist: %s", name);
      astman_send_error(s, m, buf);
      return 0;
   }
   if (ast_check_hangup(chan)) {
      astman_send_error(s, m, "Redirect failed, channel not up.\n");
      ast_channel_unlock(chan);
      return 0;
   }
   if (!ast_strlen_zero(name2))
      chan2 = ast_get_channel_by_name_locked(name2);
   if (chan2 && ast_check_hangup(chan2)) {
      astman_send_error(s, m, "Redirect failed, extra channel not up.\n");
      ast_channel_unlock(chan);
      ast_channel_unlock(chan2);
      return 0;
   }
   res = ast_async_goto(chan, context, exten, pi);
   if (!res) {
      if (!ast_strlen_zero(name2)) {
         if (chan2)
            res = ast_async_goto(chan2, context, exten, pi);
         else
            res = -1;
         if (!res)
            astman_send_ack(s, m, "Dual Redirect successful");
         else
            astman_send_error(s, m, "Secondary redirect failed");
      } else
         astman_send_ack(s, m, "Redirect successful");
   } else
      astman_send_error(s, m, "Redirect failed");
   if (chan)
      ast_channel_unlock(chan);
   if (chan2)
      ast_channel_unlock(chan2);
   return 0;
}

static int action_setvar	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1352 of file manager.c.

References ast_channel_unlock, ast_get_channel_by_name_locked(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), name, pbx_builtin_setvar_helper(), and s.

Referenced by init_manager().

{
        struct ast_channel *c = NULL;
   const char *name = astman_get_header(m, "Channel");
   const char *varname = astman_get_header(m, "Variable");
   const char *varval = astman_get_header(m, "Value");
   
   if (ast_strlen_zero(varname)) {
      astman_send_error(s, m, "No variable specified");
      return 0;
   }
   
   if (ast_strlen_zero(varval)) {
      astman_send_error(s, m, "No value specified");
      return 0;
   }

   if (!ast_strlen_zero(name)) {
      c = ast_get_channel_by_name_locked(name);
      if (!c) {
         astman_send_error(s, m, "No such channel");
         return 0;
      }
   }
   
   pbx_builtin_setvar_helper(c, varname, varval);
     
   if (c)
      ast_channel_unlock(c);

   astman_send_ack(s, m, "Variable Set"); 

   return 0;
}

static int action_status	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Manager "status" command to show channels.

Definition at line 1439 of file manager.c.

References ast_channel::_bridge, ast_channel::_state, ast_channel_unlock, ast_channel_walk_locked(), ast_get_channel_by_name_locked(), ast_state2str(), ast_strlen_zero(), astman_append(), astman_get_header(), astman_send_ack(), astman_send_error(), ast_channel::cdr, ast_channel::cid, ast_callerid::cid_name, ast_callerid::cid_num, ast_channel::context, ast_channel::exten, name, ast_channel::pbx, ast_channel::priority, s, S_OR, and ast_cdr::start.

Referenced by init_manager().

{
   const char *id = astman_get_header(m,"ActionID");
      const char *name = astman_get_header(m,"Channel");
   char idText[256] = "";
   struct ast_channel *c;
   char bridge[256];
   struct timeval now = ast_tvnow();
   long elapsed_seconds = 0;
   int all = ast_strlen_zero(name); /* set if we want all channels */

   if (!ast_strlen_zero(id))
      snprintf(idText, sizeof(idText), "ActionID: %s\r\n", id);
   if (all)
      c = ast_channel_walk_locked(NULL);
   else {
      c = ast_get_channel_by_name_locked(name);
      if (!c) {
         astman_send_error(s, m, "No such channel");
         return 0;
      }
   }
   astman_send_ack(s, m, "Channel status will follow");
   /* if we look by name, we break after the first iteration */
   while (c) {
      if (c->_bridge)
         snprintf(bridge, sizeof(bridge), "Link: %s\r\n", c->_bridge->name);
      else
         bridge[0] = '\0';
      if (c->pbx) {
         if (c->cdr) {
            elapsed_seconds = now.tv_sec - c->cdr->start.tv_sec;
         }
         astman_append(s,
         "Event: Status\r\n"
         "Privilege: Call\r\n"
         "Channel: %s\r\n"
         "CallerID: %s\r\n"      /* This parameter is deprecated and will be removed post-1.4 */
         "CallerIDNum: %s\r\n"
         "CallerIDName: %s\r\n"
         "Account: %s\r\n"
         "State: %s\r\n"
         "Context: %s\r\n"
         "Extension: %s\r\n"
         "Priority: %d\r\n"
         "Seconds: %ld\r\n"
         "%s"
         "Uniqueid: %s\r\n"
         "%s"
         "\r\n",
         c->name, 
         S_OR(c->cid.cid_num, "<unknown>"), 
         S_OR(c->cid.cid_num, "<unknown>"), 
         S_OR(c->cid.cid_name, "<unknown>"), 
         c->accountcode,
         ast_state2str(c->_state), c->context,
         c->exten, c->priority, (long)elapsed_seconds, bridge, c->uniqueid, idText);
      } else {
         astman_append(s,
         "Event: Status\r\n"
         "Privilege: Call\r\n"
         "Channel: %s\r\n"
         "CallerID: %s\r\n"      /* This parameter is deprecated and will be removed post-1.4 */
         "CallerIDNum: %s\r\n"
         "CallerIDName: %s\r\n"
         "Account: %s\r\n"
         "State: %s\r\n"
         "%s"
         "Uniqueid: %s\r\n"
         "%s"
         "\r\n",
         c->name, 
         S_OR(c->cid.cid_num, "<unknown>"), 
         S_OR(c->cid.cid_num, "<unknown>"), 
         S_OR(c->cid.cid_name, "<unknown>"), 
         c->accountcode,
         ast_state2str(c->_state), bridge, c->uniqueid, idText);
      }
      ast_channel_unlock(c);
      if (!all)
         break;
      c = ast_channel_walk_locked(c);
   }
   astman_append(s,
   "Event: StatusComplete\r\n"
   "%s"
   "\r\n",idText);
   return 0;
}

static int action_timeout	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1911 of file manager.c.

References ast_channel_setwhentohangup(), ast_channel_unlock, ast_get_channel_by_name_locked(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), name, s, and timeout.

Referenced by init_manager().

{
   struct ast_channel *c = NULL;
   const char *name = astman_get_header(m, "Channel");
   int timeout = atoi(astman_get_header(m, "Timeout"));
   if (ast_strlen_zero(name)) {
      astman_send_error(s, m, "No channel specified");
      return 0;
   }
   if (!timeout) {
      astman_send_error(s, m, "No timeout specified");
      return 0;
   }
   c = ast_get_channel_by_name_locked(name);
   if (!c) {
      astman_send_error(s, m, "No such channel");
      return 0;
   }
   ast_channel_setwhentohangup(c, timeout);
   ast_channel_unlock(c);
   astman_send_ack(s, m, "Timeout Set");
   return 0;
}

static int action_updateconfig	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1137 of file manager.c.

References ast_config_destroy(), ast_config_load_with_comments(), ast_module_reload(), ast_strlen_zero(), ast_true(), astman_append(), astman_get_header(), astman_send_error(), config_text_file_save(), handle_updates(), and s.

Referenced by init_manager().

{
   struct ast_config *cfg;
   const char *sfn = astman_get_header(m, "SrcFilename");
   const char *dfn = astman_get_header(m, "DstFilename");
   int res;
   char idText[256] = "";
   const char *id = astman_get_header(m, "ActionID");
   const char *rld = astman_get_header(m, "Reload");

   if (!ast_strlen_zero(id))
      snprintf(idText, sizeof(idText), "ActionID: %s\r\n", id);

   if (ast_strlen_zero(sfn) || ast_strlen_zero(dfn)) {
      astman_send_error(s, m, "Filename not specified");
      return 0;
   }
   if (!(cfg = ast_config_load_with_comments(sfn))) {
      astman_send_error(s, m, "Config file not found");
      return 0;
   }
   handle_updates(s, m, cfg);
   res = config_text_file_save(dfn, cfg, "Manager");
   ast_config_destroy(cfg);
   if (res) {
      astman_send_error(s, m, "Save of config failed");
      return 0;
   }
   astman_append(s, "Response: Success\r\n%s\r\n", idText);
   if (!ast_strlen_zero(rld)) {
      if (ast_true(rld))
         rld = NULL;
      ast_module_reload(rld); 
   }
   return 0;
}

static int action_userevent	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1965 of file manager.c.

References astman_get_header(), event, EVENT_FLAG_USER, message::hdrcount, message::headers, and manager_event().

Referenced by init_manager().

{
   const char *event = astman_get_header(m, "UserEvent");
   char body[2048] = "";
   int x, bodylen = 0;
   for (x = 0; x < m->hdrcount; x++) {
      if (strncasecmp("UserEvent:", m->headers[x], strlen("UserEvent:"))) {
         ast_copy_string(body + bodylen, m->headers[x], sizeof(body) - bodylen - 3);
         bodylen += strlen(m->headers[x]);
         ast_copy_string(body + bodylen, "\r\n", 3);
         bodylen += 2;
      }
   }

   manager_event(EVENT_FLAG_USER, "UserEvent", "UserEvent: %s\r\n%s", event, body);
   return 0;
}

static int action_waitevent	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1182 of file manager.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), AST_PTHREADT_NULL, ast_strlen_zero(), ast_wait_for_input(), astman_append(), astman_get_header(), astman_send_response(), eventqent::category, eventqent::eventdata, LOG_DEBUG, option_debug, s, timeout, and unuse_eventqent().

Referenced by init_manager().

{
   const char *timeouts = astman_get_header(m, "Timeout");
   int timeout = -1, max;
   int x;
   int needexit = 0;
   time_t now;
   struct eventqent *eqe;
   const char *id = astman_get_header(m,"ActionID");
   char idText[256] = "";

   if (!ast_strlen_zero(id))
      snprintf(idText, sizeof(idText), "ActionID: %s\r\n", id);

   if (!ast_strlen_zero(timeouts)) {
      sscanf(timeouts, "%i", &timeout);
   }
   
   ast_mutex_lock(&s->__lock);
   if (s->waiting_thread != AST_PTHREADT_NULL) {
      pthread_kill(s->waiting_thread, SIGURG);
   }
   if (s->sessiontimeout) {
      time(&now);
      max = s->sessiontimeout - now - 10;
      if (max < 0)
         max = 0;
      if ((timeout < 0) || (timeout > max))
         timeout = max;
      if (!s->send_events)
         s->send_events = -1;
      /* Once waitevent is called, always queue events from now on */
   }
   ast_mutex_unlock(&s->__lock);
   s->waiting_thread = pthread_self();
   if (option_debug)
      ast_log(LOG_DEBUG, "Starting waiting for an event!\n");
   for (x=0; ((x < timeout) || (timeout < 0)); x++) {
      ast_mutex_lock(&s->__lock);
      if (s->eventq && s->eventq->next)
         needexit = 1;
      if (s->waiting_thread != pthread_self())
         needexit = 1;
      if (s->needdestroy)
         needexit = 1;
      ast_mutex_unlock(&s->__lock);
      if (needexit)
         break;
      if (s->fd > 0) {
         if (ast_wait_for_input(s->fd, 1000))
            break;
      } else {
         sleep(1);
      }
   }
   if (option_debug)
      ast_log(LOG_DEBUG, "Finished waiting for an event!\n");
   ast_mutex_lock(&s->__lock);
   if (s->waiting_thread == pthread_self()) {
      astman_send_response(s, m, "Success", "Waiting for Event...");
      /* Only show events if we're the most recent waiter */
      while(s->eventq->next) {
         eqe = s->eventq->next;
         if (((s->readperm & eqe->category) == eqe->category) &&
             ((s->send_events & eqe->category) == eqe->category)) {
            astman_append(s, "%s", eqe->eventdata);
         }
         unuse_eventqent(s->eventq);
         s->eventq = eqe;
      }
      astman_append(s,
         "Event: WaitEventComplete\r\n"
         "%s"
         "\r\n", idText);
      s->waiting_thread = AST_PTHREADT_NULL;
   } else {
      ast_log(LOG_DEBUG, "Abandoning event request!\n");
   }
   ast_mutex_unlock(&s->__lock);
   return 0;
}

static int append_event	(	const char *	str,
		int	category
	)			[static]

Definition at line 2274 of file manager.c.

References ast_malloc, master_eventq, eventqent::next, num_sessions, and eventqent::usecount.

Referenced by init_manager(), and manager_event().

{
   struct eventqent *tmp, *prev = NULL;
   tmp = ast_malloc(sizeof(*tmp) + strlen(str));

   if (!tmp)
      return -1;

   tmp->next = NULL;
   tmp->category = category;
   strcpy(tmp->eventdata, str);
   
   if (master_eventq) {
      prev = master_eventq;
      while (prev->next) 
         prev = prev->next;
      prev->next = tmp;
   } else {
      master_eventq = tmp;
   }
   
   tmp->usecount = num_sessions;
   
   return 0;
}

static struct ast_manager_user* ast_get_manager_by_name_locked

(

const char *

name

)

[static]

Definition at line 395 of file manager.c.

References AST_LIST_TRAVERSE, and ast_manager_user::username.

Referenced by handle_showmanager(), and init_manager().

{
   struct ast_manager_user *user = NULL;

   AST_LIST_TRAVERSE(&users, user, list)
      if (!strcasecmp(user->username, name))
         break;
   return user;
}

static int ast_instring	(	const char *	bigstr,
		const char *	smallstr,
		char	delim
	)			[static]

Tells you if smallstr exists inside bigstr which is delim by delim and uses no buf or stringsep ast_instring("this|that|more","this",',') == 1;

feel free to move this to app.c -anthm

Definition at line 782 of file manager.c.

References ast_variable::next.

Referenced by get_perm(), and strings_to_mask().

{
   const char *val = bigstr, *next;

   do {
      if ((next = strchr(val, delim))) {
         if (!strncmp(val, smallstr, (next - val)))
            return 1;
         else
            continue;
      } else
         return !strcmp(smallstr, val);

   } while (*(val = (next + 1)));

   return 0;
}

static int ast_is_number

(

char *

string

)

[static]

Definition at line 815 of file manager.c.

Referenced by strings_to_mask().

{
   int ret = 1, x = 0;

   if (!string)
      return 0;

   for (x = 0; x < strlen(string); x++) {
      if (!(string[x] >= 48 && string[x] <= 57)) {
         ret = 0;
         break;
      }
   }
   
   return ret ? atoi(string) : 0;
}

static AST_LIST_HEAD_STATIC	(	users	,
		ast_manager_user
	)			[static]

static AST_LIST_HEAD_STATIC	(	sessions	,
		mansession
	)			[static]

int ast_manager_register2	(	const char *	action,
		int	authority,
		int(*)(struct mansession *s, const struct message *m)	func,
		const char *	synopsis,
		const char *	description
	)

register a new command with manager, including online help. This is the preferred way to register a manager command

Parameters:

	action	Name of the requested Action:
	authority	Required authority for this command
	func	Function to call for this command
	synopsis	Help text (one line, up to 30 chars) for CLI manager show commands
	description	Help text, several lines

Definition at line 2420 of file manager.c.

References ast_malloc, and ast_manager_register_struct().

Referenced by init_manager(), and load_module().

{
   struct manager_action *cur;

   cur = ast_malloc(sizeof(*cur));
   if (!cur)
      return -1;
   
   cur->action = action;
   cur->authority = auth;
   cur->func = func;
   cur->synopsis = synopsis;
   cur->description = description;
   cur->next = NULL;

   ast_manager_register_struct(cur);

   return 0;
}

static int ast_manager_register_struct

(

struct manager_action *

act

)

[static]

Definition at line 2376 of file manager.c.

References manager_action::action, ast_log(), ast_rwlock_unlock(), ast_rwlock_wrlock(), ast_verbose(), first_action, LOG_WARNING, manager_action::next, option_verbose, and VERBOSE_PREFIX_2.

Referenced by ast_manager_register2().

{
   struct manager_action *cur, *prev = NULL;
   int ret;

   ast_rwlock_wrlock(&actionlock);
   cur = first_action;
   while (cur) { /* Walk the list of actions */
      ret = strcasecmp(cur->action, act->action);
      if (ret == 0) {
         ast_log(LOG_WARNING, "Manager: Action '%s' already registered\n", act->action);
         ast_rwlock_unlock(&actionlock);
         return -1;
      } else if (ret > 0) {
         /* Insert these alphabetically */
         if (prev) {
            act->next = prev->next;
            prev->next = act;
         } else {
            act->next = first_action;
            first_action = act;
         }
         break;
      }
      prev = cur; 
      cur = cur->next;
   }
   
   if (!cur) {
      if (prev)
         prev->next = act;
      else
         first_action = act;
      act->next = NULL;
   }

   if (option_verbose > 1) 
      ast_verbose(VERBOSE_PREFIX_2 "Manager registered action %s\n", act->action);
   ast_rwlock_unlock(&actionlock);
   return 0;
}

int ast_manager_unregister

(

char *

action

)

Parameters:

action

Name of registred Action:

Definition at line 2347 of file manager.c.

References manager_action::action, ast_rwlock_unlock(), ast_rwlock_wrlock(), ast_verbose(), first_action, free, manager_action::next, option_verbose, and VERBOSE_PREFIX_2.

Referenced by __unload_module(), and unload_module().

{
   struct manager_action *cur, *prev;

   ast_rwlock_wrlock(&actionlock);
   cur = prev = first_action;
   while (cur) {
      if (!strcasecmp(action, cur->action)) {
         prev->next = cur->next;
         free(cur);
         if (option_verbose > 1) 
            ast_verbose(VERBOSE_PREFIX_2 "Manager unregistered action %s\n", action);
         ast_rwlock_unlock(&actionlock);
         return 0;
      }
      prev = cur;
      cur = cur->next;
   }
   ast_rwlock_unlock(&actionlock);
   return 0;
}

AST_RWLOCK_DEFINE_STATIC

(

actionlock

)

AST_THREADSTORAGE	(	astman_append_buf	,
		astman_append_buf_init
	)

AST_THREADSTORAGE	(	manager_event_buf	,
		manager_event_buf_init
	)

void astman_append	(	struct mansession *	s,
		const char *	fmt,
			...
	)

Definition at line 405 of file manager.c.

References ast_calloc, ast_carefulwrite(), ast_dynamic_str_thread_set_va, ast_mutex_lock(), ast_mutex_unlock(), ASTMAN_APPEND_BUF_INITSIZE, and s.

Referenced by __iax2_show_peers(), __queues_show(), _sip_show_peer(), _sip_show_peers(), action_agents(), action_command(), action_extensionstate(), action_getconfig(), action_getvar(), action_listcommands(), action_mailboxcount(), action_mailboxstatus(), action_status(), action_updateconfig(), action_waitevent(), action_zapshowchannels(), ast_cli_netstats(), astman_send_error(), astman_send_response(), manager_dbget(), manager_iax2_show_netstats(), manager_iax2_show_peers(), manager_jabber_send(), manager_parking_status(), manager_queues_show(), manager_queues_status(), manager_sip_show_peer(), manager_sip_show_peers(), process_message(), and session_do().

{
   va_list ap;
   struct ast_dynamic_str *buf;

   ast_mutex_lock(&s->__lock);

   if (!(buf = ast_dynamic_str_thread_get(&astman_append_buf, ASTMAN_APPEND_BUF_INITSIZE))) {
      ast_mutex_unlock(&s->__lock);
      return;
   }

   va_start(ap, fmt);
   ast_dynamic_str_thread_set_va(&buf, 0, &astman_append_buf, fmt, ap);
   va_end(ap);
   
   if (s->fd > -1)
      ast_carefulwrite(s->fd, buf->str, strlen(buf->str), s->writetimeout);
   else {
      if (!s->outputstr && !(s->outputstr = ast_calloc(1, sizeof(*s->outputstr)))) {
         ast_mutex_unlock(&s->__lock);
         return;
      }

      ast_dynamic_str_append(&s->outputstr, 0, "%s", buf->str);   
   }

   ast_mutex_unlock(&s->__lock);
}

const char* astman_get_header	(	const struct message *	m,
		char *	var
	)

Get header from mananger transaction

Definition at line 685 of file manager.c.

References message::hdrcount, and message::headers.

Referenced by _sip_show_peer(), _sip_show_peers(), action_agent_callback_login(), action_agent_logoff(), action_agents(), action_command(), action_events(), action_extensionstate(), action_getconfig(), action_getvar(), action_hangup(), action_listcommands(), action_mailboxcount(), action_mailboxstatus(), action_originate(), action_redirect(), action_setcdruserfield(), action_setvar(), action_status(), action_timeout(), action_transfer(), action_transferhangup(), action_updateconfig(), action_userevent(), action_waitevent(), action_zapdialoffhook(), action_zapdndoff(), action_zapdndon(), action_zapshowchannels(), astman_send_error(), astman_send_response(), authenticate(), change_monitor_action(), do_pause_or_unpause(), handle_updates(), manager_add_queue_member(), manager_dbget(), manager_dbput(), manager_iax2_show_peers(), manager_jabber_send(), manager_park(), manager_parking_status(), manager_pause_queue_member(), manager_play_dtmf(), manager_queues_status(), manager_remove_queue_member(), manager_sip_show_peer(), manager_sip_show_peers(), meetmemute(), process_message(), start_monitor_action(), and stop_monitor_action().

{
   char cmp[80];
   int x;

   snprintf(cmp, sizeof(cmp), "%s: ", var);

   for (x = 0; x < m->hdrcount; x++) {
      if (!strncasecmp(cmp, m->headers[x], strlen(cmp)))
         return m->headers[x] + strlen(cmp);
   }

   return "";
}

struct ast_variable* astman_get_variables

(

const struct message *

m

)

Get a linked list of the Variable: headers

Definition at line 700 of file manager.c.

References AST_APP_ARG, AST_DECLARE_APP_ARGS, AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), ast_variable_new(), message::hdrcount, message::headers, parse(), strsep(), and var.

Referenced by action_originate().

{
   int varlen, x, y;
   struct ast_variable *head = NULL, *cur;
   char *var, *val;

   char *parse;    
   AST_DECLARE_APP_ARGS(args,
      AST_APP_ARG(vars)[32];
   );

   varlen = strlen("Variable: ");   

   for (x = 0; x < m->hdrcount; x++) {
      if (strncasecmp("Variable: ", m->headers[x], varlen))
         continue;

      parse = ast_strdupa(m->headers[x] + varlen);

      AST_STANDARD_APP_ARGS(args, parse);
      if (args.argc) {
         for (y = 0; y < args.argc; y++) {
            if (!args.vars[y])
               continue;
            var = val = ast_strdupa(args.vars[y]);
            strsep(&val, "=");
            if (!val || ast_strlen_zero(var))
               continue;
            cur = ast_variable_new(var, val);
            if (head) {
               cur->next = head;
               head = cur;
            } else
               head = cur;
         }
      }
   }

   return head;
}

void astman_send_ack	(	struct mansession *	s,
		const struct message *	m,
		char *	msg
	)

Definition at line 772 of file manager.c.

References astman_send_response(), and s.

Referenced by action_agent_callback_login(), action_agent_logoff(), action_agents(), action_hangup(), action_originate(), action_redirect(), action_setcdruserfield(), action_setvar(), action_status(), action_timeout(), action_transfer(), action_transferhangup(), action_zapdialoffhook(), action_zapdndoff(), action_zapdndon(), action_zaprestart(), action_zapshowchannels(), change_monitor_action(), do_pause_or_unpause(), manager_add_queue_member(), manager_dbget(), manager_dbput(), manager_jabber_send(), manager_park(), manager_parking_status(), manager_pause_queue_member(), manager_play_dtmf(), manager_queues_status(), manager_remove_queue_member(), manager_sip_show_peers(), meetmemute(), process_message(), start_monitor_action(), and stop_monitor_action().

{
   astman_send_response(s, m, "Success", msg);
}

void astman_send_error	(	struct mansession *	s,
		const struct message *	m,
		char *	error
	)

Note:

NOTE: Callers of astman_send_error(), astman_send_response() or astman_send_ack() must EITHER hold the session lock _or_ be running in an action callback (in which case s->busy will be non-zero). In either of these cases, there is no need to lock-protect the session's fd, since no other output will be sent (events will be queued), and no input will be read until either the current action finishes or get_input() obtains the session lock.

Definition at line 749 of file manager.c.

References ast_strlen_zero(), astman_append(), astman_get_header(), and s.

Referenced by _sip_show_peer(), action_agent_callback_login(), action_agent_logoff(), action_extensionstate(), action_getconfig(), action_getvar(), action_hangup(), action_mailboxcount(), action_mailboxstatus(), action_originate(), action_redirect(), action_setcdruserfield(), action_setvar(), action_status(), action_timeout(), action_transfer(), action_transferhangup(), action_updateconfig(), action_zapdialoffhook(), action_zapdndoff(), action_zapdndon(), action_zaprestart(), change_monitor_action(), do_pause_or_unpause(), manager_add_queue_member(), manager_dbget(), manager_dbput(), manager_jabber_send(), manager_park(), manager_pause_queue_member(), manager_play_dtmf(), manager_remove_queue_member(), manager_sip_show_peer(), meetmemute(), process_message(), start_monitor_action(), and stop_monitor_action().

{
   const char *id = astman_get_header(m,"ActionID");

   astman_append(s, "Response: Error\r\n");
   if (!ast_strlen_zero(id))
      astman_append(s, "ActionID: %s\r\n", id);
   astman_append(s, "Message: %s\r\n\r\n", error);
}

void astman_send_response	(	struct mansession *	s,
		const struct message *	m,
		char *	resp,
		char *	msg
	)

Definition at line 759 of file manager.c.

References ast_strlen_zero(), astman_append(), astman_get_header(), and s.

Referenced by action_events(), action_logoff(), action_ping(), action_waitevent(), and astman_send_ack().

{
   const char *id = astman_get_header(m,"ActionID");

   astman_append(s, "Response: %s\r\n", resp);
   if (!ast_strlen_zero(id))
      astman_append(s, "ActionID: %s\r\n", id);
   if (msg)
      astman_append(s, "Message: %s\r\n\r\n", msg);
   else
      astman_append(s, "\r\n");
}

static int authenticate	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 875 of file manager.c.

References ast_append_ha(), ast_apply_ha(), ast_category_browse(), ast_config_AST_SYSTEM_NAME, ast_config_destroy(), ast_config_load(), ast_free_ha(), ast_inet_ntoa(), ast_log(), ast_strlen_zero(), ast_true(), ast_variable_browse(), astman_get_header(), events, key(), len, LOG_ERROR, LOG_NOTICE, LOG_WARNING, md5(), MD5Final(), MD5Init(), MD5Update(), ast_variable::name, ast_variable::next, password, s, and ast_variable::value.

Referenced by authenticate_reply(), handle_response_invite(), process_message(), and registry_rerequest().

{
   struct ast_config *cfg;
   char *cat;
   const char *user = astman_get_header(m, "Username");
   const char *pass = astman_get_header(m, "Secret");
   const char *authtype = astman_get_header(m, "AuthType");
   const char *key = astman_get_header(m, "Key");
   const char *events = astman_get_header(m, "Events");
   
   cfg = ast_config_load("manager.conf");
   if (!cfg)
      return -1;
   cat = ast_category_browse(cfg, NULL);
   while (cat) {
      if (strcasecmp(cat, "general")) {
         /* This is a user */
         if (!strcasecmp(cat, user)) {
            struct ast_variable *v;
            struct ast_ha *ha = NULL;
            char *password = NULL;

            for (v = ast_variable_browse(cfg, cat); v; v = v->next) {
               if (!strcasecmp(v->name, "secret")) {
                  password = v->value;
               } else if (!strcasecmp(v->name, "displaysystemname")) {
                  if (ast_true(v->value)) {
                     if (ast_strlen_zero(ast_config_AST_SYSTEM_NAME)) {
                        s->displaysystemname = 1;
                     } else {
                        ast_log(LOG_ERROR, "Can't enable displaysystemname in manager.conf - no system name configured in asterisk.conf\n");
                     }
                  }
               } else if (!strcasecmp(v->name, "permit") ||
                     !strcasecmp(v->name, "deny")) {
                  ha = ast_append_ha(v->name, v->value, ha);
               } else if (!strcasecmp(v->name, "writetimeout")) {
                  int val = atoi(v->value);

                  if (val < 100)
                     ast_log(LOG_WARNING, "Invalid writetimeout value '%s' at line %d\n", v->value, v->lineno);
                  else
                     s->writetimeout = val;
               }
                     
            }
            if (ha && !ast_apply_ha(ha, &(s->sin))) {
               ast_log(LOG_NOTICE, "%s failed to pass IP ACL as '%s'\n", ast_inet_ntoa(s->sin.sin_addr), user);
               ast_free_ha(ha);
               ast_config_destroy(cfg);
               return -1;
            } else if (ha)
               ast_free_ha(ha);
            if (!strcasecmp(authtype, "MD5")) {
               if (!ast_strlen_zero(key) && 
                   !ast_strlen_zero(s->challenge) && !ast_strlen_zero(password)) {
                  int x;
                  int len = 0;
                  char md5key[256] = "";
                  struct MD5Context md5;
                  unsigned char digest[16];
                  MD5Init(&md5);
                  MD5Update(&md5, (unsigned char *) s->challenge, strlen(s->challenge));
                  MD5Update(&md5, (unsigned char *) password, strlen(password));
                  MD5Final(digest, &md5);
                  for (x=0; x<16; x++)
                     len += sprintf(md5key + len, "%2.2x", digest[x]);
                  if (!strcmp(md5key, key))
                     break;
                  else {
                     ast_config_destroy(cfg);
                     return -1;
                  }
               }
            } else if (password && !strcmp(password, pass)) {
               break;
            } else {
               ast_log(LOG_NOTICE, "%s failed to authenticate as '%s'\n", ast_inet_ntoa(s->sin.sin_addr), user);
               ast_config_destroy(cfg);
               return -1;
            }  
         }
      }
      cat = ast_category_browse(cfg, cat);
   }
   if (cat) {
      ast_copy_string(s->username, cat, sizeof(s->username));
      s->readperm = get_perm(ast_variable_retrieve(cfg, cat, "read"));
      s->writeperm = get_perm(ast_variable_retrieve(cfg, cat, "write"));
      ast_config_destroy(cfg);
      if (events)
         set_eventmask(s, events);
      return 0;
   }
   ast_config_destroy(cfg);
   cfg = ast_config_load("users.conf");
   if (!cfg)
      return -1;
   cat = ast_category_browse(cfg, NULL);
   while (cat) {
      struct ast_variable *v;
      const char *password = NULL;
      int hasmanager = 0;
      if (strcasecmp(cat, user) || !strcasecmp(cat, "general")) {
         cat = ast_category_browse(cfg, cat);
         continue;
      }
      for (v = ast_variable_browse(cfg, cat); v; v = v->next) {
         if (!strcasecmp(v->name, "secret"))
            password = v->value;
         else if (!strcasecmp(v->name, "hasmanager"))
            hasmanager = ast_true(v->value);
      }
      if (!hasmanager)
         break;
      if (!password || strcmp(password, pass)) {
         ast_log(LOG_NOTICE, "%s failed to authenticate as '%s'\n", ast_inet_ntoa(s->sin.sin_addr), user);
         ast_config_destroy(cfg);
         return -1;
      }
      ast_copy_string(s->username, cat, sizeof(s->username));
      s->readperm = -1;
      s->writeperm = -1;
      ast_config_destroy(cfg);
      if (events)
         set_eventmask(s, events);
      return 0;
   }
   ast_log(LOG_NOTICE, "%s tried to authenticate with nonexistent user '%s'\n", ast_inet_ntoa(s->sin.sin_addr), user);
   ast_config_destroy(cfg);
   return -1;
}

static char* authority_to_str	(	int	authority,
		char *	res,
		int	reslen
	)			[static]

Convert authority code to string with serveral options.

Definition at line 194 of file manager.c.

References ast_strlen_zero(), and perms.

Referenced by action_listcommands(), handle_showmancmd(), handle_showmancmds(), and manager_event().

{
   int running_total = 0, i;

   memset(res, 0, reslen);
   for (i = 0; i < (sizeof(perms) / sizeof(perms[0])) - 1; i++) {
      if (authority & perms[i].num) {
         if (*res) {
            strncat(res, ",", (reslen > running_total) ? reslen - running_total : 0);
            running_total++;
         }
         strncat(res, perms[i].label, (reslen > running_total) ? reslen - running_total : 0);
         running_total += strlen(perms[i].label);
      }
   }

   if (ast_strlen_zero(res))
      ast_copy_string(res, "<none>", reslen);
   
   return res;
}

static char* complete_show_mancmd	(	const char *	line,
		const char *	word,
		int	pos,
		int	state
	)			[static]

Definition at line 216 of file manager.c.

References manager_action::action, ast_rwlock_rdlock(), ast_rwlock_unlock(), ast_strdup, first_action, and manager_action::next.

{
   struct manager_action *cur;
   int which = 0;
   char *ret = NULL;

   ast_rwlock_rdlock(&actionlock);
   for (cur = first_action; cur; cur = cur->next) { /* Walk the list of actions */
      if (!strncasecmp(word, cur->action, strlen(word)) && ++which > state) {
         ret = ast_strdup(cur->action);
         break;   /* make sure we exit even if ast_strdup() returns NULL */
      }
   }
   ast_rwlock_unlock(&actionlock);

   return ret;
}

static void destroy_session

(

struct mansession *

s

)

[static]

Definition at line 675 of file manager.c.

References AST_LIST_LOCK, AST_LIST_REMOVE, AST_LIST_UNLOCK, free_session(), s, and sessions.

Referenced by accept_thread(), and skinny_session().

{
   AST_LIST_LOCK(&sessions);
   AST_LIST_REMOVE(&sessions, s, list);
   AST_LIST_UNLOCK(&sessions);

   ast_atomic_fetchadd_int(&num_sessions, -1);
   free_session(s);
}

static int do_message

(

struct mansession *

s

)

[static]

Definition at line 2119 of file manager.c.

References AST_MAX_MANHEADERS, ast_strdupa, ast_strlen_zero(), get_input(), message::hdrcount, message::headers, process_events(), process_message(), and s.

Referenced by session_do().

{
   struct message m = { 0 };
   char header_buf[sizeof(s->inbuf)] = { '\0' };
   int res;

   for (;;) {
      /* Check if any events are pending and do them if needed */
      if (s->eventq->next) {
         if (process_events(s))
            return -1;
      }
      res = get_input(s, header_buf);
      if (res == 0) {
         continue;
      } else if (res > 0) {
         /* Strip trailing \r\n */
         if (strlen(header_buf) < 2)
            continue;
         header_buf[strlen(header_buf) - 2] = '\0';
         if (ast_strlen_zero(header_buf))
            return process_message(s, &m) ? -1 : 0;
         else if (m.hdrcount < (AST_MAX_MANHEADERS - 1))
            m.headers[m.hdrcount++] = ast_strdupa(header_buf);
      } else {
         return res;
      }
   }
}

static void* fast_originate

(

void *

data

)

[static]

Definition at line 1624 of file manager.c.

References fast_originate_helper::account, fast_originate_helper::app, fast_originate_helper::appdata, AST_CHANNEL_NAME, ast_channel_unlock, AST_FORMAT_SLINEAR, ast_pbx_outgoing_app(), ast_pbx_outgoing_exten(), ast_strlen_zero(), fast_originate_helper::cid_name, fast_originate_helper::cid_num, fast_originate_helper::context, fast_originate_helper::data, EVENT_FLAG_CALL, fast_originate_helper::exten, free, fast_originate_helper::idtext, manager_event(), fast_originate_helper::priority, S_OR, fast_originate_helper::tech, fast_originate_helper::timeout, and fast_originate_helper::vars.

Referenced by action_originate().

{
   struct fast_originate_helper *in = data;
   int res;
   int reason = 0;
   struct ast_channel *chan = NULL;
   char requested_channel[AST_CHANNEL_NAME];

   if (!ast_strlen_zero(in->app)) {
      res = ast_pbx_outgoing_app(in->tech, AST_FORMAT_SLINEAR, in->data, in->timeout, in->app, in->appdata, &reason, 1, 
         S_OR(in->cid_num, NULL), 
         S_OR(in->cid_name, NULL),
         in->vars, in->account, &chan);
   } else {
      res = ast_pbx_outgoing_exten(in->tech, AST_FORMAT_SLINEAR, in->data, in->timeout, in->context, in->exten, in->priority, &reason, 1, 
         S_OR(in->cid_num, NULL), 
         S_OR(in->cid_name, NULL),
         in->vars, in->account, &chan);
   }

   if (!chan)
      snprintf(requested_channel, AST_CHANNEL_NAME, "%s/%s", in->tech, in->data);   
   /* Tell the manager what happened with the channel */
   manager_event(EVENT_FLAG_CALL, "OriginateResponse",
      "%s"
      "Response: %s\r\n"
      "Channel: %s\r\n"
      "Context: %s\r\n"
      "Exten: %s\r\n"
      "Reason: %d\r\n"
      "Uniqueid: %s\r\n"
      "CallerID: %s\r\n"      /* This parameter is deprecated and will be removed post-1.4 */
      "CallerIDNum: %s\r\n"
      "CallerIDName: %s\r\n",
      in->idtext, res ? "Failure" : "Success", chan ? chan->name : requested_channel, in->context, in->exten, reason, 
      chan ? chan->uniqueid : "<null>",
      S_OR(in->cid_num, "<unknown>"),
      S_OR(in->cid_num, "<unknown>"),
      S_OR(in->cid_name, "<unknown>")
      );

   /* Locked by ast_pbx_outgoing_exten or ast_pbx_outgoing_app */
   if (chan)
      ast_channel_unlock(chan);
   free(in);
   return NULL;
}

static void free_session

(

struct mansession *

s

)

[static]

Definition at line 659 of file manager.c.

References ast_mutex_destroy(), free, s, and unuse_eventqent().

Referenced by accept_thread(), and destroy_session().

{
   struct eventqent *eqe;
   if (s->fd > -1)
      close(s->fd);
   if (s->outputstr)
      free(s->outputstr);
   ast_mutex_destroy(&s->__lock);
   while (s->eventq) {
      eqe = s->eventq;
      s->eventq = s->eventq->next;
      unuse_eventqent(eqe);
   }
   free(s);
}

static int get_input	(	struct mansession *	s,
		char *	output
	)			[static]

Definition at line 2065 of file manager.c.

References s.

Referenced by do_message(), and skinny_session().

{
   /* output must have at least sizeof(s->inbuf) space */
   int res;
   int x;
   struct pollfd fds[1];
   for (x = 1; x < s->inlen; x++) {
      if ((s->inbuf[x] == '\n') && (s->inbuf[x-1] == '\r')) {
         /* Copy output data up to and including \r\n */
         memcpy(output, s->inbuf, x + 1);
         /* Add trailing \0 */
         output[x+1] = '\0';
         /* Move remaining data back to the front */
         memmove(s->inbuf, s->inbuf + x + 1, s->inlen - x);
         s->inlen -= (x + 1);
         return 1;
      }
   } 
   if (s->inlen >= sizeof(s->inbuf) - 1) {
      ast_log(LOG_WARNING, "Dumping long line with no return from %s: %s\n", ast_inet_ntoa(s->sin.sin_addr), s->inbuf);
      s->inlen = 0;
   }
   fds[0].fd = s->fd;
   fds[0].events = POLLIN;
   do {
      ast_mutex_lock(&s->__lock);
      s->waiting_thread = pthread_self();
      ast_mutex_unlock(&s->__lock);

      res = poll(fds, 1, -1);

      ast_mutex_lock(&s->__lock);
      s->waiting_thread = AST_PTHREADT_NULL;
      ast_mutex_unlock(&s->__lock);
      if (res < 0) {
         if (errno == EINTR) {
            return 0;
         }
         ast_log(LOG_WARNING, "Select returned error: %s\n", strerror(errno));
         return -1;
      } else if (res > 0) {
         ast_mutex_lock(&s->__lock);
         res = read(s->fd, s->inbuf + s->inlen, sizeof(s->inbuf) - 1 - s->inlen);
         ast_mutex_unlock(&s->__lock);
         if (res < 1)
            return -1;
         break;
      }
   } while(1);
   s->inlen += res;
   s->inbuf[s->inlen] = '\0';
   return 0;
}

static int get_perm

(

const char *

instr

)

[static]

Definition at line 800 of file manager.c.

References ast_instring(), and perms.

{
   int x = 0, ret = 0;

   if (!instr)
      return 0;

   for (x = 0; x < (sizeof(perms) / sizeof(perms[0])); x++) {
      if (ast_instring(instr, perms[x].label, ','))
         ret |= perms[x].num;
   }
   
   return ret;
}

static int handle_showmanager	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

Definition at line 456 of file manager.c.

References ast_cli(), ast_get_manager_by_name_locked(), AST_LIST_LOCK, AST_LIST_UNLOCK, ast_manager_user::deny, ast_manager_user::displayconnects, ast_manager_user::permit, ast_manager_user::read, RESULT_SHOWUSAGE, RESULT_SUCCESS, ast_manager_user::secret, ast_manager_user::username, and ast_manager_user::write.

{
   struct ast_manager_user *user = NULL;

   if (argc != 4)
      return RESULT_SHOWUSAGE;

   AST_LIST_LOCK(&users);

   if (!(user = ast_get_manager_by_name_locked(argv[3]))) {
      ast_cli(fd, "There is no manager called %s\n", argv[3]);
      AST_LIST_UNLOCK(&users);
      return -1;
   }

   ast_cli(fd,"\n");
   ast_cli(fd,
      "       username: %s\n"
      "         secret: %s\n"
      "           deny: %s\n"
      "         permit: %s\n"
      "           read: %s\n"
      "          write: %s\n"
      "displayconnects: %s\n",
      (user->username ? user->username : "(N/A)"),
      (user->secret ? user->secret : "(N/A)"),
      (user->deny ? user->deny : "(N/A)"),
      (user->permit ? user->permit : "(N/A)"),
      (user->read ? user->read : "(N/A)"),
      (user->write ? user->write : "(N/A)"),
      (user->displayconnects ? "yes" : "no"));

   AST_LIST_UNLOCK(&users);

   return RESULT_SUCCESS;
}

static int handle_showmanagers	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

Definition at line 494 of file manager.c.

References ast_cli(), AST_LIST_EMPTY, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, RESULT_SHOWUSAGE, RESULT_SUCCESS, and ast_manager_user::username.

{
   struct ast_manager_user *user = NULL;
   int count_amu = 0;

   if (argc != 3)
      return RESULT_SHOWUSAGE;

   AST_LIST_LOCK(&users);

   /* If there are no users, print out something along those lines */
   if (AST_LIST_EMPTY(&users)) {
      ast_cli(fd, "There are no manager users.\n");
      AST_LIST_UNLOCK(&users);
      return RESULT_SUCCESS;
   }

   ast_cli(fd, "\nusername\n--------\n");

   AST_LIST_TRAVERSE(&users, user, list) {
      ast_cli(fd, "%s\n", user->username);
      count_amu++;
   }

   AST_LIST_UNLOCK(&users);

   ast_cli(fd,"-------------------\n");
   ast_cli(fd,"%d manager users configured.\n", count_amu);

   return RESULT_SUCCESS;
}

static int handle_showmancmd	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

Note:

The actionlock is read-locked by the caller of this function

Definition at line 436 of file manager.c.

References manager_action::action, ast_cli(), manager_action::authority, authority_to_str(), manager_action::description, first_action, manager_action::next, RESULT_SHOWUSAGE, and manager_action::synopsis.

{
   struct manager_action *cur;
   char authority[80];
   int num;

   if (argc != 4)
      return RESULT_SHOWUSAGE;

   for (cur = first_action; cur; cur = cur->next) { /* Walk the list of actions */
      for (num = 3; num < argc; num++) {
         if (!strcasecmp(cur->action, argv[num])) {
            ast_cli(fd, "Action: %s\nSynopsis: %s\nPrivilege: %s\n%s\n", cur->action, cur->synopsis, authority_to_str(cur->authority, authority, sizeof(authority) -1), cur->description ? cur->description : "");
         }
      }
   }

   return RESULT_SUCCESS;
}

static int handle_showmancmds	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

CLI command Should change to "manager show commands".

Definition at line 529 of file manager.c.

References manager_action::action, ast_cli(), ast_rwlock_rdlock(), ast_rwlock_unlock(), manager_action::authority, authority_to_str(), first_action, format, manager_action::next, RESULT_SUCCESS, and manager_action::synopsis.

{
   struct manager_action *cur;
   char authority[80];
   char *format = "  %-15.15s  %-15.15s  %-55.55s\n";

   ast_cli(fd, format, "Action", "Privilege", "Synopsis");
   ast_cli(fd, format, "------", "---------", "--------");
   
   ast_rwlock_rdlock(&actionlock);
   for (cur = first_action; cur; cur = cur->next) /* Walk the list of actions */
      ast_cli(fd, format, cur->action, authority_to_str(cur->authority, authority, sizeof(authority) -1), cur->synopsis);
   ast_rwlock_unlock(&actionlock);
   
   return RESULT_SUCCESS;
}

static int handle_showmanconn	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

CLI command show manager connected.

Definition at line 548 of file manager.c.

References ast_cli(), ast_inet_ntoa(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, format, RESULT_SUCCESS, s, and sessions.

{
   struct mansession *s;
   char *format = "  %-15.15s  %-15.15s\n";

   ast_cli(fd, format, "Username", "IP Address");
   
   AST_LIST_LOCK(&sessions);
   AST_LIST_TRAVERSE(&sessions, s, list)
      ast_cli(fd, format,s->username, ast_inet_ntoa(s->sin.sin_addr));
   AST_LIST_UNLOCK(&sessions);

   return RESULT_SUCCESS;
}

static int handle_showmaneventq	(	int	fd,
		int	argc,
		char *	argv[]
	)			[static]

CLI command show manager connected.

Definition at line 565 of file manager.c.

References ast_cli(), AST_LIST_LOCK, AST_LIST_UNLOCK, master_eventq, RESULT_SUCCESS, s, and sessions.

{
   struct eventqent *s;

   AST_LIST_LOCK(&sessions);
   for (s = master_eventq; s; s = s->next) {
      ast_cli(fd, "Usecount: %d\n",s->usecount);
      ast_cli(fd, "Category: %d\n", s->category);
      ast_cli(fd, "Event:\n%s", s->eventdata);
   }
   AST_LIST_UNLOCK(&sessions);

   return RESULT_SUCCESS;
}

static void handle_updates	(	struct mansession *	s,
		const struct message *	m,
		struct ast_config *	cfg
	)			[static]

Definition at line 1063 of file manager.c.

References ast_category_append(), ast_category_delete(), ast_category_get(), ast_category_new(), ast_category_rename(), ast_strlen_zero(), ast_variable_append(), ast_variable_delete(), ast_variable_new(), ast_variable_update(), astman_get_header(), match(), ast_variable::object, ast_variable::value, and var.

Referenced by action_updateconfig().

{
   int x;
   char hdr[40];
   const char *action, *cat, *var, *value, *match;
   struct ast_category *category;
   struct ast_variable *v;
   
   for (x=0;x<100000;x++) {
      unsigned int object = 0;

      snprintf(hdr, sizeof(hdr), "Action-%06d", x);
      action = astman_get_header(m, hdr);
      if (ast_strlen_zero(action))
         break;
      snprintf(hdr, sizeof(hdr), "Cat-%06d", x);
      cat = astman_get_header(m, hdr);
      snprintf(hdr, sizeof(hdr), "Var-%06d", x);
      var = astman_get_header(m, hdr);
      snprintf(hdr, sizeof(hdr), "Value-%06d", x);
      value = astman_get_header(m, hdr);
      if (!ast_strlen_zero(value) && *value == '>') {
         object = 1;
         value++;
      }
      snprintf(hdr, sizeof(hdr), "Match-%06d", x);
      match = astman_get_header(m, hdr);
      if (!strcasecmp(action, "newcat")) {
         if (!ast_strlen_zero(cat)) {
            category = ast_category_new(cat);
            if (category) {
               ast_category_append(cfg, category);
            }
         }
      } else if (!strcasecmp(action, "renamecat")) {
         if (!ast_strlen_zero(cat) && !ast_strlen_zero(value)) {
            category = ast_category_get(cfg, cat);
            if (category) 
               ast_category_rename(category, value);
         }
      } else if (!strcasecmp(action, "delcat")) {
         if (!ast_strlen_zero(cat))
            ast_category_delete(cfg, (char *) cat);
      } else if (!strcasecmp(action, "update")) {
         if (!ast_strlen_zero(cat) && !ast_strlen_zero(var) && (category = ast_category_get(cfg, cat)))
            ast_variable_update(category, var, value, match, object);
      } else if (!strcasecmp(action, "delete")) {
         if (!ast_strlen_zero(cat) && !ast_strlen_zero(var) && (category = ast_category_get(cfg, cat)))
            ast_variable_delete(category, (char *) var, (char *) match);
      } else if (!strcasecmp(action, "append")) {
         if (!ast_strlen_zero(cat) && !ast_strlen_zero(var) && 
            (category = ast_category_get(cfg, cat)) && 
            (v = ast_variable_new(var, value))){
            if (object || (match && !strcasecmp(match, "object")))
               v->object = 1;
            ast_variable_append(category, v);
         }
      }
   }
}

static char* html_translate

(

char *

in

)

[static]

Definition at line 346 of file manager.c.

References ast_build_string(), ast_malloc, len, and var.

{
   int x;
   int colons = 0;
   int breaks = 0;
   size_t len;
   int count = 1;
   char *tmp, *var, *val, *out;

   for (x=0; in[x]; x++) {
      if (in[x] == ':')
         colons++;
      if (in[x] == '\n')
         breaks++;
   }
   len = strlen(in) + colons * 40 + breaks * 40; /* <tr><td></td><td></td></tr>, "<tr><td colspan=\"2\"><hr></td></tr> */
   out = ast_malloc(len);
   if (!out)
      return 0;
   tmp = out;
   while (*in) {
      var = in;
      while (*in && (*in >= 32))
         in++;
      if (*in) {
         if ((count % 4) == 0){
            ast_build_string(&tmp, &len, "<tr><td colspan=\"2\"><hr></td></tr>\r\n");
         }
         count = 0;
         while (*in && (*in < 32)) {
            *in = '\0';
            in++;
            count++;
         }
         val = strchr(var, ':');
         if (val) {
            *val = '\0';
            val++;
            if (*val == ' ')
               val++;
            ast_build_string(&tmp, &len, "<tr><td>%s</td><td>%s</td></tr>\r\n", var, val);
         }
      }
   }
   return out;
}

int manager_event	(	int	category,
		const char *	event,
		const char *	fmt,
			...
	)

manager_event: Send AMI event to client

Definition at line 2301 of file manager.c.

References append_event(), ast_dynamic_str_thread_append(), ast_dynamic_str_thread_append_va, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_mutex_lock(), ast_mutex_unlock(), AST_PTHREADT_NULL, authority_to_str(), MANAGER_EVENT_BUF_INITSIZE, num_sessions, s, sessions, and timestampevents.

Referenced by __expire_registry(), __iax2_poke_noanswer(), __login_exec(), action_agent_callback_login(), action_userevent(), add_to_queue(), agent_logoff_maintenance(), aji_log_hook(), ast_change_name(), ast_channel_bridge(), ast_do_masquerade(), ast_hangup(), ast_log(), ast_park_call(), ast_set_callerid(), ast_setstate(), changethread(), conf_run(), expire_register(), fast_originate(), handle_init_event(), handle_response_peerpoke(), handle_response_register(), iax2_ack_registry(), join_queue(), leave_queue(), manager_log(), manager_state_cb(), notify_new_message(), park_exec(), parse_register_contact(), pbx_extension_helper(), phase_e_handler(), post_manager_event(), process_sdp(), quit_handler(), realtime_exec(), record_abandoned(), register_verify(), reload_logger(), reload_manager(), remove_from_queue(), ring_entry(), senddialevent(), set_member_paused(), sip_poke_noanswer(), sip_reg_timeout(), socket_process(), ss_thread(), try_calling(), update_registry(), update_status(), userevent_exec(), vm_execmain(), and zt_handle_event().

{
   struct mansession *s;
   char auth[80];
   va_list ap;
   struct timeval now;
   struct ast_dynamic_str *buf;

   /* Abort if there aren't any manager sessions */
   if (!num_sessions)
      return 0;

   if (!(buf = ast_dynamic_str_thread_get(&manager_event_buf, MANAGER_EVENT_BUF_INITSIZE)))
      return -1;

   ast_dynamic_str_thread_set(&buf, 0, &manager_event_buf,
         "Event: %s\r\nPrivilege: %s\r\n",
          event, authority_to_str(category, auth, sizeof(auth)));

   if (timestampevents) {
      now = ast_tvnow();
      ast_dynamic_str_thread_append(&buf, 0, &manager_event_buf,
            "Timestamp: %ld.%06lu\r\n",
             now.tv_sec, (unsigned long) now.tv_usec);
   }

   va_start(ap, fmt);
   ast_dynamic_str_thread_append_va(&buf, 0, &manager_event_buf, fmt, ap);
   va_end(ap);
   
   ast_dynamic_str_thread_append(&buf, 0, &manager_event_buf, "\r\n");  
   
   /* Append event to master list and wake up any sleeping sessions */
   AST_LIST_LOCK(&sessions);
   append_event(buf->str, category);
   AST_LIST_TRAVERSE(&sessions, s, list) {
      ast_mutex_lock(&s->__lock);
      if (s->waiting_thread != AST_PTHREADT_NULL)
         pthread_kill(s->waiting_thread, SIGURG);
      ast_mutex_unlock(&s->__lock);
   }
   AST_LIST_UNLOCK(&sessions);

   return 0;
}

static int manager_state_cb	(	char *	context,
		char *	exten,
		int	state,
		void *	data
	)			[static]

Definition at line 2369 of file manager.c.

References EVENT_FLAG_CALL, and manager_event().

Referenced by init_manager().

{
   /* Notify managers of change */
   manager_event(EVENT_FLAG_CALL, "ExtensionStatus", "Exten: %s\r\nContext: %s\r\nStatus: %d\r\n", exten, context, state);
   return 0;
}

static int process_events

(

struct mansession *

s

)

[static]

Definition at line 1935 of file manager.c.

References ast_carefulwrite(), ast_mutex_lock(), ast_mutex_unlock(), eventqent::category, eventqent::eventdata, master_eventq, s, and unuse_eventqent().

Referenced by do_message().

{
   struct eventqent *eqe;
   int ret = 0;
   ast_mutex_lock(&s->__lock);
   if (s->fd > -1) {
      if (!s->eventq)
         s->eventq = master_eventq;
      while(s->eventq->next) {
         eqe = s->eventq->next;
         if ((s->authenticated && (s->readperm & eqe->category) == eqe->category) &&
             ((s->send_events & eqe->category) == eqe->category)) {
            if (!ret && ast_carefulwrite(s->fd, eqe->eventdata, strlen(eqe->eventdata), s->writetimeout) < 0)
               ret = -1;
         }
         unuse_eventqent(s->eventq);
         s->eventq = eqe;
      }
   }
   ast_mutex_unlock(&s->__lock);
   return ret;
}

static int process_message	(	struct mansession *	s,
		const struct message *	m
	)			[static]

Definition at line 1983 of file manager.c.

References manager_action::action, ast_inet_ntoa(), ast_log(), ast_random(), ast_rwlock_rdlock(), ast_rwlock_unlock(), ast_strlen_zero(), ast_verbose(), astman_append(), astman_get_header(), astman_send_ack(), astman_send_error(), authenticate(), manager_action::authority, displayconnects, first_action, manager_action::func, LOG_DEBUG, LOG_EVENT, manager_action::next, option_debug, option_verbose, s, and VERBOSE_PREFIX_2.

Referenced by do_message().

{
   char action[80] = "";
   struct manager_action *tmp;
   const char *id = astman_get_header(m,"ActionID");
   char idText[256] = "";
   int ret = 0;

   ast_copy_string(action, astman_get_header(m, "Action"), sizeof(action));
   if (option_debug)
      ast_log( LOG_DEBUG, "Manager received command '%s'\n", action );

   if (ast_strlen_zero(action)) {
      astman_send_error(s, m, "Missing action in request");
      return 0;
   }
   if (!ast_strlen_zero(id)) {
      snprintf(idText, sizeof(idText), "ActionID: %s\r\n", id);
   }
   if (!s->authenticated) {
      if (!strcasecmp(action, "Challenge")) {
         const char *authtype = astman_get_header(m, "AuthType");

         if (!strcasecmp(authtype, "MD5")) {
            if (ast_strlen_zero(s->challenge))
               snprintf(s->challenge, sizeof(s->challenge), "%ld", ast_random());
            astman_append(s, "Response: Success\r\n"
                  "%s"
                  "Challenge: %s\r\n\r\n",
                  idText, s->challenge);
            return 0;
         } else {
            astman_send_error(s, m, "Must specify AuthType");
            return 0;
         }
      } else if (!strcasecmp(action, "Login")) {
         if (authenticate(s, m)) {
            sleep(1);
            astman_send_error(s, m, "Authentication failed");
            return -1;
         } else {
            s->authenticated = 1;
            if (option_verbose > 1) {
               if (displayconnects) {
                  ast_verbose(VERBOSE_PREFIX_2 "%sManager '%s' logged on from %s\n", 
                     (s->sessiontimeout ? "HTTP " : ""), s->username, ast_inet_ntoa(s->sin.sin_addr));
               }
            }
            ast_log(LOG_EVENT, "%sManager '%s' logged on from %s\n", 
               (s->sessiontimeout ? "HTTP " : ""), s->username, ast_inet_ntoa(s->sin.sin_addr));
            astman_send_ack(s, m, "Authentication accepted");
         }
      } else if (!strcasecmp(action, "Logoff")) {
         astman_send_ack(s, m, "See ya");
         return -1;
      } else
         astman_send_error(s, m, "Authentication Required");
   } else {
      if (!strcasecmp(action, "Login"))
         astman_send_ack(s, m, "Already logged in");
      else {
         ast_rwlock_rdlock(&actionlock);
         for (tmp = first_action; tmp; tmp = tmp->next) {      
            if (strcasecmp(action, tmp->action))
               continue;
            if ((s->writeperm & tmp->authority) == tmp->authority) {
               if (tmp->func(s, m))
                  ret = -1;
            } else
               astman_send_error(s, m, "Permission denied");
            break;
         }
         ast_rwlock_unlock(&actionlock);
         if (!tmp)
            astman_send_error(s, m, "Invalid/unknown command");
      }
   }
   if (ret)
      return ret;
   return process_events(s);
}

static void* session_do

(

void *

data

)

[static]

Definition at line 2149 of file manager.c.

References ast_inet_ntoa(), ast_log(), ast_verbose(), astman_append(), displayconnects, do_message(), LOG_EVENT, option_verbose, s, and VERBOSE_PREFIX_2.

Referenced by accept_thread().

{
   struct mansession *s = data;
   int res;
   
   astman_append(s, "Asterisk Call Manager/1.0\r\n");
   for (;;) {
      if ((res = do_message(s)) < 0)
         break;
   }
   if (s->authenticated) {
      if (option_verbose > 1) {
         if (displayconnects) 
            ast_verbose(VERBOSE_PREFIX_2 "Manager '%s' logged off from %s\n", s->username, ast_inet_ntoa(s->sin.sin_addr));
      }
      ast_log(LOG_EVENT, "Manager '%s' logged off from %s\n", s->username, ast_inet_ntoa(s->sin.sin_addr));
   } else {
      if (option_verbose > 1) {
         if (displayconnects)
            ast_verbose(VERBOSE_PREFIX_2 "Connect attempt from '%s' unable to authenticate\n", ast_inet_ntoa(s->sin.sin_addr));
      }
      ast_log(LOG_EVENT, "Failed attempt from %s\n", ast_inet_ntoa(s->sin.sin_addr));
   }
   destroy_session(s);
   return NULL;
}

static int set_eventmask	(	struct mansession *	s,
		const char *	eventmask
	)			[static]

Rather than braindead on,off this now can also accept a specific int mask value or a ',' delim list of mask strings (the same as manager.conf) -anthm.

Definition at line 863 of file manager.c.

References ast_mutex_lock(), ast_mutex_unlock(), s, and strings_to_mask().

Referenced by action_events().

{
   int maskint = strings_to_mask(eventmask);

   ast_mutex_lock(&s->__lock);
   if (maskint >= 0) 
      s->send_events = maskint;
   ast_mutex_unlock(&s->__lock);
   
   return maskint;
}

static int strings_to_mask

(

const char *

string

)

[static]

Definition at line 832 of file manager.c.

References ast_false(), ast_instring(), ast_is_number(), ast_strlen_zero(), ast_true(), and perms.

Referenced by set_eventmask().

{
   int x, ret = -1;
   
   x = ast_is_number((char *) string);

   if (x)
      ret = x;
   else if (ast_strlen_zero(string))
      ret = -1;
   else if (ast_false(string))
      ret = 0;
   else if (ast_true(string)) {
      ret = 0;
      for (x=0; x<sizeof(perms) / sizeof(perms[0]); x++)
         ret |= perms[x].num;    
   } else {
      ret = 0;
      for (x=0; x<sizeof(perms) / sizeof(perms[0]); x++) {
         if (ast_instring(string, perms[x].label, ',')) 
            ret |= perms[x].num;    
      }
   }

   return ret;
}

static void unuse_eventqent

(

struct eventqent *

e

)

[static]

Definition at line 653 of file manager.c.

References eventqent::next, and eventqent::usecount.

Referenced by action_waitevent(), free_session(), and process_events().

{
   if (ast_atomic_dec_and_test(&e->usecount) && e->next)
      pthread_kill(t, SIGURG);
}

static void xml_copy_escape	(	char **	dst,
		size_t *	maxlen,
		const char *	src,
		int	lower
	)			[static]

Definition at line 234 of file manager.c.

Referenced by xml_translate().

{
   while (*src && (*maxlen > 6)) {
      switch (*src) {
      case '<':
         strcpy(*dst, "&lt;");
         (*dst) += 4;
         *maxlen -= 4;
         break;
      case '>':
         strcpy(*dst, "&gt;");
         (*dst) += 4;
         *maxlen -= 4;
         break;
      case '\"':
         strcpy(*dst, "&quot;");
         (*dst) += 6;
         *maxlen -= 6;
         break;
      case '\'':
         strcpy(*dst, "&apos;");
         (*dst) += 6;
         *maxlen -= 6;
         break;
      case '&':
         strcpy(*dst, "&amp;");
         (*dst) += 5;
         *maxlen -= 5;
         break;      
      default:
         *(*dst)++ = lower ? tolower(*src) : *src;
         (*maxlen)--;
      }
      src++;
   }
}

static char* xml_translate	(	char *	in,
		struct ast_variable *	vars
	)			[static]

Definition at line 271 of file manager.c.

References ast_build_string(), ast_malloc, len, ast_variable::name, ast_variable::next, ast_variable::value, var, and xml_copy_escape().

{
   struct ast_variable *v;
   char *dest = NULL;
   char *out, *tmp, *var, *val;
   char *objtype = NULL;
   int colons = 0;
   int breaks = 0;
   size_t len;
   int count = 1;
   int escaped = 0;
   int inobj = 0;
   int x;
   
   for (v = vars; v; v = v->next) {
      if (!dest && !strcasecmp(v->name, "ajaxdest"))
         dest = v->value;
      else if (!objtype && !strcasecmp(v->name, "ajaxobjtype")) 
         objtype = v->value;
   }
   if (!dest)
      dest = "unknown";
   if (!objtype)
      objtype = "generic";
   for (x = 0; in[x]; x++) {
      if (in[x] == ':')
         colons++;
      else if (in[x] == '\n')
         breaks++;
      else if (strchr("&\"<>", in[x]))
         escaped++;
   }
   len = (size_t) (strlen(in) + colons * 5 + breaks * (40 + strlen(dest) + strlen(objtype)) + escaped * 10); /* foo="bar", "<response type=\"object\" id=\"dest\"", "&amp;" */
   out = ast_malloc(len);
   if (!out)
      return 0;
   tmp = out;
   while (*in) {
      var = in;
      while (*in && (*in >= 32))
         in++;
      if (*in) {
         if ((count > 3) && inobj) {
            ast_build_string(&tmp, &len, " /></response>\n");
            inobj = 0;
         }
         count = 0;
         while (*in && (*in < 32)) {
            *in = '\0';
            in++;
            count++;
         }
         val = strchr(var, ':');
         if (val) {
            *val = '\0';
            val++;
            if (*val == ' ')
               val++;
            if (!inobj) {
               ast_build_string(&tmp, &len, "<response type='object' id='%s'><%s", dest, objtype);
               inobj = 1;
            }
            ast_build_string(&tmp, &len, " ");           
            xml_copy_escape(&tmp, &len, var, 1);
            ast_build_string(&tmp, &len, "='");
            xml_copy_escape(&tmp, &len, val, 0);
            ast_build_string(&tmp, &len, "'");
         }
      }
   }
   if (inobj)
      ast_build_string(&tmp, &len, " /></response>\n");
   return out;
}

---

Variable Documentation

int asock = -1 [static]

Definition at line 97 of file manager.c.

Referenced by accept_thread(), and init_manager().

int block_sockets [static]

Definition at line 103 of file manager.c.

Referenced by accept_thread(), and init_manager().

struct ast_cli_entry cli_manager[] [static]

Definition at line 627 of file manager.c.

Referenced by init_manager().

struct ast_cli_entry cli_show_manager_command_deprecated [static]

Initial value:

 {
   { "show", "manager", "command", NULL },
   handle_showmancmd, NULL,
   NULL, complete_show_mancmd }

Definition at line 607 of file manager.c.

struct ast_cli_entry cli_show_manager_commands_deprecated [static]

Initial value:

 {
   { "show", "manager", "commands", NULL },
   handle_showmancmds, NULL,
   NULL }

Definition at line 612 of file manager.c.

struct ast_cli_entry cli_show_manager_connected_deprecated [static]

Initial value:

 {
   { "show", "manager", "connected", NULL },
   handle_showmanconn, NULL,
   NULL }

Definition at line 617 of file manager.c.

struct ast_cli_entry cli_show_manager_eventq_deprecated [static]

Initial value:

 {
   { "show", "manager", "eventq", NULL },
   handle_showmaneventq, NULL,
   NULL }

Definition at line 622 of file manager.c.

int displayconnects = 1 [static]

Definition at line 98 of file manager.c.

Referenced by accept_thread(), init_manager(), process_message(), and session_do().

int enabled [static]

Definition at line 95 of file manager.c.

struct manager_action* first_action [static]

Definition at line 190 of file manager.c.

Referenced by action_listcommands(), ast_manager_register_struct(), ast_manager_unregister(), complete_show_mancmd(), handle_showmancmd(), handle_showmancmds(), and process_message().

int httptimeout = 60 [static]

Definition at line 100 of file manager.c.

Referenced by init_manager().

char mandescr_command[] [static]

Initial value:

 
"Description: Run a CLI command.\n"
"Variables: (Names marked with * are required)\n"
"  *Command: Asterisk CLI command to run\n"
"  ActionID: Optional Action id for message matching.\n"

Definition at line 1604 of file manager.c.

char mandescr_events[] [static]

Definition at line 1289 of file manager.c.

char mandescr_extensionstate[] [static]

Definition at line 1863 of file manager.c.

char mandescr_getconfig[] [static]

Initial value:

"Description: A 'GetConfig' action will dump the contents of a configuration\n"
"file by category and contents.\n"
"Variables:\n"
"   Filename: Configuration filename (e.g. foo.conf)\n"

Definition at line 1020 of file manager.c.

char mandescr_getvar[] [static]

Definition at line 1387 of file manager.c.

char mandescr_hangup[] [static]

Initial value:

 
"Description: Hangup a channel\n"
"Variables: \n"
"  Channel: The channel name to be hungup\n"

Definition at line 1321 of file manager.c.

char mandescr_listcommands[] [static]

Initial value:

 
"Description: Returns the action name and synopsis for every\n"
"  action that is available to the user\n"
"Variables: NONE\n"

Definition at line 1264 of file manager.c.

char mandescr_logoff[] [static]

Initial value:

 
"Description: Logoff this manager session\n"
"Variables: NONE\n"

Definition at line 1311 of file manager.c.

char mandescr_mailboxcount[] [static]

Definition at line 1827 of file manager.c.

char mandescr_mailboxstatus[] [static]

Help text for manager command mailboxstatus.

Definition at line 1795 of file manager.c.

char mandescr_originate[] [static]

Definition at line 1672 of file manager.c.

char mandescr_ping[] [static]

Initial value:

 
"Description: A 'Ping' action will ellicit a 'Pong' response.  Used to keep the\n"
"  manager connection open.\n"
"Variables: NONE\n"

Manager PING.

Definition at line 1009 of file manager.c.

char mandescr_redirect[] [static]

Definition at line 1529 of file manager.c.

char mandescr_setvar[] [static]

Definition at line 1345 of file manager.c.

char mandescr_timeout[] [static]

Definition at line 1904 of file manager.c.

char mandescr_updateconfig[] [static]

Definition at line 1124 of file manager.c.

char mandescr_userevent[] [static]

Definition at line 1958 of file manager.c.

char mandescr_waitevent[] [static]

Manager WAITEVENT.

Definition at line 1175 of file manager.c.

struct eventqent* master_eventq = NULL

Definition at line 107 of file manager.c.

Referenced by accept_thread(), append_event(), handle_showmaneventq(), and process_events().

int num_sessions [static]

Definition at line 104 of file manager.c.

Referenced by accept_thread(), append_event(), and manager_event().

struct permalias perms[] [static]

Referenced by authority_to_str(), get_perm(), and strings_to_mask().

int portno = DEFAULT_MANAGER_PORT [static]

Definition at line 96 of file manager.c.

Referenced by ast_netsock_bind(), create_addr(), init_manager(), process_sdp(), and set_config().

char showmanager_help[] [static]

Initial value:

" Usage: manager show user <user>\n"
"        Display all information related to the manager user specified.\n"

Definition at line 603 of file manager.c.

char showmanagers_help[] [static]

Initial value:

"Usage: manager show users\n"
"       Prints a listing of all managers that are currently configured on that\n"
" system.\n"

Definition at line 598 of file manager.c.

char showmancmd_help[] [static]

Initial value:

 
"Usage: manager show command <actionname>\n"
"  Shows the detailed description for a specific Asterisk manager interface command.\n"

Definition at line 580 of file manager.c.

char showmancmds_help[] [static]

Initial value:

 
"Usage: manager show commands\n"
"  Prints a listing of all the available Asterisk manager interface commands.\n"

Definition at line 584 of file manager.c.

char showmanconn_help[] [static]

Initial value:

 
"Usage: manager show connected\n"
"  Prints a listing of the users that are currently connected to the\n"
"Asterisk manager interface.\n"

Definition at line 588 of file manager.c.

char showmaneventq_help[] [static]

Initial value:

 
"Usage: manager show eventq\n"
"  Prints a listing of all events pending in the Asterisk manger\n"
"event queue.\n"

Definition at line 593 of file manager.c.

pthread_t t [static]

Definition at line 102 of file manager.c.

Referenced by __ast_register_translator(), __schedule_action(), acf_odbc_write(), add_sdp(), add_t38_sdp(), append_date(), ast_channel_bridge(), ast_check_timing(), ast_do_masquerade(), ast_get_time_t(), ast_httpd_helper_thread(), ast_log(), ast_pbx_start(), ast_say_enumeration_full_da(), ast_say_enumeration_full_de(), ast_say_enumeration_full_en(), ast_say_number_full_de(), ast_translator_activate(), ast_translator_build_path(), ast_translator_deactivate(), ast_unregister_translator(), ast_verbose(), background_detect_exec(), build_mapping(), byteReverse(), calc_cost(), calc_txstamp(), callerid_genmsg(), callerid_getcarrier(), cdr_get_tv(), check_switch_expr(), check_user_full(), cli_prompt(), config_text_file_save(), destroy(), do_monitor(), does_peer_need_mwi(), dump_cmd_queues(), expr2_token_subst(), gen_match_to_pattern(), gen_tone(), gen_tones(), get_date(), get_trans_id(), handle_bchan(), handle_hd_hf(), handle_offhook_message(), handle_soft_key_event_message(), handle_stimulus_message(), iax2_datetime(), iax2_show_threads(), iax_template_parse(), init_manager(), launch_service(), listener(), localsub(), lws2sws(), manager_log(), MD5Update(), newpvt(), nv_background_detect_exec(), nv_detectfax_exec(), osp_create_provider(), osp_load(), packdate(), phase_d_handler(), phase_e_handler(), play_message_datetime(), prune_gateways(), rebuild_matrix(), register_verify(), rpt(), rpt_do_lstats(), rpt_tele_thread(), rxfax_exec(), send_request(), SHA1ProcessMessageBlock(), sms_readfile(), socket_read(), sqlite_log(), statechange_queue(), strip_quotes(), tdd_getcarrier(), time1(), time2(), transmit_notify_request_with_callerid(), transmit_notify_with_mwi(), transmit_state_notify(), txfax_exec(), vmu_tm(), and write_metadata().

int timestampevents [static]

Definition at line 99 of file manager.c.

Referenced by init_manager(), and manager_event().

---