[Freeswitch-trunk] [commit] r12422 - in freeswitch/trunk/libs/sofia-sip: . libsofia-sip-ua/nua
FreeSWITCH SVN
mikej at freeswitch.org
Wed Mar 4 12:41:38 PST 2009
Author: mikej
Date: Wed Mar 4 14:41:38 2009
New Revision: 12422
Log:
Wed Mar 4 12:37:47 CST 2009 Pekka Pessi <first.last at nokia.com>
* nua: moved contents of test_s2.[hc] to check_nua.[hc]
Ignore-this: f53929b29092e2d62e661fc40397492e
Removed:
freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_s2.c
freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_s2.h
Modified:
freeswitch/trunk/libs/sofia-sip/.update
freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/Makefile.am
freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_etsi.c
freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_nua.c
freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_nua.h
freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_register.c
freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_session.c
freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_simple.c
Modified: freeswitch/trunk/libs/sofia-sip/.update
==============================================================================
--- freeswitch/trunk/libs/sofia-sip/.update (original)
+++ freeswitch/trunk/libs/sofia-sip/.update Wed Mar 4 14:41:38 2009
@@ -1 +1 @@
-Wed Mar 4 14:39:41 CST 2009
+Wed Mar 4 14:40:17 CST 2009
Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/Makefile.am
==============================================================================
--- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/Makefile.am (original)
+++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/Makefile.am Wed Mar 4 14:41:38 2009
@@ -49,8 +49,7 @@
check_nua_SOURCES = check_nua.c check_nua.h \
check_session.c check_register.c \
- check_etsi.c check_simple.c \
- test_s2.h test_s2.c
+ check_etsi.c check_simple.c
check_nua_LDADD = $(nua_libs) ${top_builddir}/s2check/libs2.a \
@CHECK_LIBS@
Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_etsi.c
==============================================================================
--- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_etsi.c (original)
+++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_etsi.c Wed Mar 4 14:41:38 2009
@@ -34,9 +34,9 @@
#include "config.h"
-#include "check_nua.h"
+#undef NDEBUG
-#include "test_s2.h"
+#include "check_nua.h"
#include <sofia-sip/sip_status.h>
#include <sofia-sip/sip_header.h>
Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_nua.c
==============================================================================
--- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_nua.c (original)
+++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_nua.c Wed Mar 4 14:41:38 2009
@@ -22,7 +22,7 @@
*
*/
-/**@CFILE check2_sofia.c
+/**@CFILE check_nua.c
*
* @brief Check-driven tester for Sofia SIP User Agent library
*
@@ -33,16 +33,26 @@
#include "config.h"
-#include "test_s2.h"
+#undef NDEBUG
+
#include "check_nua.h"
+#include "s2dns.h"
+
+#include <sofia-sip/sip_header.h>
+#include <sofia-sip/sip_status.h>
+#include <sofia-sip/msg_addr.h>
+#include <sofia-sip/su_log.h>
+#include <sofia-sip/su_tagarg.h>
+#include <sofia-sip/su_alloc.h>
+#include <sofia-sip/su_string.h>
+#include <sofia-sip/sresolv.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
-
-#if HAVE_FNMATCH_H
-#include <fnmatch.h>
-#endif
+#include <assert.h>
+#include <limits.h>
+#include <time.h>
static void usage(int exitcode)
{
@@ -111,3 +121,384 @@
exit(failed ? EXIT_FAILURE : EXIT_SUCCESS);
}
+
+/* ---------------------------------------------------------------------- */
+
+/* -- Globals -------------------------------------------------------------- */
+
+struct s2nua *s2;
+
+int s2_nua_thread = 0;
+
+unsigned s2_default_registration_duration = 3600;
+
+char const s2_auth_digest_str[] =
+ "Digest realm=\"s2test\", "
+ "nonce=\"dcd98b7102dd2f0e8b11d0f600bfb0c093\", "
+ "qop=\"auth\", "
+ "algorithm=\"MD5\"";
+
+char const s2_auth_credentials[] = "Digest:\"s2test\":abc:abc";
+
+char const s2_auth2_digest_str[] =
+ "Digest realm=\"s2test2\", "
+ "nonce=\"fb0c093dcd98b7102dd2f0e8b11d0f600b\", "
+ "qop=\"auth\", "
+ "algorithm=\"MD5\"";
+
+char const s2_auth2_credentials[] = "Digest:\"s2test2\":abc:abc";
+
+char const s2_auth3_digest_str[] =
+ "Digest realm=\"s2test3\", "
+ "nonce=\"e8b11d0f600bfb0c093dcd98b7102dd2f0\", "
+ "qop=\"auth-int\", "
+ "algorithm=\"MD5-sess\"";
+
+char const s2_auth3_credentials[] = "Digest:\"s2test3\":abc:abc";
+
+/* -- NUA events -------------------------------------------------------- */
+
+struct event *s2_remove_event(struct event *e)
+{
+ if ((*e->prev = e->next))
+ e->next->prev = e->prev;
+
+ e->prev = NULL, e->next = NULL;
+
+ return e;
+}
+
+void s2_free_event(struct event *e)
+{
+ if (e) {
+ if (e->prev) {
+ if ((*e->prev = e->next))
+ e->next->prev = e->prev;
+ }
+ nua_destroy_event(e->event);
+ nua_handle_unref(e->nh);
+ free(e);
+ }
+}
+
+void s2_flush_events(void)
+{
+ while (s2->events) {
+ s2_free_event(s2->events);
+ }
+}
+
+struct event *s2_next_event(void)
+{
+ for (;;) {
+ if (s2->events)
+ return s2_remove_event(s2->events);
+
+ su_root_step(s2base->root, 100);
+ }
+}
+
+struct event *s2_wait_for_event(nua_event_t event, int status)
+{
+ struct event *e;
+
+ for (;;) {
+ for (e = s2->events; e; e = e->next) {
+ if (event != nua_i_none && event != e->data->e_event)
+ continue;
+ if (status && e->data->e_status != status)
+ continue;
+ return s2_remove_event(e);
+ }
+
+ su_root_step(s2base->root, 100);
+ }
+}
+
+int s2_check_event(nua_event_t event, int status)
+{
+ struct event *e = s2_wait_for_event(event, status);
+ s2_free_event(e);
+ return e != NULL;
+}
+
+int s2_check_callstate(enum nua_callstate state)
+{
+ int retval = 0;
+ tagi_t const *tagi;
+ struct event *e;
+
+ e = s2_wait_for_event(nua_i_state, 0);
+ if (e) {
+ tagi = tl_find(e->data->e_tags, nutag_callstate);
+ if (tagi) {
+ retval = (tag_value_t)state == tagi->t_value;
+ }
+ }
+ s2_free_event(e);
+ return retval;
+}
+
+int s2_check_substate(struct event *e, enum nua_substate state)
+{
+ int retval = 0;
+ tagi_t const *tagi;
+
+ tagi = tl_find(e->data->e_tags, nutag_substate);
+ if (tagi) {
+ retval = (tag_value_t)state == tagi->t_value;
+ }
+
+ return retval;
+}
+
+static void
+s2_nua_callback(nua_event_t event,
+ int status, char const *phrase,
+ nua_t *nua, nua_magic_t *_t,
+ nua_handle_t *nh, nua_hmagic_t *hmagic,
+ sip_t const *sip,
+ tagi_t tags[])
+{
+ struct event *e, **prev;
+
+ if (event == nua_i_active || event == nua_i_terminated)
+ return;
+
+ e = calloc(1, sizeof *e);
+ nua_save_event(nua, e->event);
+ e->nh = nua_handle_ref(nh);
+ e->data = nua_event_data(e->event);
+
+ for (prev = &s2->events; *prev; prev = &(*prev)->next)
+ ;
+
+ *prev = e, e->prev = prev;
+}
+
+
+/* ====================================================================== */
+
+SOFIAPUBVAR su_log_t nua_log[];
+SOFIAPUBVAR su_log_t soa_log[];
+SOFIAPUBVAR su_log_t nea_log[];
+SOFIAPUBVAR su_log_t nta_log[];
+SOFIAPUBVAR su_log_t tport_log[];
+SOFIAPUBVAR su_log_t su_log_default[];
+
+void
+s2_setup_logs(int level)
+{
+ su_log_soft_set_level(nua_log, level);
+ su_log_soft_set_level(soa_log, level);
+ su_log_soft_set_level(su_log_default, level);
+ su_log_soft_set_level(nea_log, level);
+ su_log_soft_set_level(nta_log, level);
+ su_log_soft_set_level(tport_log, level);
+}
+
+nua_t *s2_nua_setup(char const *label,
+ tag_type_t tag, tag_value_t value, ...)
+{
+ ta_list ta;
+
+ s2_setup(label);
+
+ s2 = su_home_new(sizeof *s2);
+
+ s2_dns_setup(s2base->root);
+
+ s2_setup_logs(0);
+ s2_sip_setup("example.org", NULL, TAG_END());
+ assert(s2sip->contact);
+
+ s2_dns_domain("example.org", 1,
+ "s2", 1, s2sip->udp.contact->m_url,
+ "s2", 1, s2sip->tcp.contact->m_url,
+ NULL);
+
+ /* enable/disable multithreading */
+ su_root_threading(s2base->root, s2_nua_thread);
+
+ ta_start(ta, tag, value);
+ s2->nua =
+ nua_create(s2base->root,
+ s2_nua_callback,
+ s2,
+ SIPTAG_FROM_STR("Alice <sip:alice at example.org>"),
+ /* NUTAG_PROXY((url_string_t *)s2sip->contact->m_url), */
+ /* Use internal DNS server */
+ NUTAG_PROXY("sip:example.org"),
+ /* Force sresolv to use localhost and s2dns as DNS server */
+#if HAVE_WIN32
+ SRESTAG_RESOLV_CONF("NUL"),
+#else
+ SRESTAG_RESOLV_CONF("/dev/null"),
+#endif
+ ta_tags(ta));
+ ta_end(ta);
+
+ return s2->nua;
+}
+
+void
+s2_nua_fast_forward(unsigned long seconds,
+ su_root_t *steproot)
+{
+ s2_fast_forward(seconds, NULL);
+
+ if (s2_nua_thread)
+ /* Wake up nua thread */
+ nua_handle_by_call_id(s2->nua, NULL);
+
+ if (steproot)
+ su_root_step(steproot, 0);
+}
+
+void s2_nua_teardown(void)
+{
+ if (s2) {
+ struct s2nua *zap = s2;
+ nua_destroy(s2->nua), s2->nua = NULL;
+ s2 = NULL;
+ su_home_unref(zap->home);
+ }
+
+ s2_dns_teardown();
+ s2_sip_teardown();
+ s2_teardown();
+
+}
+
+/* ====================================================================== */
+
+/** Register NUA user.
+ *
+ * <pre>
+ * A B
+ * |-----REGISTER---->|
+ * |<-----200 OK------|
+ * | |
+ * </pre>
+ */
+void s2_register_setup(void)
+{
+ nua_handle_t *nh;
+ struct message *m;
+
+ assert(s2 && s2->nua);
+ assert(!s2->registration->nh);
+
+ nh = nua_handle(s2->nua, NULL, TAG_END());
+
+ nua_register(nh, TAG_END());
+
+ m = s2_sip_wait_for_request(SIP_METHOD_REGISTER);
+ assert(m);
+
+ s2_save_register(m);
+
+ s2_sip_respond_to(m, NULL,
+ SIP_200_OK,
+ SIPTAG_CONTACT(s2->registration->contact),
+ TAG_END());
+ s2_sip_free_message(m);
+
+ assert(s2->registration->contact != NULL);
+ s2_check_event(nua_r_register, 200);
+
+ s2->registration->nh = nh;
+}
+
+/** Un-register NUA user.
+ *
+ * <pre>
+ * A B
+ * |-----REGISTER---->|
+ * |<-----200 OK------|
+ * | |
+ * </pre>
+ */
+void s2_register_teardown(void)
+{
+ if (s2 && s2->registration->nh) {
+ nua_handle_t *nh = s2->registration->nh;
+ struct message *m;
+
+ nua_unregister(nh, TAG_END());
+
+ m = s2_sip_wait_for_request(SIP_METHOD_REGISTER); assert(m);
+ s2_save_register(m);
+ s2_sip_respond_to(m, NULL,
+ SIP_200_OK,
+ SIPTAG_CONTACT(s2->registration->contact),
+ TAG_END());
+ assert(s2->registration->contact == NULL);
+
+ s2_sip_free_message(m);
+
+ s2_check_event(nua_r_unregister, 200);
+
+ nua_handle_destroy(nh);
+ s2->registration->nh = NULL;
+ }
+}
+
+int
+s2_save_register(struct message *rm)
+{
+ sip_contact_t *contact, *m, **m_prev;
+ sip_expires_t const *ex;
+ sip_date_t const *date;
+ sip_time_t now = rm->when.tv_sec, expires;
+
+ msg_header_free_all(s2->home, (msg_header_t *)s2->registration->aor);
+ msg_header_free_all(s2->home, (msg_header_t *)s2->registration->contact);
+ tport_unref(s2->registration->tport);
+
+ s2->registration->aor = NULL;
+ s2->registration->contact = NULL;
+ s2->registration->tport = NULL;
+
+ if (rm == NULL)
+ return 0;
+
+ assert(rm && rm->sip && rm->sip->sip_request);
+ assert(rm->sip->sip_request->rq_method == sip_method_register);
+
+ ex = rm->sip->sip_expires;
+ date = rm->sip->sip_date;
+
+ contact = sip_contact_dup(s2->home, rm->sip->sip_contact);
+
+ for (m_prev = &contact; *m_prev;) {
+ m = *m_prev;
+
+ expires = sip_contact_expires(m, ex, date,
+ s2_default_registration_duration,
+ now);
+ if (expires) {
+ char *p = su_sprintf(s2->home, "expires=%lu", (unsigned long)expires);
+ msg_header_add_param(s2->home, m->m_common, p);
+ m_prev = &m->m_next;
+ }
+ else {
+ *m_prev = m->m_next;
+ m->m_next = NULL;
+ msg_header_free(s2->home, (msg_header_t *)m);
+ }
+ }
+
+ if (contact == NULL)
+ return 0;
+
+ s2->registration->aor = sip_to_dup(s2->home, rm->sip->sip_to);
+ s2->registration->contact = contact;
+ s2->registration->tport = tport_ref(rm->tport);
+
+ s2sip->sut.aor = s2->registration->aor;
+ s2sip->sut.contact = s2->registration->contact;
+ s2sip->sut.tport = s2->registration->tport;
+
+ return 0;
+}
Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_nua.h
==============================================================================
--- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_nua.h (original)
+++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_nua.h Wed Mar 4 14:41:38 2009
@@ -1,5 +1,104 @@
+/*
+ * This file is part of the Sofia-SIP package
+ *
+ * Copyright (C) 2008 Nokia Corporation.
+ *
+ * Contact: Pekka Pessi <pekka.pessi at 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 CHECK_NUA_H
+#include <sofia-sip/su_wait.h>
+#include <sofia-sip/sip.h>
+#include <sofia-sip/tport.h>
+#include <sofia-sip/nua.h>
+#include <sofia-sip/su_string.h>
+
+#include "s2base.h"
+#include "s2util.h"
+#include "s2sip.h"
+
+struct s2nua
+{
+ su_home_t home[1];
+
+ nua_t *nua;
+
+ int shutdown;
+
+ struct event {
+ struct event *next, **prev;
+ nua_saved_event_t event[1];
+ nua_handle_t *nh;
+ nua_event_data_t const *data;
+ su_time_t when;
+ } *events;
+
+ struct {
+ nua_handle_t *nh;
+ sip_to_t *aor;
+ sip_contact_t *contact;
+ tport_t *tport;
+ } registration[1];
+};
+
+extern unsigned s2_default_registration_duration;
+extern char const s2_auth_digest_str[];
+extern char const s2_auth_credentials[];
+
+extern char const s2_auth2_digest_str[];
+extern char const s2_auth2_credentials[];
+
+extern char const s2_auth3_digest_str[];
+extern char const s2_auth3_credentials[];
+
+extern int s2_nua_thread;
+
+extern struct s2nua *s2;
+
+void s2_setup_logs(int level);
+
+struct event *s2_remove_event(struct event *);
+void s2_free_event(struct event *);
+void s2_flush_events(void);
+
+struct event *s2_next_event(void);
+struct event *s2_wait_for_event(nua_event_t event, int status);
+int s2_check_event(nua_event_t event, int status);
+int s2_check_callstate(enum nua_callstate state);
+int s2_check_substate(struct event *e, enum nua_substate state);
+
+#define SIP_METHOD_UNKNOWN sip_method_unknown, NULL
+
+void s2_flush_all(void);
+
+nua_t *s2_nua_setup(char const *label, tag_type_t tag, tag_value_t value, ...);
+
+void s2_nua_teardown(void);
+
+void s2_nua_fast_forward(unsigned long seconds,
+ su_root_t *steproot);
+
+int s2_save_register(struct message *m);
+
+void s2_register_setup(void);
+void s2_register_teardown(void);
+
#include <s2check.h>
void check_session_cases(Suite *suite, int threading);
Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_register.c
==============================================================================
--- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_register.c (original)
+++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_register.c Wed Mar 4 14:41:38 2009
@@ -33,9 +33,9 @@
#include "config.h"
-#include "check_nua.h"
+#undef NDEBUG
-#include "test_s2.h"
+#include "check_nua.h"
#include <sofia-sip/sip_status.h>
#include <sofia-sip/sip_header.h>
Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_session.c
==============================================================================
--- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_session.c (original)
+++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_session.c Wed Mar 4 14:41:38 2009
@@ -33,9 +33,9 @@
#include "config.h"
-#include "check_nua.h"
+#undef NDEBUG
-#include "test_s2.h"
+#include "check_nua.h"
#include <sofia-sip/sip_status.h>
#include <sofia-sip/sip_header.h>
@@ -1131,7 +1131,11 @@
s2_sip_respond_to(cancel, dialog, SIP_200_OK, TAG_END());
s2_sip_free_message(cancel);
- s2_register_teardown();
+ /* emulate network gone bad below
+ zap registration handle here
+ so that s2_register_teardown() does not hang
+ */
+ s2->registration->nh = NULL;
nua_set_params(s2->nua, NUTAG_SHUTDOWN_EVENTS(1), TAG_END());
fail_unless(s2_check_event(nua_r_set_params, 200));
Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_simple.c
==============================================================================
--- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_simple.c (original)
+++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_simple.c Wed Mar 4 14:41:38 2009
@@ -33,9 +33,9 @@
#include "config.h"
-#include "check_nua.h"
+#undef NDEBUG
-#include "test_s2.h"
+#include "check_nua.h"
#include <sofia-sip/sip_status.h>
#include <sofia-sip/sip_header.h>
More information about the Freeswitch-trunk
mailing list