kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-05-02 14:48:22 +00:00
Code Issues Projects Releases Wiki Activity

add loopback_bowout variable (set to false to skip auto-bowout)

Browse Source 
git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@13162 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
Anthony Minessale 2009-04-27 14:15:55 +00:00
parent 6cdb09ddb5
commit 07c6022ef7
1 changed files with 20 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/mod/endpoints/mod_loopback/mod_loopback.c
View File

@ -640,21 +640,27 @@ static switch_status_t channel_write_frame(switch_core_session_t *session, switc
) { ) {
const char *a_uuid = switch_channel_get_variable(channel, SWITCH_SIGNAL_BOND_VARIABLE); const char *a_uuid = switch_channel_get_variable(channel, SWITCH_SIGNAL_BOND_VARIABLE);
const char *b_uuid = switch_channel_get_variable(tech_pvt->other_channel, SWITCH_SIGNAL_BOND_VARIABLE); const char *b_uuid = switch_channel_get_variable(tech_pvt->other_channel, SWITCH_SIGNAL_BOND_VARIABLE);
const char *vetoa, *vetob;
switch_set_flag_locked(tech_pvt, TFLAG_BOWOUT); switch_set_flag_locked(tech_pvt, TFLAG_BOWOUT);
switch_set_flag_locked(tech_pvt->other_tech_pvt, TFLAG_BOWOUT); switch_set_flag_locked(tech_pvt->other_tech_pvt, TFLAG_BOWOUT);
switch_clear_flag_locked(tech_pvt, TFLAG_WRITE); vetoa = switch_channel_get_variable(tech_pvt->channel, "loopback_bowout");
switch_clear_flag_locked(tech_pvt->other_tech_pvt, TFLAG_WRITE); vetob = switch_channel_get_variable(tech_pvt->other_tech_pvt->channel, "loopback_bowout");
if (a_uuid && b_uuid) { if ((!vetoa || switch_true(vetoa)) && (!vetob || switch_true(vetob))) {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, switch_clear_flag_locked(tech_pvt, TFLAG_WRITE);
"%s detected bridge on both ends, attempting direct connection.\n", switch_channel_get_name(channel)); switch_clear_flag_locked(tech_pvt->other_tech_pvt, TFLAG_WRITE);
/* channel_masquerade eat your heart out....... */ if (a_uuid && b_uuid) {
switch_ivr_uuid_bridge(a_uuid, b_uuid); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG,
switch_mutex_unlock(tech_pvt->mutex); "%s detected bridge on both ends, attempting direct connection.\n", switch_channel_get_name(channel));
return SWITCH_STATUS_SUCCESS;
/* channel_masquerade eat your heart out....... */
switch_ivr_uuid_bridge(a_uuid, b_uuid);
switch_mutex_unlock(tech_pvt->mutex);
return SWITCH_STATUS_SUCCESS;
}
} }
} }
@ -675,9 +681,10 @@ static switch_status_t channel_write_frame(switch_core_session_t *session, switc
if (switch_queue_trypush(tech_pvt->other_tech_pvt->frame_queue, clone) != SWITCH_STATUS_SUCCESS) { if (switch_queue_trypush(tech_pvt->other_tech_pvt->frame_queue, clone) != SWITCH_STATUS_SUCCESS) {
switch_frame_free(&clone); switch_frame_free(&clone);
} }
switch_set_flag_locked(tech_pvt->other_tech_pvt, TFLAG_WRITE);
} }
switch_set_flag_locked(tech_pvt->other_tech_pvt, TFLAG_WRITE);
status = SWITCH_STATUS_SUCCESS; status = SWITCH_STATUS_SUCCESS;
} }