diff options
author | Richard Mudgett <rmudgett@digium.com> | 2012-03-14 22:38:29 +0000 |
---|---|---|
committer | Richard Mudgett <rmudgett@digium.com> | 2012-03-14 22:38:29 +0000 |
commit | 9b31bd3cd83b50e0843f42b70d5e111287fa8107 (patch) | |
tree | 6f9fad87dcbdc947019dd82f930bb310f9df688a /main/channel.c | |
parent | a699bb72ad8d255c84998e97addd2e20ab3f6b7b (diff) |
Fix deadlock potential with some ast_indicate/ast_indicate_data calls.
Calling ast_indicate()/ast_indicate_data() with the channel lock held can
result in a deadlock with a local channel because of how local channels
need to avoid deadlock.
........
Merged revisions 359451 from http://svn.asterisk.org/svn/asterisk/branches/1.8
........
Merged revisions 359453 from http://svn.asterisk.org/svn/asterisk/branches/10
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@359455 65c4cc65-6c06-0410-ace0-fbb531ad65f3
Diffstat (limited to 'main/channel.c')
-rw-r--r-- | main/channel.c | 36 |
1 files changed, 30 insertions, 6 deletions
diff --git a/main/channel.c b/main/channel.c index 35155bb6b..f97855fb6 100644 --- a/main/channel.c +++ b/main/channel.c @@ -3765,6 +3765,7 @@ static struct ast_frame *__ast_read(struct ast_channel *chan, int dropaudio) ast_party_connected_line_free(&connected); break; } + ast_channel_unlock(chan); if (ast_channel_connected_line_sub(NULL, chan, &connected, 0) && ast_channel_connected_line_macro(NULL, chan, &connected, 1, 0)) { ast_indicate_data(chan, AST_CONTROL_CONNECTED_LINE, @@ -3772,6 +3773,7 @@ static struct ast_frame *__ast_read(struct ast_channel *chan, int dropaudio) read_action_payload->payload_size); } ast_party_connected_line_free(&connected); + ast_channel_lock(chan); break; } ast_frfree(f); @@ -9361,10 +9363,16 @@ int ast_channel_connected_line_macro(struct ast_channel *autoservice_chan, struc } ast_channel_unlock(macro_chan); - if (!(retval = ast_app_run_macro(autoservice_chan, macro_chan, macro, macro_args))) { + retval = ast_app_run_macro(autoservice_chan, macro_chan, macro, macro_args); + if (!retval) { + struct ast_party_connected_line saved_connected; + + ast_party_connected_line_init(&saved_connected); ast_channel_lock(macro_chan); - ast_channel_update_connected_line(macro_chan, ast_channel_connected(macro_chan), NULL); + ast_party_connected_line_copy(&saved_connected, ast_channel_connected(macro_chan)); ast_channel_unlock(macro_chan); + ast_channel_update_connected_line(macro_chan, &saved_connected, NULL); + ast_party_connected_line_free(&saved_connected); } return retval; @@ -9407,9 +9415,14 @@ int ast_channel_redirecting_macro(struct ast_channel *autoservice_chan, struct a retval = ast_app_run_macro(autoservice_chan, macro_chan, macro, macro_args); if (!retval) { + struct ast_party_redirecting saved_redirecting; + + ast_party_redirecting_init(&saved_redirecting); ast_channel_lock(macro_chan); - ast_channel_update_redirecting(macro_chan, ast_channel_redirecting(macro_chan), NULL); + ast_party_redirecting_copy(&saved_redirecting, ast_channel_redirecting(macro_chan)); ast_channel_unlock(macro_chan); + ast_channel_update_redirecting(macro_chan, &saved_redirecting, NULL); + ast_party_redirecting_free(&saved_redirecting); } return retval; @@ -9443,10 +9456,16 @@ int ast_channel_connected_line_sub(struct ast_channel *autoservice_chan, struct } ast_channel_unlock(sub_chan); - if (!(retval = ast_app_run_sub(autoservice_chan, sub_chan, sub, sub_args))) { + retval = ast_app_run_sub(autoservice_chan, sub_chan, sub, sub_args); + if (!retval) { + struct ast_party_connected_line saved_connected; + + ast_party_connected_line_init(&saved_connected); ast_channel_lock(sub_chan); - ast_channel_update_connected_line(sub_chan, ast_channel_connected(sub_chan), NULL); + ast_party_connected_line_copy(&saved_connected, ast_channel_connected(sub_chan)); ast_channel_unlock(sub_chan); + ast_channel_update_connected_line(sub_chan, &saved_connected, NULL); + ast_party_connected_line_free(&saved_connected); } return retval; @@ -9482,9 +9501,14 @@ int ast_channel_redirecting_sub(struct ast_channel *autoservice_chan, struct ast retval = ast_app_run_sub(autoservice_chan, sub_chan, sub, sub_args); if (!retval) { + struct ast_party_redirecting saved_redirecting; + + ast_party_redirecting_init(&saved_redirecting); ast_channel_lock(sub_chan); - ast_channel_update_redirecting(sub_chan, ast_channel_redirecting(sub_chan), NULL); + ast_party_redirecting_copy(&saved_redirecting, ast_channel_redirecting(sub_chan)); ast_channel_unlock(sub_chan); + ast_channel_update_redirecting(sub_chan, &saved_redirecting, NULL); + ast_party_redirecting_free(&saved_redirecting); } return retval; |