Sun Aug 6 15:19:08 2006

Asterisk developer's documentation

---

AMI functions

callback to display queues status in manager More...

Data Structures
struct	fast_originate_helper
struct	permalias
Functions
static void *	accept_thread (void *ignore)
static int	action_command (struct mansession *s, struct message *m)
	action_command: Manager command "command" - execute CLI command
static int	action_events (struct mansession *s, struct message *m)
static int	action_extensionstate (struct mansession *s, struct message *m)
static int	action_getvar (struct mansession *s, struct message *m)
static int	action_hangup (struct mansession *s, struct message *m)
static int	action_listcommands (struct mansession *s, struct message *m)
static int	action_logoff (struct mansession *s, struct message *m)
static int	action_mailboxcount (struct mansession *s, struct message *m)
static int	action_mailboxstatus (struct mansession *s, struct message *m)
static int	action_originate (struct mansession *s, struct message *m)
static int	action_ping (struct mansession *s, struct message *m)
static int	action_redirect (struct mansession *s, struct message *m)
	action_redirect: The redirect manager command
static int	action_setvar (struct mansession *s, struct message *m)
static int	action_status (struct mansession *s, struct message *m)
	action_status: Manager "status" command to show channels
static int	action_timeout (struct mansession *s, struct message *m)
static int	append_event (struct mansession *s, const char *str)
int	ast_carefulwrite (int fd, char *s, int len, int timeoutms)
static int	ast_instring (char *bigstr, char *smallstr, char delim)
static int	ast_is_number (char *string)
int	ast_manager_register2 (const char *action, int auth, int(*func)(struct mansession *s, 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_MUTEX_DEFINE_STATIC (actionlock)
	AST_MUTEX_DEFINE_STATIC (sessionlock)
static int	ast_strings_to_mask (char *string)
char *	astman_get_header (struct message *m, char *var)
ast_variable *	astman_get_variables (struct message *m)
void	astman_send_ack (struct mansession *s, struct message *m, char *msg)
void	astman_send_error (struct mansession *s, struct message *m, char *error)
void	astman_send_response (struct mansession *s, struct message *m, char *resp, char *msg)
static int	authenticate (struct mansession *s, struct message *m)
static char *	authority_to_str (int authority, char *res, int reslen)
static char *	complete_show_mancmd (char *line, char *word, int pos, int state)
static void	destroy_session (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 (char *instr)
static int	handle_showmancmd (int fd, int argc, char *argv[])
static int	handle_showmancmds (int fd, int argc, char *argv[])
	handle_showmancmds: CLI command
static int	handle_showmanconn (int fd, int argc, char *argv[])
	handle_showmanconn: CLI command show manager connected
int	manager_event (int category, char *event, 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_message (struct mansession *s, struct message *m)
static void *	session_do (void *data)
static int	set_eventmask (struct mansession *s, char *eventmask)
Variables
static int	asock = -1
static int	block_sockets = 0
static int	displayconnects = 1
static int	enabled = 0
static struct manager_action *	first_action = NULL
static char	mandescr_command []
static char	mandescr_events []
static char	mandescr_extensionstate []
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 []
	PING: Manager PING.
static char	mandescr_redirect []
static char	mandescr_setvar []
static char	mandescr_timeout []
static struct permalias	perms []
static int	portno = DEFAULT_MANAGER_PORT
static struct mansession *	sessions = NULL
static struct ast_cli_entry	show_mancmd_cli
static struct ast_cli_entry	show_mancmds_cli
static struct ast_cli_entry	show_manconn_cli
static char	showmancmd_help []
static char	showmancmds_help []
static char	showmanconn_help []
static pthread_t	t

---

Detailed Description

callback to display queues status in manager

---

Function Documentation

static void* accept_thread (  void *  ignore  )  [static]

Definition at line 1426 of file manager.c. References mansession::__lock, asock, ast_log(), ast_mutex_init(), ast_mutex_lock(), ast_mutex_unlock(), ast_pthread_create, block_sockets, destroy_session(), mansession::fd, LOG_NOTICE, LOG_WARNING, malloc, mansession::next, s, mansession::send_events, session_do(), mansession::sin, mansession::t, and mansession::writetimeout. Referenced by init_manager(), and reload_config(). { int as; struct sockaddr_in sin; socklen_t sinlen; struct mansession *s; struct protoent *p; int arg = 1; int flags; pthread_attr_t attr; pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); for (;;) { sinlen = sizeof(sin); 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)); } } s = malloc(sizeof(struct mansession)); if (!s) { ast_log(LOG_WARNING, "Failed to allocate management session: %s\n", strerror(errno)); continue; } memset(s, 0, sizeof(struct mansession)); memcpy(&s->sin, &sin, sizeof(sin)); s->writetimeout = 100; if(! block_sockets) { /* For safety, make sure socket is non-blocking */ 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_mutex_lock(&sessionlock); s->next = sessions; sessions = s; ast_mutex_unlock(&sessionlock); if (ast_pthread_create(&s->t, &attr, session_do, s)) destroy_session(s); } pthread_attr_destroy(&attr); return NULL; }

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

action_command: Manager command "command" - execute CLI command Definition at line 919 of file manager.c. References ast_cli(), ast_cli_command(), ast_strlen_zero(), astman_get_header(), and mansession::fd. Referenced by init_manager(). { char *cmd = astman_get_header(m, "Command"); char *id = astman_get_header(m, "ActionID"); ast_cli(s->fd, "Response: Follows\r\nPrivilege: Command\r\n"); if (!ast_strlen_zero(id)) ast_cli(s->fd, "ActionID: %s\r\n", id); /* FIXME: Wedge a ActionID response in here, waiting for later changes */ ast_cli_command(s->fd, cmd); ast_cli(s->fd, "--END COMMAND--\r\n\r\n"); return 0; }

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

Definition at line 627 of file manager.c. References astman_get_header(), astman_send_response(), and set_eventmask(). Referenced by init_manager(). { 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, struct message *  m )  [static]

Definition at line 1179 of file manager.c. References ast_cli(), ast_extension_state(), ast_get_hint(), ast_strlen_zero(), astman_get_header(), astman_send_error(), context, exten, and mansession::fd. Referenced by init_manager(). { char *exten = astman_get_header(m, "Exten"); char *context = astman_get_header(m, "Context"); 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,256,"ActionID: %s\r\n",id); } ast_cli(s->fd, "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_getvar (  struct mansession *  s, struct message *  m )  [static]

Definition at line 724 of file manager.c. References ast_cli(), ast_get_channel_by_name_locked(), ast_mutex_unlock(), ast_strdupa, ast_strlen_zero(), astman_get_header(), astman_send_error(), mansession::fd, name, and pbx_builtin_getvar_helper(). Referenced by init_manager(). { struct ast_channel *c = NULL; char *name = astman_get_header(m, "Channel"); char *varname = astman_get_header(m, "Variable"); char *id = astman_get_header(m,"ActionID"); char *varval; char *varval2=NULL; if (!strlen(varname)) { astman_send_error(s, m, "No variable specified"); return 0; } if (strlen(name)) { c = ast_get_channel_by_name_locked(name); if (!c) { astman_send_error(s, m, "No such channel"); return 0; } } varval=pbx_builtin_getvar_helper(c,varname); if (varval) varval2 = ast_strdupa(varval); if (!varval2) varval2 = ""; if (c) ast_mutex_unlock(&c->lock); ast_cli(s->fd, "Response: Success\r\n" "Variable: %s\r\nValue: %s\r\n" ,varname,varval2); if (!ast_strlen_zero(id)) ast_cli(s->fd, "ActionID: %s\r\n",id); ast_cli(s->fd, "\r\n"); return 0; }

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

Definition at line 656 of file manager.c. References ast_get_channel_by_name_locked(), ast_mutex_unlock(), ast_softhangup(), AST_SOFTHANGUP_EXPLICIT, ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), ast_channel::lock, and name. Referenced by init_manager(). { struct ast_channel *c = NULL; 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_mutex_unlock(&c->lock); astman_send_ack(s, m, "Channel Hungup"); return 0; }

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

Definition at line 597 of file manager.c. References manager_action::action, ast_cli(), ast_mutex_lock(), ast_mutex_unlock(), ast_strlen_zero(), astman_get_header(), manager_action::authority, authority_to_str(), mansession::fd, manager_action::next, manager_action::synopsis, and mansession::writeperm. Referenced by init_manager(). { struct manager_action *cur = first_action; char idText[256] = ""; char temp[BUFSIZ]; char *id = astman_get_header(m,"ActionID"); if (!ast_strlen_zero(id)) snprintf(idText,256,"ActionID: %s\r\n",id); ast_cli(s->fd, "Response: Success\r\n%s", idText); ast_mutex_lock(&actionlock); while (cur) { /* Walk the list of actions */ if ((s->writeperm & cur->authority) == cur->authority) ast_cli(s->fd, "%s: %s (Priv: %s)\r\n", cur->action, cur->synopsis, authority_to_str(cur->authority, temp, sizeof(temp)) ); cur = cur->next; } ast_mutex_unlock(&actionlock); ast_cli(s->fd, "\r\n"); return 0; }

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

Definition at line 645 of file manager.c. References astman_send_response(). Referenced by init_manager(). { astman_send_response(s, m, "Goodbye", "Thanks for all the fish."); return -1; }

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

Definition at line 1143 of file manager.c. References ast_app_messagecount(), ast_cli(), ast_strlen_zero(), astman_get_header(), astman_send_error(), mansession::fd, and mailbox. Referenced by init_manager(). { char *mailbox = astman_get_header(m, "Mailbox"); 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_messagecount(mailbox, &newmsgs, &oldmsgs); if (!ast_strlen_zero(id)) { snprintf(idText,256,"ActionID: %s\r\n",id); } ast_cli(s->fd, "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, struct message *  m )  [static]

Definition at line 1111 of file manager.c. References ast_app_has_voicemail(), ast_cli(), ast_strlen_zero(), astman_get_header(), astman_send_error(), mansession::fd, and mailbox. Referenced by init_manager(). { char *mailbox = astman_get_header(m, "Mailbox"); 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,256,"ActionID: %s\r\n",id); ret = ast_app_has_voicemail(mailbox, NULL); ast_cli(s->fd, "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, struct message *  m )  [static]

Definition at line 994 of file manager.c. References app, ast_callerid_parse(), 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(), malloc, n, name, and ast_channel::priority. Referenced by init_manager(). { char *name = astman_get_header(m, "Channel"); char *exten = astman_get_header(m, "Exten"); char *context = astman_get_header(m, "Context"); char *priority = astman_get_header(m, "Priority"); char *timeout = astman_get_header(m, "Timeout"); char *callerid = astman_get_header(m, "CallerID"); char *account = astman_get_header(m, "Account"); char *app = astman_get_header(m, "Application"); char *appdata = astman_get_header(m, "Data"); char *async = astman_get_header(m, "Async"); 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)) { 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'; data++; 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 = malloc(sizeof(struct fast_originate_helper)); if (!fast) { res = -1; } else { memset(fast, 0, sizeof(struct fast_originate_helper)); 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; } } } 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, struct message *  m )  [static]

Definition at line 586 of file manager.c. References astman_send_response(). Referenced by init_manager(). { astman_send_response(s, m, "Pong", NULL); return 0; }

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

action_redirect: The redirect manager command Definition at line 862 of file manager.c. References ast_async_goto(), ast_get_channel_by_name_locked(), ast_mutex_unlock(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), context, exten, ast_channel::lock, and name. Referenced by init_manager(). { char *name = astman_get_header(m, "Channel"); char *name2 = astman_get_header(m, "ExtraChannel"); char *exten = astman_get_header(m, "Exten"); char *context = astman_get_header(m, "Context"); 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)) { astman_send_error(s, m, "Invalid priority\n"); return 0; } 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_strlen_zero(name2)) chan2 = ast_get_channel_by_name_locked(name2); 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_mutex_unlock(&chan->lock); if (chan2) ast_mutex_unlock(&chan2->lock); return 0; }

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

Definition at line 682 of file manager.c. References ast_get_channel_by_name_locked(), ast_mutex_unlock(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), ast_channel::lock, name, and pbx_builtin_setvar_helper(). Referenced by init_manager(). { struct ast_channel *c = NULL; char *name = astman_get_header(m, "Channel"); char *varname = astman_get_header(m, "Variable"); 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_mutex_unlock(&c->lock); astman_send_ack(s, m, "Variable Set"); return 0; }

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

action_status: Manager "status" command to show channels Definition at line 765 of file manager.c. References ast_channel::_bridge, ast_channel::_state, ast_channel::accountcode, ast_channel_walk_locked(), ast_cli(), ast_get_channel_by_name_locked(), ast_mutex_unlock(), ast_state2str(), ast_strlen_zero(), 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, mansession::fd, ast_channel::lock, ast_channel::name, name, ast_channel::pbx, ast_channel::priority, ast_cdr::start, and ast_channel::uniqueid. Referenced by init_manager(). { char *id = astman_get_header(m,"ActionID"); 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 */ astman_send_ack(s, m, "Channel status will follow"); if (!ast_strlen_zero(id)) snprintf(idText,256,"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; } } /* 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; } ast_cli(s->fd, "Event: Status\r\n" "Privilege: Call\r\n" "Channel: %s\r\n" "CallerID: %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, c->cid.cid_num ? c->cid.cid_num : "<unknown>", c->cid.cid_name ? 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 { ast_cli(s->fd, "Event: Status\r\n" "Privilege: Call\r\n" "Channel: %s\r\n" "CallerID: %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, c->cid.cid_num ? c->cid.cid_num : "<unknown>", c->cid.cid_name ? c->cid.cid_name : "<unknown>", c->accountcode, ast_state2str(c->_state), bridge, c->uniqueid, idText); } ast_mutex_unlock(&c->lock); if (!all) break; c = ast_channel_walk_locked(c); } ast_cli(s->fd, "Event: StatusComplete\r\n" "%s" "\r\n",idText); return 0; }

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

Definition at line 1216 of file manager.c. References ast_channel_setwhentohangup(), ast_get_channel_by_name_locked(), ast_mutex_unlock(), ast_strlen_zero(), astman_get_header(), astman_send_ack(), astman_send_error(), ast_channel::lock, and name. Referenced by init_manager(). { struct ast_channel *c = NULL; 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_mutex_unlock(&c->lock); astman_send_ack(s, m, "Timeout Set"); return 0; }

static int append_event (  struct mansession *  s, const char *  str )  [static]

Definition at line 1481 of file manager.c. References eventqent::eventdata, mansession::eventq, malloc, and eventqent::next. Referenced by manager_event(). { struct eventqent *tmp, *prev=NULL; tmp = malloc(sizeof(struct eventqent) + strlen(str)); if (tmp) { tmp->next = NULL; strcpy(tmp->eventdata, str); if (s->eventq) { prev = s->eventq; while(prev->next) prev = prev->next; prev->next = tmp; } else { s->eventq = tmp; } return 0; } return -1; }

int ast_carefulwrite (  int  fd, char *  s, int  len, int  timeoutms )

If you are calling ast_carefulwrite, it is assumed that you are calling it on a file descriptor that _DOES_ have NONBLOCK set. This way, there is only one system call made to do a write, unless we actually have a need to wait. This way, we get better performance. Definition at line 114 of file manager.c. References pollfd::events, pollfd::fd, poll(), and POLLOUT. Referenced by agi_debug_cli(), ast_cli(), manager_event(), and process_message(). { /* Try to write string, but wait no more than ms milliseconds before timing out */ int res=0; struct pollfd fds[1]; while(len) { res = write(fd, s, len); if ((res < 0) && (errno != EAGAIN)) { return -1; } if (res < 0) res = 0; len -= res; s += res; res = 0; if (len) { fds[0].fd = fd; fds[0].events = POLLOUT; /* Wait until writable again */ res = poll(fds, 1, timeoutms); if (res < 1) return -1; } } return res; }

static int ast_instring (  char *  bigstr, 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 395 of file manager.c. References ast_variable::next. Referenced by ast_strings_to_mask(), and get_perm(). { 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 427 of file manager.c. Referenced by ast_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; }

int ast_manager_register2 (  const char *  action, int  authority, int(*)(struct mansession *s, 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 1618 of file manager.c. References manager_action::action, ast_log(), ast_manager_register_struct(), manager_action::authority, manager_action::description, manager_action::func, LOG_WARNING, malloc, manager_action::next, and manager_action::synopsis. Referenced by init_manager(), and load_module(). { struct manager_action *cur; cur = malloc(sizeof(struct manager_action)); if (!cur) { ast_log(LOG_WARNING, "Manager: out of memory trying to register action\n"); 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 1575 of file manager.c. References manager_action::action, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_verbose(), LOG_WARNING, manager_action::next, option_verbose, and VERBOSE_PREFIX_2. Referenced by ast_manager_register2(). { struct manager_action *cur = first_action, *prev = NULL; int ret; ast_mutex_lock(&actionlock); 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_mutex_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_mutex_unlock(&actionlock); return 0; }

int ast_manager_unregister (  char *  action  )

Parameters: action  Name of registred Action: Definition at line 1547 of file manager.c. References manager_action::action, ast_mutex_lock(), ast_mutex_unlock(), ast_verbose(), free, manager_action::next, option_verbose, and VERBOSE_PREFIX_2. Referenced by __unload_module(), and unload_module(). { struct manager_action *cur = first_action, *prev = first_action; ast_mutex_lock(&actionlock); 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_mutex_unlock(&actionlock); return 0; } prev = cur; cur = cur->next; } ast_mutex_unlock(&actionlock); return 0; }

AST_MUTEX_DEFINE_STATIC (  actionlock   )

AST_MUTEX_DEFINE_STATIC (  sessionlock   )

static int ast_strings_to_mask (  char *  string  )  [static]

Definition at line 444 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(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; }

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

Get header from mananger transaction Definition at line 305 of file manager.c. References message::headers. Referenced by _sip_show_peers(), action_agent_callback_login(), action_agent_logoff(), action_agents(), action_command(), action_events(), action_extensionstate(), 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_zapdialoffhook(), action_zapdndoff(), action_zapdndon(), action_zapshowchannels(), astman_send_error(), astman_send_response(), authenticate(), change_monitor_action(), manager_add_queue_member(), manager_dbget(), manager_dbput(), manager_iax2_show_peers(), 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(), 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 (  struct message *  m  )

Get a linked list of the Variable: headers Definition at line 316 of file manager.c. References ast_app_separate_args(), ast_strdupa, ast_strlen_zero(), ast_variable_new(), message::headers, strsep(), and var. Referenced by action_originate(). { int varlen, x, y; struct ast_variable *head = NULL, *cur; char *var, *val; unsigned int var_count; char *vars[32]; varlen = strlen("Variable: "); for (x = 0; x < m->hdrcount; x++) { if (strncasecmp("Variable: ", m->headers[x], varlen)) continue; if (!(var = ast_strdupa(m->headers[x] + varlen))) return head; if ((var_count = ast_app_separate_args(var, '|', vars, sizeof(vars) / sizeof(vars[0])))) { for (y = 0; y < var_count; y++) { if (!vars[y]) continue; var = val = ast_strdupa(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, struct message *  m, char *  msg )

Definition at line 385 of file manager.c. References astman_send_response(). 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(), manager_add_queue_member(), manager_dbget(), manager_dbput(), manager_parking_status(), manager_pause_queue_member(), manager_play_dtmf(), manager_queues_status(), manager_remove_queue_member(), manager_sip_show_peers(), process_message(), start_monitor_action(), and stop_monitor_action(). { astman_send_response(s, m, "Success", msg); }

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

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 362 of file manager.c. References ast_cli(), ast_strlen_zero(), and astman_get_header(). Referenced by _sip_show_peer(), action_agent_callback_login(), action_agent_logoff(), action_extensionstate(), 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_zapdialoffhook(), action_zapdndoff(), action_zapdndon(), action_zaprestart(), change_monitor_action(), manager_add_queue_member(), manager_dbget(), manager_dbput(), manager_pause_queue_member(), manager_play_dtmf(), manager_remove_queue_member(), manager_sip_show_peer(), process_message(), start_monitor_action(), and stop_monitor_action(). { char *id = astman_get_header(m,"ActionID"); ast_cli(s->fd, "Response: Error\r\n"); if (!ast_strlen_zero(id)) ast_cli(s->fd, "ActionID: %s\r\n",id); ast_cli(s->fd, "Message: %s\r\n\r\n", error); }

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

Definition at line 372 of file manager.c. References ast_cli(), ast_strlen_zero(), astman_get_header(), and mansession::fd. Referenced by action_events(), action_logoff(), action_ping(), and astman_send_ack(). { char *id = astman_get_header(m,"ActionID"); ast_cli(s->fd, "Response: %s\r\n", resp); if (!ast_strlen_zero(id)) ast_cli(s->fd, "ActionID: %s\r\n",id); if (msg) ast_cli(s->fd, "Message: %s\r\n\r\n", msg); else ast_cli(s->fd, "\r\n"); }

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

Definition at line 488 of file manager.c. References ast_append_ha(), ast_apply_ha(), ast_category_browse(), ast_config_destroy(), ast_config_load(), ast_free_ha(), ast_inet_ntoa(), ast_log(), ast_strlen_zero(), ast_variable_browse(), ast_variable_retrieve(), astman_get_header(), cfg, mansession::challenge, events, get_perm(), key(), ast_variable::lineno, LOG_NOTICE, LOG_WARNING, MD5Final(), MD5Init(), MD5Update(), ast_variable::name, ast_variable::next, pass, password, mansession::readperm, set_eventmask(), mansession::sin, user, mansession::username, ast_variable::value, mansession::writeperm, and mansession::writetimeout. Referenced by authenticate_reply(), handle_response_invite(), process_message(), and registry_rerequest(). { struct ast_config *cfg; char iabuf[INET_ADDRSTRLEN]; char *cat; char *user = astman_get_header(m, "Username"); char *pass = astman_get_header(m, "Secret"); char *authtype = astman_get_header(m, "AuthType"); char *key = astman_get_header(m, "Key"); 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; v = ast_variable_browse(cfg, cat); while (v) { if (!strcasecmp(v->name, "secret")) { password = v->value; } 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; } v = v->next; } if (ha && !ast_apply_ha(ha, &(s->sin))) { ast_log(LOG_NOTICE, "%s failed to pass IP ACL as '%s'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), 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) && s->challenge) { 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 && !strcasecmp(password, pass)) { break; } else { ast_log(LOG_NOTICE, "%s failed to authenticate as '%s'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), 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_log(LOG_NOTICE, "%s tried to authenticate with nonexistent user '%s'\n", ast_inet_ntoa(iabuf, sizeof(iabuf), s->sin.sin_addr), user); ast_config_destroy(cfg); return -1; }

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

authority_to_str: Convert authority code to string with serveral options Definition at line 142 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 (  char *  line, char *  word, int  pos, int  state )  [static]

Definition at line 162 of file manager.c. References manager_action::action, ast_mutex_lock(), ast_mutex_unlock(), manager_action::next, and strdup. { struct manager_action *cur = first_action; int which = 0; ast_mutex_lock(&actionlock); while (cur) { /* Walk the list of actions */ if (!strncasecmp(word, cur->action, strlen(word))) { if (++which > state) { char *ret = strdup(cur->action); ast_mutex_unlock(&actionlock); return ret; } } cur = cur->next; } ast_mutex_unlock(&actionlock); return NULL; }

static void destroy_session (  struct mansession *  s  )  [static]

Definition at line 282 of file manager.c. References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), free_session(), LOG_WARNING, and mansession::next. Referenced by accept_thread(), session_do(), and skinny_session(). { struct mansession *cur, *prev = NULL; ast_mutex_lock(&sessionlock); cur = sessions; while(cur) { if (cur == s) break; prev = cur; cur = cur->next; } if (cur) { if (prev) prev->next = cur->next; else sessions = cur->next; free_session(s); } else ast_log(LOG_WARNING, "Trying to delete nonexistent session %p?\n", s); ast_mutex_unlock(&sessionlock); }

static void* fast_originate (  void *  data  )  [static]

Definition at line 932 of file manager.c. References fast_originate_helper::account, fast_originate_helper::app, fast_originate_helper::appdata, AST_FORMAT_SLINEAR, ast_mutex_unlock(), 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, ast_channel::lock, manager_event(), fast_originate_helper::priority, fast_originate_helper::tech, fast_originate_helper::timeout, ast_channel::uniqueid, 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; 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, !ast_strlen_zero(in->cid_num) ? in->cid_num : NULL, !ast_strlen_zero(in->cid_name) ? 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, !ast_strlen_zero(in->cid_num) ? in->cid_num : NULL, !ast_strlen_zero(in->cid_name) ? in->cid_name : NULL, in->vars, in->account, &chan); } if (!res) manager_event(EVENT_FLAG_CALL, "OriginateSuccess", "%s" "Channel: %s/%s\r\n" "Context: %s\r\n" "Exten: %s\r\n" "Reason: %d\r\n" "Uniqueid: %s\r\n", in->idtext, in->tech, in->data, in->context, in->exten, reason, chan ? chan->uniqueid : "<null>"); else manager_event(EVENT_FLAG_CALL, "OriginateFailure", "%s" "Channel: %s/%s\r\n" "Context: %s\r\n" "Exten: %s\r\n" "Reason: %d\r\n" "Uniqueid: %s\r\n", in->idtext, in->tech, in->data, in->context, in->exten, reason, chan ? chan->uniqueid : "<null>"); /* Locked by ast_pbx_outgoing_exten or ast_pbx_outgoing_app */ if (chan) ast_mutex_unlock(&chan->lock); free(in); return NULL; }

static void free_session (  struct mansession *  s  )  [static]

Definition at line 268 of file manager.c. References mansession::__lock, ast_mutex_destroy(), mansession::eventq, mansession::fd, free, and eventqent::next. Referenced by destroy_session(). { struct eventqent *eqe; if (s->fd > -1) close(s->fd); ast_mutex_destroy(&s->__lock); while(s->eventq) { eqe = s->eventq; s->eventq = s->eventq->next; free(eqe); } free(s); }

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

Definition at line 1333 of file manager.c. References mansession::__lock, ast_inet_ntoa(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), mansession::dead, pollfd::events, mansession::fd, pollfd::fd, mansession::inbuf, mansession::inlen, LOG_WARNING, poll(), POLLIN, and mansession::sin. Referenced by session_do(), and skinny_session(). { /* output must have at least sizeof(s->inbuf) space */ int res; int x; struct pollfd fds[1]; char iabuf[INET_ADDRSTRLEN]; 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(iabuf, sizeof(iabuf), s->sin.sin_addr), s->inbuf); s->inlen = 0; } fds[0].fd = s->fd; fds[0].events = POLLIN; do { res = poll(fds, 1, -1); if (res < 0) { if (errno == EINTR) { if (s->dead) return -1; continue; } 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 (  char *  instr  )  [static]

Definition at line 413 of file manager.c. References ast_instring(), and perms. Referenced by authenticate(). { 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_showmancmd (  int  fd, int  argc, char *  argv[] )  [static]

Definition at line 182 of file manager.c. References manager_action::action, ast_cli(), ast_mutex_lock(), ast_mutex_unlock(), manager_action::authority, authority_to_str(), manager_action::description, manager_action::next, RESULT_SHOWUSAGE, RESULT_SUCCESS, and manager_action::synopsis. { struct manager_action *cur = first_action; char authority[80]; int num; if (argc != 4) return RESULT_SHOWUSAGE; ast_mutex_lock(&actionlock); while (cur) { /* 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 : ""); } } cur = cur->next; } ast_mutex_unlock(&actionlock); return RESULT_SUCCESS; }

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

handle_showmancmds: CLI command Definition at line 206 of file manager.c. References manager_action::action, ast_cli(), ast_mutex_lock(), ast_mutex_unlock(), manager_action::authority, authority_to_str(), format, manager_action::next, RESULT_SUCCESS, and manager_action::synopsis. { struct manager_action *cur = first_action; char authority[80]; char *format = " %-15.15s %-15.15s %-55.55s\n"; ast_mutex_lock(&actionlock); ast_cli(fd, format, "Action", "Privilege", "Synopsis"); ast_cli(fd, format, "------", "---------", "--------"); while (cur) { /* Walk the list of actions */ ast_cli(fd, format, cur->action, authority_to_str(cur->authority, authority, sizeof(authority) -1), cur->synopsis); cur = cur->next; } ast_mutex_unlock(&actionlock); return RESULT_SUCCESS; }

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

handle_showmanconn: CLI command show manager connected Definition at line 226 of file manager.c. References ast_cli(), ast_inet_ntoa(), ast_mutex_lock(), ast_mutex_unlock(), format, mansession::next, RESULT_SUCCESS, s, mansession::sin, and mansession::username. { struct mansession *s; char iabuf[INET_ADDRSTRLEN]; char *format = " %-15.15s %-15.15s\n"; ast_mutex_lock(&sessionlock); s = sessions; ast_cli(fd, format, "Username", "IP Address"); while (s) { ast_cli(fd, format,s->username, ast_inet_ntoa(iabuf, sizeof(iabuf), s->sin.sin_addr)); s = s->next; } ast_mutex_unlock(&sessionlock); return RESULT_SUCCESS; }

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

manager_event: Send AMI event to client Definition at line 1502 of file manager.c. References mansession::__lock, append_event(), ast_build_string(), ast_build_string_va(), ast_carefulwrite(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_strlen_zero(), authority_to_str(), mansession::busy, mansession::dead, mansession::fd, LOG_WARNING, mansession::next, mansession::readperm, s, mansession::send_events, mansession::t, and mansession::writetimeout. Referenced by __login_exec(), action_agent_callback_login(), add_to_queue(), agent_hangup(), agent_logoff(), ast_change_name(), ast_channel_bridge(), ast_do_masquerade(), ast_hangup(), ast_log(), ast_park_call(), ast_request(), ast_set_callerid(), ast_setstate(), changethread(), conf_run(), do_parking_thread(), expire_register(), fast_originate(), forward_message(), handle_init_event(), handle_response_peerpoke(), handle_response_register(), iax2_ack_registry(), iax2_poke_noanswer(), join_queue(), leave_queue(), manager_log(), manager_state_cb(), notify_new_message(), park_exec(), parse_register_contact(), pbx_extension_helper(), process_sdp(), quit_handler(), realtime_exec(), register_verify(), reload_logger(), reload_manager(), remove_from_queue(), ring_entry(), senddialevent(), set_member_paused(), sip_poke_noanswer(), sip_reg_timeout(), socket_read(), ss_thread(), try_calling(), update_registry(), update_status(), userevent_exec(), vm_execmain(), and zt_handle_event(). { struct mansession *s; char auth[80]; char tmp[4096] = ""; char *tmp_next = tmp; size_t tmp_left = sizeof(tmp) - 2; va_list ap; ast_mutex_lock(&sessionlock); for (s = sessions; s; s = s->next) { if ((s->readperm & category) != category) continue; if ((s->send_events & category) != category) continue; if (ast_strlen_zero(tmp)) { ast_build_string(&tmp_next, &tmp_left, "Event: %s\r\nPrivilege: %s\r\n", event, authority_to_str(category, auth, sizeof(auth))); va_start(ap, fmt); ast_build_string_va(&tmp_next, &tmp_left, fmt, ap); va_end(ap); *tmp_next++ = '\r'; *tmp_next++ = '\n'; *tmp_next = '\0'; } ast_mutex_lock(&s->__lock); if (s->busy) { append_event(s, tmp); } else if (!s->dead) { if (ast_carefulwrite(s->fd, tmp, tmp_next - tmp, s->writetimeout) < 0) { ast_log(LOG_WARNING, "Disconnecting slow (or gone) manager session!\n"); s->dead = 1; pthread_kill(s->t, SIGURG); } } ast_mutex_unlock(&s->__lock); } ast_mutex_unlock(&sessionlock); return 0; }

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

Definition at line 1568 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_message (  struct mansession *  s, struct message *  m )  [static]

Definition at line 1240 of file manager.c. References mansession::__lock, manager_action::action, ast_carefulwrite(), ast_cli(), ast_inet_ntoa(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_strlen_zero(), ast_verbose(), astman_get_header(), astman_send_ack(), astman_send_error(), authenticate(), mansession::authenticated, manager_action::authority, mansession::busy, mansession::challenge, displayconnects, mansession::fd, free, manager_action::func, LOG_DEBUG, LOG_EVENT, eventqent::next, manager_action::next, option_verbose, mansession::sin, mansession::username, VERBOSE_PREFIX_2, and mansession::writeperm. Referenced by session_do(). { char action[80] = ""; struct manager_action *tmp = first_action; char *id = astman_get_header(m,"ActionID"); char idText[256] = ""; char iabuf[INET_ADDRSTRLEN]; ast_copy_string(action, astman_get_header(m, "Action"), sizeof(action)); 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,256,"ActionID: %s\r\n",id); } if (!s->authenticated) { if (!strcasecmp(action, "Challenge")) { char *authtype; authtype = astman_get_header(m, "AuthType"); if (!strcasecmp(authtype, "MD5")) { if (ast_strlen_zero(s->challenge)) snprintf(s->challenge, sizeof(s->challenge), "%d", rand()); ast_mutex_lock(&s->__lock); ast_cli(s->fd, "Response: Success\r\n" "%s" "Challenge: %s\r\n\r\n", idText,s->challenge); ast_mutex_unlock(&s->__lock); 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 "Manager '%s' logged on from %s\n", s->username, ast_inet_ntoa(iabuf, sizeof(iabuf), s->sin.sin_addr)); } } ast_log(LOG_EVENT, "Manager '%s' logged on from %s\n", s->username, ast_inet_ntoa(iabuf, sizeof(iabuf), 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 { int ret=0; struct eventqent *eqe; ast_mutex_lock(&s->__lock); s->busy = 1; ast_mutex_unlock(&s->__lock); while( tmp ) { if (!strcasecmp(action, tmp->action)) { if ((s->writeperm & tmp->authority) == tmp->authority) { if (tmp->func(s, m)) ret = -1; } else { astman_send_error(s, m, "Permission denied"); } break; } tmp = tmp->next; } if (!tmp) astman_send_error(s, m, "Invalid/unknown command"); ast_mutex_lock(&s->__lock); s->busy = 0; while(s->eventq) { if (ast_carefulwrite(s->fd, s->eventq->eventdata, strlen(s->eventq->eventdata), s->writetimeout) < 0) { ret = -1; break; } eqe = s->eventq; s->eventq = s->eventq->next; free(eqe); } ast_mutex_unlock(&s->__lock); return ret; } return 0; }

static void* session_do (  void *  data  )  [static]

Definition at line 1382 of file manager.c. References mansession::__lock, ast_cli(), ast_inet_ntoa(), ast_log(), AST_MAX_MANHEADERS, ast_mutex_lock(), ast_mutex_unlock(), ast_strlen_zero(), ast_verbose(), mansession::authenticated, destroy_session(), displayconnects, mansession::fd, get_input(), LOG_EVENT, option_verbose, process_message(), s, mansession::sin, mansession::username, and VERBOSE_PREFIX_2. Referenced by accept_thread(). { struct mansession *s = data; struct message m; char iabuf[INET_ADDRSTRLEN]; int res; ast_mutex_lock(&s->__lock); ast_cli(s->fd, "Asterisk Call Manager/1.0\r\n"); ast_mutex_unlock(&s->__lock); memset(&m, 0, sizeof(m)); for (;;) { res = get_input(s, m.headers[m.hdrcount]); if (res > 0) { /* Strip trailing \r\n */ if (strlen(m.headers[m.hdrcount]) < 2) continue; m.headers[m.hdrcount][strlen(m.headers[m.hdrcount]) - 2] = '\0'; if (ast_strlen_zero(m.headers[m.hdrcount])) { if (process_message(s, &m)) break; memset(&m, 0, sizeof(m)); } else if (m.hdrcount < AST_MAX_MANHEADERS - 1) m.hdrcount++; } else if (res < 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(iabuf, sizeof(iabuf), s->sin.sin_addr)); } ast_log(LOG_EVENT, "Manager '%s' logged off from %s\n", s->username, ast_inet_ntoa(iabuf, sizeof(iabuf), 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(iabuf, sizeof(iabuf), s->sin.sin_addr)); } ast_log(LOG_EVENT, "Failed attempt from %s\n", ast_inet_ntoa(iabuf, sizeof(iabuf), s->sin.sin_addr)); } destroy_session(s); return NULL; }

static int set_eventmask (  struct mansession *  s, 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 476 of file manager.c. References mansession::__lock, ast_mutex_lock(), ast_mutex_unlock(), ast_strings_to_mask(), and mansession::send_events. Referenced by action_events(), and authenticate(). { int maskint = ast_strings_to_mask(eventmask); ast_mutex_lock(&s->__lock); if (maskint >= 0) s->send_events = maskint; ast_mutex_unlock(&s->__lock); return maskint; }

---

Variable Documentation

int asock = -1 [static]

Definition at line 84 of file manager.c. Referenced by accept_thread(), and init_manager().

int block_sockets = 0 [static]

Definition at line 89 of file manager.c. Referenced by accept_thread(), and init_manager().

int displayconnects = 1 [static]

Definition at line 85 of file manager.c. Referenced by init_manager(), process_message(), and session_do().

int enabled = 0 [static]

Definition at line 82 of file manager.c.

struct manager_action* first_action = NULL [static]

Definition at line 107 of file manager.c.

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 912 of file manager.c. Referenced by init_manager().

char mandescr_events[] [static]

Definition at line 619 of file manager.c. Referenced by init_manager().

char mandescr_extensionstate[] [static]

Definition at line 1168 of file manager.c. Referenced by init_manager().

char mandescr_getvar[] [static]

Definition at line 717 of file manager.c. Referenced by init_manager().

char mandescr_hangup[] [static]

Initial value: "Description: Hangup a channel\n" "Variables: \n" " Channel: The channel name to be hungup\n" Definition at line 651 of file manager.c. Referenced by init_manager().

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 592 of file manager.c. Referenced by init_manager().

char mandescr_logoff[] [static]

Initial value: "Description: Logoff this manager session\n" "Variables: NONE\n" Definition at line 641 of file manager.c. Referenced by init_manager().

char mandescr_mailboxcount[] [static]

Definition at line 1132 of file manager.c. Referenced by init_manager().

char mandescr_mailboxstatus[] [static]

Help text for manager command mailboxstatus. Definition at line 1100 of file manager.c. Referenced by init_manager().

char mandescr_originate[] [static]

Definition at line 978 of file manager.c. Referenced by init_manager().

char mandescr_ping[] [static]

Initial value: "Description: A 'Ping' action will ellicit a 'Pong' response. Used to keep the " " manager connection open.\n" "Variables: NONE\n" PING: Manager PING. Definition at line 581 of file manager.c. Referenced by init_manager().

char mandescr_redirect[] [static]

Definition at line 851 of file manager.c. Referenced by init_manager().

char mandescr_setvar[] [static]

Definition at line 675 of file manager.c. Referenced by init_manager().

char mandescr_timeout[] [static]

Definition at line 1209 of file manager.c. Referenced by init_manager().

struct permalias perms[] [static]

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

int portno = DEFAULT_MANAGER_PORT [static]

Definition at line 83 of file manager.c. Referenced by ast_netsock_bind(), create_addr(), init_manager(), process_sdp(), and set_config().

struct mansession* sessions = NULL [static]

Definition at line 106 of file manager.c. Referenced by accept_thread(), and destroy_session().

struct ast_cli_entry show_mancmd_cli [static]

Initial value: { { "show", "manager", "command", NULL }, handle_showmancmd, "Show a manager interface command", showmancmd_help, complete_show_mancmd } Definition at line 256 of file manager.c.

struct ast_cli_entry show_mancmds_cli [static]

Initial value: { { "show", "manager", "commands", NULL }, handle_showmancmds, "List manager interface commands", showmancmds_help } Definition at line 260 of file manager.c.

struct ast_cli_entry show_manconn_cli [static]

Initial value: { { "show", "manager", "connected", NULL }, handle_showmanconn, "Show connected manager interface users", showmanconn_help } Definition at line 264 of file manager.c.

char showmancmd_help[] [static]

Initial value: "Usage: show manager command <actionname>\n" " Shows the detailed description for a specific Asterisk manager interface command.\n" Definition at line 243 of file manager.c.

char showmancmds_help[] [static]

Initial value: "Usage: show manager commands\n" " Prints a listing of all the available Asterisk manager interface commands.\n" Definition at line 247 of file manager.c.

char showmanconn_help[] [static]

Initial value: "Usage: show manager connected\n" " Prints a listing of the users that are currently connected to the\n" "Asterisk manager interface.\n" Definition at line 251 of file manager.c.

pthread_t t [static]

Definition at line 87 of file manager.c. Referenced by acf_odbc_write(), add_sdp(), append_date(), ast_cdr_getvar(), ast_check_timing(), ast_do_masquerade(), 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_verbose(), background_detect_exec(), build_mapping(), byteReverse(), callerid_genmsg(), callerid_getcarrier(), check_user_full(), cli_prompt(), config_text_file_save(), datetime_exec(), do_monitor(), dump_cmd_queues(), enumlookup_exec(), find_channel(), gen_tone(), gen_tones(), get_date(), get_trans_id(), handle_hd_hf(), handle_message(), iax2_datetime(), iax_template_parse(), init_manager(), launch_page(), launch_service(), listener(), localsub(), lws2sws(), manager_log(), MD5Update(), network_verboser(), packdate(), play_message_datetime(), prune_gateways(), rebuild_matrix(), register_verify(), rpt(), rpt_tele_thread(), send_request(), sendmail(), sendpage(), sqlite_log(), statechange_queue(), strip_quotes(), tdd_getcarrier(), time1(), time2(), transmit_notify_request_with_callerid(), transmit_notify_with_mwi(), transmit_state_notify(), and write_metadata().

---