February 2009 - Freeswitch-trunk - FreeSWITCH Mailing Lists

[commit] r11851 - in freeswitch/trunk/libs/sofia-sip: . libsofia-sip-ua/su
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:16:05 2009 New Revision: 11851 Log: Wed Jan 28 12:02:55 CST 2009 Pekka Pessi <first.last(a)nokia.com> * su_timer.c: removed redundant checks Modified: freeswitch/trunk/libs/sofia-sip/.update freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c Modified: freeswitch/trunk/libs/sofia-sip/.update ============================================================================== --- freeswitch/trunk/libs/sofia-sip/.update (original) +++ freeswitch/trunk/libs/sofia-sip/.update Wed Feb 11 11:16:05 2009 @@ -1 +1 @@ -Wed Feb 11 11:15:31 CST 2009 +Wed Feb 11 11:15:57 CST 2009 Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c Wed Feb 11 11:16:05 2009 @@ -156,7 +156,6 @@ */ struct su_timer_s { - /** Pointers within red-black tree */ su_task_r sut_task; /**< Task reference */ size_t sut_heap_index; /**< Timer is set (inserted in heap) */ su_time_t sut_when; /**< When timer should be waken up next time */ @@ -219,8 +218,6 @@ { int retval; - assert(timers); - if (timers == NULL) return -1; @@ -343,9 +340,6 @@ { su_timer_queue_t *timers = su_timer_tree(t, 0, "su_timer_set_interval"); - if (t == NULL) - return -1; - return su_timer_set0(timers, t, wakeup, arg, su_now(), interval); } @@ -367,9 +361,6 @@ { su_timer_queue_t *timers = su_timer_tree(t, 1, "su_timer_set"); - if (timers == NULL) - return -1; - return su_timer_set0(timers, t, wakeup, arg, su_now(), t->sut_duration); } @@ -391,9 +382,6 @@ { su_timer_queue_t *timers = su_timer_tree(t, 0, "su_timer_set_at"); - if (timers == NULL) - return -1; - return su_timer_set0(timers, t, wakeup, arg, when, 0); }

1 0

[commit] r11850 - in freeswitch/trunk/libs/sofia-sip: . libsofia-sip-ua/su
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:15:37 2009 New Revision: 11850 Log: Wed Jan 28 12:01:13 CST 2009 Pekka Pessi <first.last(a)nokia.com> * su_timer.c: timers_remove() now set sut_heap_index to 0 Modified: freeswitch/trunk/libs/sofia-sip/.update freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c Modified: freeswitch/trunk/libs/sofia-sip/.update ============================================================================== --- freeswitch/trunk/libs/sofia-sip/.update (original) +++ freeswitch/trunk/libs/sofia-sip/.update Wed Feb 11 11:15:37 2009 @@ -1 +1 @@ -Wed Feb 11 11:14:50 CST 2009 +Wed Feb 11 11:15:31 CST 2009 Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c Wed Feb 11 11:15:37 2009 @@ -225,7 +225,7 @@ return -1; if (SU_TIMER_IS_SET(t)) - timers_remove(timers[0], t->sut_heap_index)->sut_heap_index = 0; + timers_remove(timers[0], t->sut_heap_index); t->sut_wakeup = wakeup; t->sut_arg = arg; @@ -481,7 +481,7 @@ return -1; if (SU_TIMER_IS_SET(t)) - timers_remove(timers[0], t->sut_heap_index)->sut_heap_index = 0; + timers_remove(timers[0], t->sut_heap_index); t->sut_wakeup = NULL; t->sut_arg = NULL; @@ -526,7 +526,7 @@ break; } - timers_remove(timers[0], 1)->sut_heap_index = 0; + timers_remove(timers[0], 1); f = t->sut_wakeup; t->sut_wakeup = NULL; assert(f); @@ -609,7 +609,7 @@ if (su_task_cmp(task, t->sut_task)) continue; - timers_remove(timers[0], i)->sut_heap_index = 0; + timers_remove(timers[0], i); su_free(NULL, t); n++;

1 0

[commit] r11849 - in freeswitch/trunk/libs/sofia-sip: . libsofia-sip-ua/su
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:14:57 2009 New Revision: 11849 Log: Wed Jan 28 12:00:26 CST 2009 Pekka Pessi <first.last(a)nokia.com> * su_timer.c: no more type-punning Modified: freeswitch/trunk/libs/sofia-sip/.update freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c Modified: freeswitch/trunk/libs/sofia-sip/.update ============================================================================== --- freeswitch/trunk/libs/sofia-sip/.update (original) +++ freeswitch/trunk/libs/sofia-sip/.update Wed Feb 11 11:14:57 2009 @@ -1 +1 @@ -Wed Feb 11 11:14:27 CST 2009 +Wed Feb 11 11:14:50 CST 2009 Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c Wed Feb 11 11:14:57 2009 @@ -33,12 +33,15 @@ #include "config.h" #include <sys/types.h> -#include <sofia-sip/heap.h> +#include "sofia-sip/heap.h" typedef union { void *private; /* Use for debugging */ - struct timers_priv { size_t _size, _used; struct su_timer_s * _heap[2]; } *actual; + struct timers_priv { + size_t _size, _used; + struct su_timer_s * _heap[2]; + } *actual; } su_timer_heap_t; #define SU_TIMER_QUEUE_T su_timer_heap_t

1 0

[commit] r11848 - in freeswitch/trunk/libs/sofia-sip: . libsofia-sip-ua/su
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:14:33 2009 New Revision: 11848 Log: Wed Jan 28 11:52:34 CST 2009 Pekka Pessi <first.last(a)nokia.com> * su_timer.c: using heap (instead of red-black tree) for keeping timers sorted Re-recorded 20070704230449-65a35-f0434c75b0f58a069806e81942c0d5e0821dc9d3 Modified: freeswitch/trunk/libs/sofia-sip/.update freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c Modified: freeswitch/trunk/libs/sofia-sip/.update ============================================================================== --- freeswitch/trunk/libs/sofia-sip/.update (original) +++ freeswitch/trunk/libs/sofia-sip/.update Wed Feb 11 11:14:33 2009 @@ -1 +1 @@ -Wed Feb 11 11:13:59 CST 2009 +Wed Feb 11 11:14:27 CST 2009 Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/su/su_timer.c Wed Feb 11 11:14:33 2009 @@ -32,7 +32,17 @@ #include "config.h" -#include "su_port.h" +#include <sys/types.h> +#include <sofia-sip/heap.h> + +typedef union { + void *private; + /* Use for debugging */ + struct timers_priv { size_t _size, _used; struct su_timer_s * _heap[2]; } *actual; +} su_timer_heap_t; + +#define SU_TIMER_QUEUE_T su_timer_heap_t + #include "sofia-sip/su.h" #include "sofia-sip/su_wait.h" #include "sofia-sip/su_alloc.h" @@ -144,8 +154,8 @@ struct su_timer_s { /** Pointers within red-black tree */ - su_timer_t *sut_left, *sut_right, *sut_parent; su_task_r sut_task; /**< Task reference */ + size_t sut_heap_index; /**< Timer is set (inserted in heap) */ su_time_t sut_when; /**< When timer should be waken up next time */ su_duration_t sut_duration; /**< Timer duration */ su_timer_f sut_wakeup; /**< Function to call when waken up */ @@ -153,9 +163,6 @@ su_time_t sut_run; /**< When this timer was last waken up */ unsigned sut_woken; /**< Timer has waken up this many times */ unsigned short sut_running; /**< Timer is running */ - - unsigned char sut_black; /**< Black node */ - unsigned char sut_set; /**< Timer is set (inserted in tree) */ }; /** Timer running status */ @@ -165,35 +172,35 @@ run_for_ever = 2 /**< Do not compensate */ }; -#define SU_TIMER_IS_SET(sut) ((sut)->sut_set) +#define SU_TIMER_IS_SET(sut) ((sut)->sut_heap_index != 0) + +HEAP_DECLARE(su_inline, su_timer_queue_t, timers_, su_timer_t *); + +su_inline void timers_set(su_timer_t **array, size_t index, su_timer_t *t) +{ + array[t->sut_heap_index = index] = t; +} + +su_inline int timers_less(su_timer_t *a, su_timer_t *b) +{ + return + a->sut_when.tv_sec < b->sut_when.tv_sec || + (a->sut_when.tv_sec == b->sut_when.tv_sec && + a->sut_when.tv_usec < b->sut_when.tv_usec); +} + +su_inline void *timers_alloc(void *argument, void *memory, size_t size) +{ + (void)argument; + + if (size) + return realloc(memory, size); + else + return free(memory), NULL; +} -/* Accessor macros for rbtree */ -#define LEFT(sut) ((sut)->sut_left) -#define RIGHT(sut) ((sut)->sut_right) -#define PARENT(sut) ((sut)->sut_parent) -#define SET_RED(sut) ((sut)->sut_black = 0) -#define SET_BLACK(sut) ((sut)->sut_black = 1) -#define CMP(a, b) SU_TIME_CMP((a)->sut_when, (b)->sut_when) -#define IS_RED(sut) ((sut) && (sut)->sut_black == 0) -#define IS_BLACK(sut) (!(sut) || (sut)->sut_black == 1) -#define COPY_COLOR(dst, src) ((dst)->sut_black = (src)->sut_black) -#define INSERT(sut) ((sut)->sut_set = 1) -#define REMOVE(sut) ((sut)->sut_set = 0, \ - (sut)->sut_left = (sut)->sut_right = (sut)->sut_parent = NULL) - -RBTREE_PROTOS(su_inline, timers, su_timer_t); - -su_inline int timers_append(su_timer_queue_t *, su_timer_t *); -su_inline void timers_remove(su_timer_queue_t *, su_timer_t *); -su_inline su_timer_t *timers_succ(su_timer_t const *); -su_inline su_timer_t *timers_prec(su_timer_t const *); -su_inline su_timer_t *timers_first(su_timer_t const *); -su_inline su_timer_t *timers_last(su_timer_t const *); - -RBTREE_BODIES(su_inline, timers, su_timer_t, - LEFT, RIGHT, PARENT, - IS_RED, SET_RED, IS_BLACK, SET_BLACK, COPY_COLOR, - CMP, INSERT, REMOVE); +HEAP_BODIES(su_inline, su_timer_queue_t, timers_, su_timer_t *, + timers_less, timers_set, timers_alloc, NULL); /**@internal Set the timer. * @@ -207,34 +214,30 @@ su_time_t when, su_duration_t offset) { + int retval; + + assert(timers); + + if (timers == NULL) + return -1; + if (SU_TIMER_IS_SET(t)) - timers_remove(timers, t); + timers_remove(timers[0], t->sut_heap_index)->sut_heap_index = 0; t->sut_wakeup = wakeup; t->sut_arg = arg; t->sut_when = su_time_add(when, offset); - return timers_append(timers, t); -} - -/**@internal Reset the timer. - * - * @retval 0 when successful (always) - */ -su_inline int -su_timer_reset0(su_timer_queue_t *timers, - su_timer_t *t) -{ - if (SU_TIMER_IS_SET(t)) - timers_remove(timers, t); - - t->sut_wakeup = NULL; - t->sut_arg = NULL; - t->sut_running = reset; + if (timers_is_full(timers[0])) { + timers_resize(NULL, timers, 0); + assert(!timers_is_full(timers[0])); + if (timers_is_full(timers[0])) + return -1; + } - memset(&t->sut_run, 0, sizeof(t->sut_run)); + retval = timers_add(timers[0], t); assert(retval == 0); - return 0; + return retval; } /**@internal Validate timer @a t and return pointer to per-port timer tree. @@ -255,12 +258,6 @@ return NULL; } - timers = su_task_timers(t->sut_task); - - if (timers == NULL) - SU_DEBUG_1(("%s(%p): %s\n", caller, (void *)t, - "invalid timer")); - if (use_sut_duration && t->sut_duration == 0) { assert(t->sut_duration > 0); SU_DEBUG_1(("%s(%p): %s\n", caller, (void *)t, @@ -268,6 +265,17 @@ return NULL; } + timers = su_task_timers(t->sut_task); + + if (timers == NULL) { + SU_DEBUG_1(("%s(%p): %s\n", caller, (void *)t, "invalid timer")); + return NULL; + } + else if (timers_is_full(timers[0]) && timers_resize(NULL, timers, 0) == -1) { + SU_DEBUG_1(("%s(%p): %s\n", caller, (void *)t, "timer queue failed")); + return NULL; + } + return timers; } @@ -308,9 +316,7 @@ void su_timer_destroy(su_timer_t *t) { if (t) { - su_timer_queue_t *timers = su_task_timers(t->sut_task); - if (timers) - su_timer_reset0(timers, t); + su_timer_reset(t); su_task_deinit(t->sut_task); su_free(NULL, t); } @@ -471,7 +477,16 @@ if (timers == NULL) return -1; - return su_timer_reset0(timers, t); + if (SU_TIMER_IS_SET(t)) + timers_remove(timers[0], t->sut_heap_index)->sut_heap_index = 0; + + t->sut_wakeup = NULL; + t->sut_arg = NULL; + t->sut_running = reset; + + memset(&t->sut_run, 0, sizeof(t->sut_run)); + + return 0; } /** @internal Check for expired timers in queue. @@ -495,16 +510,20 @@ su_timer_f f; int n = 0; - if (!*timers) - return n; + if (timers_used(timers[0]) == 0) + return 0; + + while ((t = timers_get(timers[0], 1))) { + if (SU_TIME_CMP(t->sut_when, now) > 0) { + su_duration_t at = su_duration(t->sut_when, now); - for (;;) { - t = timers_first(*timers); + if (at < *timeout) + *timeout = at; - if (t == NULL || SU_TIME_CMP(t->sut_when, now) > 0) break; + } - timers_remove(timers, t); + timers_remove(timers[0], 1)->sut_heap_index = 0; f = t->sut_wakeup; t->sut_wakeup = NULL; assert(f); @@ -534,13 +553,6 @@ } } - if (t) { - su_duration_t at = su_duration(t->sut_when, now); - - if (at < *timeout) - *timeout = at; - } - return n; } @@ -548,9 +560,16 @@ /** Calculate duration in milliseconds until next timer expires. */ su_duration_t su_timer_next_expires(su_timer_t const * t, su_time_t now) { + su_timer_queue_t *timers; + su_duration_t tout; - t = timers_first(t); + if (!t) + return SU_DURATION_MAX; + + timers = su_task_timers(t->sut_task); + + t = timers ? timers_get(timers[0], 1) : NULL; if (!t) return SU_DURATION_MAX; @@ -573,23 +592,29 @@ */ int su_timer_reset_all(su_timer_queue_t *timers, su_task_r task) { - su_timer_t *t, *t_next; + size_t i; int n = 0; - if (!timers || !*timers) + if (!timers) return 0; - for (t = timers_first(*timers); t; t = t_next) { - t_next = timers_succ(t); + timers_sort(timers[0]); + + for (i = timers_used(timers[0]); i > 0; i--) { + su_timer_t *t = timers_get(timers[0], i); if (su_task_cmp(task, t->sut_task)) continue; - n++; - timers_remove(timers, t); + timers_remove(timers[0], i)->sut_heap_index = 0; + su_free(NULL, t); + n++; } + if (!timers_used(timers[0])) + free(timers->private), timers->private = NULL; + return n; } @@ -605,3 +630,4 @@ { return t ? su_task_root(t->sut_task) : NULL; } +

1 0

[commit] r11847 - in freeswitch/trunk/libs/sofia-sip: . libsofia-sip-ua/nua
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:14:06 2009 New Revision: 11847 Log: Wed Jan 28 13:34:54 CST 2009 Pekka Pessi <first.last(a)nokia.com> * nua_dialog.c: avoid debug output with nua_dialog_usage_set_refresh_at() Modified: freeswitch/trunk/libs/sofia-sip/.update freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_dialog.c Modified: freeswitch/trunk/libs/sofia-sip/.update ============================================================================== --- freeswitch/trunk/libs/sofia-sip/.update (original) +++ freeswitch/trunk/libs/sofia-sip/.update Wed Feb 11 11:14:06 2009 @@ -1 +1 @@ -Wed Feb 11 11:13:29 CST 2009 +Wed Feb 11 11:13:59 CST 2009 Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_dialog.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_dialog.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/nua_dialog.c Wed Feb 11 11:14:06 2009 @@ -543,7 +543,7 @@ du->du_refquested = now; - nua_dialog_usage_set_refresh_at(du, target); + du->du_refresh = target; } /** Set absolute refresh time */

1 0

[commit] r11846 - freeswitch/trunk/libs/sofia-sip
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:13:36 2009 New Revision: 11846 Log: Mon Jan 26 09:45:30 CST 2009 Pekka Pessi <first.last(a)nokia.com> * RELEASE: msg_multipart_t::mp_len from usize_t to unsigned Modified: freeswitch/trunk/libs/sofia-sip/.update freeswitch/trunk/libs/sofia-sip/RELEASE Modified: freeswitch/trunk/libs/sofia-sip/.update ============================================================================== --- freeswitch/trunk/libs/sofia-sip/.update (original) +++ freeswitch/trunk/libs/sofia-sip/.update Wed Feb 11 11:13:36 2009 @@ -1 +1 @@ -Wed Feb 11 11:12:10 CST 2009 +Wed Feb 11 11:13:29 CST 2009 Modified: freeswitch/trunk/libs/sofia-sip/RELEASE ============================================================================== --- freeswitch/trunk/libs/sofia-sip/RELEASE (original) +++ freeswitch/trunk/libs/sofia-sip/RELEASE Wed Feb 11 11:13:36 2009 @@ -25,6 +25,9 @@ libsofia-sip-ua: - **template**: Added foobar() function (sofia-sip/foobar.h). +- The mp_len type was changed from usize_t to unsigned. + The change is binary-incompatible on 64-bit platforms when compiled with + the configure opetion --disable-size-compat - This release is ABI/API compatible with applications linked against any 1.12.x release. However, applications built against this release won't work against an older library. The ABI has been tested with the nua module

1 0

[commit] r11845 - freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:13:16 2009 New Revision: 11845 Log: Wed Jan 21 10:38:08 CST 2009 Pekka Pessi <first.last(a)nokia.com> * msg_multipart_s: fixed mp_len type The msg_multipart_s should follow msg_pub_s layout. Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/msg_mime.h Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/msg_mime.h ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/msg_mime.h (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/msg/sofia-sip/msg_mime.h Wed Feb 11 11:13:16 2009 @@ -163,7 +163,7 @@ msg_multipart_t *mp_next; /**< Next part in multipart body */ /* Preamble for this part */ char *mp_data; /**< Boundary string. */ - usize_t mp_len; /**< Length of boundary (mp_data).*/ + unsigned mp_len; /**< Length of boundary (mp_data).*/ unsigned mp_flags; msg_error_t *mp_error;

1 0

[commit] r11844 - in freeswitch/trunk/libs/sofia-sip: . libsofia-sip-ua/nua libsofia-sip-ua/sresolv
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:12:33 2009 New Revision: 11844 Log: Fri Jan 23 11:13:41 CST 2009 Pekka Pessi <first.last(a)nokia.com> * sresolv: caching SRES_RECORD_ERR in case a CNAME is returned, too Tracing the CNAMEs when doing cache lookups. Added: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_simple.c Modified: freeswitch/trunk/libs/sofia-sip/.update freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/example.com freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/sres.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/sres_cache.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/test_sresolv.c Modified: freeswitch/trunk/libs/sofia-sip/.update ============================================================================== --- freeswitch/trunk/libs/sofia-sip/.update (original) +++ freeswitch/trunk/libs/sofia-sip/.update Wed Feb 11 11:12:33 2009 @@ -1 +1 @@ -Wed Feb 11 11:08:29 CST 2009 +Wed Feb 11 11:12:10 CST 2009 Added: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_simple.c ============================================================================== --- (empty file) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_simple.c Wed Feb 11 11:12:33 2009 @@ -0,0 +1,522 @@ +/* + * This file is part of the Sofia-SIP package + * + * Copyright (C) 2008 Nokia Corporation. + * + * Contact: Pekka Pessi <pekka.pessi(a)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_events.c + * + * @brief NUA module tests for SIP events + * + * @author Pekka Pessi <Pekka.Pessi(a)nokia.com> + * + * @copyright (C) 2008 Nokia Corporation. + */ + +#include "config.h" + +#include "check_nua.h" + +#include "test_s2.h" + +#include <sofia-sip/sip_status.h> +#include <sofia-sip/sip_header.h> +#include <sofia-sip/soa.h> +#include <sofia-sip/su_tagarg.h> +#include <sofia-sip/su_string.h> +#include <sofia-sip/su_tag_io.h> + +#include <stdlib.h> +#include <string.h> +#include <assert.h> + +/* define XXX as 1 in order to see all failing test cases */ +#ifndef XXX +#define XXX (0) +#endif + +/* ====================================================================== */ + +static nua_t *nua; +static soa_session_t *soa = NULL; +static struct dialog *dialog = NULL; + +#define CRLF "\r\n" + +void s2_dialog_setup(void) +{ + nua = s2_nua_setup("simple", + SIPTAG_ORGANIZATION_STR("Pussy Galore's Flying Circus"), + NUTAG_OUTBOUND("no-options-keepalive, no-validate"), + TAG_END()); + + soa = soa_create(NULL, s2->root, NULL); + + fail_if(!soa); + + soa_set_params(soa, + SOATAG_USER_SDP_STR("m=audio 5008 RTP/AVP 8 0" CRLF + "m=video 5010 RTP/AVP 34" CRLF), + TAG_END()); + + dialog = su_home_new(sizeof *dialog); fail_if(!dialog); + + s2_register_setup(); +} + +void s2_dialog_teardown(void) +{ + s2_teardown_started("simple"); + + s2_register_teardown(); + + nua_shutdown(nua); + + fail_unless(s2_check_event(nua_r_shutdown, 200)); + + s2_nua_teardown(); +} + + +static char const presence_open[] = + "<?xml version='1.0' encoding='UTF-8'?>\n" + "<presence xmlns='urn:ietf:params:xml:ns:cpim-pidf' \n" + " entity='pres:bob@example.org'>\n" + " <tuple id='ksac9udshce'>\n" + " <status><basic>open</basic></status>\n" + " <contact priority='1.0'>sip:bob@example.org</contact>\n" + " </tuple>\n" + "</presence>\n"; + +static char const presence_closed[] = + "<?xml version='1.0' encoding='UTF-8'?>\n" + "<presence xmlns='urn:ietf:params:xml:ns:cpim-pidf' \n" + " entity='pres:bob@example.org'>\n" + " <tuple id='ksac9udshce'>\n" + " <status><basic>closed</basic></status>\n" + " </tuple>\n" + "</presence>\n"; + +static char const *event_type = "presence"; +static char const *event_mime_type = "application/pidf+xml"; +static char const *event_state = presence_open; +static char const *subscription_state = "active;expires=600"; + +static struct event * +respond_to_subscribe(struct message *subscribe, + nua_event_t expect_event, + enum nua_substate expect_substate, + int status, char const *phrase, + tag_type_t tag, tag_value_t value, ...) +{ + struct event *event; + ta_list ta; + + ta_start(ta, tag, value); + s2_respond_to(subscribe, dialog, status, phrase, + ta_tags(ta)); + ta_end(ta); + + event = s2_wait_for_event(expect_event, status); fail_if(!event); + fail_unless(s2_check_substate(event, expect_substate)); + return event; +} + +static struct event * +notify_to_nua(enum nua_substate expect_substate, + tag_type_t tag, tag_value_t value, ...) +{ + struct event *event; + struct message *response; + ta_list ta; + + ta_start(ta, tag, value); + fail_if(s2_request_to(dialog, SIP_METHOD_NOTIFY, NULL, + SIPTAG_CONTENT_TYPE_STR(event_mime_type), + SIPTAG_PAYLOAD_STR(event_state), + ta_tags(ta))); + ta_end(ta); + + response = s2_wait_for_response(200, SIP_METHOD_NOTIFY); + fail_if(!response); + s2_free_message(response); + + event = s2_wait_for_event(nua_i_notify, 200); fail_if(!event); + fail_unless(s2_check_substate(event, expect_substate)); + + return event; +} + +static int send_notify_before_response = 0; + +static struct event * +subscription_by_nua(nua_handle_t *nh, + enum nua_substate current, + tag_type_t tag, tag_value_t value, ...) +{ + struct message *subscribe; + struct event *notify, *event; + ta_list ta; + enum nua_substate substate = nua_substate_active; + char const *substate_str = subscription_state; + char const *expires = "600"; + + subscribe = s2_wait_for_request(SIP_METHOD_SUBSCRIBE); + if (event_type) + fail_if(!subscribe->sip->sip_event || + strcmp(event_type, subscribe->sip->sip_event->o_type)); + + if (subscribe->sip->sip_expires && subscribe->sip->sip_expires->ex_delta == 0) { + substate = nua_substate_terminated; + substate_str = "terminated;reason=timeout"; + expires = "0"; + } + + ta_start(ta, tag, value); + + if (send_notify_before_response) { + s2_save_uas_dialog(dialog, subscribe->sip); + notify = notify_to_nua(substate, + SIPTAG_EVENT(subscribe->sip->sip_event), + SIPTAG_SUBSCRIPTION_STATE_STR(substate_str), + ta_tags(ta)); + event = respond_to_subscribe(subscribe, nua_r_subscribe, substate, + SIP_200_OK, + SIPTAG_EXPIRES_STR(expires), + TAG_END()); + s2_free_event(event); + } + else { + event = respond_to_subscribe(subscribe, nua_r_subscribe, current, + SIP_202_ACCEPTED, + SIPTAG_EXPIRES_STR(expires), + TAG_END()); + s2_free_event(event); + notify = notify_to_nua(substate, + SIPTAG_EVENT(subscribe->sip->sip_event), + SIPTAG_SUBSCRIPTION_STATE_STR(substate_str), + ta_tags(ta)); + } + + s2_free_message(subscribe); + + return notify; +} + +static void +unsubscribe_by_nua(nua_handle_t *nh, tag_type_t tag, tag_value_t value, ...) +{ + struct message *subscribe, *response; + struct event *event; + + nua_unsubscribe(nh, TAG_END()); + subscribe = s2_wait_for_request(SIP_METHOD_SUBSCRIBE); + + s2_respond_to(subscribe, dialog, SIP_200_OK, SIPTAG_EXPIRES_STR("0"), TAG_END()); + + event = s2_wait_for_event(nua_r_unsubscribe, 200); fail_if(!event); + fail_unless(s2_check_substate(event, nua_substate_active)); + s2_free_event(event); + + fail_if(s2_request_to(dialog, SIP_METHOD_NOTIFY, NULL, + SIPTAG_EVENT(subscribe->sip->sip_event), + SIPTAG_SUBSCRIPTION_STATE_STR("terminated;reason=tiemout"), + SIPTAG_CONTENT_TYPE_STR(event_mime_type), + SIPTAG_PAYLOAD_STR(event_state), + TAG_END())); + + event = s2_wait_for_event(nua_i_notify, 200); fail_if(!event); + fail_unless(s2_check_substate(event, nua_substate_terminated)); + s2_free_event(event); + + response = s2_wait_for_response(200, SIP_METHOD_NOTIFY); + fail_if(!response); + s2_free_message(response); s2_free_message(subscribe); +} + +/* ====================================================================== */ +/* 6 - Subscribe/notify */ + +START_TEST(subscribe_6_1_1) +{ + nua_handle_t *nh; + struct event *notify; + s2_case("6.1.1", "Basic subscription", + "NUA sends SUBSCRIBE, waits for NOTIFY, sends un-SUBSCRIBE"); + + nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END()); + nua_subscribe(nh, SIPTAG_EVENT_STR(event_type), TAG_END()); + notify = subscription_by_nua(nh, nua_substate_embryonic, TAG_END()); + s2_free_event(notify); + unsubscribe_by_nua(nh, TAG_END()); + nua_handle_destroy(nh); +} +END_TEST + +START_TEST(subscribe_6_1_2) +{ + nua_handle_t *nh; + struct message *subscribe, *response; + struct event *notify, *event; + + s2_case("6.1.2", "Basic subscription with refresh", + "NUA sends SUBSCRIBE, waits for NOTIFY, " + "sends re-SUBSCRIBE, waits for NOTIFY, " + "sends un-SUBSCRIBE"); + + send_notify_before_response = 1; + + nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END()); + nua_subscribe(nh, SIPTAG_EVENT_STR(event_type), TAG_END()); + notify = subscription_by_nua(nh, nua_substate_embryonic, TAG_END()); + s2_free_event(notify); + + /* Wait for refresh */ + s2_fast_forward(600); + subscribe = s2_wait_for_request(SIP_METHOD_SUBSCRIBE); + s2_respond_to(subscribe, dialog, SIP_200_OK, + SIPTAG_EXPIRES_STR("600"), + TAG_END()); + + event = s2_wait_for_event(nua_r_subscribe, 200); fail_if(!event); + fail_unless(s2_check_substate(event, nua_substate_active)); + s2_free_event(event); + + fail_if(s2_request_to(dialog, SIP_METHOD_NOTIFY, NULL, + SIPTAG_EVENT(subscribe->sip->sip_event), + SIPTAG_SUBSCRIPTION_STATE_STR("active;expires=600"), + SIPTAG_CONTENT_TYPE_STR(event_mime_type), + SIPTAG_PAYLOAD_STR(event_state), + TAG_END())); + event = s2_wait_for_event(nua_i_notify, 200); fail_if(!event); + fail_unless(s2_check_substate(event, nua_substate_active)); + s2_free_event(event); + response = s2_wait_for_response(200, SIP_METHOD_NOTIFY); + fail_if(!response); + s2_free_message(response); + + unsubscribe_by_nua(nh, TAG_END()); + + nua_handle_destroy(nh); +} +END_TEST + +START_TEST(subscribe_6_1_3) +{ + nua_handle_t *nh; + struct message *response; + struct event *notify, *event; + + s2_case("6.1.3", "Subscription terminated by notifier", + "NUA sends SUBSCRIBE, waits for NOTIFY, " + "gets NOTIFY terminating the subscription,"); + + nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END()); + nua_subscribe(nh, SIPTAG_EVENT_STR(event_type), TAG_END()); + notify = subscription_by_nua(nh, nua_substate_embryonic, TAG_END()); + s2_free_event(notify); + + fail_if(s2_request_to(dialog, SIP_METHOD_NOTIFY, NULL, + SIPTAG_EVENT_STR(event_type), + SIPTAG_SUBSCRIPTION_STATE_STR("terminated;reason=noresource"), + TAG_END())); + event = s2_wait_for_event(nua_i_notify, 200); fail_if(!event); + fail_unless(s2_check_substate(event, nua_substate_terminated)); + s2_free_event(event); + response = s2_wait_for_response(200, SIP_METHOD_NOTIFY); + fail_if(!response); + s2_free_message(response); + + nua_handle_destroy(nh); +} +END_TEST + +START_TEST(subscribe_6_1_4) +{ + nua_handle_t *nh; + struct message *response; + struct event *notify, *event; + + s2_case("6.1.4", "Subscription terminated by notifier, re-established", + "NUA sends SUBSCRIBE, waits for NOTIFY, " + "gets NOTIFY terminating the subscription,"); + + nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END()); + nua_subscribe(nh, SIPTAG_EVENT_STR(event_type), TAG_END()); + notify = subscription_by_nua(nh, nua_substate_embryonic, TAG_END()); + s2_free_event(notify); + + fail_if(s2_request_to(dialog, SIP_METHOD_NOTIFY, NULL, + SIPTAG_EVENT_STR(event_type), + SIPTAG_SUBSCRIPTION_STATE_STR("terminated;reason=deactivated"), + TAG_END())); + event = s2_wait_for_event(nua_i_notify, 200); fail_if(!event); + fail_unless(s2_check_substate(event, nua_substate_embryonic)); + s2_free_event(event); + response = s2_wait_for_response(200, SIP_METHOD_NOTIFY); + fail_if(!response); + s2_free_message(response); + + su_home_unref((void *)dialog), dialog = su_home_new(sizeof *dialog); fail_if(!dialog); + + s2_fast_forward(5); + /* nua re-establishes the subscription */ + notify = subscription_by_nua(nh, nua_substate_embryonic, TAG_END()); + s2_free_event(notify); + + /* Unsubscribe with nua_subscribe() Expires: 0 */ + nua_subscribe(nh, SIPTAG_EVENT_STR(event_type), SIPTAG_EXPIRES_STR("0"), TAG_END()); + notify = subscription_by_nua(nh, nua_substate_active, TAG_END()); + s2_free_event(notify); + + nua_handle_destroy(nh); +} +END_TEST + +TCase *subscribe_tcase(void) +{ + TCase *tc = tcase_create("6.1 - Basic SUBSCRIBE_"); + tcase_add_checked_fixture(tc, s2_dialog_setup, s2_dialog_teardown); + { + tcase_add_test(tc, subscribe_6_1_1); + tcase_add_test(tc, subscribe_6_1_2); + tcase_add_test(tc, subscribe_6_1_3); + tcase_add_test(tc, subscribe_6_1_4); + } + return tc; +} + +START_TEST(fetch_6_2_1) +{ + nua_handle_t *nh; + struct event *notify; + + s2_case("6.2.1", "Event fetch - NOTIFY after 202", + "NUA sends SUBSCRIBE with Expires 0, waits for NOTIFY"); + + nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END()); + nua_subscribe(nh, SIPTAG_EVENT_STR(event_type), SIPTAG_EXPIRES_STR("0"), TAG_END()); + notify = subscription_by_nua(nh, nua_substate_embryonic, TAG_END()); + s2_check_substate(notify, nua_substate_terminated); + s2_free_event(notify); + nua_handle_destroy(nh); +} +END_TEST + +START_TEST(fetch_6_2_2) +{ + nua_handle_t *nh; + struct event *notify; + + s2_case("6.2.2", "Event fetch - NOTIFY before 200", + "NUA sends SUBSCRIBE with Expires 0, waits for NOTIFY"); + + send_notify_before_response = 1; + + nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END()); + nua_subscribe(nh, SIPTAG_EVENT_STR(event_type), SIPTAG_EXPIRES_STR("0"), TAG_END()); + notify = subscription_by_nua(nh, nua_substate_embryonic, TAG_END()); + s2_check_substate(notify, nua_substate_terminated); + s2_free_event(notify); + nua_handle_destroy(nh); +} +END_TEST + +START_TEST(fetch_6_2_3) +{ + nua_handle_t *nh; + struct message *subscribe; + struct event *event; + + s2_case("6.2.3", "Event fetch - no NOTIFY", + "NUA sends SUBSCRIBE with Expires 0, waits for NOTIFY, times out"); + + nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END()); + nua_subscribe(nh, SIPTAG_EVENT_STR(event_type), SIPTAG_EXPIRES_STR("0"), TAG_END()); + subscribe = s2_wait_for_request(SIP_METHOD_SUBSCRIBE); + s2_respond_to(subscribe, dialog, SIP_202_ACCEPTED, + SIPTAG_EXPIRES_STR("0"), TAG_END()); + s2_free_message(subscribe); + + event = s2_wait_for_event(nua_r_subscribe, 202); fail_if(!event); + fail_unless(s2_check_substate(event, nua_substate_embryonic)); + s2_free_event(event); + + s2_fast_forward(600); + + event = s2_wait_for_event(nua_i_notify, 408); fail_if(!event); + fail_unless(s2_check_substate(event, nua_substate_terminated)); + s2_free_event(event); + + nua_handle_destroy(nh); +} +END_TEST + + +TCase *fetch_tcase(void) +{ + TCase *tc = tcase_create("6.2 - Event fetch"); + tcase_add_checked_fixture(tc, s2_dialog_setup, s2_dialog_teardown); + { + tcase_add_test(tc, fetch_6_2_1); + tcase_add_test(tc, fetch_6_2_2); + tcase_add_test(tc, fetch_6_2_3); + } + return tc; +} + +/* ====================================================================== */ + +/* Test case template */ + +START_TEST(empty) +{ + s2_case("0.0.0", "Empty test case", + "Detailed explanation for empty test case."); + + tport_set_params(s2->master, TPTAG_LOG(1), TAG_END()); + s2_setup_logs(7); + s2_setup_logs(0); + tport_set_params(s2->master, TPTAG_LOG(0), TAG_END()); +} + +END_TEST + +static TCase *empty_tcase(void) +{ + TCase *tc = tcase_create("0 - Empty"); + tcase_add_checked_fixture(tc, s2_dialog_setup, s2_dialog_teardown); + tcase_add_test(tc, empty); + + return tc; +} + +/* ====================================================================== */ + +void check_simple_cases(Suite *suite) +{ + suite_add_tcase(suite, subscribe_tcase()); + suite_add_tcase(suite, fetch_tcase()); + + if (0) /* Template */ + suite_add_tcase(suite, empty_tcase()); +} + Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/example.com ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/example.com (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/example.com Wed Feb 11 11:12:33 2009 @@ -42,6 +42,11 @@ SRV 4 50 5051 sip02 SRV 5 10 5061 sip01 +cloop CNAME cloop0 +cloop0 CNAME cloop1 +cloop1 CNAME cloop2 +cloop2 CNAME cloop0 + sip CNAME sip00 subnet A6 0 3ff0:0:: Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/sres.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/sres.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/sres.c Wed Feb 11 11:12:33 2009 @@ -495,7 +495,9 @@ static char const *sres_toplevel(char buf[], size_t bsize, char const *domain); -static sres_record_t *sres_create_record(sres_resolver_t *, sres_message_t *m); +static sres_record_t *sres_create_record(sres_resolver_t *, + sres_message_t *m, + int nth); static sres_record_t *sres_init_rr_soa(sres_cache_t *cache, sres_soa_record_t *, @@ -3539,7 +3541,7 @@ total = errorcount + m->m_ancount + m->m_nscount + m->m_arcount; - answers = su_zalloc(chome, (total + 1) * sizeof answers[0]); + answers = su_zalloc(chome, (total + 2) * sizeof answers[0]); if (!answers) return -1; @@ -3548,7 +3550,7 @@ if (i < errorcount) rr = error = sres_create_error_rr(res->res_cache, query, err); else - rr = sres_create_record(res, m); + rr = sres_create_record(res, m, i - errorcount); if (!rr) { SU_DEBUG_5(("sres_create_record: %s\n", m->m_error)); @@ -3565,12 +3567,31 @@ } if (i < total) { + SU_DEBUG_5(("sres_decode_msg: %s\n", "less records than promised")); for (i = 0; i < total; i++) sres_cache_free_record(res->res_cache, answers[i]); su_free(chome, answers); return -1; } + if (m->m_ancount > 0 && errorcount == 0 && query->q_type < sres_qtype_tsig) { + char b0[8], b1[8]; + for (i = 0; i < m->m_ancount; i++) { + if (query->q_type == answers[i]->sr_type) + break; + } + + if (i == m->m_ancount) { + /* The queried request was not found. CNAME? */ + SU_DEBUG_5(("sres_decode_msg: sent query %s, got %s\n", + sres_record_type(query->q_type, b0), + sres_record_type(answers[0]->sr_type, b1))); + rr = sres_create_error_rr(res->res_cache, query, err = SRES_RECORD_ERR); + memmove(answers + 1, answers, (sizeof answers[0]) * total++); + answers[errorcount++] = rr; + } + } + for (i = 0; i < total; i++) { rr = answers[i]; @@ -3591,7 +3612,7 @@ static sres_record_t * -sres_create_record(sres_resolver_t *res, sres_message_t *m) +sres_create_record(sres_resolver_t *res, sres_message_t *m, int nth) { sres_cache_t *cache = res->res_cache; sres_record_t *sr, sr0[1]; @@ -3614,7 +3635,11 @@ name[len] = 0; - SU_DEBUG_9(("RR received %s %s %s %d rdlen=%d\n", name, + SU_DEBUG_9(("%s RR received %s %s %s %d rdlen=%d\n", + nth < m->m_ancount ? "ANSWER" : + nth < m->m_ancount + m->m_nscount ? "AUTHORITY" : + "ADDITIONAL", + name, sres_record_type(sr->sr_type, btype), sres_record_class(sr->sr_class, bclass), sr->sr_ttl, sr->sr_rdlen)); Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/sres_cache.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/sres_cache.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/sres_cache.c Wed Feb 11 11:12:33 2009 @@ -169,15 +169,98 @@ su_home_unref(cache->cache_home); } +struct frame { + struct frame *previous; + char const *domain; +}; + +/** Count or get matching records from cache */ +static int +sres_cache_get0(sres_htable_t *htable, + sres_rr_hash_entry_t **iter, + uint16_t type, + char const *domain, + time_t now, + sres_record_t **cached, + int len, + struct frame *previous) +{ + sres_cname_record_t *cname = NULL; + int dcount = 0, derrorcount = 0, ccount = 0; + + for (; iter && *iter; iter = sres_htable_next(htable, iter)) { + sres_record_t *rr = (*iter)->rr; + + if (rr == NULL) + continue; + if (now > (*iter)->rr_expires) + continue; + if (rr->sr_name == NULL) + continue; + if (!su_casematch(rr->sr_name, domain)) + continue; + + if (rr->sr_type == type || type == sres_qtype_any) { + if (rr->sr_status == SRES_RECORD_ERR && type == sres_qtype_any) + continue; + if (cached) { + if (dcount >= len) + return -1; + cached[dcount] = rr, rr->sr_refcount++; + } + dcount++; + if (rr->sr_status) + derrorcount++; + } + + if (type != sres_type_cname && rr->sr_type == sres_type_cname) { + if (rr->sr_status == 0) + cname = rr->sr_cname; + } + } + + if (cname && dcount == derrorcount) { + /* Nothing found, trace CNAMEs */ + struct frame *f, frame = { previous, domain }; + unsigned hash = sres_hash_key(domain = cname->cn_cname); + + if (cached) { + if (dcount >= len) + return -1; + cached[dcount] = (sres_record_t *)cname; + cname->cn_record->r_refcount++; + } + dcount++; + + /* Check for cname loops */ + for (f = previous; f; f = f->previous) { + if (su_casematch(domain, f->domain)) + break; + } + + if (f == NULL) { + ccount = sres_cache_get0(htable, sres_htable_hash(htable, hash), + type, domain, now, + cached ? cached + dcount : NULL, + cached ? len - dcount : 0, + &frame); + } + if (ccount < 0) + return ccount; + } + + return dcount + ccount; +} + /** Get a list of matching records from cache. */ int sres_cache_get(sres_cache_t *cache, uint16_t type, char const *domain, sres_record_t ***return_cached) { - sres_record_t **result = NULL, *rr = NULL; - sres_rr_hash_entry_t **rr_iter, **rr_iter2; - int result_size, rr_count = 0; + sres_record_t **result = NULL; + sres_rr_hash_entry_t **slot; + int result_size, i, j; unsigned hash; time_t now; char b[8]; @@ -198,28 +281,16 @@ time(&now); /* First pass: just count the number of rr:s for array allocation */ - rr_iter2 = sres_htable_hash(cache->cache_hash, hash); - - /* Find the domain records from the hash table */ - for (rr_iter = rr_iter2; - rr_iter && *rr_iter; - rr_iter = sres_htable_next(cache->cache_hash, rr_iter)) { - rr = (*rr_iter)->rr; - - if (rr != NULL && - now <= (*rr_iter)->rr_expires && - (type == sres_qtype_any || rr->sr_type == type) && - rr->sr_name != NULL && - su_casematch(rr->sr_name, domain)) - rr_count++; - } + slot = sres_htable_hash(cache->cache_hash, hash); - if (rr_count == 0) { + i = sres_cache_get0(cache->cache_hash, slot, type, domain, now, + NULL, 0, NULL); + if (i <= 0) { UNLOCK(cache); return 0; } - result_size = (sizeof *result) * (rr_count + 1); + result_size = (sizeof *result) * (i + 1); result = su_zalloc(cache->cache_home, result_size); if (result == NULL) { UNLOCK(cache); @@ -227,35 +298,30 @@ } /* Second pass: add the rr pointers to the allocated array */ - - for (rr_iter = rr_iter2, rr_count = 0; - rr_iter && *rr_iter; - rr_iter = sres_htable_next(cache->cache_hash, rr_iter)) { - rr = (*rr_iter)->rr; - - if (rr != NULL && - now <= (*rr_iter)->rr_expires && - (type == sres_qtype_any || rr->sr_type == type) && - rr->sr_name != NULL && - su_casematch(rr->sr_name, domain)) { - SU_DEBUG_9(("rr found in cache: %s %02d\n", - rr->sr_name, rr->sr_type)); - - result[rr_count++] = rr; - rr->sr_refcount++; + j = sres_cache_get0(cache->cache_hash, slot, type, domain, now, + result, i, NULL); + if (i != j) { + /* Uh-oh. */ + SU_DEBUG_9(("%s(%p, %s, \"%s\") got %d != %d\n", "sres_cache_get", + (void *)cache, sres_record_type(type, b), domain, i, j)); + for (i = 0; i < result_size; i++) { + if (result[i]) + result[i]->sr_refcount--; } + su_free(cache->cache_home, result); + return 0; } - result[rr_count] = NULL; + result[i] = NULL; UNLOCK(cache); SU_DEBUG_9(("%s(%p, %s, \"%s\") returned %d entries\n", "sres_cache_get", - (void *)cache, sres_record_type(type, b), domain, rr_count)); + (void *)cache, sres_record_type(type, b), domain, i)); *return_cached = result; - return rr_count; + return i; } sres_record_t * Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/test_sresolv.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/test_sresolv.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/sresolv/test_sresolv.c Wed Feb 11 11:12:33 2009 @@ -90,6 +90,10 @@ #include <signal.h> #endif +#include <sofia-sip/su_log.h> + +extern su_log_t sresolv_log[]; + char const name[] = "test_sresolv"; struct sres_context_s @@ -982,24 +986,133 @@ int test_cname(sres_context_t *ctx) { sres_resolver_t *res = ctx->resolver; - sres_record_t **result; - const sres_cname_record_t *rr; + sres_record_t **result, *sr; + const sres_cname_record_t *cn; char const *domain = "sip.example.com"; BEGIN(); + TEST_1(sres_query(res, test_answer, ctx, sres_type_naptr, domain)); + TEST_RUN(ctx); + + TEST_1(result = ctx->result); + TEST_1(sr = result[0]); + TEST_1(sr->sr_record->r_status == SRES_RECORD_ERR); + TEST_1(cn = result[1]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "sip00.example.com."); + + sres_free_answers(res, ctx->result), ctx->result = NULL; + + TEST_1(result = sres_cached_answers(res, sres_type_naptr, domain)); + TEST_1(sr = result[0]); + TEST_1(sr->sr_record->r_status == SRES_RECORD_ERR); + TEST_1(cn = result[1]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "sip00.example.com."); + + sres_free_answers(res, result), ctx->result = NULL; + + TEST_1(result = sres_cached_answers(res, sres_qtype_any, domain)); + TEST_1(cn = result[0]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "sip00.example.com."); + /* We might have A record, or then not */ + + sres_free_answers(res, result), ctx->result = NULL; + + TEST_1(sres_query(res, test_answer, ctx, sres_type_a, domain)); + TEST_RUN(ctx); + + TEST_1(result = ctx->result); + TEST_1(cn = result[0]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "sip00.example.com."); + TEST_1(sr = result[1]); + TEST(sr->sr_record->r_class, sres_class_in); + TEST(sr->sr_record->r_type, sres_type_a); + + sres_free_answers(res, ctx->result), ctx->result = NULL; + + TEST_1(result = sres_cached_answers(res, sres_type_a, domain)); + TEST_1(cn = result[0]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "sip00.example.com."); + TEST_1(sr = result[1]); + TEST(sr->sr_record->r_class, sres_class_in); + TEST(sr->sr_record->r_type, sres_type_a); + + sres_free_answers(res, result); + + domain = "cloop.example.com"; + TEST_1(sres_query(res, test_answer, ctx, sres_type_a, domain)); TEST_RUN(ctx); TEST_1(result = ctx->result); - TEST_1(rr = result[0]->sr_cname); - TEST(rr->cn_record->r_class, sres_class_in); - TEST(rr->cn_record->r_type, sres_type_cname); - TEST(rr->cn_record->r_ttl, 60); - TEST_S(rr->cn_cname, "sip00.example.com."); + TEST_1(sr = result[0]); + TEST_1(sr->sr_record->r_status == SRES_RECORD_ERR); + TEST_1(cn = result[1]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "cloop0.example.com."); + TEST_1(cn = result[2]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "cloop1.example.com."); + TEST_1(cn = result[3]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "cloop2.example.com."); + TEST_1(cn = result[4]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "cloop0.example.com."); + TEST_1(result[5] == NULL); sres_free_answers(res, ctx->result), ctx->result = NULL; + TEST_1(result = sres_cached_answers(res, sres_type_a, domain)); + TEST_1(sr = result[0]); + TEST_1(sr->sr_record->r_status == SRES_RECORD_ERR); + TEST_1(cn = result[1]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "cloop0.example.com."); + TEST_1(cn = result[2]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "cloop1.example.com."); + TEST_1(cn = result[3]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "cloop2.example.com."); + TEST_1(cn = result[4]->sr_cname); + TEST(cn->cn_record->r_class, sres_class_in); + TEST(cn->cn_record->r_type, sres_type_cname); + TEST(cn->cn_record->r_ttl, 60); + TEST_S(cn->cn_cname, "cloop0.example.com."); + TEST_1(result[5] == NULL); + + sres_free_answers(res, result); + END(); } @@ -1892,10 +2005,6 @@ exit(exitcode); } -#include <sofia-sip/su_log.h> - -extern su_log_t sresolv_log[]; - int main(int argc, char **argv) { int i;

1 0

[commit] r11843 - freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:11:38 2009 New Revision: 11843 Log: Wed Jan 21 14:49:03 CST 2009 Pekka Pessi <first.last(a)nokia.com> * check_nua: added test check_simple.c, test cases for SIMPLE Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/Makefile.am freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_nua.c 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 Feb 11 11:11:38 2009 @@ -43,9 +43,11 @@ COVERAGE_INPUT = $(libnua_la_SOURCES) $(include_sofia_HEADERS) +# ---------------------------------------------------------------------- + check_nua_SOURCES = check_nua.c check_nua.h \ check_session.c check_register.c \ - check_etsi.c \ + check_etsi.c check_simple.c \ test_s2.h test_s2.c check_nua_LDADD = $(nua_libs) @CHECK_LIBS@ 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 Feb 11 11:11:38 2009 @@ -112,6 +112,7 @@ check_register_cases(suite); check_session_cases(suite); check_etsi_cases(suite); + check_simple_cases(suite); runner = srunner_create(suite);

1 0

[commit] r11842 - freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua
by FreeSWITCH SVN 11 Feb '09

11 Feb '09

Author: mikej Date: Wed Feb 11 11:11:20 2009 New Revision: 11842 Log: Wed Jan 21 14:32:32 CST 2009 Pekka Pessi <first.last(a)nokia.com> * check_nua: fiddled with some timing issues Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_etsi.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_session.c freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_s2.c 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 Feb 11 11:11:20 2009 @@ -244,6 +244,8 @@ fail_unless(s2_check_callstate(nua_callstate_ready)); fail_unless(s2_check_request(SIP_METHOD_ACK)); + s2_fast_forward(5); + respond_with_sdp(invite, d1, SIP_200_OK, TAG_END()); fail_unless(s2_check_request(SIP_METHOD_ACK)); 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 Feb 11 11:11:20 2009 @@ -2391,7 +2391,7 @@ s2_fast_forward(300); invite_timer_round(nh, "300", NULL); - s2_fast_forward(300); + s2_fast_forward(140); nua_bye(nh, TAG_END()); @@ -2403,7 +2403,7 @@ s2_free_message(bye); fail_unless(s2_check_event(nua_r_bye, 407)); - s2_fast_forward(300); + s2_fast_forward(160); nua_authenticate(nh, NUTAG_AUTH(s2_auth_credentials), TAG_END()); bye = s2_wait_for_request(SIP_METHOD_BYE); Modified: freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_s2.c ============================================================================== --- freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_s2.c (original) +++ freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/test_s2.c Wed Feb 11 11:11:20 2009 @@ -125,6 +125,8 @@ _su_time = _su_time_fast_forwarder; time_offset += seconds; + + su_root_step(s2->root, 0); } /* -- NUA events -------------------------------------------------------- */

1 0