pbx.c

	        		
	        	
		                                                

static int pbx_extension_helper(struct ast_channel *c, char *context, char *exten, int priority, char *callerid, int action) 
{
	struct ast_exten *e;
	struct ast_app *app;
	struct ast_switch *sw;
	char *data;
	char *newdata;
	int newstack = 0;
	int res;
	int status = 0;
	char *incstack[AST_PBX_MAX_STACK];
	int stacklen = 0;
	char tmp[80];
	char tmp2[80];
	char tmp3[256];
	if (ast_pthread_mutex_lock(&conlock)) {
		ast_log(LOG_WARNING, "Unable to obtain lock\n");
		if ((action == HELPER_EXISTS) || (action == HELPER_CANMATCH) || (action == HELPER_MATCHMORE))
			return 0;
		else
			return -1;
	}
	e = pbx_find_extension(c, context, exten, priority, callerid, action, incstack, &stacklen, &status, &sw, &data);
	if (e) {
		switch(action) {
		case HELPER_CANMATCH:
			pthread_mutex_unlock(&conlock);
			return -1;
		case HELPER_EXISTS:
			pthread_mutex_unlock(&conlock);
			return -1;
		case HELPER_MATCHMORE:
			pthread_mutex_unlock(&conlock);
			return -1;
		case HELPER_SPAWN:
			newstack++;
			/* Fall through */
		case HELPER_EXEC:
			app = pbx_findapp(e->app);
			pthread_mutex_unlock(&conlock);
			if (app) {
				strncpy(c->context, context, sizeof(c->context-1));
				strncpy(c->exten, exten, sizeof(c->exten)-1);
				c->priority = priority;
				newdata=pbx_substitute_variables(c,e);
				if (option_debug)
						ast_log(LOG_DEBUG, "Launching '%s'\n", app->name);
				else if (option_verbose > 2)
						ast_verbose( VERBOSE_PREFIX_3 "Executing %s(\"%s\", \"%s\") %s\n", 
								term_color(tmp, app->name, COLOR_BRCYAN, 0, sizeof(tmp)),
								term_color(tmp2, c->name, COLOR_BRMAGENTA, 0, sizeof(tmp2)),
								term_color(tmp3, (newdata ? (char *)newdata : NULL), COLOR_BRMAGENTA, 0, sizeof(tmp3)),
								(newstack ? "in new stack" : "in same stack"));
				res = pbx_exec(c, app, newdata, newstack);
				free(newdata);
				return res;
			} else {
				ast_log(LOG_WARNING, "No application '%s' for extension (%s, %s, %d)\n", e->app, context, exten, priority);
				return -1;
			}
		default:
			ast_log(LOG_WARNING, "Huh (%d)?\n", action);			return -1;
		}
	} else if (sw) {
		switch(action) {
		case HELPER_CANMATCH:
			pthread_mutex_unlock(&conlock);
			return -1;
		case HELPER_EXISTS:
			pthread_mutex_unlock(&conlock);
			return -1;
		case HELPER_MATCHMORE:
			pthread_mutex_unlock(&conlock);
			return -1;
		case HELPER_SPAWN:
			newstack++;
			/* Fall through */
		case HELPER_EXEC:
			pthread_mutex_unlock(&conlock);
			if (sw->exec)
				res = sw->exec(c, context, exten, priority, callerid, newstack, data);
			else {
				ast_log(LOG_WARNING, "No execution engine for switch %s\n", sw->name);
				res = -1;
			}
			return res;
		default:
			ast_log(LOG_WARNING, "Huh (%d)?\n", action);
			return -1;
		}
	} else {
		pthread_mutex_unlock(&conlock);
		switch(status) {
		case STATUS_NO_CONTEXT:
			if ((action != HELPER_EXISTS) && (action != HELPER_MATCHMORE))
				ast_log(LOG_NOTICE, "Cannot find extension context '%s'\n", context);
			break;
		case STATUS_NO_EXTENSION:
			if ((action != HELPER_EXISTS) && (action !=  HELPER_CANMATCH) && (action != HELPER_MATCHMORE))
				ast_log(LOG_NOTICE, "Cannot find extension '%s' in context '%s'\n", exten, context);
			break;
		case STATUS_NO_PRIORITY:
			if ((action != HELPER_EXISTS) && (action !=  HELPER_CANMATCH) && (action != HELPER_MATCHMORE))
				ast_log(LOG_NOTICE, "No such priority %d in extension '%s' in context '%s'\n", priority, exten, context);
			break;
		default:
			ast_log(LOG_DEBUG, "Shouldn't happen!\n");
		}
		if ((action != HELPER_EXISTS) && (action != HELPER_CANMATCH) && (action != HELPER_MATCHMORE))
			return -1;
		else
			return 0;
	}

}

static struct ast_exten *ast_hint_extension(struct ast_channel *c, char *context, char *exten)
{
	struct ast_exten *e;
	struct ast_switch *sw;
	char *data;
	int status = 0;
	char *incstack[AST_PBX_MAX_STACK];
	int stacklen = 0;

	if (ast_pthread_mutex_lock(&conlock)) {
		ast_log(LOG_WARNING, "Unable to obtain lock\n");
		return NULL;
	}
	e = pbx_find_extension(c, context, exten, PRIORITY_HINT, "", HELPER_EXISTS, incstack, &stacklen, &status, &sw, &data);
	ast_pthread_mutex_unlock(&conlock);	
	return e;
}

static int ast_extension_state2(struct ast_exten *e)
{
    char hint[AST_MAX_EXTENSION] = "";    
    char *cur, *rest;
    int res = -1;
    int allunavailable = 1, allbusy = 1, allfree = 1;
    int busy = 0;

    strncpy(hint, ast_get_extension_app(e), sizeof(hint)-1);
    
    cur = hint;    
    do {
	rest = strchr(cur, '&');
	if (rest) {
	    *rest = 0;
	    rest++;
	}
	
	res = ast_device_state(cur);
	switch (res) {
    case AST_DEVICE_NOT_INUSE:
		allunavailable = 0;
		allbusy = 0;
		break;
    case AST_DEVICE_INUSE:
		return AST_EXTENSION_INUSE;
    case AST_DEVICE_BUSY:
		allunavailable = 0;
		allfree = 0;
		busy = 1;
		break;
    case AST_DEVICE_UNAVAILABLE:
    case AST_DEVICE_INVALID:
		allbusy = 0;
		allfree = 0;
		break;
    default:
		allunavailable = 0;
		allbusy = 0;
		allfree = 0;
	}
        cur = rest;
    } while (cur);

    if (allfree)
		return AST_EXTENSION_NOT_INUSE;
    if (allbusy)
		return AST_EXTENSION_BUSY;
    if (allunavailable)
		return AST_EXTENSION_UNAVAILABLE;
    if (busy) 
		return AST_EXTENSION_INUSE;
	
    return AST_EXTENSION_NOT_INUSE;
}


int ast_extension_state(struct ast_channel *c, char *context, char *exten)
{
    struct ast_exten *e;

    e = ast_hint_extension(c, context, exten);    
    if (!e) 
	return -1;

    return ast_extension_state2(e);    
}

int ast_device_state_changed(const char *fmt, ...) 
{
    struct ast_hint *list;
    struct ast_state_cb *cblist;
    char hint[AST_MAX_EXTENSION];
    char device[AST_MAX_EXTENSION];
    char *cur, *rest;
    int state;
    
    va_list ap;

    va_start(ap, fmt);
    vsnprintf(device, sizeof(device)-1, fmt, ap);
    va_end(ap);

    rest = strchr(device, '-');
    if (rest) {
	*rest = 0;
    }
        
    pthread_mutex_lock(&hintlock);

    list = hints;
    
    while (list) {
	
	strcpy(hint, ast_get_extension_app(list->exten));
	cur = hint;
	do {
	    rest = strchr(cur, '&');
	    if (rest) {
		*rest = 0;
		rest++;
	    }
	    
	    if (!strcmp(cur, device)) {
	    // Found extension execute callbacks 
		state = ast_extension_state2(list->exten);
		if ((state != -1) && (state != list->laststate)) {
		    // For general callbacks
		    cblist = statecbs;
		    while (cblist) {
			cblist->callback(list->exten->parent->name, list->exten->exten, state, cblist->data);
			cblist = cblist->next;
		    }
		    
		    // For extension callbacks
    		    cblist = list->callbacks;
		    while (cblist) {
			cblist->callback(list->exten->parent->name, list->exten->exten, state, cblist->data);
			cblist = cblist->next;
		    }
		    
		    list->laststate = state;
		}
		break;
	    }
	    cur = rest;
	} while (cur);
	
	list = list->next;
    }

    pthread_mutex_unlock(&hintlock);
    return 1;
}
			
int ast_extension_state_add(char *context, char *exten, 
			    ast_state_cb_type callback, void *data)
{
    struct ast_hint *list;
    struct ast_state_cb *cblist;
    struct ast_exten *e;

    /* No context and extension add callback to statecbs list */
    if (!context && !exten) {
	pthread_mutex_lock(&hintlock);

	cblist = statecbs;
	while (cblist) {
	    if (cblist->callback == callback) {
		cblist->data = data;
		pthread_mutex_unlock(&hintlock);
	    }
	    
	    cblist = cblist->next;
	}
	
	/* Now inserts the callback */
	cblist = malloc(sizeof(struct ast_state_cb));
	if (!cblist) {
	    pthread_mutex_unlock(&hintlock);
	    return -1;
	}
	memset(cblist, 0, sizeof(struct ast_state_cb));
	cblist->id = 0;
	cblist->callback = callback;
	cblist->data = data;

        cblist->next = statecbs;
	statecbs = cblist;

	pthread_mutex_unlock(&hintlock);
	return 0;
    }

    if (!context || !exten)
	return -1;

    /* This callback type is for only one hint */
    e = ast_hint_extension(NULL, context, exten);    
    if (!e) {
        return -1;
    }
    
    pthread_mutex_lock(&hintlock);
    list = hints;        
    
    while (list) {
	if (list->exten == e)
	    break;	    
	list = list->next;    
    }

    if (!list) {
	pthread_mutex_unlock(&hintlock);
	return -1;
    }

    /* Now inserts the callback */
    cblist = malloc(sizeof(struct ast_state_cb));
    if (!cblist) {
	pthread_mutex_unlock(&hintlock);
	return -1;
    }
    memset(cblist, 0, sizeof(struct ast_state_cb));
    cblist->id = stateid++;
    cblist->callback = callback;
    cblist->data = data;

    cblist->next = list->callbacks;
    list->callbacks = cblist;

    pthread_mutex_unlock(&hintlock);
    return cblist->id;
}

int ast_extension_state_del(int id, ast_state_cb_type callback)
{
    struct ast_hint *list;
    struct ast_state_cb *cblist, *cbprev;
    
    if (!id && !callback)
	return -1;
            
    pthread_mutex_lock(&hintlock);

    /* id is zero is a callback without extension */
    if (!id) {
	cbprev = NULL;
	cblist = statecbs;
	while (cblist) {
	    if (cblist->callback == callback) {
		if (!cbprev)
		    statecbs = cblist->next;
		else
		    cbprev->next = cblist->next;

		free(cblist);

	        pthread_mutex_unlock(&hintlock);
		return 0;
	    }
	    cbprev = cblist;
	    cblist = cblist->next;
	}

        pthread_mutex_lock(&hintlock);
	return -1;
    }

    /* id greater zero is a callback with extension */
    list = hints;
    while (list) {
	cblist = list->callbacks;
	cbprev = NULL;
	while (cblist) {
	    if (cblist->id==id) {
		if (!cbprev)
		    list->callbacks = cblist->next;		
		else
		    cbprev->next = cblist->next;
		
		free(cblist);
		
		pthread_mutex_unlock(&hintlock);
		return 0;		
	    }		
    	    cbprev = cblist;				
	    cblist = cblist->next;
	}
	list = list->next;
    }
    
    pthread_mutex_unlock(&hintlock);
    return -1;
}

static int ast_add_hint(struct ast_exten *e)
{
    struct ast_hint *list;

    if (!e) return -1;
    
    pthread_mutex_lock(&hintlock);
    list = hints;        
    
    /* Search if hint exists, do nothing */
    while (list) {
	if (list->exten == e) {
	    pthread_mutex_unlock(&hintlock);
	    return -1;
	}
	list = list->next;    
    }

    list = malloc(sizeof(struct ast_hint));
    if (!list) {
	pthread_mutex_unlock(&hintlock);
	return -1;
    }
    /* Initialize and insert new item */
    memset(list, 0, sizeof(struct ast_hint));
    list->exten = e;
    list->laststate = ast_extension_state2(e);
    list->next = hints;
    hints = list;

    pthread_mutex_unlock(&hintlock);
    return 0;
}

static int ast_change_hint(struct ast_exten *oe, struct ast_exten *ne)
{ 
    struct ast_hint *list;

    pthread_mutex_lock(&hintlock);
    
    list = hints;
    
    while(list) {
	if (list->exten == oe) {
	    list->exten = ne;
	    pthread_mutex_unlock(&hintlock);	
	    return 0;
	}
	list = list->next;
    }
    pthread_mutex_unlock(&hintlock);

    return -1;
}

static int ast_remove_hint(struct ast_exten *e)
{
    /* Cleanup the Notifys if hint is removed */
    struct ast_hint *list, *prev = NULL;
    struct ast_state_cb *cblist, *cbprev;

    if (!e) 
	return -1;

    pthread_mutex_lock(&hintlock);

    list = hints;    
    while(list) {
	if (list->exten==e) {
	    cbprev = NULL;
	    cblist = list->callbacks;
	    while (cblist) {
		/* Notify with -1 and remove all callbacks */
		cbprev = cblist;	    
		cblist = cblist->next;
		cbprev->callback(list->exten->parent->name, list->exten->exten, -1, cbprev->data);
		free(cbprev);
	    }
	    list->callbacks = NULL;

	    if (!prev)
		hints = list->next;
	    else
		prev->next = list->next;

	    free(list);
	    
	    pthread_mutex_unlock(&hintlock);
	    return 0;
	} else {
	    prev = list;
    	    list = list->next;    
	}
    }

    pthread_mutex_unlock(&hintlock);
    return -1;
}


int ast_get_hint(char *hint, int maxlen, struct ast_channel *c, char *context, char *exten)
{
	struct ast_exten *e;
	e = ast_hint_extension(c, context, exten);
	if (e) {	
	    strncpy(hint, ast_get_extension_app(e), maxlen);
	    return -1;
	}
	return 0;	
}

int ast_exists_extension(struct ast_channel *c, char *context, char *exten, int priority, char *callerid) 
{
	return pbx_extension_helper(c, context, exten, priority, callerid, HELPER_EXISTS);
}

int ast_canmatch_extension(struct ast_channel *c, char *context, char *exten, int priority, char *callerid)
{
	return pbx_extension_helper(c, context, exten, priority, callerid, HELPER_CANMATCH);
}

int ast_matchmore_extension(struct ast_channel *c, char *context, char *exten, int priority, char *callerid)
{
	return pbx_extension_helper(c, context, exten, priority, callerid, HELPER_MATCHMORE);
}

int ast_spawn_extension(struct ast_channel *c, char *context, char *exten, int priority, char *callerid) 
{
	return pbx_extension_helper(c, context, exten, priority, callerid, HELPER_SPAWN);
}

int ast_pbx_run(struct ast_channel *c)
{
	int firstpass = 1;
	char digit;
	char exten[256];
	int pos;
	int waittime;
	int res=0;

	/* A little initial setup here */
	if (c->pbx)
		ast_log(LOG_WARNING, "%s already has PBX structure??\n", c->name);
	c->pbx = malloc(sizeof(struct ast_pbx));
	if (!c->pbx) {
		ast_log(LOG_WARNING, "Out of memory\n");
		return -1;
	}
	if (c->amaflags) {
		if (c->cdr) {
			ast_log(LOG_WARNING, "%s already has a call record??\n", c->name);
		} else {
			c->cdr = ast_cdr_alloc();
			if (!c->cdr) {
				ast_log(LOG_WARNING, "Unable to create Call Detail Record\n");
				free(c->pbx);
				return -1;
			}
			ast_cdr_init(c->cdr, c);
		}
	}
	memset(c->pbx, 0, sizeof(struct ast_pbx));
	/* Set reasonable defaults */
	c->pbx->rtimeout = 10;
	c->pbx->dtimeout = 5;

	/* Start by trying whatever the channel is set to */
	if (!ast_exists_extension(c, c->context, c->exten, c->priority, c->callerid)) {
		/* JK02: If not successfull fall back to 's' */
		strncpy(c->exten, "s", sizeof(c->exten)-1);
		if (!ast_exists_extension(c, c->context, c->exten, c->priority, c->callerid)) {
			/* JK02: And finally back to default if everything else failed */
			strncpy(c->context, "default", sizeof(c->context)-1);
		}
		c->priority = 1;
	}
	if (c->cdr)
		ast_cdr_start(c->cdr);
	for(;;) {
		pos = 0;
		digit = 0;
		while(ast_exists_extension(c, c->context, c->exten, c->priority, c->callerid)) {
			memset(exten, 0, sizeof(exten));
			manager_event(EVENT_FLAG_CALL, "Newexten", 
				"Channel: %s\r\n"
				"Context: %s\r\n"
				"Extension: %s\r\n"
				"Priority: %d\r\n",
				c->name, c->context, c->exten, c->priority);			
			if ((res = ast_spawn_extension(c, c->context, c->exten, c->priority, c->callerid))) {
				/* Something bad happened, or a hangup has been requested. */
				if (((res >= '0') && (res <= '9')) || ((res >= 'A') && (res <= 'F')) ||
					(res == '*') || (res == '#')) {
					ast_log(LOG_DEBUG, "Oooh, got something to jump out with ('%c')!\n", res);
					memset(exten, 0, sizeof(exten));
					pos = 0;
					exten[pos++] = digit = res;
					break;
				}
				switch(res) {
				case AST_PBX_KEEPALIVE:
					if (option_debug)
						ast_log(LOG_DEBUG, "Spawn extension (%s,%s,%d) exited KEEPALIVE on '%s'\n", c->context, c->exten, c->priority, c->name);
					else if (option_verbose > 1)
						ast_verbose( VERBOSE_PREFIX_2 "Spawn extension (%s, %s, %d) exited KEEPALIVE on '%s'\n", c->context, c->exten, c->priority, c->name);
					goto out;
					break;
				default:
					if (option_debug)
						ast_log(LOG_DEBUG, "Spawn extension (%s,%s,%d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name);
					else if (option_verbose > 1)
						ast_verbose( VERBOSE_PREFIX_2 "Spawn extension (%s, %s, %d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name);
					if (c->_softhangup == AST_SOFTHANGUP_ASYNCGOTO) {
						c->_softhangup =0;
						break;
					}
					/* atimeout */
					if (c->_softhangup == AST_SOFTHANGUP_TIMEOUT) {
						break;
					}
					goto out;
				}
			}
			if ((c->_softhangup == AST_SOFTHANGUP_TIMEOUT) && (ast_exists_extension(c,c->context,"T",1,c->callerid))) {
				strncpy(c->exten,"T",sizeof(c->exten) - 1);
				/* If the AbsoluteTimeout is not reset to 0, we'll get an infinite loop */
				c->whentohangup = 0;
			} else if (c->_softhangup) {
				ast_log(LOG_DEBUG, "Extension %s, priority %d returned normally even though call was hung up\n",
					c->exten, c->priority);
				goto out;
			}
			firstpass = 0;
			c->priority++;
		}
		if (!ast_exists_extension(c, c->context, c->exten, 1, c->callerid)) {
			/* It's not a valid extension anymore */
			if (ast_exists_extension(c, c->context, "i", 1, c->callerid)) {
				if (option_verbose > 2)
					ast_verbose(VERBOSE_PREFIX_3 "Sent into invalid extension '%s' in context '%s' on %s\n", c->exten, c->context, c->name);
				strncpy(c->exten, "i", sizeof(c->exten)-1);
				c->priority = 1;
			} else {
				ast_log(LOG_WARNING, "Channel '%s' sent into invalid extension '%s' in context '%s', but no invalid handler\n",
					c->name, c->exten, c->context);
				goto out;
			}
		} else if (c->_softhangup == AST_SOFTHANGUP_TIMEOUT) {
			/* If we get this far with AST_SOFTHANGUP_TIMEOUT, then we know that the "T" extension is next. */
			c->_softhangup = 0;
		} else {
			/* Done, wait for an extension */
			if (digit)
				waittime = c->pbx->dtimeout;
			else
				waittime = c->pbx->rtimeout;
			while (ast_matchmore_extension(c, c->context, exten, 1, c->callerid)) {
				/* As long as we're willing to wait, and as long as it's not defined, 
				   keep reading digits until we can't possibly get a right answer anymore.  */
				digit = ast_waitfordigit(c, waittime * 1000);
				if (c->_softhangup == AST_SOFTHANGUP_ASYNCGOTO) {
					c->_softhangup = 0;
				} else {
					if (!digit)
						/* No entry */
						break;
					if (digit < 0)
						/* Error, maybe a  hangup */
						goto out;
					exten[pos++] = digit;
					waittime = c->pbx->dtimeout;
				}
			}
			if (ast_exists_extension(c, c->context, exten, 1, c->callerid)) {
				/* Prepare the next cycle */
				strncpy(c->exten, exten, sizeof(c->exten)-1);
				c->priority = 1;
			} else {
				/* No such extension */
				if (strlen(exten)) {
					/* An invalid extension */
					if (ast_exists_extension(c, c->context, "i", 1, c->callerid)) {
						if (option_verbose > 2)
							ast_verbose( VERBOSE_PREFIX_3 "Invalid extension '%s' in context '%s' on %s\n", exten, c->context, c->name);
						strncpy(c->exten, "i", sizeof(c->exten)-1);
						c->priority = 1;
					} else {
						ast_log(LOG_WARNING, "Invalid extension, but no rule 'i' in context '%s'\n", c->context);
						goto out;
					}
				} else {
					/* A simple timeout */
					if (ast_exists_extension(c, c->context, "t", 1, c->callerid)) {
						if (option_verbose > 2)
							ast_verbose( VERBOSE_PREFIX_3 "Timeout on %s\n", c->name);
						strncpy(c->exten, "t", sizeof(c->exten)-1);
						c->priority = 1;
					} else {
						ast_log(LOG_WARNING, "Timeout, but no rule 't' in context '%s'\n", c->context);
						goto out;
					}
				}	
			}
		}
	}
	if (firstpass) 
		ast_log(LOG_WARNING, "Don't know what to do with '%s'\n", c->name);
out:
	if (ast_exists_extension(c, c->context, "h", 1, c->callerid)) {
		strcpy(c->exten, "h");
		c->priority = 1;
		while(ast_exists_extension(c, c->context, c->exten, c->priority, c->callerid)) {
			if ((res = ast_spawn_extension(c, c->context, c->exten, c->priority, c->callerid))) {
				/* Something bad happened, or a hangup has been requested. */
				if (option_debug)
					ast_log(LOG_DEBUG, "Spawn extension (%s,%s,%d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name);
				else if (option_verbose > 1)
					ast_verbose( VERBOSE_PREFIX_2 "Spawn extension (%s, %s, %d) exited non-zero on '%s'\n", c->context, c->exten, c->priority, c->name);
				break;
			}
			c->priority++;
		}
	}

	pbx_destroy(c->pbx);
	c->pbx = NULL;
	if (res != AST_PBX_KEEPALIVE)
		ast_hangup(c);
	return 0;
}

static void *pbx_thread(void *data)
{
	/* Oh joyeous kernel, we're a new thread, with nothing to do but
	   answer this channel and get it going.  The setjmp stuff is fairly
	   confusing, but necessary to get smooth transitions between
	   the execution of different applications (without the use of
	   additional threads) */
	struct ast_channel *c = data;
	ast_pbx_run(c);
	pthread_exit(NULL);
	return NULL;
}

int ast_pbx_start(struct ast_channel *c)
{
	pthread_t t;
	pthread_attr_t attr;
	if (!c) {
		ast_log(LOG_WARNING, "Asked to start thread on NULL channel?\n");
		return -1;
	}
	   
	/* Start a new thread, and get something handling this channel. */
	pthread_attr_init(&attr);
	pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
	if (pthread_create(&t, &attr, pbx_thread, c)) {
		ast_log(LOG_WARNING, "Failed to create new channel thread\n");
		return -1;
	}
	return 0;
}

/*
 * This function locks contexts list by &conlist, search for the rigt context
 * structure, leave context list locked and call ast_context_remove_include2
 * which removes include, unlock contexts list and return ...
 */
int ast_context_remove_include(char *context, char *include, char *registrar)
{
	struct ast_context *c;

	if (ast_lock_contexts()) return -1;

	/* walk contexts and search for the right one ...*/
	c = ast_walk_contexts(NULL);
	while (c) {
		/* we found one ... */
		if (!strcmp(ast_get_context_name(c), context)) {
			int ret;
			/* remove include from this context ... */	
			ret = ast_context_remove_include2(c, include, registrar);

			ast_unlock_contexts();

			/* ... return results */
			return ret;
		}
		c = ast_walk_contexts(c);
	}

	/* we can't find the right one context */
	ast_unlock_contexts();
	return -1;
}

/*
 * When we call this function, &conlock lock must be locked, because when
 * we giving *con argument, some process can remove/change this context
 * and after that there can be segfault.
 *
 * This function locks given context, removes include, unlock context and
 * return.
 */
int ast_context_remove_include2(struct ast_context *con, char *include, char *registrar)
{
	struct ast_include *i, *pi = NULL;

	if (ast_pthread_mutex_lock(&con->lock)) return -1;

	/* walk includes */
	i = con->includes;
	while (i) {
		/* find our include */
		if (!strcmp(i->name, include) && 
			(!strcmp(i->registrar, registrar) || !registrar)) {
			/* remove from list */
			if (pi)
				pi->next = i->next;
			else
				con->includes = i->next;
			/* free include and return */
			free(i);
			ast_pthread_mutex_unlock(&con->lock);
			return 0;
		}
		pi = i;
		i = i->next;
	}

	/* we can't find the right include */
	ast_pthread_mutex_unlock(&con->lock);
	return -1;
}

/*
 * This function locks contexts list by &conlist, search for the rigt context
 * structure, leave context list locked and call ast_context_remove_switch2
 * which removes switch, unlock contexts list and return ...
 */
int ast_context_remove_switch(char *context, char *sw, char *data, char *registrar)
{
	struct ast_context *c;

	if (ast_lock_contexts()) return -1;

	/* walk contexts and search for the right one ...*/
	c = ast_walk_contexts(NULL);
	while (c) {
		/* we found one ... */
		if (!strcmp(ast_get_context_name(c), context)) {
			int ret;
			/* remove switch from this context ... */	
			ret = ast_context_remove_switch2(c, sw, data, registrar);

			ast_unlock_contexts();

			/* ... return results */
			return ret;
		}
		c = ast_walk_contexts(c);
	}

	/* we can't find the right one context */
	ast_unlock_contexts();
	return -1;
}

/*
 * When we call this function, &conlock lock must be locked, because when
 * we giving *con argument, some process can remove/change this context
 * and after that there can be segfault.
 *
 * This function locks given context, removes switch, unlock context and
 * return.
 */
int ast_context_remove_switch2(struct ast_context *con, char *sw, char *data, char *registrar)
{
	struct ast_sw *i, *pi = NULL;

	if (ast_pthread_mutex_lock(&con->lock)) return -1;

	/* walk switchs */
	i = con->alts;
	while (i) {
		/* find our switch */
		if (!strcmp(i->name, sw) && !strcmp(i->data, data) && 
			(!strcmp(i->registrar, registrar) || !registrar)) {
			/* remove from list */
			if (pi)
				pi->next = i->next;
			else
				con->alts = i->next;
			/* free switch and return */
			free(i);
			ast_pthread_mutex_unlock(&con->lock);
			return 0;
		}
		pi = i;
		i = i->next;
	}

	/* we can't find the right switch */
	ast_pthread_mutex_unlock(&con->lock);
	return -1;
}

/*
 * This functions lock contexts list, search for the right context,
 * call ast_context_remove_extension2, unlock contexts list and return.
 * In this function we are using
 */
int ast_context_remove_extension(char *context, char *extension, int priority, char *registrar)
{
	struct ast_context *c;

	if (ast_lock_contexts()) return -1;

	/* walk contexts ... */
	c = ast_walk_contexts(NULL);
	while (c) {
		/* ... search for the right one ... */
		if (!strcmp(ast_get_context_name(c), context)) {
			/* ... remove extension ... */
			int ret = ast_context_remove_extension2(c, extension, priority,
				registrar);
			/* ... unlock contexts list and return */
			ast_unlock_contexts();
			return ret;
		}
		c = ast_walk_contexts(c);
	}

	/* we can't find the right context */
	ast_unlock_contexts();
	return -1;
}

/*
 * When do you want to call this function, make sure that &conlock is locked,
 * because some process can handle with your *con context before you lock
 * it.
 *
 * This functionc locks given context, search for the right extension and
 * fires out all peer in this extensions with given priority. If priority
 * is set to 0, all peers are removed. After that, unlock context and
 * return.
 */
int ast_context_remove_extension2(struct ast_context *con, char *extension, int priority, char *registrar)
{
	struct ast_exten *exten, *prev_exten = NULL;

	if (ast_pthread_mutex_lock(&con->lock)) return -1;

	/* go through all extensions in context and search the right one ... */
	exten = con->root;
	while (exten) {

		/* look for right extension */
		if (!strcmp(exten->exten, extension) &&
			(!strcmp(exten->registrar, registrar) || !registrar)) {
			struct ast_exten *peer;

			/* should we free all peers in this extension? (priority == 0)? */
			if (priority == 0) {
				/* remove this extension from context list */
				if (prev_exten)
					prev_exten->next = exten->next;
				else
					con->root = exten->next;

				/* fire out all peers */
				peer = exten; 
				while (peer) {
					exten = peer->peer;
					
					if (!peer->priority==PRIORITY_HINT) 
					    ast_remove_hint(peer);

					peer->datad(peer->data);
					free(peer);

					peer = exten;
				}

				ast_pthread_mutex_unlock(&con->lock);