September 2007 - Freeswitch-trunk - FreeSWITCH Mailing Lists

[commit] r5717 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 19 Sep '07

19 Sep '07

Author: anthm Date: Wed Sep 19 13:05:52 2007 New Revision: 5717 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c Log: back out patch we don't need 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 Wed Sep 19 13:05:52 2007 @@ -501,7 +501,6 @@ *expire_seconds = "3600", *retry_seconds = "30", *from_domain = "", - *to_domain = "", *register_proxy = NULL; gateway->pool = profile->pool; @@ -538,8 +537,6 @@ retry_seconds = val; } else if (!strcmp(var, "from-domain")) { from_domain = val; - } else if (!strcmp(var, "to-domain")) { - to_domain = val; } else if (!strcmp(var, "register-proxy")) { register_proxy = val; } @@ -579,10 +576,6 @@ register_proxy = proxy; } - if (switch_strlen_zero(to_domain)) { - to_domain = proxy; - } - gateway->retry_seconds = atoi(retry_seconds); if (gateway->retry_seconds < 10) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "INVALID: retry_seconds correcting the value to 30\n"); @@ -600,14 +593,17 @@ gateway->register_from = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, from_domain); gateway->register_contact = switch_core_sprintf(gateway->pool, "sip:%s@%s:%d", extension, profile->extsipip ? profile->extsipip : profile->sipip, profile->sip_port); - - if (!strncasecmp(to_domain, "sip:", 4)) { - gateway->register_proxy = switch_core_strdup(gateway->pool, proxy); - gateway->register_to = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, to_domain + 4); - } else { - gateway->register_proxy = switch_core_sprintf(gateway->pool, "sip:%s", proxy); - gateway->register_to = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, to_domain); - } + + + if (!strncasecmp(proxy, "sip:", 4)) { + gateway->register_proxy = switch_core_strdup(gateway->pool, proxy); + gateway->register_to = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, proxy + 4); + } else { + gateway->register_proxy = switch_core_sprintf(gateway->pool, "sip:%s", proxy); + gateway->register_to = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, proxy); + } + + gateway->expires_str = switch_core_strdup(gateway->pool, expire_seconds);

1 0

[commit] r5716 - freeswitch/trunk/libs/sofia-sip
by Freeswitch SVN 19 Sep '07

19 Sep '07

Author: anthm Date: Wed Sep 19 12:32:32 2007 New Revision: 5716 Modified: freeswitch/trunk/libs/sofia-sip/.update Log: lets use updated lib Modified: freeswitch/trunk/libs/sofia-sip/.update ============================================================================== --- freeswitch/trunk/libs/sofia-sip/.update (original) +++ freeswitch/trunk/libs/sofia-sip/.update Wed Sep 19 12:32:32 2007 @@ -1 +1 @@ -Sat Apr 21 16:48:55 EDT 2007 +Wed Sep 19 12:32:11 EDT 2007

1 0

[commit] r5715 - in freeswitch/trunk/libs/sofia-sip: libsofia-sip-ua/iptsec libsofia-sip-ua/msg libsofia-sip-ua/msg/sofia-sip libsofia-sip-ua/nua libsofia-sip-ua/nua/sofia-sip libsofia-sip-ua/sdp/sofia-sip libsofia-sip-ua/sip libsofia-sip-ua/sip/sofia-sip libsofia-sip-ua/su libsofia-sip-ua/su/sofia-sip libsofia-sip-ua/tport libsofia-sip-ua/url utils
by Freeswitch SVN 19 Sep '07

19 Sep '07

Author: mikej Date: Wed Sep 19 12:24:40 2007 New Revision: 5715 Added: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/certificates-update Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/iptsec/auth_client.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/iptsec/test_auth_digest.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/msg_generic.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/msg_types.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_class.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_class.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_msg.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_params.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_params.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_register.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_stack.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_tag.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/outbound.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/outbound.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/sofia-sip/nua_tag.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_basic_call.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_init.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_nua.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_nua_params.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_proxy.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_proxy.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sdp/sofia-sip/sdp.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip.doxyaliases freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip_basic.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip_tag_class.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sofia-sip/sip_tag_class.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/sofia-sip/su.h freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/agent.pem freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/tport_type_tcp.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/url/url.c freeswitch/trunk/libs/sofia-sip/utils/sip-options.c Log: merge darcs tree Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/iptsec/auth_client.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/iptsec/auth_client.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/iptsec/auth_client.c Wed Sep 19 12:24:40 2007 @@ -160,7 +160,7 @@ if (!ca || !ch) return -1; - if (strcmp(ca->ca_scheme, scheme)) + if (strcasecmp(ca->ca_scheme, scheme)) return 0; if (strcmp(ca->ca_realm, realm)) return 0; @@ -433,7 +433,7 @@ continue; if (AUTH_CLIENT_IS_EXTENDED(ca) && ca->ca_clear) continue; - if (!ca->ca_scheme[0] || strcmp(ca->ca_scheme, d->ca_scheme)) + if (!ca->ca_scheme[0] || strcasecmp(ca->ca_scheme, d->ca_scheme)) continue; if (!ca->ca_realm[0] || strcmp(ca->ca_realm, d->ca_realm)) continue; @@ -1012,6 +1012,8 @@ break; } + /* XXX - should report error if the auth scheme is not known? */ + aucsize = auc ? (size_t)auc->auc_size : (sizeof *ca); size = aucsize + realmlen; if (!auc) Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/iptsec/test_auth_digest.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/iptsec/test_auth_digest.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/iptsec/test_auth_digest.c Wed Sep 19 12:24:40 2007 @@ -484,7 +484,7 @@ "From:surf3.ims3.so.noklab.net <sip:surf3@ims3.so.noklab.net>;tag=I8hFdg0H3OK\r\n" "To:<sip:surf3@ims3.so.noklab.net>\r\n" "Via:SIP/2.0/UDP 10.21.36.70:23800;branch=z9hG4bKJjKGu9vIHqf;received=10.21.36.70;rport\r\n" - "WWW-Authenticate:Digest algorithm=MD5,nonce=\"h7wIpP+atU+/+Zau5UwLMA==\",realm=\"ims3.so.noklab.net\"\r\n" + "WWW-Authenticate:DIGEST algorithm=MD5,nonce=\"h7wIpP+atU+/+Zau5UwLMA==\",realm=\"ims3.so.noklab.net\"\r\n" "Content-Length:0\r\n" "Security-Server:digest\r\n" "r\n"; @@ -526,11 +526,13 @@ TEST_1(m1 = read_message(MSG_DO_EXTRACT_COPY, challenge)); TEST_1(sip = sip_object(m1)); + TEST_1(aucs == NULL); TEST(auc_challenge(&aucs, home, sip->sip_www_authenticate, sip_authorization_class), 1); + TEST_1(aucs != NULL); msg_destroy(m1); - - TEST(auc_all_credentials(&aucs, "Digest", "\"ims3.so.noklab.net\"", + + TEST(auc_all_credentials(&aucs, "DIGEST", "\"ims3.so.noklab.net\"", "surf3.private(a)ims3.so.noklab.net", "1234"), 1); TEST_1(m2 = read_message(MSG_DO_EXTRACT_COPY, request)); Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/msg_generic.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/msg_generic.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/msg_generic.c Wed Sep 19 12:24:40 2007 @@ -112,10 +112,13 @@ char *s, isize_t slen) { + msg_numeric_t *x = (msg_numeric_t *)h; uint32_t value = 0; issize_t retval = msg_uint32_d(&s, &value); - h->sh_numeric->x_value = value; + assert(x->x_common->h_class->hc_size >= sizeof *x); + + x->x_value = value; if (*s) return -1; @@ -125,12 +128,14 @@ issize_t msg_numeric_e(char b[], isize_t bsiz, msg_header_t const *h, int flags) { - uint32_t value = h->sh_numeric->x_value; + msg_numeric_t *x = (msg_numeric_t *)h; + + assert(x->x_common->h_class->hc_size >= sizeof *x); - if (h->sh_numeric->x_value > 0xffffffff) + if (x->x_value > 0xffffffffU) return -1; - return snprintf(b, bsiz, "%lu", (unsigned long)value); + return snprintf(b, bsiz, "%lu", x->x_value); } /* ====================================================================== */ Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/msg_types.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/msg_types.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/msg_types.h Wed Sep 19 12:24:40 2007 @@ -134,7 +134,8 @@ /** Numeric header. * - * A numeric header has a 32-bit integer as its value. + * A numeric header has value range of a 32-bit, 0..4294967295. The @a + * x_value field is unsigned long, however. */ struct msg_numeric_s { msg_common_t x_common[1]; /**< Common fragment info */ Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_class.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_class.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_class.c Wed Sep 19 12:24:40 2007 @@ -193,6 +193,14 @@ return b; } +msg_hclass_t test_numeric_class[] = + MSG_HEADER_CLASS(msg_, numeric, "Numeric", "", x_common, + single, msg_generic, msg_generic); + +msg_hclass_t test_auth_class[] = + MSG_HEADER_CLASS(msg_, auth, "Auth", "", au_params, + append, msg_auth, msg_generic); + /** Extract the message body, including separator line. * * @param[in,out] msg message object @@ -411,3 +419,4 @@ return t ? -1 : 0; } + Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_class.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_class.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_class.h Wed Sep 19 12:24:40 2007 @@ -110,6 +110,9 @@ msg_content_encoding_t *msg_content_encoding; /**< Content-Encoding */ msg_content_length_t *msg_content_length; /**< Content-Length */ + + msg_auth_t *msg_auth; /**< Auth (testing) */ + msg_numeric_t *msg_numeric; /**< Numeric (testing) */ /* === Headers end here */ msg_unknown_t *msg_unknown; @@ -160,6 +163,17 @@ return (msg_test_t *)msg_public(msg, MSG_TEST_PROTOCOL_TAG); } +#define msg_auth_class test_auth_class + +#define msg_numeric_class test_numeric_class + +enum { + msg_auth_hash = 22894, + msg_numeric_hash = 24435 +}; + +SOFIAPUBVAR msg_hclass_t test_auth_class[1], test_numeric_class[1]; + SOFIA_END_DECLS #endif /* !defined(TEST_CLASS_H) */ Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_msg.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_msg.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/test_msg.c Wed Sep 19 12:24:40 2007 @@ -127,7 +127,7 @@ char *s; msg_numeric_t x[1]; - memset(x, 0, sizeof (x)); + memset(x, 0, sizeof (x)); x->x_common->h_class = test_numeric_class; TEST_1(msg_numeric_d(NULL, (msg_header_t *)x, s = error1, strlen(error1)) < 0); } Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_params.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_params.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_params.c Wed Sep 19 12:24:40 2007 @@ -287,6 +287,8 @@ * NUTAG_ENABLEINVITE() \n * NUTAG_ENABLEMESSAGE() \n * NUTAG_ENABLEMESSENGER() \n + * NUTAG_INITIAL_ROUTE() \n + * NUTAG_INITIAL_ROUTE_STR() \n * NUTAG_INSTANCE() \n * NUTAG_INVITE_TIMER() \n * NUTAG_KEEPALIVE() \n @@ -404,6 +406,8 @@ * NUTAG_ENABLEINVITE() \n * NUTAG_ENABLEMESSAGE() \n * NUTAG_ENABLEMESSENGER() \n + * NUTAG_INITIAL_ROUTE() \n + * NUTAG_INITIAL_ROUTE_STR() \n * NUTAG_INSTANCE() \n * NUTAG_INVITE_TIMER() \n * NUTAG_KEEPALIVE() \n @@ -635,10 +639,10 @@ } /* Set copy of header to handle pref structure */ -#define NHP_SET_HEADER(nhp, name, v) \ +#define NHP_SET_HEADER(nhp, name, hdr, v) \ if ((v) != 0) { \ - sip_##name##_t const *_value = (sip_##name##_t const *)(v); \ - sip_##name##_t *_new = NULL; \ + sip_##hdr##_t const *_value = (sip_##hdr##_t const *)(v); \ + sip_##hdr##_t *_new = NULL; \ if (_value != SIP_NONE) \ _new = sip_##name##_dup(home, _value); \ if (NHP_ISSET(nhp, name)) \ @@ -649,10 +653,10 @@ } /* Set header made of string to handle pref structure */ -#define NHP_SET_HEADER_STR(nhp, name, v) \ +#define NHP_SET_HEADER_STR(nhp, name, hdr, v) \ if ((v) != 0) { \ char const *_value = (char const *)(v); \ - sip_##name##_t *_new = NULL; \ + sip_##hdr##_t *_new = NULL; \ if (_value != SIP_NONE) \ _new = sip_##name##_make(home, _value); \ if (NHP_ISSET(nhp, name)) \ @@ -662,6 +666,26 @@ return -1; \ } +/* Append copy of header to handle pref structure */ +#define NHP_APPEND_HEADER(nhp, name, hdr, is_str, next, v) \ + { \ + sip_##hdr##_t const *_value = (sip_##hdr##_t const *)(v); \ + char const *_str = (char const *)(v); \ + sip_##hdr##_t *_new = NULL; \ + sip_##hdr##_t **_end = &nhp->nhp_##name; \ + if (_value != SIP_NONE && _value != NULL) { \ + _new = (is_str) \ + ? sip_##hdr##_make(home, _str) \ + : sip_##hdr##_dup(home, _value); \ + if (_new == NULL) return -1; \ + } \ + if (NHP_ISSET(nhp, name)) \ + while(*_end) \ + _end = next(*_end); \ + nhp->nhp_set.nhb_##name = 1; \ + *_end = _new; \ + } + /* Set copy of string from header to handle pref structure */ #define NHP_SET_STR_BY_HEADER(nhp, name, v) \ if ((v) != 0) { \ @@ -894,6 +918,15 @@ NHP_SET(nhp, appl_method, (sip_allow_t *)appl_method); } } + else if (tag == nutag_initial_route || + tag == nutag_initial_route_str) { +#define next_route(r) (&(r)->r_next) + NHP_APPEND_HEADER(nhp, initial_route, route, + (tag == nutag_initial_route_str), + next_route, + t->t_value); + sip_route_fix(nhp->nhp_initial_route); + } /* SIPTAG_USER_AGENT(user_agent) */ else if (tag == siptag_user_agent) { NHP_SET_STR_BY_HEADER(nhp, user_agent, value); @@ -1079,6 +1112,14 @@ NHP_ZAP_OVERRIDEN(tbf, dst, m_features); NHP_ZAP_OVERRIDEN(tbf, dst, outbound); +#define NHP_ZAP_OVERRIDEN_HDR(tbf, nhp, pref) \ + (((tbf)->nhp_set.nhb_##pref \ + && (tbf)->nhp_##pref != (nhp)->nhp_##pref \ + ? msg_header_free(home, (void *)(tbf)->nhp_##pref) : (void)0), \ + (void)(!(nhp)->nhp_set.nhb_##pref ? (nhp)->nhp_##pref = NULL : NULL)) + + NHP_ZAP_OVERRIDEN_HDR(tbf, dst, initial_route); + return dst; } @@ -1399,6 +1440,8 @@ * NUTAG_ENABLEINVITE() \n * NUTAG_ENABLEMESSAGE() \n * NUTAG_ENABLEMESSENGER() \n + * NUTAG_INITIAL_ROUTE() \n + * NUTAG_INITIAL_ROUTE_STR() \n * NUTAG_INSTANCE() \n * NUTAG_INVITE_TIMER() \n * NUTAG_KEEPALIVE() \n @@ -1523,15 +1566,16 @@ TAG_IF(nhp->nhp_set.nhb_##pref, TAG(nhp->nhp_##pref)) /* Include tag in the list returned to user - * if it has been earlier set (by user) returning default parameters */ + * if it has been earlier set (by user) + * but always include in the default parameters */ #define TIFD(TAG, pref) \ TAG_IF(nh == dnh || nhp->nhp_set.nhb_##pref, TAG(nhp->nhp_##pref)) /* Include string tag made out of SIP header * if it has been earlier set (by user) */ #define TIF_STR(TAG, pref) \ - TAG_IF(nhp->nhp_set.nhb_##pref, \ - TAG(nhp->nhp_set.nhb_##pref && nhp->nhp_##pref \ + TAG_IF(nhp->nhp_set.nhb_##pref, \ + TAG(nhp->nhp_set.nhb_##pref && nhp->nhp_##pref \ ? sip_header_as_string(tmphome, (void *)nhp->nhp_##pref) : NULL)) /* Include header tag made out of string @@ -1597,6 +1641,9 @@ TIF_SIP(SIPTAG_ORGANIZATION, organization), TIF(SIPTAG_ORGANIZATION_STR, organization), + TIF(NUTAG_INITIAL_ROUTE, initial_route), + TIF_STR(NUTAG_INITIAL_ROUTE_STR, initial_route), + TIF(NUTAG_REGISTRAR, registrar), TIF(NUTAG_KEEPALIVE, keepalive), TIF(NUTAG_KEEPALIVE_STREAM, keepalive_stream), Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_params.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_params.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_params.h Wed Sep 19 12:24:40 2007 @@ -108,7 +108,7 @@ /* Subscriber state, i.e. nua_substate_pending */ unsigned nhp_substate; - /* REGISTER Keepalive intervals */ + /* REGISTER keepalive intervals */ unsigned nhp_keepalive, nhp_keepalive_stream; char const *nhp_registrar; @@ -124,14 +124,17 @@ char const *nhp_m_features; char const *nhp_instance; - /**< Outbound OPTIONS */ + /** Outbound OPTIONS */ char const *nhp_outbound; - /**< Network detection: NONE, INFORMAL, TRY_FULL */ + /** Network detection: NONE, INFORMAL, TRY_FULL */ int nhp_detect_network_updates; sip_allow_t *nhp_appl_method; + /** Initial route set */ + sip_route_t *nhp_initial_route; + union { struct { /* A bit for each feature set by application */ unsigned nhb_retry_count:1; @@ -182,6 +185,7 @@ unsigned nhb_outbound:1; unsigned nhb_detect_network_updates:1; unsigned nhb_appl_method:1; + unsigned nhb_initial_route:1; unsigned :0; } set_bits; unsigned set_unsigned[2]; Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_register.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_register.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_register.c Wed Sep 19 12:24:40 2007 @@ -245,7 +245,6 @@ sip_contact_t *nua_handle_contact_by_via(nua_handle_t *nh, su_home_t *home, int in_dialog, - char const *extra_username, sip_via_t const *v, char const *transport, char const *m_param, @@ -268,12 +267,12 @@ outbound_owner_vtable nua_stack_outbound_callbacks = { sizeof nua_stack_outbound_callbacks, - nua_handle_contact_by_via, - nua_stack_outbound_refresh, - nua_stack_outbound_status, - nua_stack_outbound_failed, - nua_stack_outbound_failed, - nua_stack_outbound_credentials + /* oo_contact */ nua_handle_contact_by_via, + /* oo_refresh */ nua_stack_outbound_refresh, + /* oo_status */ nua_stack_outbound_status, + /* oo_probe_error */ nua_stack_outbound_failed, + /* oo_keepalive_error */ nua_stack_outbound_failed, + /* oo_credentials */ nua_stack_outbound_credentials }; /**@fn void nua_register(nua_handle_t *nh, tag_type_t tag, tag_value_t value, ...); @@ -1364,7 +1363,7 @@ v2[1].v_next = NULL; - contact = nua_handle_contact_by_via(nh, home, 0, NULL, v2, protocol, NULL); + contact = nua_handle_contact_by_via(nh, home, 0, v2, protocol, NULL); v = sip_via_dup(home, v2); @@ -1780,7 +1779,7 @@ if (nr0 && nr0->nr_via) { char const *tport = nr0->nr_via->v_next ? NULL : nr0->nr_via->v_protocol; m = nua_handle_contact_by_via(nh, nh->nh_home, 0, - NULL, nr0->nr_via, tport, NULL); + nr0->nr_via, tport, NULL); } } @@ -1918,7 +1917,6 @@ sip_contact_t *nua_handle_contact_by_via(nua_handle_t *nh, su_home_t *home, int in_dialog, - char const *extra_username, sip_via_t const *v, char const *transport, char const *m_param, @@ -1926,11 +1924,12 @@ { su_strlst_t *l; char const *s; - char const *scheme = "sip:", *host, *port, *maddr, *comp; + char const *host, *port, *maddr, *comp; int one = 1; char _transport[16]; va_list va; sip_contact_t *m; + url_t url = URL_INIT_AS(sip); if (!v) return NULL; @@ -1946,7 +1945,7 @@ if (sip_transport_has_tls(v->v_protocol) || sip_transport_has_tls(transport)) { - scheme = "sips:"; + url.url_type = url_sips; if (port && strcmp(port, SIPS_DEFAULT_SERV) == 0) port = NULL; if (port || host_is_ip_address(host)) @@ -1974,6 +1973,25 @@ } } + s = NH_PGET(nh, m_username); + if (s) + url.url_user = s; + url.url_host = host; + url.url_port = port; + url.url_params = su_strdup(home, NH_PGET(nh, m_params)); + if (transport) { + url.url_params = url_strip_param_string((char*)url.url_params, "transport"); + url_param_add(home, &url, su_sprintf(home, "transport=%s", transport)); + } + if (maddr) { + url.url_params = url_strip_param_string((char*)url.url_params, "maddr"); + url_param_add(home, &url, su_sprintf(home, "maddr=%s", maddr)); + } + if (comp) { + url.url_params = url_strip_param_string((char*)url.url_params, "comp"); + url_param_add(home, &url, su_sprintf(home, "comp=%s", comp)); + } + l = su_strlst_create(NULL); s = NH_PGET(nh, m_display); @@ -1984,25 +2002,9 @@ su_strlst_append(l, s); su_strlst_append(l, quote ? "\" " : " "); } + su_strlst_append(l, "<"); - su_strlst_append(l, scheme); - s = NH_PGET(nh, m_username); - if (s) su_strlst_append(l, s); - if (extra_username) su_strlst_append(l, s); - if (s || extra_username) - su_strlst_append(l, "@"); - su_strlst_append(l, host); - if (port) - su_strlst_append(l, ":"), su_strlst_append(l, port); - if (transport) - su_strlst_append(l, ";transport="), su_strlst_append(l, transport); - if (maddr) - su_strlst_append(l, ";maddr="), su_strlst_append(l, maddr); - if (comp) - su_strlst_append(l, ";comp="), su_strlst_append(l, comp); - s = NH_PGET(nh, m_params); - if (s) - s[0] == ';' ? "" : su_strlst_append(l, ";"), su_strlst_append(l, s); + su_strlst_append(l, url_as_string(home, &url)); su_strlst_append(l, ">"); va_start(va, m_param); Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_stack.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_stack.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_stack.c Wed Sep 19 12:24:40 2007 @@ -1997,6 +1997,12 @@ t = nh->nh_tags, sip_add_tagis(msg, sip, &t); } + if (!ds->ds_route) { + sip_route_t *initial_route = NH_PGET(nh, initial_route); + if (initial_route) + sip_add_dup(msg, sip, (sip_header_t *)initial_route); + } + for (t = cr->cr_tags; t; t = t_next(t)) { if (t->t_tag == siptag_contact || t->t_tag == siptag_contact_str) Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_tag.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_tag.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_tag.c Wed Sep 19 12:24:40 2007 @@ -103,6 +103,10 @@ tag_typedef_t nutag_certificate_dir = STRTAG_TYPEDEF(certificate_dir); tag_typedef_t nutag_certificate_phrase = STRTAG_TYPEDEF(certificate_phrase); +extern msg_hclass_t sip_route_class[]; +tag_typedef_t nutag_initial_route = SIPEXTHDRTAG_TYPEDEF(initial_route, route); +tag_typedef_t nutag_initial_route_str = STRTAG_TYPEDEF(inital_route_str); + tag_typedef_t nutag_registrar = URLTAG_TYPEDEF(registrar); tag_typedef_t nutag_identity = PTRTAG_TYPEDEF(identity); tag_typedef_t nutag_m_display = STRTAG_TYPEDEF(m_display); Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/outbound.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/outbound.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/outbound.c Wed Sep 19 12:24:40 2007 @@ -581,7 +581,10 @@ return 0; } - gruu = (char *)msg_header_find_param(m->m_common, "gruu="); + gruu = (char *)msg_header_find_param(m->m_common, "pub-gruu="); + + if (gruu == NULL || gruu[0] == '\0') + gruu = (char *)msg_header_find_param(m->m_common, "gruu="); if (gruu == NULL || gruu[0] == '\0') return 0; @@ -1004,14 +1007,14 @@ v = v0; *v0 = *via; v0->v_next = NULL; - dcontact = ob->ob_oo->oo_contact(ob->ob_owner, home, 1, - NULL, v, v->v_protocol, NULL); + dcontact = ob->ob_oo->oo_contact(ob->ob_owner, home, 1, + v, v->v_protocol, NULL); if (ob->ob_instance && ob->ob_reg_id != 0) snprintf(reg_id_param, sizeof reg_id_param, ";reg-id=%u", ob->ob_reg_id); rcontact = ob->ob_oo->oo_contact(ob->ob_owner, home, 0, - NULL, v, v->v_protocol, + v, v->v_protocol, ob->ob_instance, reg_id_param, NULL); v = sip_via_dup(home, v); @@ -1112,7 +1115,7 @@ char reg_id_param[20]; dcontact = ob->ob_oo->oo_contact(ob->ob_owner, home, 1, - NULL, v, tport, NULL); + v, tport, NULL); if (!dcontact) return -1; @@ -1120,7 +1123,7 @@ snprintf(reg_id_param, sizeof reg_id_param, ";reg-id=%u", ob->ob_reg_id); rcontact = ob->ob_oo->oo_contact(ob->ob_owner, home, 0, - NULL, v, v->v_protocol, + v, v->v_protocol, ob->ob_instance, reg_id_param, NULL); if (!rcontact) return -1; Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/outbound.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/outbound.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/outbound.h Wed Sep 19 12:24:40 2007 @@ -119,7 +119,6 @@ sip_contact_t *(*oo_contact)(outbound_owner_t *, su_home_t *home, int used_in_dialog, - char const *extra_username, sip_via_t const *v, char const *transport, char const *m_param, Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/sofia-sip/nua_tag.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/sofia-sip/nua_tag.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/sofia-sip/nua_tag.h Wed Sep 19 12:24:40 2007 @@ -1086,6 +1086,85 @@ #define NUTAG_PROXY_REF(x) NTATAG_DEFAULT_PROXY_REF(x) #define nutag_proxy ntatag_default_proxy + +/** Specify initial route set. + * + * The initial route set is used instead or or in addition to the outbound + * proxy URL given by NUTAG_PROXY(). The NUTAG_INITIAL_ROUTE() accepts a + * list of parsed @Route header structures, NUTAG_INITIAL_ROUTE_STR() an + * unparsed string. + * + * If a tag list contains multiple NUTAG_INITIAL_ROUTE() or + * NUTAG_INITIAL_ROUTE_STR() tags, the route set is constructed from them + * all. + * + * @par Used with + * nua_set_params() \n + * nua_set_hparams() \n + * any handle-specific nua call + * + * @par Parameter type + * sip_route_t const * + * + * @par Values + * Linked list of #sip_route_t structures + * + * Corresponding tag taking reference parameter is NUTAG_INITIAL_ROUTE_REF(). + * + * @since @NEW_1_12_7. + */ +#define NUTAG_INITIAL_ROUTE(x) nutag_initial_route, siptag_route_v(x) +SOFIAPUBVAR tag_typedef_t nutag_initial_route; + +#define NUTAG_INITIAL_ROUTE_REF(x) nutag_initial_route_ref, siptag_route_vr(&(x)) +SOFIAPUBVAR tag_typedef_t nutag_initial_route_ref; + + +/** Specify initial route set. + * + * The initial route set is used instead or or in addition to the outbound + * proxy URL given by NUTAG_PROXY(). The NUTAG_INITIAL_ROUTE() accepts a + * list of parsed @Route header structures, NUTAG_INITIAL_ROUTE_STR() a + * unparsed string containing route URIs, quoted with <> and separated by + * commas. + * + * Please note that the syntax requires <> around the @Route URIs if they + * contain parameters, e.g., "lr". + * + * If a tag list contains multiple NUTAG_INITIAL_ROUTE() or + * NUTAG_INITIAL_ROUTE_STR() tags, the route set is constructed from them + * all. + * + * The initial route set can be reset with NUTAG_INITIAL_ROUTE(NULL). + * + * If a tag list of a request contains SIPTAG_ROUTE() or + * SIPTAG_ROUTE_STR() tags, the resulting route set will contain first the + * initial route entries followed by the route URIs given with the + * SIPTAG_ROUTE()/SIPTAG_ROUTE_STR() tags. + * + * @par Used with + * nua_set_params() \n + * nua_set_hparams() \n + * any handle-specific nua call + * + * @par Parameter type + * sip_route_t const * + * + * @par Values + * Linked list of #sip_route_t structures + * + * Corresponding tag taking reference parameter is NUTAG_INITIAL_ROUTE_STR_REF(). + * + * @since @NEW_1_12_7. + */ +#define NUTAG_INITIAL_ROUTE_STR(x) nutag_initial_route_str, tag_str_v(x) +SOFIAPUBVAR tag_typedef_t nutag_initial_route_str; + +#define NUTAG_INITIAL_ROUTE_STR_REF(x) nutag_initial_route_str_ref, tag_str_vr(&(x)) +SOFIAPUBVAR tag_typedef_t nutag_initial_route_str_ref; + + + /** Registrar URL * * @par Used with @@ -1461,7 +1540,7 @@ /**URL parameters for @Contact. * - * Specify URL parameters for the Contact header URI generated for + * Specify URL parameters for the @Contact header URI generated for * registration request and dialog-creating requests/responses. * * Please note that some proxies may remove even the non-transport Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_basic_call.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_basic_call.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_basic_call.c Wed Sep 19 12:24:40 2007 @@ -1436,12 +1436,13 @@ struct endpoint *a = &ctx->a, *b = &ctx->b; struct call *a_call = a->call, *b_call = b->call; struct event *e; + sip_route_t *r, rb[1]; sip_t *sip; sip_contact_t ma[1], mb[1]; if (print_headings) - printf("TEST NUA-3.1: Basic call\n"); + printf("TEST NUA-3.6: Basic call\n"); a_call->sdp = "m=audio 5008 RTP/AVP 8"; b_call->sdp = "m=audio 5010 RTP/AVP 0 8"; @@ -1460,9 +1461,17 @@ mb->m_url->url_user = "b++b"; contact_for_b = mb; - + + sip_route_init(rb)->r_url[0] = b->contact->m_url[0]; + rb->r_url->url_user = "bob+0"; + url_param_add(nua_handle_home(a_call->nh), rb->r_url, "lr"); + INVITE(a, a_call, a_call->nh, - TAG_IF(!ctx->proxy_tests, NUTAG_URL(b->contact->m_url)), + NUTAG_URL("sip:bob@example.org"), /* Expanded by proxy */ + SIPTAG_ROUTE_STR("B2 <sip:bob+2@example.org>;bar=foo"), /* Last in list */ + NUTAG_INITIAL_ROUTE(ctx->lr), /* Removed by proxy (if any) */ + NUTAG_INITIAL_ROUTE(rb), /* Used to route request to b (not removed) */ + NUTAG_INITIAL_ROUTE_STR("B1 <sip:bob+1@example.org;lr>;foo=bar"), /* Next in list */ SOATAG_USER_SDP_STR(a_call->sdp), SIPTAG_CONTACT(ma), TAG_END()); @@ -1517,6 +1526,14 @@ TEST_1(sip->sip_contact); TEST_S(sip->sip_contact->m_display, "Alice B."); TEST_S(sip->sip_contact->m_url->url_user, "a++a"); + TEST_1(r = sip->sip_route); + TEST_S(r->r_url->url_user, "bob+0"); + TEST_1(r = r->r_next); + TEST_S(r->r_url->url_user, "bob+1"); + TEST_1(r = r->r_next); + TEST_S(r->r_url->url_user, "bob+2"); + TEST_1(!r->r_next); + TEST_1(e = e->next); TEST_E(e->data->e_event, nua_i_state); TEST(callstate(e->data->e_tags), nua_callstate_received); /* RECEIVED */ TEST_1(is_offer_recv(e->data->e_tags)); @@ -1598,7 +1615,7 @@ nua_handle_destroy(b_call->nh), b_call->nh = NULL; if (print_headings) - printf("TEST NUA-3.1: PASSED\n"); + printf("TEST NUA-3.6: PASSED\n"); END(); } Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_init.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_init.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_init.c Wed Sep 19 12:24:40 2007 @@ -72,6 +72,7 @@ sip_supported_t const *supported = NULL; char const *appl_method = NULL; url_t const *p_uri, *a_uri, *b_uri; /* Proxy URI */ + char const *initial_route = NULL; /* Initial route towards internal proxy */ char const *a_bind, *a_bind2; int err = -1; url_t b_proxy[1]; @@ -164,6 +165,9 @@ if (start_nat && p_uri == NULL) p_uri = url_hdup(ctx->home, (void *)o_proxy); + if (ctx->p) + initial_route = test_proxy_route_uri(ctx->p, &ctx->lr); + if (start_nat && p_uri != NULL) { int family = 0; su_sockaddr_t su[1]; @@ -259,6 +263,7 @@ ctx->a.nua = nua_create(ctx->root, a_callback, ctx, NUTAG_PROXY(a_uri ? a_uri : o_proxy), + NUTAG_INITIAL_ROUTE_STR(initial_route), SIPTAG_FROM_STR("sip:alice@example.com"), NUTAG_URL(a_bind), TAG_IF(a_bind != a_bind2, NUTAG_SIPS_URL(a_bind2)), Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_nua.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_nua.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_nua.h Wed Sep 19 12:24:40 2007 @@ -180,6 +180,7 @@ } a, b, c; struct proxy *p; + sip_route_t const *lr; struct nat *nat; }; Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_nua_params.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_nua_params.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_nua_params.c Wed Sep 19 12:24:40 2007 @@ -43,6 +43,8 @@ #define __func__ "test_nua_params" #endif +sip_route_t *GLOBAL_ROUTE; + int test_tag_filter(void) { BEGIN(); @@ -104,7 +106,6 @@ ctx->root = su_root_create(NULL); TEST_1(ctx->root); - /* Disable threading by command line switch? */ su_root_threading(ctx->root, ctx->threading); ctx->a.nua = nua_create(ctx->root, a_callback, ctx, @@ -153,7 +154,6 @@ SIPTAG_ALLOW_EVENTS_STR("reg"), SIPTAG_USER_AGENT_STR("test_nua/1.0"), - SIPTAG_ORGANIZATION_STR("Open Laboratory"), NUTAG_M_DISPLAY("XXX"), @@ -163,6 +163,12 @@ NUTAG_INSTANCE("urn:uuid:3eb007b1-6d7f-472e-8b64-29e482795da8"), NUTAG_OUTBOUND("bar"), + NUTAG_INITIAL_ROUTE(NULL), + NUTAG_INITIAL_ROUTE(sip_route_make(tmphome, "<sip:tst@example.net;lr>")), + NUTAG_INITIAL_ROUTE_STR("<sip:str1@example.net;lr>"), + NUTAG_INITIAL_ROUTE_STR("sip:str2@example.net;lr=foo"), + NUTAG_INITIAL_ROUTE_STR(NULL), + TAG_END()); run_a_until(ctx, nua_r_set_params, until_final_response); @@ -221,6 +227,12 @@ SIPTAG_ALLOW_EVENTS(sip_allow_events_make(tmphome, "presence")), NUTAG_ALLOW_EVENTS("presence.winfo"), + NUTAG_INITIAL_ROUTE(NULL), + NUTAG_INITIAL_ROUTE(sip_route_make(nua_handle_home(nh), "<sip:1@example.com;lr>")), + NUTAG_INITIAL_ROUTE_STR("<sip:2@example.com;lr>"), + /* Check for sip_route_fix() */ + NUTAG_INITIAL_ROUTE_STR("sip:3@example.com;lr=foo"), + NUTAG_INITIAL_ROUTE_STR(NULL), SIPTAG_USER_AGENT(sip_user_agent_make(tmphome, "test_nua")), @@ -287,6 +299,9 @@ sip_organization_t const *organization = NONE; char const *organization_str = "NONE"; + sip_route_t *initial_route = NONE; + char const *initial_route_str = NONE; + char const *outbound = "NONE"; char const *m_display = "NONE"; char const *m_username = "NONE"; @@ -352,6 +367,9 @@ SIPTAG_ORGANIZATION_REF(organization), SIPTAG_ORGANIZATION_STR_REF(organization_str), + NUTAG_INITIAL_ROUTE_REF(initial_route), + NUTAG_INITIAL_ROUTE_STR_REF(initial_route_str), + NUTAG_REGISTRAR_REF(registrar), NUTAG_KEEPALIVE_REF(keepalive), NUTAG_KEEPALIVE_STREAM_REF(keepalive_stream), @@ -364,7 +382,7 @@ NUTAG_INSTANCE_REF(instance), TAG_END()); - TEST(n, 48); + TEST(n, 50); TEST_S(sip_header_as_string(tmphome, (void *)from), Alice); TEST_S(from_str, Alice); @@ -414,6 +432,17 @@ "Pussy Galore's Flying Circus"); TEST_S(organization_str, "Pussy Galore's Flying Circus"); + TEST_1(initial_route); TEST_1(initial_route != (void *)-1); + TEST_S(initial_route->r_url->url_user, "1"); + TEST_1(url_has_param(initial_route->r_url, "lr")); + TEST_1(initial_route->r_next); + TEST_S(initial_route->r_next->r_url->url_user, "2"); + TEST_1(url_has_param(initial_route->r_next->r_url, "lr")); + TEST_1(initial_route->r_next->r_next); + TEST_S(initial_route->r_next->r_next->r_url->url_user, "3"); + TEST_1(url_has_param(initial_route->r_next->r_next->r_url, "lr")); + TEST_1(!initial_route->r_next->r_next->r_next); + TEST_S(url_as_string(tmphome, registrar->us_url), "sip:sip.wonderland.org"); TEST(keepalive, 66); @@ -473,6 +502,9 @@ sip_organization_t const *organization = NONE; char const *organization_str = "NONE"; + sip_route_t *initial_route = NONE; + char const *initial_route_str = "NONE"; + url_string_t const *registrar = NONE; char const *outbound = "NONE"; @@ -585,6 +617,9 @@ TEST_P(organization, NONE); TEST_S(organization_str, "NONE"); + TEST_1(initial_route == (void *)-1); + TEST_S(initial_route_str, "NONE"); + TEST_S(outbound, "NONE"); TEST_S(m_display, "NONE"); TEST_S(m_username, "NONE"); Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_proxy.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_proxy.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_proxy.c Wed Sep 19 12:24:40 2007 @@ -100,6 +100,8 @@ nta_agent_t *agent; url_t const *uri; + sip_route_t *lr; + char const *lr_str; url_t const *rr_uri; nta_leg_t *defleg; @@ -326,7 +328,12 @@ return -1; proxy->uri = nta_agent_contact(proxy->agent)->m_url; - + proxy->lr_str = su_sprintf(proxy->home, "<" URL_PRINT_FORMAT ";lr>", URL_PRINT_ARGS(proxy->uri)); + proxy->lr = sip_route_make(proxy->home, proxy->lr_str); + + if (!proxy->lr) + return -1; + return 0; } @@ -391,6 +398,19 @@ return p ? p->uri : NULL; } +/* Return the proxy route URI */ +char const *test_proxy_route_uri(struct proxy const *p, + sip_route_t const **return_route) +{ + if (p == NULL) + return NULL; + + if (return_route) + *return_route = p->lr; + + return p->lr_str; +} + void test_proxy_domain_set_expiration(struct domain *d, sip_time_t min_expires, sip_time_t expires, @@ -796,8 +816,9 @@ /* Remove our routes */ while (t->sip->sip_route && - url_has_param(t->sip->sip_route->r_url, "lr") && - url_cmp(t->proxy->rr_uri, t->sip->sip_route->r_url) == 0) { + url_has_param(t->sip->sip_route->r_url, "lr") && + (url_cmp(t->proxy->lr->r_url, t->sip->sip_route->r_url) == 0 || + url_cmp(t->proxy->rr_uri, t->sip->sip_route->r_url) == 0)) { sip_route_remove(t->msg, t->sip); /* add record-route also to the forwarded request */ t->rr = 1; Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_proxy.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_proxy.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_proxy.h Wed Sep 19 12:24:40 2007 @@ -39,6 +39,9 @@ url_t const *test_proxy_uri(struct proxy const *); +char const *test_proxy_route_uri(struct proxy const *p, + sip_route_t const **return_route); + struct domain *test_proxy_add_domain(struct proxy *, url_t const *domain, tag_type_t, tag_value_t, ...); Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sdp/sofia-sip/sdp.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sdp/sofia-sip/sdp.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sdp/sofia-sip/sdp.h Wed Sep 19 12:24:40 2007 @@ -320,7 +320,7 @@ unsigned rm_predef : 1; /**< is this entry well-known? */ unsigned rm_pt : 7; /**< Payload type */ unsigned rm_any : 1; /**< Wildcard entry */ - int :0; + unsigned :0; }; SOFIAPUBVAR sdp_rtpmap_t const * const sdp_rtpmap_well_known[128]; Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip.doxyaliases ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip.doxyaliases (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip.doxyaliases Wed Sep 19 12:24:40 2007 @@ -65,6 +65,8 @@ "WWWAuthenticate=@ref sip_www_authenticate \"WWW-Authenticate\"" \ "Warning=@ref sip_warning \"Warning\"" \ "ReferSub=@ref sip_refer_sub \"Refer-Sub\"" \ + "AlertInfo=@ref sip_alert_info \"Alert-Info\"" \ + "ReplyTo=@ref sip_reply_to \"Reply-To\"" \ "SuppressBodyIfMatch=@ref sip_suppress_body_if_match \"Suppress-Body-If-Match\"" \ "SuppressNotifyIfMatch=@ref sip_suppress_notify_if_match \"Suppress-Notify-If-Match\"" \ Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip_basic.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip_basic.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip_basic.c Wed Sep 19 12:24:40 2007 @@ -1484,13 +1484,18 @@ char *s, isize_t slen) { - return sip_numeric_d(home, h, s, slen); + sip_content_length_t *l = (sip_content_length_t *)h; + issize_t retval = msg_uint32_d(&s, &l->l_length); + if (*s) + retval = -1; + return retval; } issize_t sip_content_length_e(char b[], isize_t bsiz, sip_header_t const *h, int flags) { + sip_content_length_t const *l = (sip_content_length_t const *)h; assert(sip_is_content_length(h)); - return sip_numeric_e(b, bsiz, h, flags); + return snprintf(b, bsiz, "%lu", (unsigned long)l->l_length); } /**@ingroup sip_content_length Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip_tag_class.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip_tag_class.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sip_tag_class.c Wed Sep 19 12:24:40 2007 @@ -48,6 +48,28 @@ #include <string.h> #include <limits.h> +/** Tag class for tags containing SIP headers. @HIDE + * + * Tags in this class are not automatically added to the message with + * sip_add_tl() or sip_add_tagis(). + */ +tag_class_t sipexthdrtag_class[1] = + {{ + sizeof(siphdrtag_class), + /* tc_next */ NULL, + /* tc_len */ NULL, + /* tc_move */ NULL, + /* tc_xtra */ msghdrtag_xtra, + /* tc_dup */ msghdrtag_dup, + /* tc_free */ NULL, + /* tc_find */ NULL, + /* tc_snprintf */ msghdrtag_snprintf, + /* tc_filter */ siptag_filter, + /* tc_ref_set */ t_ptr_ref_set, + /* tc_scan */ msghdrtag_scan, + }}; + + /** Tag class for SIP header tags. @HIDE */ tag_class_t siphdrtag_class[1] = {{ Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sofia-sip/sip_tag_class.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sofia-sip/sip_tag_class.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sip/sofia-sip/sip_tag_class.h Wed Sep 19 12:24:40 2007 @@ -65,6 +65,22 @@ {{ TAG_NAMESPACE, #t, sipmsgtag_class, \ (tag_value_t)SIP_PROTOCOL_TAG }} +/** Tag class for SIP headers */ +SOFIAPUBVAR tag_class_t siphdrtag_class[1]; +/** Tag class for string values of SIP headers */ +SOFIAPUBVAR tag_class_t sipstrtag_class[1]; +/** Tag class for SIP message */ +SOFIAPUBVAR tag_class_t sipmsgtag_class[1]; + +/** Define a named tag type using structure of SIP header @a t. */ +#define SIPEXTHDRTAG_TYPEDEF(n, t) \ +{{ TAG_NAMESPACE, #n, sipexthdrtag_class, \ + (tag_value_t)sip_##t##_class }} + +/** Tag class using SIP header structure */ +SOFIAPUBVAR tag_class_t sipexthdrtag_class[1]; + + /**@internal Filter SIP header tag items. */ SOFIAPUBFUN tagi_t *siptag_filter(tagi_t *dst, tagi_t const f[], tagi_t const *src, Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/sofia-sip/su.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/sofia-sip/su.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/sofia-sip/su.h Wed Sep 19 12:24:40 2007 @@ -293,6 +293,9 @@ SOFIAPUBFUN int su_setreuseaddr(su_socket_t s, int reuse); /** Get the error code associated with the socket. */ SOFIAPUBFUN int su_soerror(su_socket_t s); +/** Get the socket type. */ +SOFIAPUBFUN int su_getsocktype(su_socket_t s); + /** Get size of message available in socket. */ SOFIAPUBFUN issize_t su_getmsgsize(su_socket_t s); Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su.c Wed Sep 19 12:24:40 2007 @@ -337,6 +337,17 @@ return error; } +int su_getsocktype(su_socket_t s) +{ + int socktype = 0; + socklen_t intlen = sizeof(socktype); + + if (getsockopt(s, SOL_SOCKET, SO_TYPE, (void *)&socktype, &intlen) < 0) + return -1; + + return socktype; +} + int su_setreuseaddr(su_socket_t s, int reuse) { return setsockopt(s, SOL_SOCKET, SO_REUSEADDR, Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/agent.pem ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/agent.pem (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/agent.pem Wed Sep 19 12:24:40 2007 @@ -1,35 +1,34 @@ -----BEGIN CERTIFICATE----- -MIIDPjCCAqegAwIBAgIHJQIBAZACBjANBgkqhkiG9w0BAQUFADBwMQswCQYDVQQG -EwJVUzETMBEGA1UECBMKQ2FsaWZvcm5pYTERMA8GA1UEBxMIU2FuIEpvc2UxDjAM -BgNVBAoTBXNpcGl0MSkwJwYDVQQLEyBTaXBpdCBUZXN0IENlcnRpZmljYXRlIEF1 -dGhvcml0eTAeFw0wMzEyMDMxODMwMjJaFw0wNjEyMDIxODMwMjJaMGUxCzAJBgNV +MIIDIjCCAougAwIBAgIJAPHSWjotpO2kMA0GCSqGSIb3DQEBBQUAMHAxCzAJBgNV BAYTAlVTMRMwEQYDVQQIEwpDYWxpZm9ybmlhMREwDwYDVQQHEwhTYW4gSm9zZTEO -MAwGA1UEChMFc2lwaXQxHjAcBgNVBAMTFXBla2thLm5va2lhLnNpcGl0Lm5ldDCB -nzANBgkqhkiG9w0BAQEFAAOBjQAwgYkCgYEAsdJn/O6JoIC1I2iXOVJLQypmt9sN -HmvB84853Qx9KS+xqP3U2nqNMnDQby6ZmTsRHNGAK5QuGugU11wocmYNP0/TQFaz -KNLhNt0pMBOfpAV9vG6pCSkocObsUo2XFULPTEB/SzGcvE1G1em3XmwRfPA178y9 -L2+sVNT5Vtt5KfMCAwEAAaOB7DCB6TAgBgNVHREEGTAXghVwZWtrYS5ub2tpYS5z -aXBpdC5uZXQwCQYDVR0TBAIwADAdBgNVHQ4EFgQU1OjdL9cdA0NNbxPDQ9xZUZG6 -NnIwgZoGA1UdIwSBkjCBj4AUa0YXFOqUdiWAVG4TVNqh41QUobahdKRyMHAxCzAJ -BgNVBAYTAlVTMRMwEQYDVQQIEwpDYWxpZm9ybmlhMREwDwYDVQQHEwhTYW4gSm9z -ZTEOMAwGA1UEChMFc2lwaXQxKTAnBgNVBAsTIFNpcGl0IFRlc3QgQ2VydGlmaWNh -dGUgQXV0aG9yaXR5ggEAMA0GCSqGSIb3DQEBBQUAA4GBADCO35LJqgiK5OUR+DuT -N4CfUhsn9T5kDSf2rikna4ZFbuS7smc/oVu4g26HHjt6DKs4UEx9OmyXFslSENZ+ -tFNeVClpHJrPsNwjk/uyjhfeW1NezhXMIi6q8DYcwE5I7r+Uz2XST+jWCTb4obPY -10ysI7e7/rgCoITe+qO2U35D +MAwGA1UEChMFc2lwaXQxKTAnBgNVBAsTIFNpcGl0IFRlc3QgQ2VydGlmaWNhdGUg +QXV0aG9yaXR5MB4XDTA3MDkxNzIwMDMzOVoXDTA5MDkxNjIwMDMzOVowNzE1MDMG +A1UEAxMsQz1GSSwgTD1IZWxzaW5raSwgTz1zb2ZpYS1zaXAsIENOPXRwb3J0IHRl +c3QwgZ8wDQYJKoZIhvcNAQEBBQADgY0AMIGJAoGBALUlg4LStE/8WEjUny7Edpl1 +M0HCdE9Tfu8bHfcbCBDhlSQfQkAl0NilfB8tkX8Uz8LnTTsmtz76tDEORNEQRVng +FSyg2ugryDxNKURCsdq5WyMUh1XFnu0TLAdD8z5/hqAn6+jo5gcoT92uxNsXYA79 +6qctdS8WMGuaRPsUUbRBAgMBAAGjgfwwgfkwCQYDVR0TBAIwADAdBgNVHQ4EFgQU +12vA8bvBkE0q8hrFrvmE033MLq4wgZoGA1UdIwSBkjCBj4AUa0YXFOqUdiWAVG4T +VNqh41QUobahdKRyMHAxCzAJBgNVBAYTAlVTMRMwEQYDVQQIEwpDYWxpZm9ybmlh +MREwDwYDVQQHEwhTYW4gSm9zZTEOMAwGA1UEChMFc2lwaXQxKTAnBgNVBAsTIFNp +cGl0IFRlc3QgQ2VydGlmaWNhdGUgQXV0aG9yaXR5ggEAMCMGA1UdEQQcMBqCGHRw +b3J0LXRlc3Quc29maWEtc2lwLm9yZzALBgNVHQ8EBAMCBaAwDQYJKoZIhvcNAQEF +BQADgYEAiJ2FvB4RUOieuiqy3m3SbVtVeUJ9cLbPMF/MGKMGhxgCm61GTteQHW6y +f7gg2UkDeFoWclzqJam677fy+1IzVhpna6611vNow71w344eFBzg4GRBPhzR+qNn +X5CcWPWME2olV64dngtFsECdYnW58gGVuXhPW2CYiZ8nPq1gu18= -----END CERTIFICATE----- -----BEGIN RSA PRIVATE KEY----- -MIICXAIBAAKBgQCx0mf87omggLUjaJc5UktDKma32w0ea8HzjzndDH0pL7Go/dTa -eo0ycNBvLpmZOxEc0YArlC4a6BTXXChyZg0/T9NAVrMo0uE23SkwE5+kBX28bqkJ -KShw5uxSjZcVQs9MQH9LMZy8TUbV6bdebBF88DXvzL0vb6xU1PlW23kp8wIDAQAB -AoGAVtICT64vqBvvVPB2FVimwo5rRI1BJH88XSyq9dBpM7jDp1z3lgyL7/rA6ef4 -uqXqPwXS7HQW5rA1rMikPuawxE5UG31OG3U0+H/OGl0xwAq57mEtRDR8464jSUPY -l9bzkRpjnEgdUtkLnogm8F4mALexdc3KxIgg3uo/OOg0N5ECQQDZon1JBNEYWxEF -GBNbEvQthPy7rRLmxontgcsfhRvm5lSbuC+VP1uRHibwwIrXOUZD8uuEVdVZNzfV -bGPdh70HAkEA0Ss6HyAWczRBzrvC8eVvPmkI9XihdLqUFLTDL0R1sMCISwW/FEeH -X9yFqOY+y6EJAitzhxtol+0k+UsIJl5ctQJAXU0L6QHnokloQobPxXuasukQcGUC -dW0oNGowapLmI1cbbqbHv3QqDUyf5Rambx5ewUKjNViW3miNxzFwnshSgQJAINuQ -gskwnaJM4CPgqM0o333yeVUcz9BraKFItAkmD8D+6AIcFRxzaJykpnac0LIYTy3y -NPwaPxtynnKp8hUKrQJBAM1i5051UzJVFuRedwtPdGDrfkNwoJm27fwWozSQcBC6 -G5VnTrQ6V8VCJglNzVhy9b2WqlqfWV3D5BCgxyuH984= +MIICXQIBAAKBgQC1JYOC0rRP/FhI1J8uxHaZdTNBwnRPU37vGx33GwgQ4ZUkH0JA +JdDYpXwfLZF/FM/C5007Jrc++rQxDkTREEVZ4BUsoNroK8g8TSlEQrHauVsjFIdV +xZ7tEywHQ/M+f4agJ+vo6OYHKE/drsTbF2AO/eqnLXUvFjBrmkT7FFG0QQIDAQAB +AoGAU6lrv7QIyxhEvf5VNohOLjnO3oQsq6ZobY4cnM/DPeixtOkq8+2DM0vas5uc +IxE9k0q4hKUw5MltB2sLpXLaVAz3d9GjouKhMyzIv1UcHZli6OStSIVl458usfAy +SnJLvCP12fp4S4cSAc7Q+z5v83ztGHqPvl7GOXaiNL5BNfECQQDfo8ElGtBZtUKu +MPw/+07dPoMX4DHZ6Q9+4g3gfMoxkM+1RrFItDtkZx7W5aiWzcRrHlSB+2k/33Q1 +XyxyDnaHAkEAz1uxknSlLn//WwD5kwqPVOscWoQMHWNPG34H4Ktx/8IQ3WZGaECh +g/09XViIM4t5l1xDLZaWymcXBNqdRTXo9wJBAJDzBSO0fmg2eJKIQ2aAzvvNIZCf +ChCP4zA8+fuPRknb7xQyToOt9XS89ZsZXSzpDy7SiLl6pxv0C9Dv79G5GA8CQQCi +L5oIb2vznvHgADc1J4FMbkjTE41WPyLU4hLPS8nyvZvrT9+qE0NBtYWVyXVeu6zz +EpsIwUxYK6H5jfSM+cmpAkBRoE3KPkKJzqMYW2jNNk1CrE9YbHPcdWxsqh8+86CG +oK1ABCIX/PA4t1i0KWi0gJ3DQFr+c77XOhtChE0P2kA0 -----END RSA PRIVATE KEY----- Added: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/certificates-update ============================================================================== --- (empty file) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/certificates-update Wed Sep 19 12:24:40 2007 @@ -0,0 +1,100 @@ +#! /bin/sh +# +# Generate agent.pem +# +# Copyright (C) 2007 Nokia Corporation +# +# Author: Pekka Pessi +# Based on Mikko Haataja's perl script +# + +CN='C=FI, L=Helsinki, O=sofia-sip, CN=tport test' +ALTNAME=DNS:tport-test.sofia-sip.org +#ALTNAME=URI:sips:tport-test.sofia-sip.org +DAYS=730 + +umask 077 + +T=${TMPDIR:-/tmp}/sofia-sip-certs-${USER}-$$-`date +%N` +CA=${T}/CA + +mkdir $T || exit 1 +mkdir $T/CA || exit 1 + +cat > $CA/cakey.pem <<EOF +-----BEGIN RSA PRIVATE KEY----- +Proc-Type: 4,ENCRYPTED +DEK-Info: DES-EDE3-CBC,4B47A0A73ADE342E + +aHmlPa+ZrOV6v+Jk0SClxzpxoG3j0ZuyoVkF9rzq2bZkzVBKLU6xhWwjMDqwA8dH +3fCRLhMGIUVnmymXYhTW9svI1gpFxMBQHJcKpV/SmgFn/fbYk98Smo2izHOniIiu +NOu2zr+bMiaBphOAZ/OCtVUxUOoBDKN9lR39UCDOgkEQzp9Vbw7l736yu5H9GMHP +JtGLJyx3RhS3TvLfLAJZhjm/wZ/9QM8GjyJEiDhMQRJVeIZGvv4Yr1u6yYHiHfjX +tX2eds8Luc83HbSvjAyjnkLtJsAZ/8cFzrd7pjFzbogLdWuil+kpkkf5h1uzh7oa +um0M1EXBE4tcDHsfg1iqEsDMIei/U+/rWfk1PrzYlklwZp8S03vulkDm1fT76W7d +mRBg4+CrHA6qYn6EPWB37OBtfEqAfINnIcI1dWzso9A0bTPD4EJO0JA0PcZ/2JgT +PaKySgooHQ8AHNQebelch6M5LFExpaOADJKrqauKcc2HeUxXaYIpac5/7drIl3io +UloqUnMlGa3eLP7BZIMsZKCfHZ8oqwU4g6mmmJath2gODRDx3mfhH6yaimDL7v4i +SAIIkrEHXfSyovrTJymfSfQtYxUraVZDqax6oj/eGllRxliGfMLYG9ceU+yU/8FN +LE7P+Cs19H5tHHzx1LlieaK43u/XvbXHlB5mqL/fZdkUIBJsjbBVx0HR8eQl2CH9 +YJDMOPLADecwHoyKA0AY59oN9d41oF7yZtN9KwNdslROYH7mNJlqMMenhXCLN+Nz +vVU5/7/ugZFhZqfS46c1WdmSvuqpDp7TBtMeaH/PXjysBr0iZffOxQ== +-----END RSA PRIVATE KEY----- +EOF + +cat > $CA/cacert.pem <<EOF +-----BEGIN CERTIFICATE----- +MIIDJDCCAo2gAwIBAgIBADANBgkqhkiG9w0BAQUFADBwMQswCQYDVQQGEwJVUzET +MBEGA1UECBMKQ2FsaWZvcm5pYTERMA8GA1UEBxMIU2FuIEpvc2UxDjAMBgNVBAoT +BXNpcGl0MSkwJwYDVQQLEyBTaXBpdCBUZXN0IENlcnRpZmljYXRlIEF1dGhvcml0 +eTAeFw0wMzA3MTgxMjIxNTJaFw0xMzA3MTUxMjIxNTJaMHAxCzAJBgNVBAYTAlVT +MRMwEQYDVQQIEwpDYWxpZm9ybmlhMREwDwYDVQQHEwhTYW4gSm9zZTEOMAwGA1UE +ChMFc2lwaXQxKTAnBgNVBAsTIFNpcGl0IFRlc3QgQ2VydGlmaWNhdGUgQXV0aG9y +aXR5MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDDIh6DkcUDLDyK9BEUxkud ++nJ4xrCVGKfgjHm6XaSuHiEtnfELHM+9WymzkBNzZpJu30yzsxwfKoIKugdNUrD4 +N3viCicwcN35LgP/KnbN34cavXHr4ZlqxH+OdKB3hQTpQa38A7YXdaoz6goW2ft5 +Mi74z03GNKP/G9BoKOGd5QIDAQABo4HNMIHKMB0GA1UdDgQWBBRrRhcU6pR2JYBU +bhNU2qHjVBShtjCBmgYDVR0jBIGSMIGPgBRrRhcU6pR2JYBUbhNU2qHjVBShtqF0 +pHIwcDELMAkGA1UEBhMCVVMxEzARBgNVBAgTCkNhbGlmb3JuaWExETAPBgNVBAcT +CFNhbiBKb3NlMQ4wDAYDVQQKEwVzaXBpdDEpMCcGA1UECxMgU2lwaXQgVGVzdCBD +ZXJ0aWZpY2F0ZSBBdXRob3JpdHmCAQAwDAYDVR0TBAUwAwEB/zANBgkqhkiG9w0B +AQUFAAOBgQCWbRvv1ZGTRXxbH8/EqkdSCzSoUPrs+rQqR0xdQac9wNY/nlZbkR3O +qAezG6Sfmklvf+DOg5RxQq/+Y6I03LRepc7KeVDpaplMFGnpfKsibETMipwzayNQ +QgUf4cKBiF+65Ue7hZuDJa2EMv8qW4twEhGDYclpFU9YozyS1OhvUg== +-----END CERTIFICATE----- +EOF + +cat > $T/a.cnf <<EOF +[ req ] +default_bits = 1024 +prompt = no +distinguished_name = req_dn + +[ req_dn ] +commonName = $CN + +[ ext ] +basicConstraints=CA:FALSE +subjectKeyIdentifier=hash +authorityKeyIdentifier=keyid,issuer:always +subjectAltName=$ALTNAME +#keyUsage=digitalSignature:TRUE,keyEncipherment:TRUE + +EOF + +cat $T/a.cnf + +openssl req -new -out $T/a_req.pem -newkey rsa:1024 -keyout $T/a_key.pem \ + -sha1 -config $T/a.cnf -days $DAYS -nodes + +openssl x509 -req -in $T/a_req.pem -sha1 \ + -extensions ext -extfile $T/a.cnf \ + -CA $CA/cacert.pem -CAkey $CA/cakey.pem \ + -passin pass:password \ + -CAcreateserial \ + -days $DAYS \ + -out $T/a_cert.pem + +cat $T/a_cert.pem $T/a_key.pem + +rm $CA/* && rmdir $CA && rm $T/* && rmdir $T Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/tport_type_tcp.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/tport_type_tcp.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/tport/tport_type_tcp.c Wed Sep 19 12:24:40 2007 @@ -313,6 +313,7 @@ if (i + self->tp_ping >= 4) tport_tcp_pong(self); else + self->tp_ping += (unsigned short)i; if (i == iovec->siv_len && veclen == 1) { Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/url/url.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/url/url.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/url/url.c Wed Sep 19 12:24:40 2007 @@ -337,8 +337,8 @@ return url_canonize2(d, s, n, syn33, mask32, mask64, mask96); } -#define SYN33(c) (1 << (c - 33)) -#define IS_SYN33(syn33, c) ((syn33 & (1 << (c - 33))) != 0) +#define SYN33(c) (1U << (c - 33)) +#define IS_SYN33(syn33, c) ((syn33 & (1U << (c - 33))) != 0) /** Canonize a URL component (with precomputed mask) */ static Modified: freeswitch/trunk/libs/sofia-sip/utils/sip-options.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/utils/sip-options.c (original) +++ freeswitch/trunk/libs/sofia-sip/utils/sip-options.c Wed Sep 19 12:24:40 2007 @@ -61,6 +61,10 @@ * <dt>--method=s</dt> * <dd>Specify the request method (defaults to OPTIONS). * </dd> + * <dt>--extra | -x/dt> + * <dd>Read extra headers (and optionally a message body) from the standard + * input + * </dd> * </dl> * * @section return Return Codes

1 0

[commit] r5714 - freeswitch/trunk/src/mod/applications/mod_conference
by Freeswitch SVN 19 Sep '07

19 Sep '07

Author: anthm Date: Wed Sep 19 12:20:00 2007 New Revision: 5714 Modified: freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c Log: add endconf member flag to make a specific member cause the conference to end when he leaves Modified: freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c ============================================================================== --- freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c (original) +++ freeswitch/trunk/src/mod/applications/mod_conference/mod_conference.c Wed Sep 19 12:20:00 2007 @@ -131,7 +131,8 @@ MFLAG_NOCHANNEL = (1 << 5), MFLAG_INTREE = (1 << 6), MFLAG_WASTE_BANDWIDTH = (1 << 7), - MFLAG_FLUSH_BUFFER = (1 << 8) + MFLAG_FLUSH_BUFFER = (1 << 8), + MFLAG_ENDCONF = (1 << 9) } member_flag_t; typedef enum { @@ -626,6 +627,10 @@ member->sh = NULL; } + if (switch_test_flag(member, MFLAG_ENDCONF)) { + switch_set_flag_locked(member->conference, CFLAG_DESTRUCT); + } + member->conference = NULL; if (!switch_test_flag(member, MFLAG_NOCHANNEL)) { @@ -3903,6 +3908,8 @@ *f &= ~MFLAG_CAN_HEAR; } else if (strstr(flags, "waste")) { *f |= MFLAG_WASTE_BANDWIDTH; + } else if (strstr(flags, "endconf")) { + *f |= MFLAG_ENDCONF; } } @@ -3973,6 +3980,15 @@ return; } + if ((flags_str = strstr(mydata, flags_prefix))) { + char *p; + + *flags_str = '\0'; + flags_str += strlen(flags_prefix); + if ((p = strchr(flags_str, '}'))) { + *p = '\0'; + } + } /* is this a bridging conference ? */ if (!strncasecmp(mydata, bridge_prefix, strlen(bridge_prefix))) { @@ -4269,15 +4285,6 @@ /* Install our Signed Linear codec so we get the audio in that format */ switch_core_session_set_read_codec(member.session, &member.read_codec); - if ((flags_str = strstr(mydata, flags_prefix))) { - char *p; - - *flags_str = '\0'; - flags_str += strlen(flags_prefix); - if ((p = strchr(flags_str, '}'))) { - *p = '\0'; - } - } mflags = conference->mflags; set_mflags(flags_str, &mflags);

1 0

[commit] r5713 - in freeswitch/trunk: conf src/mod/endpoints/mod_sofia
by Freeswitch SVN 19 Sep '07

19 Sep '07

Author: anthm Date: Wed Sep 19 11:28:16 2007 New Revision: 5713 Modified: freeswitch/trunk/conf/directory.xml freeswitch/trunk/conf/sofia.conf.xml 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_reg.c Log: add register-proxy option to gateways so you can send outbound reg to your local proxy dest for the outside Modified: freeswitch/trunk/conf/directory.xml ============================================================================== --- freeswitch/trunk/conf/directory.xml (original) +++ freeswitch/trunk/conf/directory.xml Wed Sep 19 11:28:16 2007 @@ -19,6 +19,8 @@    +  +     Modified: freeswitch/trunk/conf/sofia.conf.xml ============================================================================== --- freeswitch/trunk/conf/sofia.conf.xml (original) +++ freeswitch/trunk/conf/sofia.conf.xml Wed Sep 19 11:28:16 2007 @@ -22,6 +22,8 @@    +  +     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 Wed Sep 19 11:28:16 2007 @@ -196,6 +196,7 @@ char *register_proxy; char *register_context; char *expires_str; + char *register_url; uint32_t freq; time_t expires; time_t retry; 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 Wed Sep 19 11:28:16 2007 @@ -501,7 +501,8 @@ *expire_seconds = "3600", *retry_seconds = "30", *from_domain = "", - *to_domain = ""; + *to_domain = "", + *register_proxy = NULL; gateway->pool = profile->pool; gateway->profile = profile; @@ -539,13 +540,11 @@ from_domain = val; } else if (!strcmp(var, "to-domain")) { to_domain = val; + } else if (!strcmp(var, "register-proxy")) { + register_proxy = val; } } - - if (switch_strlen_zero(to_domain)) { - to_domain = proxy; - } - + if (switch_strlen_zero(realm)) { realm = name; } @@ -563,7 +562,7 @@ if (switch_strlen_zero(extension)) { extension = username; } - + if (switch_strlen_zero(proxy)) { proxy = realm; } @@ -576,6 +575,14 @@ from_domain = realm; } + if (switch_strlen_zero(register_proxy)) { + register_proxy = proxy; + } + + if (switch_strlen_zero(to_domain)) { + to_domain = proxy; + } + gateway->retry_seconds = atoi(retry_seconds); if (gateway->retry_seconds < 10) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "INVALID: retry_seconds correcting the value to 30\n"); @@ -589,6 +596,7 @@ if (switch_true(caller_id_in_from)) { switch_set_flag(gateway, REG_FLAG_CALLERID); } + gateway->register_url = switch_core_sprintf(gateway->pool, "sip:%s", register_proxy); gateway->register_from = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, from_domain); gateway->register_contact = switch_core_sprintf(gateway->pool, "sip:%s@%s:%d", extension, profile->extsipip ? profile->extsipip : profile->sipip, profile->sip_port); 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 Wed Sep 19 11:28:16 2007 @@ -73,6 +73,7 @@ case REG_STATE_UNREGISTER: nua_unregister(gateway_ptr->nh, + NUTAG_URL(gateway_ptr->register_url), SIPTAG_FROM_STR(gateway_ptr->register_from), SIPTAG_CONTACT_STR(gateway_ptr->register_contact), SIPTAG_EXPIRES_STR(gateway_ptr->expires_str), @@ -97,6 +98,7 @@ if (now) { nua_register(gateway_ptr->nh, + NUTAG_URL(gateway_ptr->register_url), SIPTAG_FROM_STR(gateway_ptr->register_from), SIPTAG_CONTACT_STR(gateway_ptr->register_contact), SIPTAG_EXPIRES_STR(gateway_ptr->expires_str), @@ -105,6 +107,7 @@ gateway_ptr->retry = now + gateway_ptr->retry_seconds; } else { nua_unregister(gateway_ptr->nh, + NUTAG_URL(gateway_ptr->register_url), SIPTAG_FROM_STR(gateway_ptr->register_from), SIPTAG_CONTACT_STR(gateway_ptr->register_contact), SIPTAG_EXPIRES_STR(gateway_ptr->expires_str), @@ -700,7 +703,7 @@ goto cancel; } } - + snprintf(authentication, sizeof(authentication), "%s:%s:%s:%s", scheme, realm, gateway->register_username, gateway->register_password); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Authenticating '%s' with '%s'.\n", profile->username, authentication);

1 0

[commit] r5712 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 19 Sep '07

19 Sep '07

Author: mikej Date: Wed Sep 19 11:05:55 2007 New Revision: 5712 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c Log: merge patch from MODENDP-24, add to-domain param to gateway that overrides the proxy domain for the to header 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 Wed Sep 19 11:05:55 2007 @@ -500,7 +500,8 @@ *context = "default", *expire_seconds = "3600", *retry_seconds = "30", - *from_domain = ""; + *from_domain = "", + *to_domain = ""; gateway->pool = profile->pool; gateway->profile = profile; @@ -536,9 +537,15 @@ retry_seconds = val; } else if (!strcmp(var, "from-domain")) { from_domain = val; + } else if (!strcmp(var, "to-domain")) { + to_domain = val; } } + if (switch_strlen_zero(to_domain)) { + to_domain = proxy; + } + if (switch_strlen_zero(realm)) { realm = name; } @@ -586,12 +593,12 @@ gateway->register_contact = switch_core_sprintf(gateway->pool, "sip:%s@%s:%d", extension, profile->extsipip ? profile->extsipip : profile->sipip, profile->sip_port); - if (!strncasecmp(proxy, "sip:", 4)) { + if (!strncasecmp(to_domain, "sip:", 4)) { gateway->register_proxy = switch_core_strdup(gateway->pool, proxy); - gateway->register_to = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, proxy + 4); + gateway->register_to = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, to_domain + 4); } else { gateway->register_proxy = switch_core_sprintf(gateway->pool, "sip:%s", proxy); - gateway->register_to = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, proxy); + gateway->register_to = switch_core_sprintf(gateway->pool, "sip:%s@%s", username, to_domain); } gateway->expires_str = switch_core_strdup(gateway->pool, expire_seconds);

1 0

[commit] r5711 - freeswitch/trunk/build
by Freeswitch SVN 19 Sep '07

19 Sep '07

Author: mikej Date: Wed Sep 19 10:58:40 2007 New Revision: 5711 Modified: freeswitch/trunk/build/fixautomake.sh freeswitch/trunk/build/fixlibtool.sh Log: use newer versions Modified: freeswitch/trunk/build/fixautomake.sh ============================================================================== --- freeswitch/trunk/build/fixautomake.sh (original) +++ freeswitch/trunk/build/fixautomake.sh Wed Sep 19 10:58:40 2007 @@ -1,9 +1,9 @@ cd /tmp mkdir fix_automake cd fix_automake -wget http://mirrors.kernel.org/gnu/automake/automake-1.9.tar.gz -tar -zxvf automake-1.9.tar.gz -cd automake-1.9 +wget http://mirrors.kernel.org/gnu/automake/automake-1.10.tar.gz +tar -zxvf automake-1.10.tar.gz +cd automake-1.10 ./configure --prefix=/usr make make install Modified: freeswitch/trunk/build/fixlibtool.sh ============================================================================== --- freeswitch/trunk/build/fixlibtool.sh (original) +++ freeswitch/trunk/build/fixlibtool.sh Wed Sep 19 10:58:40 2007 @@ -1,9 +1,9 @@ cd /tmp mkdir fix_libtool cd fix_libtool -wget http://mirrors.kernel.org/gnu/libtool/libtool-1.5.22.tar.gz -tar -zxvf libtool-1.5.22.tar.gz -cd libtool-1.5.22 +wget http://mirrors.kernel.org/gnu/libtool/libtool-1.5.24.tar.gz +tar -zxvf libtool-1.5.24.tar.gz +cd libtool-1.5.24 if test "`uname -s`" = "Darwin"; then ./configure --prefix=/usr --program-prefix=g else

1 0

[commit] r5710 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 18 Sep '07

18 Sep '07

Author: anthm Date: Tue Sep 18 13:31:36 2007 New Revision: 5710 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c 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_reg.c Log: add register-gateway variable to directory users to allow inbound reg to trigger an outbound one 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 Tue Sep 18 13:31:36 2007 @@ -942,9 +942,11 @@ "TRYING", "REGISTER", "REGED", + "UNREGISTER", "FAILED", "EXPIRED", - "NOREG" }; + "NOREG", + NULL}; struct cb_helper { sofia_profile_t *profile; @@ -1169,6 +1171,34 @@ } + if (!strcasecmp(argv[1], "unregister")) { + char *gname = argv[2]; + sofia_gateway_t *gateway_ptr; + + if (switch_strlen_zero(gname)) { + stream->write_function(stream, "No gateway name provided!\n"); + goto done; + } + + if (!strcasecmp(gname, "all")) { + for (gateway_ptr = profile->gateways; gateway_ptr; gateway_ptr = gateway_ptr->next) { + gateway_ptr->retry = 0; + gateway_ptr->state = REG_STATE_UNREGISTER; + } + stream->write_function(stream, "+OK\n"); + } else if ((gateway_ptr = sofia_reg_find_gateway(gname))) { + gateway_ptr->retry = 0; + gateway_ptr->state = REG_STATE_UNREGISTER; + stream->write_function(stream, "+OK\n"); + sofia_reg_release_gateway(gateway_ptr); + } else { + stream->write_function(stream, "Invalid gateway!\n"); + } + + goto done; + } + + if (!strcasecmp(argv[1], "stop") || !strcasecmp(argv[1], "restart")) { int rsec = 3; int diff = (int) (time(NULL) - profile->started); 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 Sep 18 13:31:36 2007 @@ -174,6 +174,7 @@ REG_STATE_TRYING, REG_STATE_REGISTER, REG_STATE_REGED, + REG_STATE_UNREGISTER, REG_STATE_FAILED, REG_STATE_EXPIRED, REG_STATE_NOREG, @@ -432,7 +433,7 @@ switch_status_t config_sofia(int reload, char *profile_name); void sofia_reg_auth_challange(nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, sofia_regtype_t regtype, const char *realm, int stale); auth_res_t sofia_reg_parse_auth(sofia_profile_t *profile, sip_authorization_t const *authorization, - const char *regstr, char *np, size_t nplen, char *ip, switch_event_t **v_event); + const char *regstr, char *np, size_t nplen, char *ip, switch_event_t **v_event, long exptime); void sofia_reg_handle_sip_r_challenge(int status, char const *phrase, nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, switch_core_session_t *session, sip_t const *sip, tagi_t tags[]); 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 Sep 18 13:31:36 2007 @@ -87,7 +87,7 @@ char network_ip[80]; get_addr(network_ip, sizeof(network_ip), &((struct sockaddr_in *) msg_addrinfo(nua_current_request(nua))->ai_addr)->sin_addr); auth_res = sofia_reg_parse_auth(profile, authorization, - (char *) sip->sip_request->rq_method_name, tech_pvt->key, strlen(tech_pvt->key), network_ip, NULL); + (char *) sip->sip_request->rq_method_name, tech_pvt->key, strlen(tech_pvt->key), network_ip, NULL, 0); } if (auth_res != AUTH_OK) { 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 Sep 18 13:31:36 2007 @@ -70,6 +70,16 @@ gateway_ptr->expires = now + gateway_ptr->freq; gateway_ptr->state = REG_STATE_REGED; break; + + case REG_STATE_UNREGISTER: + nua_unregister(gateway_ptr->nh, + SIPTAG_FROM_STR(gateway_ptr->register_from), + SIPTAG_CONTACT_STR(gateway_ptr->register_contact), + SIPTAG_EXPIRES_STR(gateway_ptr->expires_str), + NUTAG_REGISTRAR(gateway_ptr->register_proxy), + NUTAG_OUTBOUND("no-options-keepalive"), NUTAG_OUTBOUND("no-validate"), NUTAG_KEEPALIVE(0), TAG_NULL()); + gateway_ptr->state = REG_STATE_NOREG; + break; case REG_STATE_UNREGED: if ((gateway_ptr->nh = nua_handle(gateway_ptr->profile->nua, NULL, NUTAG_URL(gateway_ptr->register_proxy), @@ -322,6 +332,7 @@ const char *rpid = "unknown"; const char *display = "\"user\""; char network_ip[80]; + char *register_gateway = NULL; int network_port; int cd = 0; @@ -390,25 +401,30 @@ if (authorization) { char *v_contact_str; - if ((auth_res = sofia_reg_parse_auth(profile, authorization, sip->sip_request->rq_method_name, key, keylen, network_ip, v_event)) == AUTH_STALE) { + if ((auth_res = sofia_reg_parse_auth(profile, authorization, sip->sip_request->rq_method_name, key, keylen, network_ip, v_event, exptime)) + == AUTH_STALE) { stale = 1; } - if (v_event && *v_event && (v_contact_str = switch_event_get_header(*v_event, "force-contact"))) { - if (!strcasecmp(v_contact_str, "nat-connectile-dysfunction") || !strcasecmp(v_contact_str, "NDLB-connectile-dysfunction")) { - if (contact->m_url->url_params) { - snprintf(contact_str, sizeof(contact_str), "%s <sip:%s@%s:%d;%s>", - display, contact->m_url->url_user, network_ip, network_port, contact->m_url->url_params); + if (v_event && *v_event) { + register_gateway = switch_event_get_header(*v_event, "register-gateway"); + + if ((v_contact_str = switch_event_get_header(*v_event, "force-contact"))) { + if (!strcasecmp(v_contact_str, "nat-connectile-dysfunction") || !strcasecmp(v_contact_str, "NDLB-connectile-dysfunction")) { + if (contact->m_url->url_params) { + snprintf(contact_str, sizeof(contact_str), "%s <sip:%s@%s:%d;%s>", + display, contact->m_url->url_user, network_ip, network_port, contact->m_url->url_params); + } else { + snprintf(contact_str, sizeof(contact_str), "%s <sip:%s@%s:%d>", display, contact->m_url->url_user, network_ip, network_port); + } + cd = 1; } else { - snprintf(contact_str, sizeof(contact_str), "%s <sip:%s@%s:%d>", display, contact->m_url->url_user, network_ip, network_port); - } - cd = 1; - } else { - char *p; - switch_copy_string(contact_str, v_contact_str, sizeof(contact_str)); - for(p = contact_str; p && *p; p++) { - if (*p == '\'' || *p == '[' || *p == ']') { - *p = '"'; + char *p; + switch_copy_string(contact_str, v_contact_str, sizeof(contact_str)); + for(p = contact_str; p && *p; p++) { + if (*p == '\'' || *p == '[' || *p == ']') { + *p = '"'; + } } } } @@ -438,12 +454,11 @@ if (regtype != REG_REGISTER) { return 0; } - + if (exptime) { if (!sofia_reg_find_reg_url(profile, to_user, to_host, buf, sizeof(buf))) { sql = switch_mprintf("insert into sip_registrations values ('%q','%q','%q','%q', '%q', %ld)", to_user, to_host, contact_str, cd ? "Registered(NATHACK)" : "Registered", rpid, (long) time(NULL) + (long) exptime * 2); - } else { sql = switch_mprintf @@ -716,7 +731,7 @@ } auth_res_t sofia_reg_parse_auth(sofia_profile_t *profile, sip_authorization_t const *authorization, - const char *regstr, char *np, size_t nplen, char *ip, switch_event_t **v_event) + const char *regstr, char *np, size_t nplen, char *ip, switch_event_t **v_event, long exptime) { int indexnum; const char *cur; @@ -829,9 +844,59 @@ for (param = switch_xml_child(xparams, "variable"); param; param = param->next) { const char *var = switch_xml_attr_soft(param, "name"); const char *val = switch_xml_attr_soft(param, "value"); - + sofia_gateway_t *gateway_ptr = NULL; + if (!switch_strlen_zero(var) && !switch_strlen_zero(val)) { switch_event_add_header(*v_event, SWITCH_STACK_BOTTOM, var, "%s", val); + + if (!strcasecmp(var, "register-gateway")) { + if (!strcasecmp(val, "all")) { + switch_xml_t gateways_tag, gateway_tag; + if ((gateways_tag = switch_xml_child(user, "gateways"))) { + for (gateway_tag = switch_xml_child(gateways_tag, "gateway"); gateway_tag; gateway_tag = gateway_tag->next) { + char *name = (char *) switch_xml_attr_soft(gateway_tag, "name"); + if (switch_strlen_zero(name)) { + name = "anonymous"; + } + + if ((gateway_ptr = sofia_reg_find_gateway(name))) { + gateway_ptr->retry = 0; + if (exptime) { + gateway_ptr->state = REG_STATE_UNREGED; + } else { + gateway_ptr->state = REG_STATE_UNREGISTER; + } + sofia_reg_release_gateway(gateway_ptr); + } + + } + } + } else { + int x, argc; + char *mydata, *argv[50]; + + mydata = strdup(val); + assert(mydata != NULL); + + argc = switch_separate_string(mydata, ',', argv, (sizeof(argv) / sizeof(argv[0]))); + + for (x = 0; x < argc; x++) { + if ((gateway_ptr = sofia_reg_find_gateway((char *)argv[x]))) { + gateway_ptr->retry = 0; + if (exptime) { + gateway_ptr->state = REG_STATE_UNREGED; + } else { + gateway_ptr->state = REG_STATE_UNREGISTER; + } + sofia_reg_release_gateway(gateway_ptr); + } else { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Gateway '%s' not found.\n", argv[x]); + } + } + + free(mydata); + } + } } } }

1 0

[commit] r5709 - freeswitch/trunk/scripts/contrib/trixter
by Freeswitch SVN 16 Sep '07

16 Sep '07

Author: trixter Date: Sun Sep 16 13:36:06 2007 New Revision: 5709 Added: freeswitch/trunk/scripts/contrib/trixter/call-progress.pl (contents, props changed) Log: perl script using event socket to monitor ring/answer/hangup events and issue commands when it gets them Added: freeswitch/trunk/scripts/contrib/trixter/call-progress.pl ============================================================================== --- (empty file) +++ freeswitch/trunk/scripts/contrib/trixter/call-progress.pl Sun Sep 16 13:36:06 2007 @@ -0,0 +1,153 @@ +#!/usr/bin/perl +# -*- mode:cperl; tab-width:4; c-basic-offset:4; c-indent-level:4; indent-tabs-mode:nil; -*- +use FreeSWITCH::Client; +use POSIX ':signal_h'; # used for alarm to ensure we get heartbeats +use Data::Dumper; # used to print out myhash debug info + + +# configure these +my $password = "ClueCon"; # the password for event socket +my $host = "localhost"; # the hostname to connect to +my $port = 8021; # the port to connect to +my $timeout = 30; # seconds to expect a heartbeat event or reconnect +my $conntime = 30; # seconds to wait between connection attempts +my $CIDNAME = "its me"; # name to use when originating a call +my $CIDNUM = "1234567890"; # number to use when originating a call +my $TIMEOUT = 30; # timeout to wait for answer + +# array of the regexps for channels that match, useful if you dont want to do this for +# all calls on your switch +my @channels = ( + '^sofia\/mydomain.com\/\d+\(a)192.168.0.6$', + '^sofia/external/888(a)conference.freeswitch.org$', +); + +## +# dont touch these +## +my $fs; +my $lastheartbeat; +my $lastconnect; + + +sub watchedChannel($) { + my $channame = shift; + +print "Checking $channame\n"; + + + foreach $regexp (@channels) { + if($channame =~ /$regexp/) { + return 1; + } + } + return undef; +} + + +sub do_ring($) { + my $myhash = shift; + + print "Got RING for $myhash->{'channel-name'} - $myhash->{'unique-id'}\n"; + + # here we are going to just hang it up since its just a silly example + # but for variety lets wait 2 seconds before it dies + $fs->sendmsg({'command' => "api sched_hangup +2 $myhash->{'unique-id'}"}); +} + + +sub do_answer($) { + my $myhash = shift; + + print "Got ANSWER for $myhash->{'channel-name'}\n"; + + # here we are going to just hang it up since its just a silly example + $fs->sendmsg({'command' => "api killchan $myhash->{'unique-id'}"}); +} + + + +sub do_hangup($) { + my $myhash = shift; + + print "Got HANGUP for $myhash->{'channel-name'} $myhash->{'unique-id'}\n"; + + # hey it was a hangup, lets call someone now! + $cmd = "api originate sofia/mydomain.com/123\@192.168.0.6 &playback(/sounds/conf-enter.raw) XML default \"$CIDNAME\" \"$CIDNUM\""; + $fs->sendmsg({'command' => $cmd}); +} + + + +# this connects to the event socket +sub es_connect() { + if(! defined $lastconnect) { + $lastconnect = time - $conntime; + } + + if($lastconnect <= (time - $conntime)) { + $lastconnect = time; + print "Connecting to $host:$port\n"; + eval { + $fs = init FreeSWITCH::Client {-password => $password, -host => $host, -port => $port}; + if(defined $fs) { + $fs->sendmsg({'command' => 'event plain CHANNEL_STATE CHANNEL_ANSWER heartbeat CHANNEL_HANGUP all'}); + $lastheartbeat = time; + } + } or do { + print "Error connecting - waiting for retry\n"; + } + } + + } + + +sigaction SIGALRM, new POSIX::SigAction sub { + if ($lastheartbeat < (time - $timeout)) { + print "Did not receive a heartbeat in the specified timeout\n"; + if (defined $fs) { + $fs->disconnect(); + undef $fs; + } + es_connect(); + } + + # reset the alarm + alarm $timeout; +} or die "Error setting SIGALRM handler: $!\n"; + + + +es_connect(); +alarm $timeout; + +while (1) { + if(defined $fs) { + my $reply = $fs->readhash(undef); + if ($reply->{socketerror}) { + es_connect(); + } + + if ($reply->{body}) { + $myhash = $reply->{event}; + + if ($myhash->{'event-name'} eq "HEARTBEAT") { ## Deal with heartbeats + $lastheartbeat = time; + print "Got a heartbeat\n"; + + } elsif (watchedChannel($myhash->{'channel-name'})) { + if ($myhash->{'event-name'} eq "CHANNEL_ANSWER") { ## deal with answers + do_answer($myhash); + } elsif ($myhash->{'event-name'} eq "CHANNEL_STATE" && $myhash->{'channel-state'} eq "CS_RING") { + do_ring($myhash); + } elsif ($myhash->{'event-name'} eq "CHANNEL_HANGUP") { ## last thing done on a channel + do_hangup($myhash); + } else { ## Unknown event + print Dumper $myhash; + # print "$reply->{body}\n"; # print out what was sent, myhash is translated by Client.pm + } + } # end channel-name filter + } + } +} +

1 0

[commit] r5708 - freeswitch/trunk/scripts/contrib/trixter
by Freeswitch SVN 16 Sep '07

16 Sep '07

Author: trixter Date: Sun Sep 16 13:35:27 2007 New Revision: 5708 Added: freeswitch/trunk/scripts/contrib/trixter/README Log: index of the files in my contrib dir Added: freeswitch/trunk/scripts/contrib/trixter/README ============================================================================== --- (empty file) +++ freeswitch/trunk/scripts/contrib/trixter/README Sun Sep 16 13:35:27 2007 @@ -0,0 +1,102 @@ +These are examples written by Bret McDanel <trixter AT 0xdecafbad.com> +In general, web apps are written in PHP, event socket apps are written +in perl. The perl examples use FreeSWITCH::Client which is located in +svn root scripts/socket. + +Most of these examples are not useful in their current state, and require +some modification to make them useful. They are to provide implementation +references for various tasks. For example, xml-cdr will read the CDR records +from FreeSWITCH[tm] but does not process them because there is no way to +know how you will want them stored. You would be required to implement +whatever database system (mysql, flat file, CSV, etc) and store the records +yourself, but it shows how you can receive the CDR records and manipulate +them. + + +== LICENSE == +All of these scripts are licensed under a public domain license unless +otherwise stated within the individual files. What this means that I +still maintain the copyright but you are totally free to do whatever +with the programs whether commercial or FOSS. + + + +== FILE LIST == + +asyncsock.pl + Perl app utilizing EVENT SOCKET that will bind to a port and + is called via the dialplan 'socket' application. It will read + DTMF building a string of DTMF after an interdigit timeout or + total timeout. + + +callcredit.pl + Perl app utilizing EVENT SOCKET that pings a webserver for each + call in progress checking to see if credit still remains. Can + form the basis for a prepaid calling platform where instead of + reserving large amounts of credit, not allowing credit updates + mid-call, or allowing customers to go negative by placing multiple + concurrent calls. + + +calls.pl + Perl app utilizing EVENT SOCKET that relays new call and hangup + events to a webserver so that you can monitor in realtime calls + that are active on a given switch. All properties are relayed. + + +conf-dtmf.pl + Perl app that will read DTMF events from a conference and play + a sound file. Could be used as the basis for advanced custom + menus from within a conference. You need to bind the DTMF key + to 'event' within conference.conf.xml to be sent to event socket. + uses EVENT SOCKET + + +disa.js + Javascript app that will enable DISA functionality + with black/white lists, pins and other goodies + + +faxlib.jm + Javascript class that integrates faxing - DEPRECATED + this has litle use now that dptools has a fax detect and transfer + to a given extension app + + +call-progress.pl + PERL app utilizing EVENT SOCKET that will monitor RING/ANSWER/HANGUP + events and issue a command at that time. + + +makecombinedfsxml.pl + PERL app that makes freeswitch-combined.xml from a freeswitch.xml + + +regexptest.pl + PERL app that tests regexps in CLI mode + + +softphone.pl + PERL/TK app that functions like a softphone which lets you place + calls from port audio. Uses EVENT SOCKET + + +xml-cdr + PHP xml-cdr web app that receives CDR entries enabling a web based + CDR tracking facility in realtime + + +xml-curl + PHP xml-curl web app that will deliver configuration files, dialplans + and other goodies to FreeSWITCH[tm] + + +xml-rpc + PHP xml-rpc web app that will let you monitor calls, confs and execute + some commands to control conference members + + +vile + This is vile's stuff, he didn't have his own directory when they were + added and they are not yet moved into his repository

1 0