Convert the PBX core to use read/write locks. This yields a nifty performance improve...
[asterisk/asterisk.git] / main / pbx.c
index e45495e..f129667 100644 (file)
@@ -160,7 +160,7 @@ struct ast_ignorepat {
 
 /*! \brief ast_context: An extension context */
 struct ast_context {
-       ast_mutex_t lock;                       /*!< A lock to prevent multiple threads from clobbering the context */
+       ast_rwlock_t lock;                      /*!< A lock to prevent multiple threads from clobbering the context */
        struct ast_exten *root;                 /*!< The root of the list of extensions */
        struct ast_context *next;               /*!< Link them together */
        struct ast_include *includes;           /*!< Include other contexts */
@@ -265,7 +265,8 @@ static struct pbx_builtin {
        "Answer a channel if ringing",
        "  Answer([delay]): If the call has not been answered, this application will\n"
        "answer it. Otherwise, it has no effect on the call. If a delay is specified,\n"
-       "Asterisk will wait this number of milliseconds before answering the call.\n"
+       "Asterisk will wait this number of milliseconds before returning to\n"
+       "the dialplan after answering the call.\n"
        },
 
        { "BackGround", pbx_builtin_background,
@@ -322,8 +323,13 @@ static struct pbx_builtin {
        "calling channel to continue dialplan execution at the specified priority.\n"
        "If no specific extension, or extension and context, are specified, then this\n"
        "application will jump to the specified priority of the current extension.\n"
+       "  At least a priority is required as an argument, or the goto will return a -1,\n"
+       "and the channel and call will be terminated.\n"
        "  If the attempt to jump to another location in the dialplan is not successful,\n"
-       "then the channel will continue at the next priority of the current extension.\n"
+       "then the execution engine will try to find and execute the code in the 'i' (invalid)\n"
+       "extension in the current context. If that does not exist, it will try to execute the\n"
+       "'h' extension. If either or neither the 'h' or 'i' extensions have been defined, the\n"
+       "channel is hung up, and the execution of instructions on the channel is terminated.\n"
        },
 
        { "GotoIf", pbx_builtin_gotoif,
@@ -334,7 +340,12 @@ static struct pbx_builtin {
        "'labeliftrue' if the condition is true, or 'labeliffalse' if the condition is\n"
        "false. The labels are specified with the same syntax as used within the Goto\n"
        "application.  If the label chosen by the condition is omitted, no jump is\n"
-       "performed, but execution continues with the next priority in the dialplan.\n"
+       "performed, and the execution passes to the next instruction.\n"
+       "If the target location is bogus, and does not exist, the execution engine will try \n"
+       "to find and execute the code in the 'i' (invalid)\n"
+       "extension in the current context. If that does not exist, it will try to execute the\n"
+       "'h' extension. If either or neither the 'h' or 'i' extensions have been defined, the\n"
+       "channel is hung up, and the execution of instructions on the channel is terminated.\n"
        },
 
        { "GotoIfTime", pbx_builtin_gotoiftime,
@@ -342,6 +353,7 @@ static struct pbx_builtin {
        "  GotoIfTime(<times>|<weekdays>|<mdays>|<months>?[[context|]exten|]priority):\n"
        "This application will have the calling channel jump to the specified location\n"
        "in the dialplan if the current time matches the given time specification.\n"
+       "If the target jump location is bogus, the same actions would be taken as for Goto.\n"
        },
 
        { "ImportVar", pbx_builtin_importvar,
@@ -461,7 +473,7 @@ static struct pbx_builtin {
 };
 
 static struct ast_context *contexts;
-AST_MUTEX_DEFINE_STATIC(conlock);              /*!< Lock for the ast_context list */
+AST_RWLOCK_DEFINE_STATIC(conlock);             /*!< Lock for the ast_context list */
 
 static AST_RWLIST_HEAD_STATIC(apps, ast_app);
 
@@ -863,12 +875,12 @@ int ast_extension_close(const char *pattern, const char *data, int needmore)
 struct ast_context *ast_context_find(const char *name)
 {
        struct ast_context *tmp = NULL;
-       ast_mutex_lock(&conlock);
+       ast_rdlock_contexts();
        while ( (tmp = ast_walk_contexts(tmp)) ) {
                if (!name || !strcasecmp(name, tmp->name))
                        break;
        }
-       ast_mutex_unlock(&conlock);
+       ast_unlock_contexts();
        return tmp;
 }
 
@@ -1096,7 +1108,7 @@ static char *substring(const char *value, int offset, int length, char *workspac
        return ret;
 }
 
-/*! \brief  Support for Asterisk built-in variables and functions in the dialplan
+/*! \brief  Support for Asterisk built-in variables in the dialplan
 
 \note  See also
        - \ref AstVar   Channel variables
@@ -1414,11 +1426,11 @@ int ast_func_read(struct ast_channel *chan, const char *function, char *workspac
        struct ast_custom_function *acfptr = ast_custom_function_find(copy);
 
        if (acfptr == NULL)
-               ast_log(LOG_ERROR, "Function %s not registered\n", function);
+               ast_log(LOG_ERROR, "Function %s not registered\n", copy);
        else if (!acfptr->read)
-               ast_log(LOG_ERROR, "Function %s cannot be read\n", function);
+               ast_log(LOG_ERROR, "Function %s cannot be read\n", copy);
        else
-               return acfptr->read(chan, function, args, workspace, len);
+               return acfptr->read(chan, copy, args, workspace, len);
        return -1;
 }
 
@@ -1429,11 +1441,11 @@ int ast_func_write(struct ast_channel *chan, const char *function, const char *v
        struct ast_custom_function *acfptr = ast_custom_function_find(copy);
 
        if (acfptr == NULL)
-               ast_log(LOG_ERROR, "Function %s not registered\n", function);
+               ast_log(LOG_ERROR, "Function %s not registered\n", copy);
        else if (!acfptr->write)
-               ast_log(LOG_ERROR, "Function %s cannot be written to\n", function);
+               ast_log(LOG_ERROR, "Function %s cannot be written to\n", copy);
        else
-               return acfptr->write(chan, function, args, value);
+               return acfptr->write(chan, copy, args, value);
 
        return -1;
 }
@@ -1459,7 +1471,7 @@ static void pbx_substitute_variables_helper_full(struct ast_channel *c, struct v
                nextexp = NULL;
                nextthing = strchr(whereweare, '$');
                if (nextthing) {
-                       switch(nextthing[1]) {
+                       switch (nextthing[1]) {
                        case '{':
                                nextvar = nextthing;
                                pos = nextvar - whereweare;
@@ -1563,7 +1575,7 @@ static void pbx_substitute_variables_helper_full(struct ast_channel *c, struct v
                        needsub = 0;
 
                        /* Find the end of it */
-                       while(brackets && *vare) {
+                       while (brackets && *vare) {
                                if ((vare[0] == '$') && (vare[1] == '[')) {
                                        needsub++;
                                        brackets++;
@@ -1631,7 +1643,7 @@ static void pbx_substitute_variables(char *passdata, int datalen, struct ast_cha
        memset(passdata, 0, datalen);
 
        /* No variables or expressions in e->data, so why scan it? */
-       if (!strchr(e->data, '$') && !strstr(e->data,"${") && !strstr(e->data,"$[") && !strstr(e->data,"$(")) {
+       if (e->data && !strchr(e->data, '$') && !strstr(e->data,"${") && !strstr(e->data,"$[") && !strstr(e->data,"$(")) {
                ast_copy_string(passdata, e->data, datalen);
                return;
        }
@@ -1660,21 +1672,21 @@ static int pbx_extension_helper(struct ast_channel *c, struct ast_context *con,
 
        int matching_action = (action == E_MATCH || action == E_CANMATCH || action == E_MATCHMORE);
 
-       ast_mutex_lock(&conlock);
+       ast_rdlock_contexts();
        e = pbx_find_extension(c, con, &q, context, exten, priority, label, callerid, action);
        if (e) {
                if (matching_action) {
-                       ast_mutex_unlock(&conlock);
+                       ast_unlock_contexts();
                        return -1;      /* success, we found it */
                } else if (action == E_FINDLABEL) { /* map the label to a priority */
                        res = e->priority;
-                       ast_mutex_unlock(&conlock);
+                       ast_unlock_contexts();
                        return res;     /* the priority we were looking for */
                } else {        /* spawn */
                        if (!e->cached_app)
                                e->cached_app = pbx_findapp(e->app);
                        app = e->cached_app;
-                       ast_mutex_unlock(&conlock);
+                       ast_unlock_contexts();
                        if (!app) {
                                ast_log(LOG_WARNING, "No application '%s' for extension (%s, %s, %d)\n", e->app, context, exten, priority);
                                return -1;
@@ -1716,7 +1728,7 @@ static int pbx_extension_helper(struct ast_channel *c, struct ast_context *con,
                        return pbx_exec(c, app, passdata);      /* 0 on success, -1 on failure */
                }
        } else if (q.swo) {     /* not found here, but in another switch */
-               ast_mutex_unlock(&conlock);
+               ast_unlock_contexts();
                if (matching_action)
                        return -1;
                else {
@@ -1727,7 +1739,7 @@ static int pbx_extension_helper(struct ast_channel *c, struct ast_context *con,
                        return q.swo->exec(c, q.foundcontext ? q.foundcontext : context, exten, priority, callerid, q.data);
                }
        } else {        /* not found anywhere, see what happened */
-               ast_mutex_unlock(&conlock);
+               ast_unlock_contexts();
                switch (q.status) {
                case STATUS_NO_CONTEXT:
                        if (!matching_action)
@@ -1760,9 +1772,9 @@ static struct ast_exten *ast_hint_extension(struct ast_channel *c, const char *c
        struct ast_exten *e;
        struct pbx_find_info q = { .stacklen = 0 }; /* the rest is set in pbx_find_context */
 
-       ast_mutex_lock(&conlock);
+       ast_rdlock_contexts();
        e = pbx_find_extension(c, NULL, &q, context, exten, PRIORITY_HINT, NULL, "", E_MATCH);
-       ast_mutex_unlock(&conlock);
+       ast_unlock_contexts();
 
        return e;
 }
@@ -2402,7 +2414,7 @@ static int __ast_pbx_run(struct ast_channel *c)
                if (c->cdr && ast_opt_end_cdr_before_h_exten)
                        ast_cdr_end(c->cdr);
                set_ext_pri(c, "h", 1);
-               while(ast_exists_extension(c, c->context, c->exten, c->priority, c->cid.cid_num)) {
+               while (ast_exists_extension(c, c->context, c->exten, c->priority, c->cid.cid_num)) {
                        if ((res = ast_spawn_extension(c, c->context, c->exten, c->priority, c->cid.cid_num))) {
                                /* Something bad happened, or a hangup has been requested. */
                                if (option_debug)
@@ -2505,8 +2517,10 @@ enum ast_pbx_result ast_pbx_start(struct ast_channel *c)
        pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
        if (ast_pthread_create(&t, &attr, pbx_thread, c)) {
                ast_log(LOG_WARNING, "Failed to create new channel thread\n");
+               pthread_attr_destroy(&attr);
                return AST_PBX_FAILED;
        }
+       pthread_attr_destroy(&attr);
 
        return AST_PBX_SUCCESS;
 }
@@ -2543,7 +2557,7 @@ static struct ast_context *find_context_locked(const char *context)
 {
        struct ast_context *c = NULL;
 
-       ast_lock_contexts();
+       ast_rdlock_contexts();
        while ( (c = ast_walk_contexts(c)) ) {
                if (!strcmp(ast_get_context_name(c), context))
                        return c;
@@ -2584,7 +2598,7 @@ int ast_context_remove_include2(struct ast_context *con, const char *include, co
        struct ast_include *i, *pi = NULL;
        int ret = -1;
 
-       ast_mutex_lock(&con->lock);
+       ast_wrlock_context(con);
 
        /* find our include */
        for (i = con->includes; i; pi = i, i = i->next) {
@@ -2602,7 +2616,8 @@ int ast_context_remove_include2(struct ast_context *con, const char *include, co
                }
        }
 
-       ast_mutex_unlock(&con->lock);
+       ast_unlock_context(con);
+
        return ret;
 }
 
@@ -2637,7 +2652,7 @@ int ast_context_remove_switch2(struct ast_context *con, const char *sw, const ch
        struct ast_sw *i;
        int ret = -1;
 
-       ast_mutex_lock(&con->lock);
+       ast_wrlock_context(con);
 
        /* walk switches */
        AST_LIST_TRAVERSE_SAFE_BEGIN(&con->alts, i, list) {
@@ -2652,7 +2667,7 @@ int ast_context_remove_switch2(struct ast_context *con, const char *sw, const ch
        }
        AST_LIST_TRAVERSE_SAFE_END
 
-       ast_mutex_unlock(&con->lock);
+       ast_unlock_context(con);
 
        return ret;
 }
@@ -2689,7 +2704,7 @@ int ast_context_remove_extension2(struct ast_context *con, const char *extension
        struct ast_exten *exten, *prev_exten = NULL;
        struct ast_exten *peer;
 
-       ast_mutex_lock(&con->lock);
+       ast_wrlock_context(con);
 
        /* scan the extension list to find matching extension-registrar */
        for (exten = con->root; exten; prev_exten = exten, exten = exten->next) {
@@ -2699,7 +2714,7 @@ int ast_context_remove_extension2(struct ast_context *con, const char *extension
        }
        if (!exten) {
                /* we can't find right extension */
-               ast_mutex_unlock(&con->lock);
+               ast_unlock_context(con);
                return -1;
        }
 
@@ -2726,7 +2741,7 @@ int ast_context_remove_extension2(struct ast_context *con, const char *extension
                                break; /* found our priority */
                }
                if (!peer) { /* not found */
-                       ast_mutex_unlock(&con->lock);
+                       ast_unlock_context(con);
                        return -1;
                }
                /* we are first priority extension? */
@@ -2751,7 +2766,7 @@ int ast_context_remove_extension2(struct ast_context *con, const char *extension
                destroy_exten(peer);
                /* XXX should we return -1 ? */
        }
-       ast_mutex_unlock(&con->lock);
+       ast_unlock_context(con);
        return 0;
 }
 
@@ -2766,7 +2781,7 @@ int ast_context_lockmacro(const char *context)
        struct ast_context *c = NULL;
        int ret = -1;
 
-       ast_lock_contexts();
+       ast_rdlock_contexts();
 
        while ((c = ast_walk_contexts(c))) {
                if (!strcmp(ast_get_context_name(c), context)) {
@@ -2794,7 +2809,7 @@ int ast_context_unlockmacro(const char *context)
        struct ast_context *c = NULL;
        int ret = -1;
 
-       ast_lock_contexts();
+       ast_rdlock_contexts();
 
        while ((c = ast_walk_contexts(c))) {
                if (!strcmp(ast_get_context_name(c), context)) {
@@ -3175,7 +3190,7 @@ static char *complete_show_dialplan_context(const char *line, const char *word,
        if (pos != 2)
                return NULL;
 
-       ast_lock_contexts();
+       ast_rdlock_contexts();
 
        wordlen = strlen(word);
 
@@ -3222,7 +3237,7 @@ static int show_dialplan_helper(int fd, const char *context, const char *exten,
        struct ast_context *c = NULL;
        int res = 0, old_total_exten = dpc->total_exten;
 
-       ast_lock_contexts();
+       ast_rdlock_contexts();
 
        /* walk all contexts ... */
        while ( (c = ast_walk_contexts(c)) ) {
@@ -3237,7 +3252,7 @@ static int show_dialplan_helper(int fd, const char *context, const char *exten,
 
                dpc->context_existence = 1;
 
-               ast_lock_context(c);
+               ast_rdlock_context(c);
 
                /* are we looking for exten too? if yes, we print context
                 * only if we find our extension.
@@ -3450,7 +3465,7 @@ static int manager_show_dialplan_helper(struct mansession *s, const struct messa
                ast_log(LOG_DEBUG, "manager_show_dialplan: Context: -%s- Extension: -%s-\n", context, exten);
 
        /* try to lock contexts */
-       if (ast_lock_contexts()) {
+       if (ast_rdlock_contexts()) {
                astman_send_error(s, m, "Failed to lock contexts\r\n");
                ast_log(LOG_WARNING, "Failed to lock contexts list for manager: listdialplan\n");
                return -1;
@@ -3470,7 +3485,7 @@ static int manager_show_dialplan_helper(struct mansession *s, const struct messa
                if (option_debug > 2)
                        ast_log(LOG_DEBUG, "manager_show_dialplan: Found Context: %s \n", ast_get_context_name(c));
 
-               if (ast_lock_context(c)) {      /* failed to lock */
+               if (ast_rdlock_context(c)) {    /* failed to lock */
                        if (option_debug > 2)
                                ast_log(LOG_DEBUG, "manager_show_dialplan: Failed to lock context\n");
                        continue;
@@ -3717,7 +3732,7 @@ static void unreference_cached_app(struct ast_app *app)
        struct ast_context *context = NULL;
        struct ast_exten *eroot = NULL, *e = NULL;
 
-       ast_lock_contexts();
+       ast_rdlock_contexts();
        while ((context = ast_walk_contexts(context))) {
                while ((eroot = ast_walk_context_extensions(context, eroot))) {
                        while ((e = ast_walk_extension_priorities(eroot, e))) {
@@ -3758,7 +3773,7 @@ static struct ast_context *__ast_context_create(struct ast_context **extcontexts
        int length = sizeof(struct ast_context) + strlen(name) + 1;
 
        if (!extcontexts) {
-               ast_mutex_lock(&conlock);
+               ast_wrlock_contexts();
                local_contexts = &contexts;
        } else
                local_contexts = extcontexts;
@@ -3770,12 +3785,12 @@ static struct ast_context *__ast_context_create(struct ast_context **extcontexts
                                tmp = NULL;
                        }
                        if (!extcontexts)
-                               ast_mutex_unlock(&conlock);
+                               ast_unlock_contexts();
                        return tmp;
                }
        }
        if ((tmp = ast_calloc(1, length))) {
-               ast_mutex_init(&tmp->lock);
+               ast_rwlock_init(&tmp->lock);
                ast_mutex_init(&tmp->macrolock);
                strcpy(tmp->name, name);
                tmp->root = NULL;
@@ -3791,7 +3806,7 @@ static struct ast_context *__ast_context_create(struct ast_context **extcontexts
        }
 
        if (!extcontexts)
-               ast_mutex_unlock(&conlock);
+               ast_unlock_contexts();
        return tmp;
 }
 
@@ -3836,7 +3851,7 @@ void ast_merge_contexts_and_delete(struct ast_context **extcontexts, const char
           in addition, the locks _must_ be taken in this order, because there are already
           other code paths that use this order
        */
-       ast_mutex_lock(&conlock);
+       ast_wrlock_contexts();
        AST_RWLIST_WRLOCK(&hints);
 
        /* preserve all watchers for hints associated with this registrar */
@@ -3914,7 +3929,7 @@ void ast_merge_contexts_and_delete(struct ast_context **extcontexts, const char
        }
 
        AST_RWLIST_UNLOCK(&hints);
-       ast_mutex_unlock(&conlock);
+       ast_unlock_contexts();
 
        return;
 }
@@ -4218,13 +4233,13 @@ int ast_context_add_include2(struct ast_context *con, const char *value,
        new_include->next      = NULL;
        new_include->registrar = registrar;
 
-       ast_mutex_lock(&con->lock);
+       ast_wrlock_context(con);
 
        /* ... go to last include and check if context is already included too... */
        for (i = con->includes; i; i = i->next) {
                if (!strcasecmp(i->name, new_include->name)) {
                        free(new_include);
-                       ast_mutex_unlock(&con->lock);
+                       ast_unlock_context(con);
                        errno = EEXIST;
                        return -1;
                }
@@ -4238,7 +4253,8 @@ int ast_context_add_include2(struct ast_context *con, const char *value,
                con->includes = new_include;
        if (option_verbose > 2)
                ast_verbose(VERBOSE_PREFIX_3 "Including context '%s' in context '%s'\n", new_include->name, ast_get_context_name(con));
-       ast_mutex_unlock(&con->lock);
+
+       ast_unlock_context(con);
 
        return 0;
 }
@@ -4308,13 +4324,13 @@ int ast_context_add_switch2(struct ast_context *con, const char *value,
        new_sw->registrar = registrar;
 
        /* ... try to lock this context ... */
-       ast_mutex_lock(&con->lock);
+       ast_wrlock_context(con);
 
        /* ... go to last sw and check if context is already swd too... */
        AST_LIST_TRAVERSE(&con->alts, i, list) {
                if (!strcasecmp(i->name, new_sw->name) && !strcasecmp(i->data, new_sw->data)) {
                        free(new_sw);
-                       ast_mutex_unlock(&con->lock);
+                       ast_unlock_context(con);
                        errno = EEXIST;
                        return -1;
                }
@@ -4326,7 +4342,7 @@ int ast_context_add_switch2(struct ast_context *con, const char *value,
        if (option_verbose > 2)
                ast_verbose(VERBOSE_PREFIX_3 "Including switch '%s/%s' in context '%s'\n", new_sw->name, new_sw->data, ast_get_context_name(con));
 
-       ast_mutex_unlock(&con->lock);
+       ast_unlock_context(con);
 
        return 0;
 }
@@ -4351,7 +4367,7 @@ int ast_context_remove_ignorepat2(struct ast_context *con, const char *ignorepat
 {
        struct ast_ignorepat *ip, *ipl = NULL;
 
-       ast_mutex_lock(&con->lock);
+       ast_wrlock_context(con);
 
        for (ip = con->ignorepats; ip; ip = ip->next) {
                if (!strcmp(ip->pattern, ignorepat) &&
@@ -4363,13 +4379,13 @@ int ast_context_remove_ignorepat2(struct ast_context *con, const char *ignorepat
                                con->ignorepats = ip->next;
                                free(ip);
                        }
-                       ast_mutex_unlock(&con->lock);
+                       ast_unlock_context(con);
                        return 0;
                }
                ipl = ip;
        }
 
-       ast_mutex_unlock(&con->lock);
+       ast_unlock_context(con);
        errno = EINVAL;
        return -1;
 }
@@ -4404,12 +4420,12 @@ int ast_context_add_ignorepat2(struct ast_context *con, const char *value, const
        strcpy((char *)ignorepat->pattern, value);
        ignorepat->next = NULL;
        ignorepat->registrar = registrar;
-       ast_mutex_lock(&con->lock);
+       ast_wrlock_context(con);
        for (ignorepatc = con->ignorepats; ignorepatc; ignorepatc = ignorepatc->next) {
                ignorepatl = ignorepatc;
                if (!strcasecmp(ignorepatc->pattern, value)) {
                        /* Already there */
-                       ast_mutex_unlock(&con->lock);
+                       ast_unlock_context(con);
                        errno = EEXIST;
                        return -1;
                }
@@ -4418,7 +4434,7 @@ int ast_context_add_ignorepat2(struct ast_context *con, const char *value, const
                ignorepatl->next = ignorepat;
        else
                con->ignorepats = ignorepat;
-       ast_mutex_unlock(&con->lock);
+       ast_unlock_context(con);
        return 0;
 
 }
@@ -4538,7 +4554,7 @@ static int ext_strncpy(char *dst, const char *src, int len)
        int count=0;
 
        while (*src && (count < len - 1)) {
-               switch(*src) {
+               switch (*src) {
                case ' ':
                        /*      otherwise exten => [a-b],1,... doesn't work */
                        /*              case '-': */
@@ -4556,10 +4572,6 @@ static int ext_strncpy(char *dst, const char *src, int len)
        return count;
 }
 
-static void null_datad(void *foo)
-{
-}
-
 /*! \brief add the extension in the priority chain.
  * returns 0 on success, -1 on failure
  */
@@ -4581,7 +4593,8 @@ static int add_pri(struct ast_context *con, struct ast_exten *tmp,
                   replacement?  If so, replace, otherwise, bonk. */
                if (!replace) {
                        ast_log(LOG_WARNING, "Unable to register extension '%s', priority %d in '%s', already in use\n", tmp->exten, tmp->priority, con->name);
-                       tmp->datad(tmp->data);
+                       if (tmp->datad)
+                               tmp->datad(tmp->data);
                        free(tmp);
                        return -1;
                }
@@ -4599,7 +4612,8 @@ static int add_pri(struct ast_context *con, struct ast_exten *tmp,
                if (tmp->priority == PRIORITY_HINT)
                        ast_change_hint(e,tmp);
                /* Destroy the old one */
-               e->datad(e->data);
+               if (e->datad)
+                       e->datad(e->data);
                free(e);
        } else {        /* Slip ourselves in just before e */
                tmp->peer = e;
@@ -4683,8 +4697,6 @@ int ast_add_extension2(struct ast_context *con,
                length ++;      /* just the '\0' */
 
        /* Be optimistic:  Build the extension structure first */
-       if (datad == NULL)
-               datad = null_datad;
        if (!(tmp = ast_calloc(1, length)))
                return -1;
 
@@ -4713,7 +4725,7 @@ int ast_add_extension2(struct ast_context *con,
        tmp->datad = datad;
        tmp->registrar = registrar;
 
-       ast_mutex_lock(&con->lock);
+       ast_wrlock_context(con);
        res = 0; /* some compilers will think it is uninitialized otherwise */
        for (e = con->root; e; el = e, e = e->next) {   /* scan the extension list */
                res = ext_cmp(e->exten, extension);
@@ -4732,7 +4744,7 @@ int ast_add_extension2(struct ast_context *con,
        }
        if (e && res == 0) { /* exact match, insert in the pri chain */
                res = add_pri(con, tmp, el, e, replace);
-               ast_mutex_unlock(&con->lock);
+               ast_unlock_context(con);
                if (res < 0) {
                        errno = EEXIST; /* XXX do we care ? */
                        return 0; /* XXX should we return -1 maybe ? */
@@ -4747,17 +4759,19 @@ int ast_add_extension2(struct ast_context *con,
                        el->next = tmp;
                else
                        con->root = tmp;
-               ast_mutex_unlock(&con->lock);
+               ast_unlock_context(con);
                if (tmp->priority == PRIORITY_HINT)
                        ast_add_hint(tmp);
        }
        if (option_debug) {
                if (tmp->matchcid) {
-                       ast_log(LOG_DEBUG, "Added extension '%s' priority %d (CID match '%s') to %s\n",
-                               tmp->exten, tmp->priority, tmp->cidmatch, con->name);
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "Added extension '%s' priority %d (CID match '%s') to %s\n",
+                                       tmp->exten, tmp->priority, tmp->cidmatch, con->name);
                } else {
-                       ast_log(LOG_DEBUG, "Added extension '%s' priority %d to %s\n",
-                               tmp->exten, tmp->priority, con->name);
+                       if (option_debug)
+                               ast_log(LOG_DEBUG, "Added extension '%s' priority %d to %s\n",
+                                       tmp->exten, tmp->priority, con->name);
                }
        }
        if (option_verbose > 2) {
@@ -4942,7 +4956,7 @@ int ast_pbx_outgoing_exten(const char *type, int format, void *data, int timeout
                                if (option_verbose > 3)
                                        ast_verbose(VERBOSE_PREFIX_4 "Channel %s was never answered.\n", chan->name);
 
-                               if(chan->cdr) { /* update the cdr */
+                               if (chan->cdr) { /* update the cdr */
                                        /* here we update the status of the call, which sould be busy.
                                         * if that fails then we set the status to failed */
                                        if (ast_cdr_disposition(chan->cdr, chan->hangupcause))
@@ -5016,8 +5030,10 @@ int ast_pbx_outgoing_exten(const char *type, int format, void *data, int timeout
                        }
                        ast_hangup(chan);
                        res = -1;
+                       pthread_attr_destroy(&attr);
                        goto outgoing_exten_cleanup;
                }
+               pthread_attr_destroy(&attr);
                res = 0;
        }
 outgoing_exten_cleanup:
@@ -5074,7 +5090,7 @@ int ast_pbx_outgoing_app(const char *type, int format, void *data, int timeout,
                                ast_log(LOG_WARNING, "%s already has a call record??\n", chan->name);
                        } else {
                                chan->cdr = ast_cdr_alloc();   /* allocate a cdr for the channel */
-                               if(!chan->cdr) {
+                               if (!chan->cdr) {
                                        /* allocation of the cdr failed */
                                        free(chan->pbx);
                                        res = -1;
@@ -5119,6 +5135,7 @@ int ast_pbx_outgoing_app(const char *type, int format, void *data, int timeout,
                                                        if (locked_channel)
                                                                *locked_channel = chan;
                                                }
+                                               pthread_attr_destroy(&attr);
                                        }
                                }
                        } else {
@@ -5177,11 +5194,13 @@ int ast_pbx_outgoing_app(const char *type, int format, void *data, int timeout,
                                ast_channel_unlock(chan);
                        ast_hangup(chan);
                        res = -1;
+                       pthread_attr_destroy(&attr);
                        goto outgoing_app_cleanup;
                } else {
                        if (locked_channel)
                                *locked_channel = chan;
                }
+               pthread_attr_destroy(&attr);
                res = 0;
        }
 outgoing_app_cleanup:
@@ -5197,7 +5216,7 @@ void __ast_context_destroy(struct ast_context *con, const char *registrar)
        struct ast_exten *e, *el, *en;
        struct ast_ignorepat *ipi;
 
-       ast_mutex_lock(&conlock);
+       ast_wrlock_contexts();
        for (tmp = contexts; tmp; ) {
                struct ast_context *next;       /* next starting point */
                for (; tmp; tmpl = tmp, tmp = tmp->next) {
@@ -5209,7 +5228,7 @@ void __ast_context_destroy(struct ast_context *con, const char *registrar)
                }
                if (!tmp)       /* not found, we are done */
                        break;
-               ast_mutex_lock(&tmp->lock);
+               ast_wrlock_context(tmp);
                if (option_debug)
                        ast_log(LOG_DEBUG, "delete ctx %s %s\n", tmp->name, tmp->registrar);
                next = tmp->next;
@@ -5219,7 +5238,7 @@ void __ast_context_destroy(struct ast_context *con, const char *registrar)
                        contexts = next;
                /* Okay, now we're safe to let it go -- in a sense, we were
                   ready to let it go as soon as we locked it. */
-               ast_mutex_unlock(&tmp->lock);
+               ast_unlock_context(tmp);
                for (tmpi = tmp->includes; tmpi; ) { /* Free includes */
                        struct ast_include *tmpil = tmpi;
                        tmpi = tmpi->next;
@@ -5242,12 +5261,12 @@ void __ast_context_destroy(struct ast_context *con, const char *registrar)
                        e = e->next;
                        destroy_exten(el);
                }
-               ast_mutex_destroy(&tmp->lock);
+               ast_rwlock_destroy(&tmp->lock);
                free(tmp);
                /* if we have a specific match, we are done, otherwise continue */
                tmp = con ? NULL : next;
        }
-       ast_mutex_unlock(&conlock);
+       ast_unlock_contexts();
 }
 
 void ast_context_destroy(struct ast_context *con, const char *registrar)
@@ -5329,21 +5348,11 @@ static int pbx_builtin_congestion(struct ast_channel *chan, void *data)
 static int pbx_builtin_answer(struct ast_channel *chan, void *data)
 {
        int delay = 0;
-       int res;
 
-       if (chan->_state == AST_STATE_UP)
-               delay = 0;
-       else if (!ast_strlen_zero(data))
+       if ((chan->_state != AST_STATE_UP) && !ast_strlen_zero(data))
                delay = atoi(data);
 
-       res = ast_answer(chan);
-       if (res)
-               return res;
-
-       if (delay)
-               res = ast_safe_sleep(chan, delay);
-
-       return res;
+       return __ast_answer(chan, delay);
 }
 
 AST_APP_OPTIONS(resetcdr_opts, {
@@ -5578,10 +5587,10 @@ static int pbx_builtin_background(struct ast_channel *chan, void *data)
 
        AST_STANDARD_APP_ARGS(args, parse);
 
-       if (!args.lang)
+       if (ast_strlen_zero(args.lang))
                args.lang = (char *)chan->language;     /* XXX this is const */
 
-       if (!args.context)
+       if (ast_strlen_zero(args.context))
                args.context = chan->context;
 
        if (args.options) {
@@ -5978,27 +5987,37 @@ int load_pbx(void)
 /*
  * Lock context list functions ...
  */
-int ast_lock_contexts()
+int ast_wrlock_contexts()
+{
+       return ast_rwlock_wrlock(&conlock);
+}
+
+int ast_rdlock_contexts()
 {
-       return ast_mutex_lock(&conlock);
+       return ast_rwlock_rdlock(&conlock);
 }
 
 int ast_unlock_contexts()
 {
-       return ast_mutex_unlock(&conlock);
+       return ast_rwlock_unlock(&conlock);
 }
 
 /*
  * Lock context ...
  */
-int ast_lock_context(struct ast_context *con)
+int ast_wrlock_context(struct ast_context *con)
+{
+       return ast_rwlock_wrlock(&con->lock);
+}
+
+int ast_rdlock_context(struct ast_context *con)
 {
-       return ast_mutex_lock(&con->lock);
+       return ast_rwlock_rdlock(&con->lock);
 }
 
 int ast_unlock_context(struct ast_context *con)
 {
-       return ast_mutex_unlock(&con->lock);
+       return ast_rwlock_unlock(&con->lock);
 }
 
 /*