November 2006 - Freeswitch-trunk - FreeSWITCH Mailing Lists

[commit] r3393 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 17 Nov '06

17 Nov '06

Author: anthm Date: Thu Nov 16 19:13:36 2006 New Revision: 3393 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Log: update 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 Thu Nov 16 19:13:36 2006 @@ -4413,13 +4413,12 @@ oregp->state = REG_STATE_REGED; break; case REG_STATE_UNREGED: - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "registering %s\n", oregp->name); if ((oregp->nh = nua_handle(oregp->profile->nua, NULL, NUTAG_URL(oregp->register_proxy), SIPTAG_TO_STR(oregp->register_to), NUTAG_CALLSTATE_REF(ss_state), SIPTAG_FROM_STR(oregp->register_from), TAG_END()))) { - + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "registering %s\n", oregp->name); oregp->sofia_private.oreg = oregp; nua_handle_bind(oregp->nh, &oregp->sofia_private); @@ -4431,6 +4430,9 @@ TAG_NULL()); oregp->retry = now + 10; oregp->state = REG_STATE_TRYING; + } else { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error registering %s\n", oregp->name); + oregp->state = REG_STATE_FAILED; } break;

1 0

[commit] r3392 - freeswitch/trunk/libs
by Freeswitch SVN 16 Nov '06

16 Nov '06

Author: mikej Date: Thu Nov 16 18:09:36 2006 New Revision: 3392 Modified: freeswitch/trunk/libs/portaudio.build.sh Log: fix portaudio build on ppc, thanks puzzled on irc. Modified: freeswitch/trunk/libs/portaudio.build.sh ============================================================================== --- freeswitch/trunk/libs/portaudio.build.sh (original) +++ freeswitch/trunk/libs/portaudio.build.sh Thu Nov 16 18:09:36 2006 @@ -45,6 +45,9 @@ if [ $arch = "amd64" ] ; then opts="-fPIC" fi +if [ $arch = "ppc" ] ; then +opts="-fPIC" +fi CFLAGS=$opts ./configure $@ $MAKE

1 0

[commit] r3391 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 16 Nov '06

16 Nov '06

Author: anthm Date: Thu Nov 16 17:30:19 2006 New Revision: 3391 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Log: ignore options reply (nevermind) 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 Thu Nov 16 17:30:19 2006 @@ -4271,6 +4271,10 @@ //sip_r_unregister(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; + case nua_r_options: + //sip_r_options(status, phrase, nua, profile, nh, sofia_private, sip, tags); + break; + case nua_i_options: sip_i_options(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; @@ -4343,7 +4347,6 @@ case nua_r_publish: //sip_r_publish(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; - case nua_r_options: case nua_r_message: case nua_r_notify: if (nh) {

1 0

[commit] r3390 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 16 Nov '06

16 Nov '06

Author: anthm Date: Thu Nov 16 17:16:30 2006 New Revision: 3390 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Log: ignore options reply 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 Thu Nov 16 17:16:30 2006 @@ -4271,10 +4271,6 @@ //sip_r_unregister(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; - case nua_r_options: - //sip_r_options(status, phrase, nua, profile, nh, sofia_private, sip, tags); - break; - case nua_i_options: sip_i_options(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; @@ -4347,6 +4343,7 @@ case nua_r_publish: //sip_r_publish(status, phrase, nua, profile, nh, sofia_private, sip, tags); break; + case nua_r_options: case nua_r_message: case nua_r_notify: if (nh) {

1 0

[commit] r3389 - in freeswitch/trunk/src: . mod/endpoints/mod_sofia
by Freeswitch SVN 16 Nov '06

16 Nov '06

Author: anthm Date: Thu Nov 16 16:20:00 2006 New Revision: 3389 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c freeswitch/trunk/src/switch_log.c Log: update 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 Thu Nov 16 16:20:00 2006 @@ -167,7 +167,8 @@ TFLAG_XFER = (1 << 19), TFLAG_NOMEDIA = (1 << 20), TFLAG_BUGGY_2833 = (1 << 21), - TFLAG_SIP_HOLD = (1 << 22) + TFLAG_SIP_HOLD = (1 << 22), + TFLAG_RWLOCK = (1 << 23) } TFLAGS; static struct { @@ -2754,7 +2755,12 @@ break; case nua_callstate_terminated: if (session) { + if (switch_test_flag(tech_pvt, TFLAG_RWLOCK)) { + switch_core_session_rwunlock(session); + switch_clear_flag(tech_pvt, TFLAG_RWLOCK); + } if (!switch_test_flag(tech_pvt, TFLAG_BYE)) { + switch_set_flag_locked(tech_pvt, TFLAG_BYE); if (switch_test_flag(tech_pvt, TFLAG_NOHUP)) { switch_clear_flag_locked(tech_pvt, TFLAG_NOHUP); @@ -3977,7 +3983,8 @@ } attach_private(session, profile, tech_pvt, username); - + switch_core_session_read_lock(session); + switch_set_flag(tech_pvt, TFLAG_RWLOCK); channel = switch_core_session_get_channel(session); switch_channel_set_variable(channel, "endpoint_disposition", "INBOUND CALL"); set_chat_hash(tech_pvt, sip); Modified: freeswitch/trunk/src/switch_log.c ============================================================================== --- freeswitch/trunk/src/switch_log.c (original) +++ freeswitch/trunk/src/switch_log.c Thu Nov 16 16:20:00 2006 @@ -238,6 +238,8 @@ node->content = content; node->timestamp = now; switch_queue_push(LOG_QUEUE, node); + } else { + free(data); } } }

1 0

[commit] r3388 - in freeswitch/trunk/src: . include
by Freeswitch SVN 16 Nov '06

16 Nov '06

Author: anthm Date: Thu Nov 16 14:43:25 2006 New Revision: 3388 Modified: freeswitch/trunk/src/include/switch_core.h freeswitch/trunk/src/switch.c freeswitch/trunk/src/switch_core.c Log: vg mode Modified: freeswitch/trunk/src/include/switch_core.h ============================================================================== --- freeswitch/trunk/src/include/switch_core.h (original) +++ freeswitch/trunk/src/include/switch_core.h Thu Nov 16 14:43:25 2006 @@ -219,9 +219,10 @@ /*! \brief Destroy the core + \param vg nonzero to skip core uninitilize for memory debugging \note to be called at application shutdown */ -SWITCH_DECLARE(switch_status_t) switch_core_destroy(void); +SWITCH_DECLARE(switch_status_t) switch_core_destroy(int vg); ///\} Modified: freeswitch/trunk/src/switch.c ============================================================================== --- freeswitch/trunk/src/switch.c (original) +++ freeswitch/trunk/src/switch.c Thu Nov 16 14:43:25 2006 @@ -195,6 +195,7 @@ char pid_path[256] = ""; // full path to the pid file const char *err = NULL; // error value for return from freeswitch initialization int bg = 0; // TRUE if we are running in background mode + int vg = 0; // TRUE if we are running in vg mode FILE *f; // file handle to the pid file pid_t pid = 0; // int x; // @@ -265,6 +266,10 @@ if (argv[x] && !strcmp(argv[x], "-nc")) { bg++; } + + if (argv[x] && !strcmp(argv[x], "-vg")) { + vg++; + } } if (die) { @@ -302,5 +307,5 @@ switch_core_runtime_loop(bg); - return switch_core_destroy(); + return switch_core_destroy(vg); } Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Thu Nov 16 14:43:25 2006 @@ -4070,7 +4070,7 @@ return 0; } -SWITCH_DECLARE(switch_status_t) switch_core_destroy(void) +SWITCH_DECLARE(switch_status_t) switch_core_destroy(int vg) { switch_event_t *event; if (switch_event_create(&event, SWITCH_EVENT_SHUTDOWN) == SWITCH_STATUS_SUCCESS) { @@ -4097,7 +4097,9 @@ switch_core_db_close(runtime.db); switch_core_db_close(runtime.event_db); switch_xml_destroy(); - + if (vg) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Full destruction of the core disabled for memory debugging purposes.\n"); + } switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Finalizing Shutdown.\n"); switch_log_shutdown(); @@ -4108,7 +4110,9 @@ if (runtime.memory_pool) { apr_pool_destroy(runtime.memory_pool); - apr_terminate(); + if (!vg) { + apr_terminate(); + } } #ifdef WIN32

1 0

[commit] r3387 - freeswitch/trunk/libs/libdingaling/src
by Freeswitch SVN 16 Nov '06

16 Nov '06

Author: anthm Date: Thu Nov 16 14:28:05 2006 New Revision: 3387 Modified: freeswitch/trunk/libs/libdingaling/src/libdingaling.c Log: pesky interop Modified: freeswitch/trunk/libs/libdingaling/src/libdingaling.c ============================================================================== --- freeswitch/trunk/libs/libdingaling/src/libdingaling.c (original) +++ freeswitch/trunk/libs/libdingaling/src/libdingaling.c Thu Nov 16 14:28:05 2006 @@ -264,9 +264,9 @@ session->id = apr_pstrdup(session->pool, id); session->them = apr_pstrdup(session->pool, them); - - session->initiator = apr_pstrdup(session->pool, (flags & LDL_FLAG_OUTBOUND) ? me : them); - + if (flags & LDL_FLAG_OUTBOUND) { + session->initiator = apr_pstrdup(session->pool, me); + } if (ldl_test_flag(handle, LDL_FLAG_COMPONENT)) { session->login = apr_pstrdup(session->pool, me);

1 0

[commit] r3386 - freeswitch/trunk/src
by Freeswitch SVN 16 Nov '06

16 Nov '06

Author: mikej Date: Thu Nov 16 13:48:53 2006 New Revision: 3386 Modified: freeswitch/trunk/src/switch_rtp.c Log: logic fix on rtp_common_read on a not ready session, init bytes to 0 so the checks outside of the while loop work. Modified: freeswitch/trunk/src/switch_rtp.c ============================================================================== --- freeswitch/trunk/src/switch_rtp.c (original) +++ freeswitch/trunk/src/switch_rtp.c Thu Nov 16 13:48:53 2006 @@ -757,7 +757,7 @@ static int rtp_common_read(switch_rtp_t *rtp_session, switch_payload_t *payload_type, switch_frame_flag_t *flags) { - switch_size_t bytes; + switch_size_t bytes = 0; switch_status_t status; uint8_t check = 1;

1 0

[commit] r3385 - in freeswitch/trunk: libs/libdingaling libs/libdingaling/src src/mod/endpoints/mod_dingaling
by Freeswitch SVN 16 Nov '06

16 Nov '06

Author: anthm Date: Thu Nov 16 11:10:39 2006 New Revision: 3385 Modified: freeswitch/trunk/libs/libdingaling/.update freeswitch/trunk/libs/libdingaling/src/libdingaling.c freeswitch/trunk/libs/libdingaling/src/libdingaling.h freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c Log: update Modified: freeswitch/trunk/libs/libdingaling/.update ============================================================================== --- freeswitch/trunk/libs/libdingaling/.update (original) +++ freeswitch/trunk/libs/libdingaling/.update Thu Nov 16 11:10:39 2006 @@ -1 +1 @@ -Wed Nov 15 20:20:53 UTC 2006 +Thu Nov 16 16:09:31 UTC 2006 Modified: freeswitch/trunk/libs/libdingaling/src/libdingaling.c ============================================================================== --- freeswitch/trunk/libs/libdingaling/src/libdingaling.c (original) +++ freeswitch/trunk/libs/libdingaling/src/libdingaling.c Thu Nov 16 11:10:39 2006 @@ -250,7 +250,7 @@ } -ldl_status ldl_session_create(ldl_session_t **session_p, ldl_handle_t *handle, char *id, char *them, char *me) +ldl_status ldl_session_create(ldl_session_t **session_p, ldl_handle_t *handle, char *id, char *them, char *me, ldl_user_flag_t flags) { ldl_session_t *session = NULL; @@ -264,10 +264,10 @@ session->id = apr_pstrdup(session->pool, id); session->them = apr_pstrdup(session->pool, them); - if (me) { - session->initiator = apr_pstrdup(session->pool, me); - } + + session->initiator = apr_pstrdup(session->pool, (flags & LDL_FLAG_OUTBOUND) ? me : them); + if (ldl_test_flag(handle, LDL_FLAG_COMPONENT)) { session->login = apr_pstrdup(session->pool, me); } else { @@ -298,7 +298,7 @@ char *msg = NULL; if (!(session = apr_hash_get(handle->sessions, id, APR_HASH_KEY_STRING))) { - ldl_session_create(&session, handle, id, from, to); + ldl_session_create(&session, handle, id, from, to, LDL_FLAG_NONE); if (!session) { return LDL_STATUS_MEMERR; } Modified: freeswitch/trunk/libs/libdingaling/src/libdingaling.h ============================================================================== --- freeswitch/trunk/libs/libdingaling/src/libdingaling.h (original) +++ freeswitch/trunk/libs/libdingaling/src/libdingaling.h Thu Nov 16 11:10:39 2006 @@ -110,10 +110,12 @@ } ldl_flag_t; typedef enum { + LDL_FLAG_NONE = 0, LDL_FLAG_TLS = (1 << 10), LDL_FLAG_SASL_PLAIN = (1 << 11), LDL_FLAG_SASL_MD5 = (1 << 12), LDL_FLAG_COMPONENT = (1 << 13), + LDL_FLAG_OUTBOUND = (1 << 14) } ldl_user_flag_t; typedef enum { @@ -253,9 +255,10 @@ \param id the id to use for the session \param them the id of the other end of the call \param me the id of our end of the call + \param flags user flags \return SUCCESS OR FAILURE */ -ldl_status ldl_session_create(ldl_session_t **session_p, ldl_handle_t *handle, char *id, char *them, char *me); +ldl_status ldl_session_create(ldl_session_t **session_p, ldl_handle_t *handle, char *id, char *them, char *me, ldl_user_flag_t flags); /*! \brief get the id of a session Modified: freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c Thu Nov 16 11:10:39 2006 @@ -1565,7 +1565,7 @@ switch_stun_random_string(sess_id, 10, "0123456789"); tech_pvt->us = switch_core_session_strdup(session, user); tech_pvt->them = switch_core_session_strdup(session, full_id); - ldl_session_create(&dlsession, mdl_profile->handle, sess_id, full_id, user); + ldl_session_create(&dlsession, mdl_profile->handle, sess_id, full_id, user, LDL_FLAG_OUTBOUND); tech_pvt->profile = mdl_profile; ldl_session_set_private(dlsession, *new_session); //ldl_session_set_value(dlsession, "dnis", dnis);

1 0

[commit] r3384 - in freeswitch/trunk: libs/libdingaling/src src src/mod/endpoints/mod_dingaling
by Freeswitch SVN 16 Nov '06

16 Nov '06

Author: anthm Date: Thu Nov 16 10:50:17 2006 New Revision: 3384 Modified: freeswitch/trunk/libs/libdingaling/src/libdingaling.c freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c freeswitch/trunk/src/switch_rtp.c Log: update Modified: freeswitch/trunk/libs/libdingaling/src/libdingaling.c ============================================================================== --- freeswitch/trunk/libs/libdingaling/src/libdingaling.c (original) +++ freeswitch/trunk/libs/libdingaling/src/libdingaling.c Thu Nov 16 10:50:17 2006 @@ -264,9 +264,9 @@ session->id = apr_pstrdup(session->pool, id); session->them = apr_pstrdup(session->pool, them); - //if (me) { - //session->initiator = apr_pstrdup(session->pool, them); - //} + if (me) { + session->initiator = apr_pstrdup(session->pool, me); + } if (ldl_test_flag(handle, LDL_FLAG_COMPONENT)) { session->login = apr_pstrdup(session->pool, me); @@ -1468,14 +1468,29 @@ } +static void add_elements(ldl_session_t *session, iks *tag) +{ + apr_hash_index_t *hi; + for (hi = apr_hash_first(session->pool, session->variables); hi; hi = apr_hash_next(hi)) { + void *val = NULL; + const void *key = NULL; + apr_hash_this(hi, &key, NULL, &val); + if (val) { + iks *var = iks_insert(tag, "info_element"); + iks_insert_attrib(var, "xmlns", "http://www.freeswitch.org/jie"); + iks_insert_attrib(var, "name", (char *) key); + iks_insert_attrib(var, "value", (char *) val); + } + } +} + static ldl_status new_session_iq(ldl_session_t *session, iks **iqp, iks **sessp, unsigned int *id, char *type) { iks *iq, *sess; unsigned int myid; char idbuf[80]; - apr_hash_index_t *hi; myid = next_id(); snprintf(idbuf, sizeof(idbuf), "%u", myid); @@ -1491,19 +1506,7 @@ iks_insert_attrib(sess, "type", type); iks_insert_attrib(sess, "id", session->id); iks_insert_attrib(sess, "initiator", session->initiator ? session->initiator : session->them); - for (hi = apr_hash_first(session->pool, session->variables); hi; hi = apr_hash_next(hi)) { - void *val = NULL; - const void *key = NULL; - apr_hash_this(hi, &key, NULL, &val); - if (val) { - iks *var = iks_insert(sess, "info_element"); - iks_insert_attrib(var, "xmlns", "http://www.freeswitch.org/jie"); - iks_insert_attrib(var, "name", (char *) key); - iks_insert_attrib(var, "value", (char *) val); - } - } - *sessp = sess; *iqp = iq; *id = myid; @@ -1717,6 +1720,8 @@ new_session_iq(session, &iq, &sess, &id, "transport-info"); tag = iks_insert(sess, "transport"); iks_insert_attrib(tag, "xmlns", "http://www.google.com/transport/p2p"); + + add_elements(session, tag); tag = iks_insert(tag, "candidate"); if (candidates[x].name) { Modified: freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_dingaling/mod_dingaling.c Thu Nov 16 10:50:17 2006 @@ -248,7 +248,7 @@ } rpid = translate_rpid(rpid, status); - ldl_handle_send_presence(profile->handle, sub_to, sub_from, "probe", rpid, status); + //ldl_handle_send_presence(profile->handle, sub_to, sub_from, "probe", rpid, status); ldl_handle_send_presence(profile->handle, sub_to, sub_from, type, rpid, status); @@ -333,7 +333,6 @@ type, rpid, status, proto, from); - for (hi = switch_hash_first(apr_hash_pool_get(globals.profile_hash), globals.profile_hash); hi; hi = switch_hash_next(hi)) { char *errmsg; switch_hash_this(hi, NULL, NULL, &val); @@ -819,6 +818,7 @@ cand[0].protocol = "udp"; switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Send Candidate %s:%d [%s]\n", cand[0].address, cand[0].port, cand[0].username); tech_pvt->cand_id = ldl_session_candidates(tech_pvt->dlsession, cand, 1); + switch_set_flag_locked(tech_pvt, TFLAG_TRANSPORT); switch_set_flag_locked(tech_pvt, TFLAG_RTP_READY); } switch_clear_flag_locked(tech_pvt, TFLAG_DO_CAND); @@ -913,6 +913,7 @@ started = switch_time_now(); if (switch_test_flag(tech_pvt, TFLAG_OUTBOUND)) { + tech_pvt->next_cand = switch_time_now() + DL_CAND_WAIT; tech_pvt->next_desc = switch_time_now(); } else { tech_pvt->next_cand = switch_time_now() + DL_CAND_WAIT; @@ -1567,9 +1568,9 @@ ldl_session_create(&dlsession, mdl_profile->handle, sess_id, full_id, user); tech_pvt->profile = mdl_profile; ldl_session_set_private(dlsession, *new_session); - ldl_session_set_value(dlsession, "dnis", dnis); - ldl_session_set_value(dlsession, "caller_id_name", outbound_profile->caller_id_name); - ldl_session_set_value(dlsession, "caller_id_number", outbound_profile->caller_id_number); + //ldl_session_set_value(dlsession, "dnis", dnis); + //ldl_session_set_value(dlsession, "caller_id_name", outbound_profile->caller_id_name); + //ldl_session_set_value(dlsession, "caller_id_number", outbound_profile->caller_id_number); tech_pvt->dlsession = dlsession; if (!get_codecs(tech_pvt)) { terminate_session(new_session, __LINE__, SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER); @@ -2101,7 +2102,13 @@ execute_sql(profile->dbname, sql, profile->mutex); switch_core_db_free(sql); } + if (is_special(to)) { + ldl_handle_send_presence(profile->handle, to, from, NULL, "unknown", "Click To Call"); + } + +#if 0 + if (is_special(to)) { if (switch_event_create(&event, SWITCH_EVENT_PRESENCE_IN) == SWITCH_STATUS_SUCCESS) { switch_event_add_header(event, SWITCH_STACK_BOTTOM, "proto", MDL_CHAT_PROTO); switch_event_add_header(event, SWITCH_STACK_BOTTOM, "login", "%s", profile->login); @@ -2111,6 +2118,7 @@ switch_event_fire(&event); } } +#endif break; case LDL_SIGNAL_ROSTER: if (switch_event_create(&event, SWITCH_EVENT_ROSTER) == SWITCH_STATUS_SUCCESS) { @@ -2135,7 +2143,12 @@ switch_event_fire(&event); } + if (is_special(to)) { + ldl_handle_send_presence(profile->handle, to, from, NULL, "unknown", "Click To Call"); + } +#if 0 + if (is_special(to)) { if (switch_event_create(&event, SWITCH_EVENT_PRESENCE_IN) == SWITCH_STATUS_SUCCESS) { switch_event_add_header(event, SWITCH_STACK_BOTTOM, "proto", MDL_CHAT_PROTO); switch_event_add_header(event, SWITCH_STACK_BOTTOM, "login", "%s", profile->login); @@ -2146,7 +2159,7 @@ } } break; - +#endif case LDL_SIGNAL_PRESENCE_OUT: if ((sql = switch_mprintf("update subscriptions set show='%q', status='%q' where sub_from='%q'", msg, subject, from))) { @@ -2285,6 +2298,7 @@ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Creating a session for %s\n", ldl_session_get_id(dlsession)); ldl_session_set_private(dlsession, session); tech_pvt->dlsession = dlsession; + switch_channel_set_name(channel, "DingaLing/new"); switch_channel_set_state(channel, CS_INIT); switch_core_session_thread_launch(session); } else { @@ -2414,176 +2428,178 @@ } } } - break; case LDL_SIGNAL_CANDIDATES: if (signal) { ldl_candidate_t *candidates; unsigned int len = 0; + unsigned int x; - if (ldl_session_get_candidates(dlsession, &candidates, &len) == LDL_STATUS_SUCCESS) { - unsigned int x; + if (ldl_session_get_candidates(dlsession, &candidates, &len) != LDL_STATUS_SUCCESS) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Candidate Error!\n"); + switch_set_flag(tech_pvt, TFLAG_BYE); + switch_clear_flag(tech_pvt, TFLAG_IO); + status = LDL_STATUS_FALSE; + goto done; + } - if (tech_pvt->remote_ip) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Already picked an IP [%s]\n", tech_pvt->remote_ip); - break; - } + if (tech_pvt->remote_ip) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Already picked an IP [%s]\n", tech_pvt->remote_ip); + break; + } - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "%u candidates\n", len); - for(x = 0; x < len; x++) { - uint8_t lanaddr = 0; + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "%u candidates\n", len); + for(x = 0; x < len; x++) { + uint8_t lanaddr = 0; - if (profile->lanaddr) { - lanaddr = strncasecmp(candidates[x].address, profile->lanaddr, strlen(profile->lanaddr)) ? 0 : 1; - } + if (profile->lanaddr) { + lanaddr = strncasecmp(candidates[x].address, profile->lanaddr, strlen(profile->lanaddr)) ? 0 : 1; + } - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "candidates %s:%d\n", candidates[x].address, candidates[x].port); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "candidates %s:%d\n", candidates[x].address, candidates[x].port); - if (!strcasecmp(candidates[x].protocol, "udp") && (!strcasecmp(candidates[x].type, "local") || !strcasecmp(candidates[x].type, "stun")) && - ((profile->lanaddr && lanaddr) || - (strncasecmp(candidates[x].address, "10.", 3) && - strncasecmp(candidates[x].address, "192.168.", 8) && - strncasecmp(candidates[x].address, "127.", 4) && - strncasecmp(candidates[x].address, "1.", 2) && - strncasecmp(candidates[x].address, "2.", 2) && - strncasecmp(candidates[x].address, "172.16.", 7) && - strncasecmp(candidates[x].address, "172.17.", 7) && - strncasecmp(candidates[x].address, "172.18.", 7) && - strncasecmp(candidates[x].address, "172.19.", 7) && - strncasecmp(candidates[x].address, "172.2", 5) && - strncasecmp(candidates[x].address, "172.30.", 7) && - strncasecmp(candidates[x].address, "172.31.", 7) - ))) { - ldl_payload_t payloads[5]; - char *exten; - char *context; - char *cid_name; - char *cid_num; - char *tmp, *t, *them = NULL; + if (!strcasecmp(candidates[x].protocol, "udp") && (!strcasecmp(candidates[x].type, "local") || !strcasecmp(candidates[x].type, "stun")) && + ((profile->lanaddr && lanaddr) || + (strncasecmp(candidates[x].address, "10.", 3) && + strncasecmp(candidates[x].address, "192.168.", 8) && + strncasecmp(candidates[x].address, "127.", 4) && + strncasecmp(candidates[x].address, "1.", 2) && + strncasecmp(candidates[x].address, "2.", 2) && + strncasecmp(candidates[x].address, "172.16.", 7) && + strncasecmp(candidates[x].address, "172.17.", 7) && + strncasecmp(candidates[x].address, "172.18.", 7) && + strncasecmp(candidates[x].address, "172.19.", 7) && + strncasecmp(candidates[x].address, "172.2", 5) && + strncasecmp(candidates[x].address, "172.30.", 7) && + strncasecmp(candidates[x].address, "172.31.", 7) + ))) { + ldl_payload_t payloads[5]; + char *exten; + char *context; + char *cid_name; + char *cid_num; + char *tmp, *t, *them = NULL; - memset(payloads, 0, sizeof(payloads)); + memset(payloads, 0, sizeof(payloads)); - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Acceptable Candidate %s:%d\n", candidates[x].address, candidates[x].port); + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Acceptable Candidate %s:%d\n", candidates[x].address, candidates[x].port); - if (!switch_test_flag(tech_pvt, TFLAG_OUTBOUND)) { - ldl_session_accept_candidate(dlsession, &candidates[x]); - } + if (!switch_test_flag(tech_pvt, TFLAG_OUTBOUND)) { + switch_set_flag_locked(tech_pvt, TFLAG_TRANSPORT_ACCEPT); + ldl_session_accept_candidate(dlsession, &candidates[x]); + } - if (!(exten = ldl_session_get_value(dlsession, "dnis"))) { - exten = profile->exten; - /* if it's _auto_ set the extension to match the username portion of the called address */ - if (!strcmp(exten, "_auto_")) { - if ((t = ldl_session_get_callee(dlsession))) { - if ((them = strdup(t))) { - char *a, *b, *p; - if ((p = strchr(them, '/'))) { - *p = '\0'; - } + if (!(exten = ldl_session_get_value(dlsession, "dnis"))) { + exten = profile->exten; + /* if it's _auto_ set the extension to match the username portion of the called address */ + if (!strcmp(exten, "_auto_")) { + if ((t = ldl_session_get_callee(dlsession))) { + if ((them = strdup(t))) { + char *a, *b, *p; + if ((p = strchr(them, '/'))) { + *p = '\0'; + } - if ((a = strchr(them, '+')) && (b = strrchr(them, '+')) && a != b) { - *b++ = '\0'; - switch_channel_set_variable(channel, "dl_user", them); - switch_channel_set_variable(channel, "dl_host", b); - } - exten = them; + if ((a = strchr(them, '+')) && (b = strrchr(them, '+')) && a != b) { + *b++ = '\0'; + switch_channel_set_variable(channel, "dl_user", them); + switch_channel_set_variable(channel, "dl_host", b); } + exten = them; } } } + } - if (!(context = ldl_session_get_value(dlsession, "context"))) { - context = profile->context; - } + if (!(context = ldl_session_get_value(dlsession, "context"))) { + context = profile->context; + } - if (!(cid_name = ldl_session_get_value(dlsession, "caller_id_name"))) { - cid_name = tech_pvt->recip; - } + if (!(cid_name = ldl_session_get_value(dlsession, "caller_id_name"))) { + cid_name = tech_pvt->recip; + } - if (!(cid_num = ldl_session_get_value(dlsession, "caller_id_number"))) { - cid_num = tech_pvt->recip; - } + if (!(cid_num = ldl_session_get_value(dlsession, "caller_id_number"))) { + cid_num = tech_pvt->recip; + } - /* context of "_auto_" means set it to the domain */ - if (profile->context && !strcmp(profile->context, "_auto_")) { - context = profile->name; - } + /* context of "_auto_" means set it to the domain */ + if (profile->context && !strcmp(profile->context, "_auto_")) { + context = profile->name; + } - tech_pvt->them = switch_core_session_strdup(session, ldl_session_get_callee(dlsession)); - tech_pvt->us = switch_core_session_strdup(session, ldl_session_get_caller(dlsession)); + tech_pvt->them = switch_core_session_strdup(session, ldl_session_get_callee(dlsession)); + tech_pvt->us = switch_core_session_strdup(session, ldl_session_get_caller(dlsession)); - if ((tmp = strdup(tech_pvt->us))) { - char *p, *q; + if ((tmp = strdup(tech_pvt->us))) { + char *p, *q; - if ((p = strchr(tmp, '@'))) { - *p++ = '\0'; - if ((q = strchr(p, '/'))) { - *q = '\0'; - } - switch_channel_set_variable(channel, "dl_from_user", tmp); - switch_channel_set_variable(channel, "dl_from_host", p); + if ((p = strchr(tmp, '@'))) { + *p++ = '\0'; + if ((q = strchr(p, '/'))) { + *q = '\0'; } - - switch_safe_free(tmp); + switch_channel_set_variable(channel, "dl_from_user", tmp); + switch_channel_set_variable(channel, "dl_from_host", p); } + + switch_safe_free(tmp); + } - if (!tech_pvt->caller_profile) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Creating an identity for %s %s <%s> %s\n", - ldl_session_get_id(dlsession), cid_name, cid_num, exten); + if (!tech_pvt->caller_profile) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Creating an identity for %s %s <%s> %s\n", + ldl_session_get_id(dlsession), cid_name, cid_num, exten); - if ((tech_pvt->caller_profile = switch_caller_profile_new(switch_core_session_get_pool(session), - ldl_handle_get_login(profile->handle), - profile->dialplan, - cid_name, - cid_num, - ldl_session_get_ip(dlsession), - ldl_session_get_value(dlsession, "ani"), - ldl_session_get_value(dlsession, "aniii"), - ldl_session_get_value(dlsession, "rdnis"), - (char *)modname, - context, - exten)) != 0) { - char name[128]; - snprintf(name, sizeof(name), "DingaLing/%s", tech_pvt->caller_profile->destination_number); - switch_channel_set_name(channel, name); - switch_channel_set_caller_profile(channel, tech_pvt->caller_profile); - } + if ((tech_pvt->caller_profile = switch_caller_profile_new(switch_core_session_get_pool(session), + ldl_handle_get_login(profile->handle), + profile->dialplan, + cid_name, + cid_num, + ldl_session_get_ip(dlsession), + ldl_session_get_value(dlsession, "ani"), + ldl_session_get_value(dlsession, "aniii"), + ldl_session_get_value(dlsession, "rdnis"), + (char *)modname, + context, + exten)) != 0) { + char name[128]; + snprintf(name, sizeof(name), "DingaLing/%s", tech_pvt->caller_profile->destination_number); + switch_channel_set_name(channel, name); + switch_channel_set_caller_profile(channel, tech_pvt->caller_profile); } + } - switch_safe_free(them); + switch_safe_free(them); - if (lanaddr) { - switch_set_flag_locked(tech_pvt, TFLAG_LANADDR); - } + if (lanaddr) { + switch_set_flag_locked(tech_pvt, TFLAG_LANADDR); + } - if (!get_codecs(tech_pvt)) { - terminate_session(&session, __LINE__, SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER); - status = LDL_STATUS_FALSE; - goto done; - } + if (!get_codecs(tech_pvt)) { + terminate_session(&session, __LINE__, SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER); + status = LDL_STATUS_FALSE; + goto done; + } - tech_pvt->remote_ip = switch_core_session_strdup(session, candidates[x].address); - ldl_session_set_ip(dlsession, tech_pvt->remote_ip); - tech_pvt->remote_port = candidates[x].port; - tech_pvt->remote_user = switch_core_session_strdup(session, candidates[x].username); + tech_pvt->remote_ip = switch_core_session_strdup(session, candidates[x].address); + ldl_session_set_ip(dlsession, tech_pvt->remote_ip); + tech_pvt->remote_port = candidates[x].port; + tech_pvt->remote_user = switch_core_session_strdup(session, candidates[x].username); - if (!switch_test_flag(tech_pvt, TFLAG_OUTBOUND)) { - if (!do_candidates(tech_pvt, 0)) { - terminate_session(&session, __LINE__, SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER); - status = LDL_STATUS_FALSE; - goto done; - } + if (!switch_test_flag(tech_pvt, TFLAG_OUTBOUND)) { + if (!do_candidates(tech_pvt, 0)) { + terminate_session(&session, __LINE__, SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER); + status = LDL_STATUS_FALSE; + goto done; } - - - switch_set_flag_locked(tech_pvt, TFLAG_TRANSPORT); - - status = LDL_STATUS_SUCCESS; - goto done; } + + status = LDL_STATUS_SUCCESS; + goto done; } } } Modified: freeswitch/trunk/src/switch_rtp.c ============================================================================== --- freeswitch/trunk/src/switch_rtp.c (original) +++ freeswitch/trunk/src/switch_rtp.c Thu Nov 16 10:50:17 2006 @@ -765,7 +765,7 @@ rtp_session->last_time = switch_time_now(); } - for(;;) { + while(rtp_session->ready) { bytes = sizeof(rtp_msg_t); status = switch_socket_recvfrom(rtp_session->from_addr, rtp_session->sock, 0, (void *)&rtp_session->recv_msg, &bytes);

1 0