From 117c0315cc1b4c77eae8996b7d917d34c628b59c Mon Sep 17 00:00:00 2001 From: Anthony Minessale Date: Mon, 19 May 2008 21:02:26 +0000 Subject: [PATCH] following the att_xfer can o worms deeper git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@8475 d0543943-73ff-0310-b7d9-9358b9ac24b2 --- src/include/switch_core_event_hook.h | 4 +- src/include/switch_ivr.h | 2 +- src/include/switch_types.h | 14 +++ .../applications/mod_dptools/mod_dptools.c | 61 ++++++++-- src/switch_core_io.c | 4 +- src/switch_ivr_async.c | 112 +++++++++++++----- src/switch_ivr_originate.c | 21 ++-- 7 files changed, 167 insertions(+), 51 deletions(-) diff --git a/src/include/switch_core_event_hook.h b/src/include/switch_core_event_hook.h index b914762bb6..1898ac7f2b 100644 --- a/src/include/switch_core_event_hook.h +++ b/src/include/switch_core_event_hook.h @@ -56,8 +56,8 @@ typedef switch_status_t (*switch_video_read_frame_hook_t) (switch_core_session_t typedef switch_status_t (*switch_write_frame_hook_t) (switch_core_session_t *, switch_frame_t *, switch_io_flag_t, int); typedef switch_status_t (*switch_video_write_frame_hook_t) (switch_core_session_t *, switch_frame_t *, switch_io_flag_t, int); typedef switch_status_t (*switch_kill_channel_hook_t) (switch_core_session_t *, int); -typedef switch_status_t (*switch_send_dtmf_hook_t) (switch_core_session_t *, const switch_dtmf_t *); -typedef switch_status_t (*switch_recv_dtmf_hook_t) (switch_core_session_t *, const switch_dtmf_t *); +typedef switch_status_t (*switch_send_dtmf_hook_t) (switch_core_session_t *, const switch_dtmf_t *, switch_dtmf_direction_t direction); +typedef switch_status_t (*switch_recv_dtmf_hook_t) (switch_core_session_t *, const switch_dtmf_t *, switch_dtmf_direction_t direction); typedef switch_status_t (*switch_state_change_hook_t) (switch_core_session_t *); typedef switch_call_cause_t (*switch_resurrect_session_hook_t)(switch_core_session_t **, switch_memory_pool_t **, void *); diff --git a/src/include/switch_ivr.h b/src/include/switch_ivr.h index 4e7ac3069e..d5c786c052 100644 --- a/src/include/switch_ivr.h +++ b/src/include/switch_ivr.h @@ -753,7 +753,7 @@ SWITCH_DECLARE(switch_status_t) switch_ivr_read(switch_core_session_t *session, const char *valid_terminators); SWITCH_DECLARE(switch_status_t) switch_ivr_bind_dtmf_meta_session(switch_core_session_t *session, uint32_t key, - switch_bool_t dial_b, switch_bool_t exec_b, const char *app); + switch_bind_flag_t bind_flags, const char *app); SWITCH_DECLARE(switch_status_t) switch_ivr_unbind_dtmf_meta_session(switch_core_session_t *session); SWITCH_DECLARE(switch_status_t) switch_ivr_soft_hold(switch_core_session_t *session, const char *unhold_key, const char *moh_a, const char *moh_b); SWITCH_DECLARE(switch_status_t) switch_ivr_say(switch_core_session_t *session, const char *tosay, const char *module_name, const char *say_type, const char *say_method, switch_input_args_t *args); diff --git a/src/include/switch_types.h b/src/include/switch_types.h index 1bea8418e4..02b6d67f0c 100644 --- a/src/include/switch_types.h +++ b/src/include/switch_types.h @@ -150,6 +150,20 @@ typedef struct { uint32_t duration; } switch_dtmf_t; +typedef enum { + SBF_DIAL_ALEG = (1 << 0), + SBF_EXEC_ALEG = (1 << 1), + SBF_DIAL_BLEG = (1 << 2), + SBF_EXEC_BLEG = (1 << 3), + SBF_EXEC_OPPOSITE = (1 << 4), + SBF_EXEC_SAME = (1 << 5) +} switch_bind_flag_t; + +typedef enum { + SWITCH_DTMF_RECV, + SWITCH_DTMF_SEND +} switch_dtmf_direction_t; + typedef enum { SOF_NONE = 0, SOF_NOBLOCK = (1 << 0), diff --git a/src/mod/applications/mod_dptools/mod_dptools.c b/src/mod/applications/mod_dptools/mod_dptools.c index b8e296d41c..d860108c6c 100644 --- a/src/mod/applications/mod_dptools/mod_dptools.c +++ b/src/mod/applications/mod_dptools/mod_dptools.c @@ -160,7 +160,7 @@ SWITCH_STANDARD_APP(soft_hold_function) } } -#define BIND_SYNTAX " [a|b] [a|b] " +#define BIND_SYNTAX " [a|b|ab] [a|b|o|s] " SWITCH_STANDARD_APP(dtmf_bind_function) { char *argv[4] = { 0 }; @@ -170,10 +170,46 @@ SWITCH_STANDARD_APP(dtmf_bind_function) if (!switch_strlen_zero(data) && (lbuf = switch_core_session_strdup(session, data)) && (argc = switch_separate_string(lbuf, ' ', argv, (sizeof(argv) / sizeof(argv[0])))) == 4) { int kval = atoi(argv[0]); - char a1 = (char)tolower(*argv[1]); - char a2 = (char)tolower(*argv[2]); - - if (switch_ivr_bind_dtmf_meta_session(session, kval, a1 == 'b', a2 == 'b', argv[3]) != SWITCH_STATUS_SUCCESS) { + switch_bind_flag_t bind_flags = 0; + + if (strchr(argv[1], 'a')) { + bind_flags |= SBF_DIAL_ALEG; + } + if (strchr(argv[1], 'b')) { + bind_flags |= SBF_DIAL_BLEG; + } + if (strchr(argv[2], 'a')) { + if ((bind_flags & SBF_EXEC_BLEG)) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Cannot bind execute to multiple legs\n"); + } else { + bind_flags |= SBF_EXEC_ALEG; + } + } + if (strchr(argv[2], 'b')) { + if ((bind_flags & SBF_EXEC_ALEG)) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Cannot bind execute to multiple legs\n"); + } else { + bind_flags |= SBF_EXEC_BLEG; + } + } + + if (strchr(argv[2], 'o')) { + if ((bind_flags & SBF_EXEC_BLEG) || (bind_flags & SBF_EXEC_ALEG) || (bind_flags & SBF_EXEC_SAME)) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Cannot bind execute to multiple legs\n"); + } else { + bind_flags |= SBF_EXEC_OPPOSITE; + } + } + + if (strchr(argv[2], 's')) { + if ((bind_flags & SBF_EXEC_BLEG) || (bind_flags & SBF_EXEC_ALEG) || (bind_flags & SBF_EXEC_SAME)) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Cannot bind execute to multiple legs\n"); + } else { + bind_flags |= SBF_EXEC_SAME; + } + } + + if (switch_ivr_bind_dtmf_meta_session(session, kval, bind_flags, argv[3]) != SWITCH_STATUS_SUCCESS) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Bind Error!\n"); } } else { @@ -1381,6 +1417,8 @@ SWITCH_STANDARD_APP(att_xfer_function) switch_channel_t *channel, *peer_channel = NULL; const char *bond = NULL; int timelimit = 60; + switch_core_session_t *b_session = NULL; + channel = switch_core_session_get_channel(session); @@ -1396,7 +1434,7 @@ SWITCH_STANDARD_APP(att_xfer_function) } if (switch_ivr_originate(session, &peer_session, &cause, data, timelimit, NULL, NULL, NULL, NULL, SOF_NONE) != SWITCH_STATUS_SUCCESS) { - return; + goto end; } peer_channel = switch_core_session_get_channel(peer_session); @@ -1404,12 +1442,16 @@ SWITCH_STANDARD_APP(att_xfer_function) switch_channel_set_flag(channel, CF_INNER_BRIDGE); switch_ivr_multi_threaded_bridge(session, peer_session, xfer_on_dtmf, peer_session, NULL); - + switch_channel_clear_flag(peer_channel, CF_INNER_BRIDGE); switch_channel_clear_flag(channel, CF_INNER_BRIDGE); + if (!switch_channel_get_state(peer_channel) >= CS_HANGUP) { + switch_core_session_rwunlock(peer_session); + goto end; + } + if (bond) { - switch_core_session_t *b_session; char buf[128] = ""; if (!switch_channel_ready(channel)) { @@ -1431,12 +1473,13 @@ SWITCH_STANDARD_APP(att_xfer_function) switch_channel_set_variable(channel, SWITCH_SIGNAL_BOND_VARIABLE, bond); } + end: + if (peer_session) { switch_core_session_rwunlock(peer_session); } switch_channel_set_variable(channel, SWITCH_HOLDING_UUID_VARIABLE, NULL); - } diff --git a/src/switch_core_io.c b/src/switch_core_io.c index 30c46908ed..c7e9740bdc 100644 --- a/src/switch_core_io.c +++ b/src/switch_core_io.c @@ -962,7 +962,7 @@ SWITCH_DECLARE(switch_status_t) switch_core_session_recv_dtmf(switch_core_sessio } for (ptr = session->event_hooks.recv_dtmf; ptr; ptr = ptr->next) { - if ((status = ptr->recv_dtmf(session, &new_dtmf)) != SWITCH_STATUS_SUCCESS) { + if ((status = ptr->recv_dtmf(session, &new_dtmf, SWITCH_DTMF_RECV)) != SWITCH_STATUS_SUCCESS) { return status; } } @@ -993,7 +993,7 @@ SWITCH_DECLARE(switch_status_t) switch_core_session_send_dtmf(switch_core_sessio for (ptr = session->event_hooks.send_dtmf; ptr; ptr = ptr->next) { - if ((status = ptr->send_dtmf(session, dtmf)) != SWITCH_STATUS_SUCCESS) { + if ((status = ptr->send_dtmf(session, dtmf, SWITCH_DTMF_SEND)) != SWITCH_STATUS_SUCCESS) { return SWITCH_STATUS_SUCCESS; } } diff --git a/src/switch_ivr_async.c b/src/switch_ivr_async.c index fb545bbf44..b7d2b67a9a 100644 --- a/src/switch_ivr_async.c +++ b/src/switch_ivr_async.c @@ -928,7 +928,7 @@ static int teletone_dtmf_generate_handler(teletone_generation_session_t * ts, te return 0; } -static switch_status_t generate_on_dtmf(switch_core_session_t *session, const switch_dtmf_t *dtmf) +static switch_status_t generate_on_dtmf(switch_core_session_t *session, const switch_dtmf_t *dtmf, switch_dtmf_direction_t direction) { switch_channel_t *channel = switch_core_session_get_channel(session); switch_media_bug_t *bug = switch_channel_get_private(channel, "dtmf_generate"); @@ -1298,17 +1298,23 @@ SWITCH_DECLARE(switch_status_t) switch_ivr_tone_detect_session(switch_core_sessi typedef struct { const char *app; uint32_t flags; + switch_bind_flag_t bind_flags; } dtmf_meta_app_t; typedef struct { dtmf_meta_app_t map[10]; time_t last_digit; - switch_bool_t meta_on; + switch_bool_t meta_on; + int up; +} dtmf_meta_settings_t; + +typedef struct { + dtmf_meta_settings_t sr[2]; } dtmf_meta_data_t; #define SWITCH_META_VAR_KEY "__dtmf_meta" -static switch_status_t meta_on_dtmf(switch_core_session_t *session, const switch_dtmf_t *dtmf) +static switch_status_t meta_on_dtmf(switch_core_session_t *session, const switch_dtmf_t *dtmf, switch_dtmf_direction_t direction) { switch_channel_t *channel = switch_core_session_get_channel(session); dtmf_meta_data_t *md = switch_channel_get_private(channel, SWITCH_META_VAR_KEY); @@ -1320,39 +1326,77 @@ static switch_status_t meta_on_dtmf(switch_core_session_t *session, const switch return SWITCH_STATUS_SUCCESS; } - if (md->meta_on && now - md->last_digit > 5) { - md->meta_on = SWITCH_FALSE; + if (direction == SWITCH_DTMF_RECV && !md->sr[SWITCH_DTMF_RECV].up) { + return SWITCH_STATUS_SUCCESS; + } + + if (direction == SWITCH_DTMF_SEND && !md->sr[SWITCH_DTMF_SEND].up) { + return SWITCH_STATUS_SUCCESS; + } + + if (md->sr[direction].meta_on && now - md->sr[direction].last_digit > 5) { + md->sr[direction].meta_on = SWITCH_FALSE; switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "%s Meta digit timeout parsing %c\n", switch_channel_get_name(channel), dtmf->digit); return SWITCH_STATUS_SUCCESS; } - md->last_digit = now; + md->sr[direction].last_digit = now; if (dtmf->digit == '*') { - if (md->meta_on) { - md->meta_on = SWITCH_FALSE; + if (md->sr[direction].meta_on) { + md->sr[direction].meta_on = SWITCH_FALSE; return SWITCH_STATUS_SUCCESS; } else { - md->meta_on = SWITCH_TRUE; + md->sr[direction].meta_on = SWITCH_TRUE; return SWITCH_STATUS_FALSE; } } - if (md->meta_on) { + if (md->sr[direction].meta_on) { if (dtmf->digit >= '0' && dtmf->digit <= '9') { *digit = dtmf->digit; dval = atoi(digit); - if (md->map[dval].app) { + int ok = 0; + + if (direction == SWITCH_DTMF_RECV && (md->sr[direction].map[dval].bind_flags & SBF_DIAL_ALEG)) { + ok = 1; + } else if (direction == SWITCH_DTMF_SEND && (md->sr[direction].map[dval].bind_flags & SBF_DIAL_BLEG)) { + ok = 1; + } + + if (ok && md->sr[direction].map[dval].app) { + uint32_t flags = md->sr[direction].map[dval].flags; + + if ((md->sr[direction].map[dval].bind_flags & SBF_EXEC_OPPOSITE)) { + if (direction == SWITCH_DTMF_SEND) { + flags |= SMF_ECHO_ALEG; + } else { + flags |= SMF_ECHO_BLEG; + } + } else if ((md->sr[direction].map[dval].bind_flags & SBF_EXEC_SAME)) { + if (direction == SWITCH_DTMF_SEND) { + flags |= SMF_ECHO_BLEG; + } else { + flags |= SMF_ECHO_ALEG; + } + } else if ((md->sr[direction].map[dval].bind_flags & SBF_EXEC_ALEG)) { + flags |= SMF_ECHO_ALEG; + } else if ((md->sr[direction].map[dval].bind_flags & SBF_EXEC_BLEG)) { + flags |= SMF_ECHO_BLEG; + } else { + flags |= SMF_ECHO_ALEG; + } + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "%s Processing meta digit '%c' [%s]\n", - switch_channel_get_name(channel), dtmf->digit, md->map[dval].app); - switch_ivr_broadcast(switch_core_session_get_uuid(session), md->map[dval].app, md->map[dval].flags); + switch_channel_get_name(channel), dtmf->digit, md->sr[direction].map[dval].app); + switch_ivr_broadcast(switch_core_session_get_uuid(session), md->sr[direction].map[dval].app, flags); } else { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "%s Ignoring meta digit '%c' not mapped\n", switch_channel_get_name(channel), dtmf->digit); } } - md->meta_on = SWITCH_FALSE; + md->sr[direction].meta_on = SWITCH_FALSE; return SWITCH_STATUS_FALSE; } @@ -1368,7 +1412,7 @@ SWITCH_DECLARE(switch_status_t) switch_ivr_unbind_dtmf_meta_session(switch_core_ } SWITCH_DECLARE(switch_status_t) switch_ivr_bind_dtmf_meta_session(switch_core_session_t *session, uint32_t key, - switch_bool_t dial_b, switch_bool_t exec_b, const char *app) + switch_bind_flag_t bind_flags, const char *app) { switch_channel_t *channel = switch_core_session_get_channel(session); dtmf_meta_data_t *md = switch_channel_get_private(channel, SWITCH_META_VAR_KEY); @@ -1377,25 +1421,39 @@ SWITCH_DECLARE(switch_status_t) switch_ivr_bind_dtmf_meta_session(switch_core_se switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Invalid key %u\n", key); return SWITCH_STATUS_FALSE; } - + if (!md) { md = switch_core_session_alloc(session, sizeof(*md)); switch_channel_set_private(channel, SWITCH_META_VAR_KEY, md); - if (dial_b) { - switch_core_event_hook_add_send_dtmf(session, meta_on_dtmf); - } else { - switch_core_event_hook_add_recv_dtmf(session, meta_on_dtmf); - } + switch_core_event_hook_add_send_dtmf(session, meta_on_dtmf); + switch_core_event_hook_add_recv_dtmf(session, meta_on_dtmf); } if (!switch_strlen_zero(app)) { - md->map[key].app = switch_core_session_strdup(session, app); - md->map[key].flags = exec_b ? SMF_ECHO_BLEG : SMF_ECHO_ALEG; - md->map[key].flags |= SMF_HOLD_BLEG; - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Bound: %d %s\n", key, app); + if ((bind_flags & SBF_DIAL_ALEG)) { + md->sr[SWITCH_DTMF_RECV].up = 1; + md->sr[SWITCH_DTMF_RECV].map[key].app = switch_core_session_strdup(session, app); + md->sr[SWITCH_DTMF_RECV].map[key].flags |= SMF_HOLD_BLEG; + md->sr[SWITCH_DTMF_RECV].map[key].bind_flags = bind_flags; + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Bound A-Leg: %d %s\n", key, app); + } + if ((bind_flags & SBF_DIAL_BLEG)) { + md->sr[SWITCH_DTMF_SEND].up = 1; + md->sr[SWITCH_DTMF_SEND].map[key].app = switch_core_session_strdup(session, app); + md->sr[SWITCH_DTMF_SEND].map[key].flags |= SMF_HOLD_BLEG; + md->sr[SWITCH_DTMF_SEND].map[key].bind_flags = bind_flags; + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Bound B-Leg: %d %s\n", key, app); + } + } else { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "UnBound: %d\n", key); - md->map[key].app = NULL; + if ((bind_flags & SBF_DIAL_ALEG)) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "UnBound A-Leg: %d\n", key); + md->sr[SWITCH_DTMF_SEND].map[key].app = NULL; + } else { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "UnBound: B-Leg %d\n", key); + md->sr[SWITCH_DTMF_SEND].map[key].app = NULL; + } } return SWITCH_STATUS_SUCCESS; diff --git a/src/switch_ivr_originate.c b/src/switch_ivr_originate.c index 1e42c57530..6bb77b8c42 100644 --- a/src/switch_ivr_originate.c +++ b/src/switch_ivr_originate.c @@ -1154,16 +1154,17 @@ SWITCH_DECLARE(switch_status_t) switch_ivr_originate(switch_core_session_t *sess } } } - - if (caller_channel && i == 0) { - holding = switch_channel_get_variable(caller_channel, SWITCH_HOLDING_UUID_VARIABLE); - holding = switch_core_session_strdup(session, holding); - switch_channel_set_variable(caller_channel, SWITCH_HOLDING_UUID_VARIABLE, NULL); - } - if (holding) { - switch_ivr_uuid_bridge(holding, switch_core_session_get_uuid(peer_sessions[i])); - } else { - switch_channel_hangup(peer_channels[i], reason); + if (switch_channel_ready(peer_channels[i])) { + if (caller_channel && i == 0) { + holding = switch_channel_get_variable(caller_channel, SWITCH_HOLDING_UUID_VARIABLE); + holding = switch_core_session_strdup(session, holding); + switch_channel_set_variable(caller_channel, SWITCH_HOLDING_UUID_VARIABLE, NULL); + } + if (holding) { + switch_ivr_uuid_bridge(holding, switch_core_session_get_uuid(peer_sessions[i])); + } else { + switch_channel_hangup(peer_channels[i], reason); + } } } }