October 2007 - Freeswitch-trunk - FreeSWITCH Mailing Lists

[commit] r6097 - in freeswitch/trunk/src: . include mod/applications/mod_dptools
by Freeswitch SVN 31 Oct '07

31 Oct '07

Author: anthm Date: Wed Oct 31 12:44:02 2007 New Revision: 6097 Modified: freeswitch/trunk/src/include/switch_ivr.h freeswitch/trunk/src/mod/applications/mod_dptools/mod_dptools.c freeswitch/trunk/src/switch_ivr_async.c Log: add inband dtmf generator Modified: freeswitch/trunk/src/include/switch_ivr.h ============================================================================== --- freeswitch/trunk/src/include/switch_ivr.h (original) +++ freeswitch/trunk/src/include/switch_ivr.h Wed Oct 31 12:44:02 2007 @@ -227,6 +227,21 @@ */ SWITCH_DECLARE(switch_status_t) switch_ivr_stop_inband_dtmf_session(switch_core_session_t *session); + +/*! + \brief Start generating DTMF inband + \param session the session to generate on + \return SWITCH_STATUS_SUCCESS if all is well +*/ +SWITCH_DECLARE(switch_status_t) switch_ivr_inband_dtmf_generate_session(switch_core_session_t *session, switch_bool_t read_stream); + +/*! + \brief Stop generating DTMF inband + \param session the session to stop generating + \return SWITCH_STATUS_SUCCESS if all is well +*/ +SWITCH_DECLARE(switch_status_t) switch_ivr_stop_inband_dtmf_generate_session(switch_core_session_t *session); + /*! \brief XXX DESCRIBE ME \param session the session to act on Modified: freeswitch/trunk/src/mod/applications/mod_dptools/mod_dptools.c ============================================================================== --- freeswitch/trunk/src/mod/applications/mod_dptools/mod_dptools.c (original) +++ freeswitch/trunk/src/mod/applications/mod_dptools/mod_dptools.c Wed Oct 31 12:44:02 2007 @@ -819,6 +819,25 @@ switch_ivr_stop_inband_dtmf_session(session); } +SWITCH_STANDARD_APP(dtmf_session_generate_function) +{ + switch_bool_t do_read = SWITCH_TRUE; + + if (!switch_strlen_zero(data)) { + if (!strcasecmp(data, "write")) { + do_read = SWITCH_FALSE; + } + } + + switch_ivr_inband_dtmf_generate_session(session, do_read); +} + + +SWITCH_STANDARD_APP(stop_dtmf_session_generate_function) +{ + switch_ivr_stop_inband_dtmf_generate_session(session); +} + SWITCH_STANDARD_APP(fax_detect_session_function) { switch_ivr_tone_detect_session(session, "fax", "1100.0", "r", 0, NULL, NULL); @@ -1346,6 +1365,9 @@ SWITCH_ADD_APP(app_interface, "execute_extension", "Execute an extension", "Execute an extension", exe_function, EXE_SYNTAX, SAF_SUPPORT_NOMEDIA); SWITCH_ADD_APP(app_interface, "stop_dtmf", "stop inband dtmf", "Stop detecting inband dtmf.", stop_dtmf_session_function, "", SAF_NONE); SWITCH_ADD_APP(app_interface, "start_dtmf", "Detect dtmf", "Detect inband dtmf on the session", dtmf_session_function, "", SAF_NONE); + SWITCH_ADD_APP(app_interface, "stop_dtmf_generate", "stop inband dtmf generation", "Stop generating inband dtmf.", + stop_dtmf_session_generate_function, "[write]", SAF_NONE); + SWITCH_ADD_APP(app_interface, "start_dtmf_generate", "Generate dtmf", "Generate inband dtmf on the session", dtmf_session_generate_function, "", SAF_NONE); SWITCH_ADD_APP(app_interface, "stop_tone_detect", "stop detecting tones", "Stop detecting tones", stop_fax_detect_session_function, "", SAF_NONE); SWITCH_ADD_APP(app_interface, "fax_detect", "Detect faxes", "Detect fax send tone", fax_detect_session_function, "", SAF_NONE); SWITCH_ADD_APP(app_interface, "tone_detect", "Detect tones", "Detect tones", tone_detect_session_function, "", SAF_NONE); Modified: freeswitch/trunk/src/switch_ivr_async.c ============================================================================== --- freeswitch/trunk/src/switch_ivr_async.c (original) +++ freeswitch/trunk/src/switch_ivr_async.c Wed Oct 31 12:44:02 2007 @@ -70,7 +70,7 @@ switch_threadattr_t *thd_attr = NULL; - switch_channel_answer(channel); + switch_channel_pre_answer(channel); if (switch_channel_test_flag(channel, CF_VIDEO)) { eh.session = session; @@ -221,7 +221,7 @@ return SWITCH_STATUS_GENERR; } - switch_channel_answer(channel); + switch_channel_pre_answer(channel); if (limit) { to = time(NULL) + limit; @@ -343,7 +343,7 @@ return SWITCH_STATUS_GENERR; } - switch_channel_answer(channel); + switch_channel_pre_answer(channel); if ((p = switch_channel_get_variable(channel, "RECORD_TITLE"))) { vval = (const char *) switch_core_session_strdup(session, p); @@ -474,7 +474,7 @@ pvt->session = session; - switch_channel_answer(channel); + switch_channel_pre_answer(channel); if ((status = switch_core_media_bug_add(session, inband_dtmf_callback, pvt, 0, SMBF_READ_STREAM, &bug)) != SWITCH_STATUS_SUCCESS) { return status; @@ -486,6 +486,157 @@ } +typedef struct { + switch_core_session_t *session; + teletone_generation_session_t ts; + switch_buffer_t *audio_buffer; + switch_mutex_t *mutex; + int read; +} switch_inband_dtmf_generate_t; + +static int teletone_dtmf_generate_handler(teletone_generation_session_t * ts, teletone_tone_map_t * map) +{ + switch_buffer_t *audio_buffer = ts->user_data; + int wrote; + + if (!audio_buffer) { + return -1; + } + + wrote = teletone_mux_tones(ts, map); + switch_buffer_write(audio_buffer, ts->buffer, wrote * 2); + + return 0; +} + + +static switch_status_t generate_on_dtmf(switch_core_session_t *session, const char *dtmf) +{ + + switch_media_bug_t *bug; + switch_channel_t *channel = switch_core_session_get_channel(session); + + if ((bug = (switch_media_bug_t *) switch_channel_get_private(channel, "dtmf_generate"))) { + switch_inband_dtmf_generate_t *pvt = (switch_inband_dtmf_generate_t *) switch_core_media_bug_get_user_data(bug); + + if (pvt) { + switch_mutex_lock(pvt->mutex); + teletone_run(&pvt->ts, (char *)dtmf); + switch_mutex_unlock(pvt->mutex); + return SWITCH_STATUS_FALSE; + } + } + return SWITCH_STATUS_SUCCESS; +} + +static switch_bool_t inband_dtmf_generate_callback(switch_media_bug_t *bug, void *user_data, switch_abc_type_t type) +{ + switch_inband_dtmf_generate_t *pvt = (switch_inband_dtmf_generate_t *) user_data; + switch_frame_t *frame; + switch_channel_t *channel = switch_core_session_get_channel(pvt->session); + switch_codec_t *read_codec; + + assert(channel != NULL); + read_codec = switch_core_session_get_read_codec(pvt->session); + + switch (type) { + case SWITCH_ABC_TYPE_INIT: + { + switch_buffer_create_dynamic(&pvt->audio_buffer, 512, 1024, 0); + teletone_init_session(&pvt->ts, 0, teletone_dtmf_generate_handler, pvt->audio_buffer); + pvt->ts.rate = read_codec->implementation->actual_samples_per_second; + pvt->ts.channels = 1; + switch_mutex_init(&pvt->mutex, SWITCH_MUTEX_NESTED, switch_core_session_get_pool(pvt->session)); + switch_core_event_hook_add_recv_dtmf(pvt->session, generate_on_dtmf); + } + break; + case SWITCH_ABC_TYPE_CLOSE: + { + switch_buffer_destroy(&pvt->audio_buffer); + teletone_destroy_session(&pvt->ts); + switch_core_event_hook_remove_recv_dtmf(pvt->session, generate_on_dtmf); + } + break; + case SWITCH_ABC_TYPE_READ_REPLACE: + case SWITCH_ABC_TYPE_WRITE_REPLACE: + { + switch_size_t bytes; + switch_mutex_lock(pvt->mutex); + if (pvt->read) { + frame = switch_core_media_bug_get_read_replace_frame(bug); + } else { + frame = switch_core_media_bug_get_write_replace_frame(bug); + } + if (switch_buffer_inuse(pvt->audio_buffer) && (bytes = switch_buffer_read(pvt->audio_buffer, frame->data, frame->datalen))) { + if (bytes < frame->datalen) { + switch_byte_t *dp = frame->data; + memset(dp + bytes, 0, frame->datalen - bytes); + } + } + if (pvt->read) { + switch_core_media_bug_set_read_replace_frame(bug, frame); + } else { + switch_core_media_bug_set_write_replace_frame(bug, frame); + } + switch_mutex_unlock(pvt->mutex); + } + break; + default: + break; + } + + return SWITCH_TRUE; +} + +SWITCH_DECLARE(switch_status_t) switch_ivr_stop_inband_dtmf_generate_session(switch_core_session_t *session) +{ + switch_media_bug_t *bug; + switch_channel_t *channel = switch_core_session_get_channel(session); + + assert(channel != NULL); + if ((bug = switch_channel_get_private(channel, "dtmf_generate"))) { + switch_channel_set_private(channel, "dtmf_generate", NULL); + switch_core_media_bug_remove(session, &bug); + return SWITCH_STATUS_SUCCESS; + } + + return SWITCH_STATUS_FALSE; + +} + +SWITCH_DECLARE(switch_status_t) switch_ivr_inband_dtmf_generate_session(switch_core_session_t *session, switch_bool_t read_stream) +{ + switch_channel_t *channel; + switch_codec_t *read_codec; + switch_media_bug_t *bug; + switch_status_t status; + switch_inband_dtmf_generate_t *pvt; + + channel = switch_core_session_get_channel(session); + assert(channel != NULL); + + read_codec = switch_core_session_get_read_codec(session); + assert(read_codec != NULL); + + if (!(pvt = switch_core_session_alloc(session, sizeof(*pvt)))) { + return SWITCH_STATUS_MEMERR; + } + + pvt->session = session; + pvt->read = !!read_stream; + switch_channel_pre_answer(channel); + + if ((status = switch_core_media_bug_add(session, inband_dtmf_generate_callback, pvt, 0, + pvt->read ? SMBF_READ_REPLACE : SMBF_WRITE_REPLACE, &bug)) != SWITCH_STATUS_SUCCESS) { + return status; + } + + switch_channel_set_private(channel, "dtmf_generate", bug); + + return SWITCH_STATUS_SUCCESS; +} + + #define MAX_TONES 16 typedef struct { teletone_multi_tone_t mt;

1 0

[commit] r6096 - freeswitch/trunk/libs/apr/network_io/unix
by Freeswitch SVN 31 Oct '07

31 Oct '07

Author: brian Date: Wed Oct 31 12:12:01 2007 New Revision: 6096 Modified: freeswitch/trunk/libs/apr/network_io/unix/sendrecv.c Log: small fix to apr for OS X 10.5 for sendfile Modified: freeswitch/trunk/libs/apr/network_io/unix/sendrecv.c ============================================================================== --- freeswitch/trunk/libs/apr/network_io/unix/sendrecv.c (original) +++ freeswitch/trunk/libs/apr/network_io/unix/sendrecv.c Wed Oct 31 12:12:01 2007 @@ -148,6 +148,8 @@ apr_size_t *len) { apr_ssize_t rv; + + from->salen = sizeof(from->sa); do { rv = recvfrom(sock->socketdes, buf, (*len), flags, @@ -172,6 +174,8 @@ return errno; } + apr_sockaddr_vars_set(from, from->sa.sin.sin_family, ntohs(from->sa.sin.sin_port)); + (*len) = rv; if (rv == 0 && sock->type == SOCK_STREAM) { return APR_EOF; @@ -399,6 +403,109 @@ return rv < 0 ? errno : APR_SUCCESS; } +#elif defined(DARWIN) + +/* OS/X Release 10.5 or greater */ +apr_status_t apr_socket_sendfile(apr_socket_t * sock, apr_file_t * file, + apr_hdtr_t * hdtr, apr_off_t * offset, + apr_size_t * len, apr_int32_t flags) +{ + apr_off_t nbytes = *len; + int rv; + struct sf_hdtr headerstruct; + + /* Ignore flags for now. */ + flags = 0; + + if (!hdtr) { + hdtr = &no_hdtr; + } + + headerstruct.headers = hdtr->headers; + headerstruct.hdr_cnt = hdtr->numheaders; + headerstruct.trailers = hdtr->trailers; + headerstruct.trl_cnt = hdtr->numtrailers; + + /* BSD can send the headers/footers as part of the system call */ + do { + if (sock->options & APR_INCOMPLETE_WRITE) { + apr_status_t arv; + sock->options &= ~APR_INCOMPLETE_WRITE; + arv = apr_wait_for_io_or_timeout(NULL, sock, 0); + if (arv != APR_SUCCESS) { + *len = 0; + return arv; + } + } + if (nbytes) { + /* We won't dare call sendfile() if we don't have + * header or file bytes to send because nbytes == 0 + * means send the remaining file to EOF. + */ + rv = sendfile(file->filedes, /* file to be sent */ + sock->socketdes, /* socket */ + *offset, /* where in the file to start */ + &nbytes, /* number of bytes to write/written */ + &headerstruct, /* Headers/footers */ + flags); /* undefined, set to 0 */ + + if (rv == -1) { + if (errno == EAGAIN) { + if (sock->timeout > 0) { + sock->options |= APR_INCOMPLETE_WRITE; + } + /* BSD's sendfile can return -1/EAGAIN even if it + * sent bytes. Sanitize the result so we get normal EAGAIN + * semantics w.r.t. bytes sent. + */ + if (nbytes) { + /* normal exit for a big file & non-blocking io */ + (*len) = nbytes; + return APR_SUCCESS; + } + } + } + else { /* rv == 0 (or the kernel is broken) */ + if (nbytes == 0) { + /* Most likely the file got smaller after the stat. + * Return an error so the caller can do the Right Thing. + */ + (*len) = nbytes; + return APR_EOF; + } + } + } + else { + /* just trailer bytes... use writev() + */ + rv = writev(sock->socketdes, + hdtr->trailers, + hdtr->numtrailers); + if (rv > 0) { + nbytes = rv; + rv = 0; + } + else { + nbytes = 0; + } + } + if ((rv == -1) && (errno == EAGAIN) + && (sock->timeout > 0)) { + apr_status_t arv = apr_wait_for_io_or_timeout(NULL, sock, 0); + if (arv != APR_SUCCESS) { + *len = 0; + return arv; + } + } + } while (rv == -1 && (errno == EINTR || errno == EAGAIN)); + + (*len) = nbytes; + if (rv == -1) { + return errno; + } + return APR_SUCCESS; +} + #elif defined(__FreeBSD__) || defined(__DragonFly__) /* Release 3.1 or greater */ @@ -407,7 +514,10 @@ apr_size_t * len, apr_int32_t flags) { off_t nbytes = 0; - int rv, i; + int rv; +#if defined(__FreeBSD_version) && __FreeBSD_version < 460001 + int i; +#endif struct sf_hdtr headerstruct; apr_size_t bytes_to_send = *len; @@ -872,7 +982,9 @@ for (i = 0; i < hdtr->numheaders; i++, curvec++) { sfv[curvec].sfv_fd = SFV_FD_SELF; sfv[curvec].sfv_flag = 0; - sfv[curvec].sfv_off = (apr_off_t)hdtr->headers[i].iov_base; + /* Cast to unsigned long to prevent sign extension of the + * pointer value for the LFS case; see PR 39463. */ + sfv[curvec].sfv_off = (unsigned long)hdtr->headers[i].iov_base; sfv[curvec].sfv_len = hdtr->headers[i].iov_len; requested_len += sfv[curvec].sfv_len; } @@ -896,7 +1008,7 @@ for (i = 0; i < hdtr->numtrailers; i++, curvec++) { sfv[curvec].sfv_fd = SFV_FD_SELF; sfv[curvec].sfv_flag = 0; - sfv[curvec].sfv_off = (apr_off_t)hdtr->trailers[i].iov_base; + sfv[curvec].sfv_off = (unsigned long)hdtr->trailers[i].iov_base; sfv[curvec].sfv_len = hdtr->trailers[i].iov_len; requested_len += sfv[curvec].sfv_len; }

1 0

[commit] r6095 - in freeswitch/trunk/src: . include mod/endpoints/mod_sofia
by Freeswitch SVN 31 Oct '07

31 Oct '07

Author: anthm Date: Wed Oct 31 09:08:45 2007 New Revision: 6095 Modified: freeswitch/trunk/src/include/switch_types.h freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c freeswitch/trunk/src/switch_channel.c freeswitch/trunk/src/switch_rtp.c Log: make channel hangup with media_timeout cause when rtp timeout occurs Modified: freeswitch/trunk/src/include/switch_types.h ============================================================================== --- freeswitch/trunk/src/include/switch_types.h (original) +++ freeswitch/trunk/src/include/switch_types.h Wed Oct 31 09:08:45 2007 @@ -1006,7 +1006,8 @@ SWITCH_CAUSE_BLIND_TRANSFER = 600, SWITCH_CAUSE_ATTENDED_TRANSFER = 601, SWITCH_CAUSE_ALLOTTED_TIMEOUT = 602, - SWITCH_CAUSE_USER_CHALLENGE = 603 + SWITCH_CAUSE_USER_CHALLENGE = 603, + SWITCH_CAUSE_MEDIA_TIMEOUT = 604 } switch_call_cause_t; typedef enum { Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Wed Oct 31 09:08:45 2007 @@ -387,7 +387,10 @@ status = switch_rtp_zerocopy_read_frame(tech_pvt->video_rtp_session, &tech_pvt->video_read_frame); if (status != SWITCH_STATUS_SUCCESS && status != SWITCH_STATUS_BREAK) { - return SWITCH_STATUS_FALSE; + if (status == SWITCH_STATUS_TIMEOUT) { + switch_channel_hangup(tech_pvt->channel, SWITCH_CAUSE_MEDIA_TIMEOUT); + } + return status; } payload = tech_pvt->video_read_frame.payload; @@ -492,11 +495,12 @@ status = switch_rtp_zerocopy_read_frame(tech_pvt->rtp_session, &tech_pvt->read_frame); if (status != SWITCH_STATUS_SUCCESS && status != SWITCH_STATUS_BREAK) { - return SWITCH_STATUS_FALSE; + if (status == SWITCH_STATUS_TIMEOUT) { + switch_channel_hangup(tech_pvt->channel, SWITCH_CAUSE_MEDIA_TIMEOUT); + } + return status; } - - - + payload = tech_pvt->read_frame.payload; if (switch_rtp_has_dtmf(tech_pvt->rtp_session)) { Modified: freeswitch/trunk/src/switch_channel.c ============================================================================== --- freeswitch/trunk/src/switch_channel.c (original) +++ freeswitch/trunk/src/switch_channel.c Wed Oct 31 09:08:45 2007 @@ -97,6 +97,7 @@ {"ATTENDED_TRANSFER", SWITCH_CAUSE_ATTENDED_TRANSFER}, {"ALLOTTED_TIMEOUT", SWITCH_CAUSE_ALLOTTED_TIMEOUT}, {"USER_CHALLENGE", SWITCH_CAUSE_USER_CHALLENGE}, + {"MEDIA_TIMEOUT", SWITCH_CAUSE_MEDIA_TIMEOUT}, {NULL, 0} }; Modified: freeswitch/trunk/src/switch_rtp.c ============================================================================== --- freeswitch/trunk/src/switch_rtp.c (original) +++ freeswitch/trunk/src/switch_rtp.c Wed Oct 31 09:08:45 2007 @@ -906,7 +906,7 @@ do_2833(rtp_session); if (!bytes && rtp_session->max_missed_packets) { if (++rtp_session->missed_count >= rtp_session->max_missed_packets) { - return -1; + return -2; } } @@ -1204,7 +1204,7 @@ if (bytes < 0) { *datalen = 0; - return SWITCH_STATUS_GENERR; + return bytes == -2 ? SWITCH_STATUS_TIMEOUT : SWITCH_STATUS_GENERR; } else if (bytes == 0) { *datalen = 0; return SWITCH_STATUS_BREAK; @@ -1244,7 +1244,7 @@ if (bytes < 0) { frame->datalen = 0; - return SWITCH_STATUS_GENERR; + return bytes == -2 ? SWITCH_STATUS_TIMEOUT : SWITCH_STATUS_GENERR; } else if (bytes == 0) { frame->datalen = 0; return SWITCH_STATUS_BREAK;

1 0

[commit] r6094 - freeswitch/trunk/src/mod/endpoints/mod_opal
by Freeswitch SVN 31 Oct '07

31 Oct '07

Author: lzwierko Date: Wed Oct 31 02:05:45 2007 New Revision: 6094 Modified: freeswitch/trunk/src/mod/endpoints/mod_opal/Makefile.am freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.cpp freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.h Log: Modified: freeswitch/trunk/src/mod/endpoints/mod_opal/Makefile.am ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_opal/Makefile.am (original) +++ freeswitch/trunk/src/mod/endpoints/mod_opal/Makefile.am Wed Oct 31 02:05:45 2007 @@ -12,16 +12,14 @@ MODNAME=mod_opal -OPAL_DIR=$(switch_builddir)/libs/opal +OPALDIR=$(switch_builddir)/libs/opal mod_LTLIBRARIES = mod_opal.la mod_opal_la_SOURCES = opalh323_backend.cpp mod_opalh323.cpp -mod_opal_la_CFLAGS = $(AM_CFLAGS) -mod_opal_la_CFLAGS += -I. -I$(OPAL_DIR)/include -mod_opal_la_CPPFLAGS = $(AM_CPPFLAGS) -mod_opal_la_CPPFLAGS += -I. -I$(OPAL_DIR)/include +mod_opal_la_CPPFLAGS = $(AM_CPPFLAGS) -D_REENTRANT -fno-exceptions -Wall -DPTRACING -Os -felide-constructors -Wreorder -I$(OPALDIR)/include + mod_opal_la_LIBADD = $(switch_builddir)/libfreeswitch.la -mod_opal_la_LDFLAGS = -avoid-version -module -no-undefined +mod_opal_la_LDFLAGS = -avoid-version -module -no-undefined -export-symbols-regex ^switch_module_.*$ -rpath $(PREFIX)/$(libdir) -L$(OPALDIR)/lib -lopal_linux_x86_r -lpt_linux_x86_r -lpthread -lsasl2 -lssl -lcrypto -lexpat -ldl #Override the linstall target so we just install the .so/.dylib @@ -34,5 +32,3 @@ else \ $(LIBTOOL) --mode=install $(INSTALL) $(MODNAME).$(DYNAMIC_LIB_EXTEN) $(DESTDIR)$(PREFIX)/$(moddir) >/dev/null ; \ fi - -##include $(OPAL_DIR)/opal_inc.mak Modified: freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.cpp ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.cpp (original) +++ freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.cpp Wed Oct 31 02:05:45 2007 @@ -63,7 +63,7 @@ static bool OpalH323Private_Delete(OpalH323Private_t *o_private) { - switch_mutex_destroy(o_private->m_mutex); + return (switch_mutex_destroy(o_private->m_mutex)==SWITCH_STATUS_SUCCESS); } /** Default constructor @@ -105,9 +105,7 @@ switch_memory_pool_t* i_memoryPool, switch_endpoint_interface_t *i_endpointInterface ) -{ - bool result = true; - +{ /* check if not initialized */ assert(m_isInitialized); @@ -180,21 +178,21 @@ -switch_core_session_t* FSOpalManager::getSessionToken(PString &i_token) +switch_core_session_t* FSOpalManager::getSessionToken(const PString &i_token) { assert(m_pSessionsHashTable); assert(m_pSessionsHashTableMutex); return static_cast<switch_core_session_t*>(switch_core_hash_find_locked(m_pSessionsHashTable,(const char*)i_token,m_pSessionsHashTableMutex)); } -void FSOpalManager::saveSessionToken(PString &i_token,switch_core_session_t* i_session) +void FSOpalManager::saveSessionToken(const PString &i_token,switch_core_session_t* i_session) { assert(m_pSessionsHashTable); assert(m_pSessionsHashTableMutex); switch_core_hash_insert_locked(m_pSessionsHashTable,(const char*)i_token,i_session,m_pSessionsHashTableMutex); } -void FSOpalManager::deleteToken(PString &i_token) +void FSOpalManager::deleteSessionToken(const PString &i_token) { assert(m_pSessionsHashTable); assert(m_pSessionsHashTableMutex); @@ -209,7 +207,7 @@ ) { //TODO check if options and stringOptions fields ever apply - retrun OnIncomingConnection(connection); + return OnIncomingConnection(connection); } BOOL FSOpalManager::OnIncomingConnection( @@ -218,7 +216,7 @@ ) { //TODO, check if options field ever applies - retrun OnIncomingConnection(connection); + return OnIncomingConnection(connection); } BOOL FSOpalManager::OnIncomingConnection( @@ -228,20 +226,20 @@ /* allocate new session in switch core*/ switch_core_session_t *session = switch_core_session_request(m_pEndpointInterface , NULL); assert(session); - if(!sesion) + if(!session) { ///TODO add cause to the connection - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Could not allocate session object?\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Could not allocate session object?\n"); return FALSE; } /* allocate private resources */ OpalH323Private_t *tech_pvt = NULL; - if(!OpalH323Private_Create(&tech_pvt)) + if(!OpalH323Private_Create(&tech_pvt,session)) { ///TODO add cause to the connection switch_core_session_destroy(&session); - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Could not allocate private object?\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Could not allocate private object?\n"); return false; } tech_pvt->m_opalConnection = &connection; @@ -263,17 +261,17 @@ /** Create calling side profile */ tech_pvt->m_callerProfile = switch_caller_profile_new( switch_core_session_get_pool(session), - *connection.GetRemotePartyName(), /** username */ + (const char*)connection.GetRemotePartyName(), /** username */ "default", /** TODO -> this should be configurable by core */ - *connection.GetRemotePartyName(), /** caller_id_name */ - *connection.GetRemotePartyNumber(), /** caller_id_number */ - *connection.GetRemotePartyAddress(), /** network addr */ + (const char*)connection.GetRemotePartyName(), /** caller_id_name */ + (const char*)connection.GetRemotePartyNumber(), /** caller_id_number */ + (const char*)connection.GetRemotePartyAddress(), /** network addr */ NULL, /** ANI */ NULL, /** ANI II */ NULL, /** RDNIS */ m_pModuleName, /** source */ NULL, /** TODO -> set context */ - *connection.GetCalledDestinationNumber() /** destination_number */ + (const char*)connection.GetCalledDestinationNumber() /** destination_number */ ); if(!tech_pvt->m_callerProfile) /* should never error */ @@ -288,7 +286,7 @@ /** Set up sessions channel */ switch_channel_t *channel = switch_core_session_get_channel(session); - switch_channel_set_name(channel,*connection.GetToken()); + switch_channel_set_name(channel,(const char*)connection.GetToken()); switch_channel_set_caller_profile(channel, tech_pvt->m_callerProfile); switch_channel_set_state(channel, CS_INIT); @@ -301,7 +299,7 @@ /** lunch thread */ if (switch_core_session_thread_launch(session) != SWITCH_STATUS_SUCCESS) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Error spawning thread\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Error spawning thread\n"); deleteSessionToken(connection.GetToken()); switch_mutex_unlock(tech_pvt->m_mutex); OpalH323Private_Delete(tech_pvt); @@ -387,7 +385,7 @@ switch_call_cause_t FSOpalManager::io_outgoing_channel(switch_core_session_t *i_session, switch_caller_profile_t *i_profile, switch_core_session_t **o_newSession, switch_memory_pool_t **o_memPool) { assert(m_isInitialized); - return 0; + return SWITCH_CAUSE_SUCCESS; } switch_status_t FSOpalManager::io_read_frame(switch_core_session_t *i_session, switch_frame_t **o_frame, int i_timout, switch_io_flag_t i_flag, int i_streamId) @@ -430,7 +428,7 @@ { assert(m_isInitialized); - OpalH323Private_t* tech_prv = switch_core_session_get_private(i_session); + OpalH323Private_t* tech_prv = static_cast<OpalH323Private_t*>(switch_core_session_get_private(i_session)); assert(tech_prv); switch_mutex_lock(tech_prv->m_mutex); @@ -438,55 +436,55 @@ switch(i_message->message_id) { case SWITCH_MESSAGE_REDIRECT_AUDIO: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_REDIRECT_AUDIO\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_REDIRECT_AUDIO\n"); break; case SWITCH_MESSAGE_TRANSMIT_TEXT: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_TRANSMIT_TEXT\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_TRANSMIT_TEXT\n"); break; case SWITCH_MESSAGE_INDICATE_ANSWER: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_ANSWER\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_ANSWER\n"); /* set call answer */ - tech_prv->m_opalConnection->AnsweringCall(AnswerCallNow); + //tech_prv->m_opalConnection->AnsweringCall(AnswerCallNow); break; case SWITCH_MESSAGE_INDICATE_PROGRESS: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_PROGRESS\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_PROGRESS\n"); break; case SWITCH_MESSAGE_INDICATE_BRIDGE: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_BRIDGE\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_BRIDGE\n"); break; case SWITCH_MESSAGE_INDICATE_UNBRIDGE: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_UNBRIDGE\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_UNBRIDGE\n"); break; case SWITCH_MESSAGE_INDICATE_TRANSFER: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_TRANSFER\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_TRANSFER\n"); break; case SWITCH_MESSAGE_INDICATE_RINGING: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_RINGING\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_RINGING\n"); break; case SWITCH_MESSAGE_INDICATE_MEDIA: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_MEDIA\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_MEDIA\n"); break; case SWITCH_MESSAGE_INDICATE_NOMEDIA: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_NOMEDIA\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_NOMEDIA\n"); break; case SWITCH_MESSAGE_INDICATE_HOLD: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_HOLD\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_HOLD\n"); break; case SWITCH_MESSAGE_INDICATE_UNHOLD: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_UNHOLD\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_UNHOLD\n"); break; case SWITCH_MESSAGE_INDICATE_REDIRECT: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_REDIRECT\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_REDIRECT\n"); break; case SWITCH_MESSAGE_INDICATE_REJECT: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_REJECT\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_REJECT\n"); break; case SWITCH_MESSAGE_INDICATE_BROADCAST: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_BROADCAST\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_BROADCAST\n"); break; case SWITCH_MESSAGE_INDICATE_MEDIA_REDIRECT: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_MEDIA_REDIRECT\n"); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG "SWITCH_MESSAGE_INDICATE_MEDIA_REDIRECT\n"); break; } Modified: freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.h ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.h (original) +++ freeswitch/trunk/src/mod/endpoints/mod_opal/opalh323_backend.h Wed Oct 31 02:05:45 2007 @@ -94,12 +94,27 @@ switch_status_t io_read_video_frame(switch_core_session_t *, switch_frame_t **, int, switch_io_flag_t, int); switch_status_t io_write_video_frame(switch_core_session_t *, switch_frame_t *, int, switch_io_flag_t, int); + virtual BOOL OnIncomingConnection( + OpalConnection & connection, ///< Connection that is calling + unsigned options, ///< options for new connection (can't use default as overrides will fail) + OpalConnection::StringOptions * stringOptions + ); + virtual BOOL OnIncomingConnection( + OpalConnection & connection, ///< Connection that is calling + unsigned options ///< options for new connection (can't use default as overrides will fail) + ); + + virtual BOOL OnIncomingConnection( + OpalConnection & connection ///< Connection that is calling + ); + + private: - void saveSessionToken(PString &i_token,switch_core_session_t* i_session); - switch_core_session_t* getSessionToken(PString &i_token); - void deleteToken(PString &i_token); + void saveSessionToken(const PString &i_token,switch_core_session_t* i_session); + switch_core_session_t* getSessionToken(const PString &i_token); + void deleteSessionToken(const PString &i_token); const char *m_pModuleName; /* name of this module */

1 0

[commit] r6093 - in freeswitch/trunk: conf src src/include src/mod/endpoints/mod_sofia
by Freeswitch SVN 31 Oct '07

31 Oct '07

Author: anthm Date: Tue Oct 30 22:12:30 2007 New Revision: 6093 Modified: freeswitch/trunk/conf/sofia.conf.xml freeswitch/trunk/src/include/switch_rtp.h freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.h freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_glue.c freeswitch/trunk/src/switch_rtp.c Log: rtp timeout Modified: freeswitch/trunk/conf/sofia.conf.xml ============================================================================== --- freeswitch/trunk/conf/sofia.conf.xml (original) +++ freeswitch/trunk/conf/sofia.conf.xml Tue Oct 30 22:12:30 2007 @@ -95,7 +95,8 @@ <param name="ext-rtp-ip" value="$${external_rtp_ip}"/>  - +  +     Modified: freeswitch/trunk/src/include/switch_rtp.h ============================================================================== --- freeswitch/trunk/src/include/switch_rtp.h (original) +++ freeswitch/trunk/src/include/switch_rtp.h Tue Oct 30 22:12:30 2007 @@ -130,6 +130,8 @@ */ SWITCH_DECLARE(switch_status_t) switch_rtp_set_remote_address(switch_rtp_t *rtp_session, const char *host, switch_port_t port, const char **err); +SWITCH_DECLARE(void) switch_rtp_set_max_missed_packets(switch_rtp_t *rtp_session, uint32_t max); + /*! \brief Assign a local address to the RTP session \param rtp_session an RTP session to assign the local address to Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.h ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.h (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.h Tue Oct 30 22:12:30 2007 @@ -259,6 +259,7 @@ time_t started; uint32_t session_timeout; uint32_t max_proceeding; + uint32_t rtp_timeout_sec; #ifdef SWITCH_HAVE_ODBC char *odbc_dsn; char *odbc_user; Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c Tue Oct 30 22:12:30 2007 @@ -893,6 +893,11 @@ if (v_max_proceeding >= 0) { profile->max_proceeding = v_max_proceeding; } + } else if (!strcasecmp(var, "rtp-timeout-sec")) { + int v = atoi(val); + if (v >= 0) { + profile->rtp_timeout_sec = v; + } } else if (!strcasecmp(var, "manage-presence")) { if (switch_true(val)) { profile->pflags |= PFLAG_PRESENCE; Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_glue.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_glue.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_glue.c Tue Oct 30 22:12:30 2007 @@ -937,6 +937,8 @@ switch_rtp_flag_t flags; switch_status_t status; char tmp[50]; + uint32_t rtp_timeout_sec = tech_pvt->profile->rtp_timeout_sec; + assert(tech_pvt != NULL); @@ -1061,6 +1063,20 @@ } + if ((val = switch_channel_get_variable(tech_pvt->channel, "rtp_timeout_sec"))) { + int v = atoi(val); + if (v >= 0) { + rtp_timeout_sec = v; + } + } + + if (rtp_timeout_sec) { + uint32_t packets; + packets = (tech_pvt->read_codec.implementation->samples_per_second * rtp_timeout_sec) / + tech_pvt->read_codec.implementation->samples_per_frame; + + switch_rtp_set_max_missed_packets(tech_pvt->rtp_session, packets); + } if (tech_pvt->te) { switch_rtp_set_telephony_event(tech_pvt->rtp_session, tech_pvt->te); Modified: freeswitch/trunk/src/switch_rtp.c ============================================================================== --- freeswitch/trunk/src/switch_rtp.c (original) +++ freeswitch/trunk/src/switch_rtp.c Tue Oct 30 22:12:30 2007 @@ -168,6 +168,8 @@ uint8_t cn; switch_time_t last_time; stfu_instance_t *jb; + uint32_t max_missed_packets; + uint32_t missed_count; }; static int global_init = 0; @@ -392,6 +394,11 @@ return status; } +SWITCH_DECLARE(void) switch_rtp_set_max_missed_packets(switch_rtp_t *rtp_session, uint32_t max) +{ + rtp_session->max_missed_packets = max; +} + SWITCH_DECLARE(switch_status_t) switch_rtp_set_remote_address(switch_rtp_t *rtp_session, const char *host, switch_port_t port, const char **err) { *err = "Success"; @@ -897,6 +904,11 @@ if (check) { do_2833(rtp_session); + if (!bytes && rtp_session->max_missed_packets) { + if (++rtp_session->missed_count >= rtp_session->max_missed_packets) { + return -1; + } + } if (rtp_session->jb && (jb_frame = stfu_n_read_a_frame(rtp_session->jb))) { memcpy(rtp_session->recv_msg.body, jb_frame->data, jb_frame->dlen); @@ -905,9 +917,9 @@ } bytes = jb_frame->dlen + rtp_header_len; rtp_session->recv_msg.header.ts = htonl(jb_frame->ts); - } else if (switch_test_flag(rtp_session, SWITCH_RTP_FLAG_USE_TIMER)) { - uint8_t *data = (uint8_t *) rtp_session->recv_msg.body; - /* We're late! We're Late! */ + } else if (switch_test_flag(rtp_session, SWITCH_RTP_FLAG_USE_TIMER)) { /* We're late! We're Late! */ + uint8_t *data = (uint8_t *) rtp_session->recv_msg.body; + if (!switch_test_flag(rtp_session, SWITCH_RTP_FLAG_NOBLOCK) && status == SWITCH_STATUS_BREAK) { switch_yield(1000); continue; @@ -942,7 +954,7 @@ return 2 + rtp_header_len; } - + if (bytes && switch_test_flag(rtp_session, SWITCH_RTP_FLAG_SECURE)) { @@ -959,6 +971,9 @@ bytes = sbytes; } + if (bytes > 0) { + rtp_session->missed_count = 0; + } if (status == SWITCH_STATUS_BREAK || bytes == 0) { if (switch_test_flag(rtp_session, SWITCH_RTP_FLAG_DATAWAIT)) {

1 0

[commit] r6092 - freeswitch/trunk/src
by Freeswitch SVN 30 Oct '07

30 Oct '07

Author: anthm Date: Tue Oct 30 18:15:37 2007 New Revision: 6092 Modified: freeswitch/trunk/src/switch_ivr_menu.c Log: update for relative paths Modified: freeswitch/trunk/src/switch_ivr_menu.c ============================================================================== --- freeswitch/trunk/src/switch_ivr_menu.c (original) +++ freeswitch/trunk/src/switch_ivr_menu.c Tue Oct 30 18:15:37 2007 @@ -258,24 +258,18 @@ args.buf = ptr; args.buflen = len; - if (*sound == '/' || *sound == '\\') { - status = switch_ivr_play_file(session, NULL, sound, &args); - } else { - if (strlen(sound) > 4 && strncmp(sound, "say:", 4) == 0) { - if (menu->tts_engine && menu->tts_voice) { - status = switch_ivr_speak_text(session, menu->tts_engine, menu->tts_voice, sound + 4, &args); - } else { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "No TTS engine to play sound\n"); - } + if (strlen(sound) > 4 && strncasecmp(sound, "say:", 4) == 0) { + if (menu->tts_engine && menu->tts_voice) { + status = switch_ivr_speak_text(session, menu->tts_engine, menu->tts_voice, sound + 4, &args); } else { - if (strlen(sound) > 7 && strncmp(sound, "phrase:", 7) == 0) { - status = switch_ivr_phrase_macro(session, sound + 7, "", menu->phrase_lang, &args); - } else { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "play_or_say: no player for [%s]. Use say: or phrase:\n", sound); - } + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "No TTS engine to play sound\n"); } + } else if (strlen(sound) > 7 && strncasecmp(sound, "phrase:", 7) == 0) { + status = switch_ivr_phrase_macro(session, sound + 7, "", menu->phrase_lang, &args); + } else { + status = switch_ivr_play_file(session, NULL, sound, &args); } - + if (need) { menu->ptr += strlen(menu->buf); if (strlen(menu->buf) < need) {

1 0

[commit] r6091 - freeswitch/trunk/src
by Freeswitch SVN 30 Oct '07

30 Oct '07

Author: brian Date: Tue Oct 30 16:19:24 2007 New Revision: 6091 Modified: freeswitch/trunk/src/switch_swig.c Log: small fix Modified: freeswitch/trunk/src/switch_swig.c ============================================================================== --- freeswitch/trunk/src/switch_swig.c (original) +++ freeswitch/trunk/src/switch_swig.c Tue Oct 30 16:19:24 2007 @@ -55,7 +55,7 @@ path = NULL; } - status = switch_core_init(path, &err); + status = switch_core_init(path, SCF_NONE, &err); return status == SWITCH_STATUS_SUCCESS ? 1 : 0; }

1 0

[commit] r6090 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 30 Oct '07

30 Oct '07

Author: anthm Date: Tue Oct 30 10:32:00 2007 New Revision: 6090 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c Log: add lost code Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c Tue Oct 30 10:32:00 2007 @@ -816,6 +816,8 @@ switch_xml_t domain, xml = NULL, user, param, xparams; char hexdigest[2 * SU_MD5_DIGEST_SIZE + 1] = ""; char *pbuf = NULL; + char *domain_name = NULL; + username = realm = nonce = uri = qop = cnonce = nc = response = NULL; if (authorization->au_params) { @@ -884,12 +886,19 @@ pbuf = switch_mprintf("profile=%s", profile->name); - if (switch_xml_locate_user(username, realm, ip, &xml, &domain, &user, pbuf) != SWITCH_STATUS_SUCCESS) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "can't find user [%s@%s]\n", username, realm); + + if (!switch_strlen_zero(profile->reg_domain)) { + domain_name = profile->reg_domain; + } else { + domain_name = realm; + } + + if (switch_xml_locate_user(username, domain_name, ip, &xml, &domain, &user, pbuf) != SWITCH_STATUS_SUCCESS) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "can't find user [%s@%s]\n", username, domain_name); ret = AUTH_FORBIDDEN; goto end; } - + if (!(xparams = switch_xml_child(user, "params"))) { ret = AUTH_OK; goto end;

1 0

[commit] r6089 - freeswitch/trunk/src
by Freeswitch SVN 30 Oct '07

30 Oct '07

Author: mikej Date: Mon Oct 29 23:50:11 2007 New Revision: 6089 Modified: freeswitch/trunk/src/switch_cpp.cpp Log: add missing license header. Modified: freeswitch/trunk/src/switch_cpp.cpp ============================================================================== --- freeswitch/trunk/src/switch_cpp.cpp (original) +++ freeswitch/trunk/src/switch_cpp.cpp Mon Oct 29 23:50:11 2007 @@ -1,3 +1,35 @@ +/* + * FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application + * Copyright (C) 2005/2006, Anthony Minessale II <anthmct(a)yahoo.com> + * + * Version: MPL 1.1 + * + * The contents of this file are subject to the Mozilla Public License Version + * 1.1 (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * http://www.mozilla.org/MPL/ + * + * Software distributed under the License is distributed on an "AS IS" basis, + * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License + * for the specific language governing rights and limitations under the + * License. + * + * The Original Code is FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application + * + * The Initial Developer of the Original Code is + * Anthony Minessale II <anthmct(a)yahoo.com> + * Portions created by the Initial Developer are Copyright (C) + * the Initial Developer. All Rights Reserved. + * + * Contributor(s): + * + * Anthony Minessale II <anthmct(a)yahoo.com> + * + * + * switch_cpp.cpp -- C++ wrapper + * + */ + #include <switch.h> #include <switch_cpp.h>

1 0

[commit] r6088 - freeswitch/trunk/src/mod/applications/mod_fifo
by Freeswitch SVN 29 Oct '07

29 Oct '07

Author: mikej Date: Mon Oct 29 16:49:22 2007 New Revision: 6088 Modified: freeswitch/trunk/src/mod/applications/mod_fifo/ (props changed) freeswitch/trunk/src/mod/applications/mod_fifo/mod_fifo.c Log: fix release build for mod_fifo. svn:ignore props. Modified: freeswitch/trunk/src/mod/applications/mod_fifo/mod_fifo.c ============================================================================== --- freeswitch/trunk/src/mod/applications/mod_fifo/mod_fifo.c (original) +++ freeswitch/trunk/src/mod/applications/mod_fifo/mod_fifo.c Mon Oct 29 16:49:22 2007 @@ -485,7 +485,7 @@ { int len = 0; fifo_node_t *node; - char *data; + char *data = NULL; int argc = 0; char *argv[5] = { 0 }; switch_hash_index_t *hi;

1 0