Made ast_queue_hangup() and ast_queue_hangup_with_cause() lock instead of trylock.

It made no sense to trylock the channel and then unconditionally lock the
channel right after.


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@367227 65c4cc65-6c06-0410-ace0-fbb531ad65f3
certified/11.2
Richard Mudgett 14 years ago
parent ab4c9f2247
commit c857131945

@ -1313,32 +1313,39 @@ int ast_queue_frame_head(struct ast_channel *chan, struct ast_frame *fin)
int ast_queue_hangup(struct ast_channel *chan) int ast_queue_hangup(struct ast_channel *chan)
{ {
struct ast_frame f = { AST_FRAME_CONTROL, .subclass.integer = AST_CONTROL_HANGUP }; struct ast_frame f = { AST_FRAME_CONTROL, .subclass.integer = AST_CONTROL_HANGUP };
int res;
/* Yeah, let's not change a lock-critical value without locking */ /* Yeah, let's not change a lock-critical value without locking */
if (!ast_channel_trylock(chan)) { ast_channel_lock(chan);
ast_channel_softhangup_internal_flag_add(chan, AST_SOFTHANGUP_DEV); ast_channel_softhangup_internal_flag_add(chan, AST_SOFTHANGUP_DEV);
manager_event(EVENT_FLAG_CALL, "HangupRequest", manager_event(EVENT_FLAG_CALL, "HangupRequest",
"Channel: %s\r\n" "Channel: %s\r\n"
"Uniqueid: %s\r\n", "Uniqueid: %s\r\n",
ast_channel_name(chan), ast_channel_name(chan),
ast_channel_uniqueid(chan)); ast_channel_uniqueid(chan));
res = ast_queue_frame(chan, &f);
ast_channel_unlock(chan); ast_channel_unlock(chan);
} return res;
return ast_queue_frame(chan, &f);
} }
/*! \brief Queue a hangup frame for channel */ /*! \brief Queue a hangup frame for channel */
int ast_queue_hangup_with_cause(struct ast_channel *chan, int cause) int ast_queue_hangup_with_cause(struct ast_channel *chan, int cause)
{ {
struct ast_frame f = { AST_FRAME_CONTROL, .subclass.integer = AST_CONTROL_HANGUP }; struct ast_frame f = { AST_FRAME_CONTROL, .subclass.integer = AST_CONTROL_HANGUP };
int res;
if (cause >= 0) if (cause >= 0) {
f.data.uint32 = cause; f.data.uint32 = cause;
}
/* Yeah, let's not change a lock-critical value without locking */ /* Yeah, let's not change a lock-critical value without locking */
if (!ast_channel_trylock(chan)) { ast_channel_lock(chan);
ast_channel_softhangup_internal_flag_add(chan, AST_SOFTHANGUP_DEV); ast_channel_softhangup_internal_flag_add(chan, AST_SOFTHANGUP_DEV);
if (cause < 0) if (cause < 0) {
f.data.uint32 = ast_channel_hangupcause(chan); f.data.uint32 = ast_channel_hangupcause(chan);
}
manager_event(EVENT_FLAG_CALL, "HangupRequest", manager_event(EVENT_FLAG_CALL, "HangupRequest",
"Channel: %s\r\n" "Channel: %s\r\n"
@ -1347,10 +1354,10 @@ int ast_queue_hangup_with_cause(struct ast_channel *chan, int cause)
ast_channel_name(chan), ast_channel_name(chan),
ast_channel_uniqueid(chan), ast_channel_uniqueid(chan),
cause); cause);
ast_channel_unlock(chan);
}
return ast_queue_frame(chan, &f); res = ast_queue_frame(chan, &f);
ast_channel_unlock(chan);
return res;
} }
/*! \brief Queue a control frame */ /*! \brief Queue a control frame */

Loading…
Cancel
Save