Preston_PLB/freeswitch
1
0
Fork 0
forked from Mirrors/freeswitch
Code Pull Requests Activity

add missing files

Browse Source 
git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@11967 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
Michael Jerris 2009-02-12 21:58:06 +00:00
parent ee9d2d4982
commit ed23436a8e
3 changed files with 2804 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

998
libs/sofia-sip/libsofia-sip-ua/sresolv/check_sres_sip.c Normal file
View File

@ -0,0 +1,998 @@
/*
* This file is part of the Sofia-SIP package
*
* Copyright (C) 2009 Nokia Corporation.
*
* Contact: Pekka Pessi <pekka.pessi@nokia.com>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public License
* as published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA
*
*/
/**@CFILE check_sres_sip.c
*
* @brief Check-driven tester for SIP URI resolver
*
* @author Pekka Pessi <Pekka.Pessi@nokia.com>
*
* @copyright (C) 2009 Nokia Corporation.
*/
#include "config.h"
#define SRES_SIP_MAGIC_T void
#include <sofia-sip/sres_sip.h>
#include "s2check.h"
#include "s2dns.h"
#include <sofia-sip/su_wait.h>
#include <sofia-sip/sresolv.h>
#include <sofia-sip/su_log.h>
#include <sofia-sip/su_string.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <assert.h>
SOFIAPUBVAR su_log_t sresolv_log[];
static void
setup_logs(int level)
{
su_log_soft_set_level(sresolv_log, level);
}
/* */
struct context {
su_root_t *root;
sres_resolver_t *sres;
} x[1];
static su_addrinfo_t hint_udp_tcp[2];
static su_addrinfo_t hint_udp_tcp_tls[2];
static su_addrinfo_t hint_udp_tcp_ip4[2];
static su_addrinfo_t hint_tls[1];
static su_addrinfo_t hint_tls_udp_tcp[1];
static void
resolver_setup(void)
{
x->root = su_root_create(NULL);
assert(x->root);
s2_dns_setup(x->root);
s2_dns_record("test.example.com.", sres_type_a,
"test.example.com.", sres_type_a, "12.13.14.25",
NULL);
x->sres = sres_resolver_create(
x->root, NULL,
#if HAVE_WIN32
SRESTAG_RESOLV_CONF("NUL"),
#else
SRESTAG_RESOLV_CONF("/dev/null"),
#endif
TAG_END());
hint_udp_tcp[0].ai_protocol = TPPROTO_UDP;
hint_udp_tcp[0].ai_next = &hint_udp_tcp[1];
hint_udp_tcp[1].ai_protocol = TPPROTO_TCP;
hint_udp_tcp_ip4[0].ai_protocol = TPPROTO_UDP;
hint_udp_tcp_ip4[0].ai_family = AF_INET;
hint_udp_tcp_ip4[0].ai_next = &hint_udp_tcp_ip4[1];
hint_udp_tcp_ip4[1].ai_protocol = TPPROTO_TCP;
hint_udp_tcp_ip4[1].ai_family = AF_INET;
hint_tls[0].ai_protocol = TPPROTO_TLS;
hint_tls_udp_tcp[0].ai_protocol = TPPROTO_TLS;
hint_tls_udp_tcp[0].ai_next = hint_udp_tcp;
hint_udp_tcp_tls[0].ai_protocol = TPPROTO_UDP;
hint_udp_tcp_tls[0].ai_next = &hint_udp_tcp_tls[1];
hint_udp_tcp_tls[1].ai_protocol = TPPROTO_TCP;
hint_udp_tcp_tls[1].ai_next = &hint_udp_tcp_tls[2];
hint_udp_tcp_tls[2].ai_protocol = TPPROTO_TLS;
hint_udp_tcp_tls[2].ai_next = NULL;
setup_logs(0);
}
static void
resolver_teardown(void)
{
sres_resolver_unref(x->sres), x->sres = NULL;
s2_dns_teardown();
}
/* ---------------------------------------------------------------------- */
static uint16_t
ai_port(su_addrinfo_t const *ai)
{
return ai && ai->ai_addr ?
ntohs(((struct sockaddr_in *)ai->ai_addr)->sin_port) : 0;
}
static int
ai_ip4_match(su_addrinfo_t const *ai,
char const *addr,
uint16_t port)
{
struct in_addr in, in_in_ai;
if (ai_port(ai) != port)
return 0;
if (ai->ai_family != AF_INET)
return 0;
if (su_inet_pton(AF_INET, addr, &in) <= 0)
return 0;
in_in_ai = ((struct sockaddr_in *)ai->ai_addr)->sin_addr;
return memcmp(&in, &in_in_ai, (sizeof in)) == 0;
}
/* ---------------------------------------------------------------------- */
START_TEST(invalid)
{
sres_sip_t *srs;
#if 0
s2_case("1.0", "Check invalid input values",
"Detailed explanation for empty test case.");
#endif
srs = sres_sip_new(NULL, (void *)"sip:test.example.com.", NULL,
1, 1,
NULL, NULL);
fail_if(srs != NULL);
srs = sres_sip_new(x->sres, NULL, NULL,
1, 1,
NULL, NULL);
fail_if(srs != NULL);
srs = sres_sip_new(x->sres, (void *)"tilu.liu.", NULL, 1, 1, NULL, NULL);
fail_unless(srs != NULL);
fail_if(sres_sip_error(srs) != SRES_SIP_ERR_BAD_URI);
fail_if(sres_sip_next_step(srs));
fail_if(sres_sip_results(srs) != NULL);
sres_sip_unref(srs);
}
END_TEST
static void
resolver_callback(void *userdata,
sres_sip_t *srs,
int final)
{
if (final)
su_root_break((su_root_t *)userdata);
}
START_TEST(not_found)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
srs = sres_sip_new(x->sres, (void *)"sip:notfound.example.net", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_run(x->root);
ai = sres_sip_results(srs);
fail_if(ai != NULL);
fail_if(sres_sip_error(srs) != SRES_SIP_ERR_NO_NAME);
sres_sip_unref(srs);
}
END_TEST
START_TEST(found_a)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
srs = sres_sip_new(x->sres, (void *)"sip:test.example.com", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_run(x->root);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_if((ai = ai->ai_next));
sres_sip_unref(srs);
}
END_TEST
START_TEST(found_ip)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
url_string_t *uri;
srs = sres_sip_new(x->sres, (void *)"sip:127.21.50.37", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
fail_if(sres_sip_next_step(srs));
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_if((ai = ai->ai_next));
sres_sip_unref(srs);
srs = sres_sip_new(x->sres, (void *)"sip:127.21.50.37:", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
fail_if(sres_sip_next_step(srs));
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_if((ai = ai->ai_next));
sres_sip_unref(srs);
#if SU_HAVE_IN6
uri = (void *)"sip:[3ff0:0010:3012:c000:02c0:95ff:fee2:4b78]";
srs = sres_sip_new(x->sres, uri, NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
fail_if(sres_sip_next_step(srs));
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_if((ai = ai->ai_next));
sres_sip_unref(srs);
#endif
}
END_TEST
START_TEST(found_maddr_a)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
url_string_t *uri;
s2_dns_record("maddr.example.com", sres_type_a,
"", sres_type_a, "11.12.13.14",
NULL);
uri = (void *)"sip:test.example.com;lr=1;maddr=maddr.example.com;more";
srs = sres_sip_new(x->sres, uri, NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_run(x->root);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_unless(ai_ip4_match(ai, "11.12.13.14", 5060));
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_if((ai = ai->ai_next));
sres_sip_unref(srs);
}
END_TEST
START_TEST(found_cname)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
url_string_t *uri;
s2_dns_record("cname1.example.com", sres_type_a,
"", sres_type_cname, "a.example.com.",
NULL);
s2_dns_record("cname1.example.com", sres_type_naptr,
"", sres_type_cname, "a.example.com.",
NULL);
s2_dns_record("a.example.com", sres_type_a,
"", sres_type_a, "11.12.13.14",
NULL);
s2_dns_record("cname2.example.com", sres_type_a,
"", sres_type_cname, "a.example.com.",
"test.example.com", sres_type_a, "11.12.13.14",
NULL);
uri = (void *)"sip:cname1.example.com";
srs = sres_sip_new(x->sres, uri, NULL, 1, 1, resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_run(x->root);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_unless(ai_ip4_match(ai, "11.12.13.14", 5060));
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_if((ai = ai->ai_next));
sres_sip_unref(srs);
}
END_TEST
START_TEST(found_maddr_ip)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
url_string_t *uri;
uri = (void *)"sip:not.existing.net;maddr=127.21.50.37";
srs = sres_sip_new(x->sres, uri, NULL, 1, 1, resolver_callback, x->root);
fail_if(srs == NULL);
fail_if(sres_sip_next_step(srs));
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_if((ai = ai->ai_next));
sres_sip_unref(srs);
#if SU_HAVE_IN6
uri = (void *)"sip:test.example.com:"
";maddr=3ff0:0010:3012:c000:02c0:95ff:fee2:4b78";
srs = sres_sip_new(x->sres, uri, NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
fail_if(sres_sip_next_step(srs));
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_if((ai = ai->ai_next));
sres_sip_unref(srs);
uri = (void *)"sip:test.example.com:"
";maddr=[3ff0:0010:3012:c000:02c0:95ff:fee2:4b78]";
srs = sres_sip_new(x->sres, uri, NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
fail_if(sres_sip_next_step(srs));
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_if((ai = ai->ai_next));
sres_sip_unref(srs);
#endif
}
END_TEST
START_TEST(found_a_aaaa)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
s2_dns_default("example.com.");
s2_dns_record("ip6ip4.example.com.", sres_type_a,
"", sres_type_a, "12.13.14.25",
"", sres_type_aaaa, "3ff0:0010:3012:c000:02c0:95ff:fee2:4b78",
NULL);
s2_dns_record("ip6ip4", sres_type_aaaa,
"", sres_type_aaaa, "3ff0:0010:3012:c000:02c0:95ff:fee2:4b78",
"", sres_type_a, "12.13.14.25",
NULL);
srs = sres_sip_new(x->sres, (void *)"sip:ip6ip4.example.com", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_run(x->root);
ai = sres_sip_results(srs);
assert(ai != NULL);
#if SU_HAVE_IN6
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_unless(ai->ai_family == AF_INET6);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET6);
fail_if(!(ai = ai->ai_next));
#endif
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_unless(ai->ai_family == AF_INET);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_unless(!(ai = ai->ai_next));
sres_sip_unref(srs);
}
END_TEST
START_TEST(found_naptr)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
char const *d;
s2_dns_default(d = "example.com.");
s2_dns_record(d, sres_type_naptr,
/* order priority flags services regexp target */
d, sres_type_naptr, 20, 50, "s", "SIP+D2T", "", "_sip._tcp",
/* priority weight port target */
"_sip._tcp", sres_type_srv, 2, 100, 5060, "sip00",
"sip00", sres_type_a, "12.13.14.15",
NULL);
srs = sres_sip_new(x->sres, (void *)"sip:example.com", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_unless(!(ai = ai->ai_next));
sres_sip_unref(srs);
}
END_TEST
START_TEST(ignore_naptr)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
char const *d;
s2_dns_default(d = "example.com.");
s2_dns_record(d, sres_type_naptr,
/* order priority flags services regexp target */
d, sres_type_naptr, 20, 50, "s", "SIP+D2T", "", "_sip._tcp",
/* priority weight port target */
"_sip._tcp", sres_type_srv, 2, 100, 5060, "sip00",
"sip00", sres_type_a, "12.13.14.15",
NULL);
s2_dns_record(d, sres_type_a,
"", sres_type_a, "13.14.15.16",
NULL);
srs = sres_sip_new(x->sres, (void *)"sip:example.com:5060", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
ai = ai->ai_next; assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TCP);
ai = ai->ai_next; assert(ai == NULL);
sres_sip_unref(srs);
}
END_TEST
START_TEST(found_naptr2)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
char const *d;
/* Test case without caching, two A addresses */
s2_dns_default(d = "example.com.");
s2_dns_record(d, sres_type_naptr,
/* order priority flags services regexp target */
"", sres_type_naptr, 20, 50, "s", "SIP+D2T", "", "_sip._tcp",
NULL);
s2_dns_record("_sip._tcp", sres_type_srv,
/* priority weight port target */
"", sres_type_srv, 2, 100, 5060, "sip00",
NULL);
s2_dns_record("sip00", sres_type_a,
"", sres_type_a, "12.13.14.15",
"", sres_type_a, "12.13.14.16",
NULL);
srs = sres_sip_new(x->sres, (void *)"sip:example.com", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_unless(!(ai = ai->ai_next));
sres_sip_unref(srs);
}
END_TEST
START_TEST(found_naptr3)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
char const *d;
/* Check that sip: resolves only to TLS */
s2_dns_default(d = "example.com.");
s2_dns_record(d, sres_type_naptr,
/* order priority flags services regexp target */
d, sres_type_naptr, 30, 50, "s", "SIP+D2T", "", "_sip._tcp.srv00",
d, sres_type_naptr, 20, 50, "s", "SIPS+D2T", "", "_sips._tcp.srv00",
/* priority weight port target */
"_sips._tcp.srv00", sres_type_srv, 2, 100, 5061, "sips00",
"sips00", sres_type_a, "12.13.14.15",
"_sip._tcp.srv00", sres_type_srv, 2, 100, 5060, "sip00",
"sip00", sres_type_a, "12.13.14.16",
NULL);
srs = sres_sip_new(x->sres, (void *)"sip:example.com", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TLS);
fail_unless(ai->ai_family == AF_INET);
fail_unless(!(ai = ai->ai_next));
sres_sip_unref(srs);
/* Hint no support for TLS */
srs = sres_sip_new(x->sres, (void *)"sip:example.com", hint_udp_tcp,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_unless(!(ai = ai->ai_next));
sres_sip_unref(srs);
}
END_TEST
START_TEST(found_naptr_with_a)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
char const *d;
int i;
s2_dns_default(d = "example.com.");
s2_dns_record(d, sres_type_naptr,
/* order priority flags services regexp target */
"", sres_type_naptr, 20, 50, "a", "SIP+D2U", "", "sip00",
"", sres_type_naptr, 20, 50, "a", "SIP+D2T", "", "sip00",
"", sres_type_naptr, 20, 50, "a", "SIPS+D2T", "", "sip00",
"sip00", sres_type_a, "12.13.14.15",
NULL);
/* Check that cache does not change ordering */
for (i = 0; i < 3; i++) {
srs = sres_sip_new(x->sres, (void *)"sip:example.com", NULL,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
if (i == 0) {
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
}
else {
fail_if(sres_sip_next_step(srs));
}
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_unless(ai->ai_family == AF_INET);
ai = ai->ai_next;
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
ai = ai->ai_next;
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TLS);
fail_unless(ai->ai_family == AF_INET);
fail_if(ai->ai_next);
sres_sip_unref(srs);
}
}
END_TEST
START_TEST(found_srv)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
char const *d;
/* Check that hints are followed: */
s2_dns_default(d = "example.com.");
s2_dns_record("_sips._tcp", sres_type_srv,
"", sres_type_srv, 2, 100, 5061, "sips00",
"sips00", sres_type_a, "12.13.14.15",
NULL);
s2_dns_record("_sip._tcp", sres_type_srv,
"", sres_type_srv, 2, 100, 5060, "sip00",
"sip00", sres_type_a, "12.13.14.16",
NULL);
srs = sres_sip_new(x->sres, (void *)"sip:example.com", hint_udp_tcp,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_unless(!(ai = ai->ai_next));
sres_sip_unref(srs);
/* Hints prefer TLS */
srs = sres_sip_new(x->sres, (void *)"sip:example.com", hint_tls_udp_tcp,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TLS);
fail_unless(ai->ai_family == AF_INET);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_unless(!(ai = ai->ai_next));
sres_sip_unref(srs);
/* Hints support TLS, prefer TCP */
srs = sres_sip_new(x->sres, (void *)"sip:example.com", hint_udp_tcp_tls,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TLS);
fail_unless(ai->ai_family == AF_INET);
fail_unless(!(ai = ai->ai_next));
sres_sip_unref(srs);
sres_resolver_unref(x->sres);
x->sres = sres_resolver_create(
x->root, NULL,
#if HAVE_WIN32
SRESTAG_RESOLV_CONF("NUL"),
#else
SRESTAG_RESOLV_CONF("/dev/null"),
#endif
TAG_END());
/* Add UDP record */
s2_dns_record("_sip._udp", sres_type_srv,
"", sres_type_srv, 1, 100, 5060, "sip00",
"sip00", sres_type_a, "12.13.14.16",
NULL);
srs = sres_sip_new(x->sres, (void *)"sip:example.com", hint_udp_tcp_tls,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_unless(ai->ai_family == AF_INET);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_if(!(ai = ai->ai_next));
fail_if(ai->ai_protocol != TPPROTO_TLS);
fail_unless(ai->ai_family == AF_INET);
fail_unless(!(ai = ai->ai_next));
sres_sip_unref(srs);
}
END_TEST
START_TEST(found_multi_srv)
{
sres_sip_t *srs;
su_addrinfo_t const *ai;
char const *d;
int i;
su_addrinfo_t hints[1];
/* Check that srv records are selected correctly by priority and weight */
s2_dns_default(d = "example.com.");
s2_dns_record("_sips._tcp", sres_type_srv,
"", sres_type_srv, 2, 100, 5061, "sips00",
"", sres_type_srv, 2, 100, 5061, "sips01",
"", sres_type_srv, 2, 200, 5061, "sips02",
"sips00", sres_type_a, "12.13.0.10",
"sips01", sres_type_a, "12.13.1.10",
"sips02", sres_type_a, "12.13.2.10",
NULL);
mark_point();
s2_dns_record("_sip._tcp", sres_type_srv,
"", sres_type_srv, 4, 1, 5060, "sip00",
"", sres_type_srv, 3, 100, 5060, "sip01",
"", sres_type_srv, 3, 10, 5060, "sip02",
"sip00", sres_type_a, "12.13.0.1",
"sip00", sres_type_a, "12.13.0.2",
"sip01", sres_type_a, "12.13.1.2",
"sip01", sres_type_a, "12.13.1.1",
"sip02", sres_type_a, "12.13.2.1",
"sip02", sres_type_a, "12.13.2.2",
NULL);
mark_point();
s2_dns_record("_sip._udp", sres_type_srv,
"", sres_type_srv, 10, 100, 5060, "sip00",
"", sres_type_srv, 10, 0, 5060, "sip01",
"", sres_type_srv, 1, 100, 5060, "sip02",
"sip00", sres_type_a, "12.13.0.1",
"sip00", sres_type_a, "12.13.0.2",
"sip01", sres_type_a, "12.13.1.2",
"sip01", sres_type_a, "12.13.1.1",
"sip02", sres_type_a, "12.13.2.1",
"sip02", sres_type_a, "12.13.2.2",
NULL);
mark_point();
/* Ask resolver to return canonic names */
*hints = *hint_udp_tcp_tls, hints->ai_flags |= AI_CANONNAME;
srs = sres_sip_new(x->sres, (void *)"sip:example.com", hints,
1, 1,
resolver_callback, x->root);
fail_if(srs == NULL);
while (sres_sip_next_step(srs))
su_root_step(x->root, 1000);
ai = sres_sip_results(srs);
for (i = 0; i < 6; i++) {
static char const * const names[] = {
"sip02.", "sip02.", /* Selected because priority */
"sip00.", "sip00.", /* Because of sip01 has weight=0 */
"sip01.", "sip01."
};
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_UDP);
fail_unless(ai->ai_family == AF_INET);
fail_unless(ai_port(ai) == 5060);
fail_if(memcmp(ai->ai_canonname, names[i], strlen(names[i])) != 0);
ai = ai->ai_next;
}
for (i = 0; i < 6; i++) {
static char const * const names[] = {
"sip", "sip",
"sip", "sip",
"sip00.", "sip00."
};
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TCP);
fail_unless(ai->ai_family == AF_INET);
fail_unless(ai_port(ai) == 5060);
fail_if(memcmp(ai->ai_canonname, names[i], strlen(names[i])) != 0);
ai = ai->ai_next;
}
for (i = 0; i < 3; i++) {
assert(ai != NULL);
fail_if(ai->ai_protocol != TPPROTO_TLS);
fail_unless(ai->ai_family == AF_INET);
fail_unless(ai_port(ai) == 5061);
ai = ai->ai_next;
}
sres_sip_unref(srs);
}
END_TEST
TCase *api_tcase(void)
{
TCase *tc = tcase_create("1 - Test simple resolving");
tcase_add_checked_fixture(tc, resolver_setup, resolver_teardown);
tcase_add_test(tc, invalid);
tcase_add_test(tc, not_found);
tcase_add_test(tc, found_a);
tcase_add_test(tc, found_cname);
tcase_add_test(tc, found_ip);
tcase_add_test(tc, found_maddr_a);
tcase_add_test(tc, found_maddr_ip);
tcase_add_test(tc, found_a_aaaa);
tcase_add_test(tc, found_naptr);
tcase_add_test(tc, found_naptr2);
tcase_add_test(tc, found_naptr3);
tcase_add_test(tc, found_naptr_with_a);
tcase_add_test(tc, ignore_naptr);
tcase_add_test(tc, found_srv);
tcase_add_test(tc, found_multi_srv);
return tc;
}
/* ---------------------------------------------------------------------- */
static void usage(int exitcode)
{
fprintf(exitcode ? stderr : stdout,
"usage: check_sres_sip [--xml=logfile] case,...\n");
exit(exitcode);
}
int main(int argc, char *argv[])
{
int i, failed = 0;
Suite *suite = suite_create("Unit tests for SIP URI resolver");
SRunner *runner;
char const *xml = NULL;
s2_select_tests(getenv("CHECK_CASES"));
for (i = 1; argv[i]; i++) {
if (su_strnmatch(argv[i], "--xml=", strlen("--xml="))) {
xml = argv[i] + strlen("--xml=");
}
else if (su_strmatch(argv[i], "--xml")) {
if (!(xml = argv[++i]))
usage(2);
}
else if (su_strmatch(argv[i], "-?") ||
su_strmatch(argv[i], "-h") ||
su_strmatch(argv[i], "--help"))
usage(0);
else
s2_select_tests(argv[i]);
}
suite_add_tcase(suite, api_tcase());
runner = srunner_create(suite);
if (xml)
srunner_set_xml(runner, xml);
srunner_run_all(runner, CK_ENV);
failed = srunner_ntests_failed(runner);
srunner_free(runner);
exit(failed ? EXIT_FAILURE : EXIT_SUCCESS);
}

121
libs/sofia-sip/libsofia-sip-ua/sresolv/sofia-sip/sres_sip.h Normal file
View File

@ -0,0 +1,121 @@
/*
* This file is part of the Sofia-SIP package
*
* Copyright (C) 2009 Nokia Corporation.
*
* Contact: Pekka Pessi <pekka.pessi@nokia.com>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public License
* as published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA
*
*/
#ifndef SOFIA_SIP_SRES_SIP_H
/** Defined when <sofia-sip/sres_sip.h> has been included. */
#define SOFIA_SIP_SRES_SIP_H
/**@file sofia-sip/sres_sip.h
* @brief Asynchronous resolver for SIP
*
* @author Pekka Pessi <Pekka.Pessi@nokia.com>
*/
#ifndef SU_TYPES_H
#include <sofia-sip/su_types.h>
#endif
#ifndef SU_ADDRINFO_H
#include <sofia-sip/su_addrinfo.h>
#endif
#ifndef URL_H
#include <sofia-sip/url.h>
#endif
#ifndef SOFIA_RESOLV_SRES_H
#include <sofia-resolv/sres.h>
#endif
SOFIA_BEGIN_DECLS
typedef struct sres_sip_s sres_sip_t;
#ifndef SRES_SIP_MAGIC_T
/** Default type of application context for NTA resolver.
*
* Application may define this to appropriate type before including
* <sofia-sip/sres_sip.h>. */
#define SRES_SIP_MAGIC_T struct sres_sip_magic_s
#endif
/** Application context for NTA resolver. */
typedef SRES_SIP_MAGIC_T sres_sip_magic_t;
typedef void sres_sip_notify_f(sres_sip_magic_t *context,
sres_sip_t *resolver,
int error);
SOFIAPUBFUN sres_sip_t *sres_sip_new(
sres_resolver_t *sres,
url_string_t const *url,
su_addrinfo_t const *hints,
int naptr, int srv,
sres_sip_notify_f *callback,
sres_sip_magic_t *magic);
SOFIAPUBFUN sres_sip_t *sres_sip_ref(sres_sip_t *);
SOFIAPUBFUN void sres_sip_unref(sres_sip_t *);
SOFIAPUBFUN su_addrinfo_t const *sres_sip_results(sres_sip_t *);
SOFIAPUBFUN su_addrinfo_t const *sres_sip_next(sres_sip_t *);
SOFIAPUBFUN int sres_sip_next_step(sres_sip_t *nr);
SOFIAPUBFUN int sres_sip_error(sres_sip_t *nr);
/* Errors */
enum {
SRES_SIP_ERR_FAULT = -1, /* Invalid pointers */
SRES_SIP_ERR_BAD_URI = -2, /* Invalid URI */
SRES_SIP_ERR_BAD_HINTS = -3, /* Invalid hints */
SRES_SIP_ERR_NO_NAME = -4, /* No domain found */
SRES_SIP_ERR_NO_DATA = -5, /* No matching records */
SRES_SIP_ERR_NO_TPORT = -6, /* Unknown transport */
SRES_SIP_ERR_FAIL = -7, /* Permanent resolving error */
SRES_SIP_ERR_AGAIN = -8, /* Temporary resolving error */
SRES_SIP_ERR_INTERNAL = -9, /* Internal error */
_SRES_SIP_ERR_LAST
};
/* Well-known transport numbers */
enum {
TPPROTO_TCP = 6,
TPPROTO_UDP = 17,
TPPROTO_SCTP = 132,
TPPROTO_SECURE = 256,
TPPROTO_TLS = TPPROTO_SECURE | TPPROTO_TCP,
TPPROTO_NONE = 0
};
#define TPPROTO_TCP TPPROTO_TCP
#define TPPROTO_UDP TPPROTO_UDP
#define TPPROTO_SCTP TPPROTO_SCTP
#define TPPROTO_TLS TPPROTO_TLS
#define TPPROTO_NONE TPPROTO_NONE
SOFIA_END_DECLS
#endif /* SOFIA_SIP_SRES_SIP_H */

1685
libs/sofia-sip/libsofia-sip-ua/sresolv/sres_sip.c Normal file
View File

File diff suppressed because it is too large Load Diff