diff options
author | markster <markster@f38db490-d61c-443f-a65b-d21fe96a405b> | 2004-06-22 04:54:52 +0000 |
---|---|---|
committer | markster <markster@f38db490-d61c-443f-a65b-d21fe96a405b> | 2004-06-22 04:54:52 +0000 |
commit | 2fbbfca4f41c58816c2e3ecb61daf3ee0b8be02b (patch) | |
tree | a8fdd4aa5b1fe4c613efa559007cafad883bbe97 /channels/chan_local.c | |
parent | 64b7fe35eb3ad0b50862624db38ddf3f3a55d98b (diff) |
Can't check outbound without having lock (bug #1886)
git-svn-id: http://svn.digium.com/svn/asterisk/trunk@3269 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'channels/chan_local.c')
-rwxr-xr-x | channels/chan_local.c | 15 |
1 files changed, 10 insertions, 5 deletions
diff --git a/channels/chan_local.c b/channels/chan_local.c index c6cb4c7cf..6421243d9 100755 --- a/channels/chan_local.c +++ b/channels/chan_local.c @@ -121,9 +121,10 @@ retrylock: static int local_answer(struct ast_channel *ast) { struct local_pvt *p = ast->pvt->pvt; - int isoutbound = IS_OUTBOUND(ast, p); + int isoutbound; int res = -1; ast_mutex_lock(&p->lock); + isoutbound = IS_OUTBOUND(ast, p); if (isoutbound) { /* Pass along answer since somebody answered us */ struct ast_frame answer = { AST_FRAME_CONTROL, AST_CONTROL_ANSWER }; @@ -174,11 +175,12 @@ static int local_write(struct ast_channel *ast, struct ast_frame *f) { struct local_pvt *p = ast->pvt->pvt; int res = -1; - int isoutbound = IS_OUTBOUND(ast, p); + int isoutbound; /* Just queue for delivery to the other side */ ast_mutex_lock(&p->lock); + isoutbound = IS_OUTBOUND(ast, p); res = local_queue_frame(p, isoutbound, f, ast); check_bridge(p, isoutbound); ast_mutex_unlock(&p->lock); @@ -207,9 +209,10 @@ static int local_indicate(struct ast_channel *ast, int condition) struct local_pvt *p = ast->pvt->pvt; int res = -1; struct ast_frame f = { AST_FRAME_CONTROL, }; - int isoutbound = IS_OUTBOUND(ast, p); + int isoutbound; /* Queue up a frame representing the indication as a control frame */ ast_mutex_lock(&p->lock); + isoutbound = IS_OUTBOUND(ast, p); f.subclass = condition; res = local_queue_frame(p, isoutbound, &f, ast); ast_mutex_unlock(&p->lock); @@ -221,8 +224,9 @@ static int local_digit(struct ast_channel *ast, char digit) struct local_pvt *p = ast->pvt->pvt; int res = -1; struct ast_frame f = { AST_FRAME_DTMF, }; - int isoutbound = IS_OUTBOUND(ast, p); + int isoutbound; ast_mutex_lock(&p->lock); + isoutbound = IS_OUTBOUND(ast, p); f.subclass = digit; res = local_queue_frame(p, isoutbound, &f, ast); ast_mutex_unlock(&p->lock); @@ -282,12 +286,13 @@ static void local_destroy(struct local_pvt *p) static int local_hangup(struct ast_channel *ast) { struct local_pvt *p = ast->pvt->pvt; - int isoutbound = IS_OUTBOUND(ast, p); + int isoutbound; struct ast_frame f = { AST_FRAME_CONTROL, AST_CONTROL_HANGUP }; struct local_pvt *cur, *prev=NULL; struct ast_channel *ochan = NULL; int glaredetect; ast_mutex_lock(&p->lock); + isoutbound = IS_OUTBOUND(ast, p); if (isoutbound) { p->chan = NULL; p->launchedpbx = 0; |