Wed Aug 20 06:29:37 2008

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
struct	variable_count
Defines
#define	ASTMAN_APPEND_BUF_INITSIZE   256
#define	MANAGER_EVENT_BUF_INITSIZE   256
#define	MAX_BLACKLIST_CMD_LEN   2
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 (const 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 int	check_blacklist (const char *cmd)
static char *	complete_show_mancmd (const char *line, const char *word, int pos, int state)
static int	compress_char (char c)
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 int	variable_count_cmp_fn (void *obj, void *vstr, int flags)
static int	variable_count_hash_fn (const void *vvc, const int flags)
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
struct {
char *   words [AST_MAX_CMD_LEN]
}	command_blacklist []
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 116 of file manager.c.

Referenced by astman_append().

#define MANAGER_EVENT_BUF_INITSIZE   256

Definition at line 113 of file manager.c.

Referenced by manager_event().

#define MAX_BLACKLIST_CMD_LEN   2

Definition at line 134 of file manager.c.

Referenced by check_blacklist().

---

Function Documentation

static void* accept_thread

(

void *

ignore

)

[static]

Definition at line 2360 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, errno, pollfd::events, pollfd::fd, ast_channel::flags, 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 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);
            num_sessions--;
            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);

      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;

      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);
      num_sessions++;
      /* 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_atomic_fetchadd_int(&s->eventq->usecount, 1);
      AST_LIST_UNLOCK(&sessions);
      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 1730 of file manager.c.

References ast_calloc, ast_cli_command(), ast_free, ast_strlen_zero(), astman_append(), astman_get_header(), astman_send_error(), check_blacklist(), s, S_OR, and term_strip().

Referenced by init_manager().

{
   const char *cmd = astman_get_header(m, "Command");
   const char *id = astman_get_header(m, "ActionID");
   char *buf, *final_buf;
   char template[] = "/tmp/ast-ami-XXXXXX";  /* template for temporary file */
   int fd = mkstemp(template);
   off_t l;

   if (ast_strlen_zero(cmd)) {
      astman_send_error(s, m, "No command provided");
      return 0;
   }

   if (check_blacklist(cmd)) {
      astman_send_error(s, m, "Command blacklisted");
      return 0;
   }

   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(fd, cmd);  /* XXX need to change this to use a FILE * */
   l = lseek(fd, 0, SEEK_END);   /* how many chars available */

   /* This has a potential to overflow the stack.  Hence, use the heap. */
   buf = ast_calloc(1, l + 1);
   final_buf = ast_calloc(1, l + 1);
   if (buf) {
      lseek(fd, 0, SEEK_SET);
      read(fd, buf, l);
      buf[l] = '\0';
      if (final_buf) {
         term_strip(final_buf, buf, l);
         final_buf[l] = '\0';
      }
      astman_append(s, "%s", S_OR(final_buf, buf));
      ast_free(buf);
   }
   close(fd);
   unlink(template);
   astman_append(s, "--END COMMAND--\r\n\r\n");
   if (final_buf)
      ast_free(final_buf);
   return 0;
}

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

Definition at line 1386 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 2036 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 1115 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 1478 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 1415 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 1359 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 1404 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 2000 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 1968 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 1842 of file manager.c.

References app, ast_callerid_parse(), ast_calloc, ast_findlabel_extension(), AST_FORMAT_SLINEAR, ast_free, ast_parse_allow_disallow(), 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, ast_channel::data, exten, fast_originate(), format, name, ast_channel::priority, s, and ast_channel::tech.

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");
   const char *codecs = astman_get_header(m, "Codecs");
   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];
   int format = AST_FORMAT_SLINEAR;
   
   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");
         return 0;
      }
   }
   if (!ast_strlen_zero(timeout) && (sscanf(timeout, "%d", &to) != 1)) {
      astman_send_error(s, m, "Invalid timeout");
      return 0;
   }
   ast_copy_string(tmp, name, sizeof(tmp));
   tech = tmp;
   data = strchr(tmp, '/');
   if (!data) {
      astman_send_error(s, m, "Invalid channel");
      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_strlen_zero(codecs)) {
      format = 0;
      ast_parse_allow_disallow(NULL, &format, codecs, 1);
   }
   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->format = format;
         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)) {
            ast_free(fast);
            res = -1;
         } else {
            res = 0;
         }
         pthread_attr_destroy(&attr);
      }
   } else if (!ast_strlen_zero(app)) {
         res = ast_pbx_outgoing_app(tech, format, data, to, app, appdata, &reason, 1, l, n, vars, account, NULL);
      } else {
      if (exten && context && pi)
            res = ast_pbx_outgoing_exten(tech, format, 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<