[Freeswitch-svn] [commit] r9514 - freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua

Freeswitch SVN mikej at freeswitch.org
Wed Sep 10 12:23:02 EDT 2008


Author: mikej
Date: Wed Sep 10 12:23:01 2008
New Revision: 9514

Modified:
   freeswitch/trunk/libs/sofia-sip/libsofia-sip-ua/nua/check_session.c

Log:
Wed Sep 10 10:49:06 EDT 2008  Pekka Pessi <first.last at nokia.com>
  * check_session.c: added test cases for nua_handle_destroy() and nua_respond()



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 Sep 10 12:23:01 2008
@@ -2186,6 +2186,646 @@
 
 /* ====================================================================== */
 
+START_TEST(destroy_4_3_1)
+{
+  nua_handle_t *nh;
+  struct message *invite, *cancel;
+
+  s2_case("4.3.1", "Destroy handle after INVITE sent",
+	  "NUA sends INVITE, handle gets destroyed.");
+
+  nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END());
+
+  invite = invite_sent_by_nua(nh, TAG_END());
+  process_offer(invite);
+
+  nua_handle_destroy(nh);
+
+  s2_respond_to(invite, dialog, SIP_100_TRYING, TAG_END());
+
+  cancel = s2_wait_for_request(SIP_METHOD_CANCEL);
+  fail_if(!cancel);
+  s2_respond_to(invite, dialog, SIP_487_REQUEST_CANCELLED, TAG_END());
+  s2_free_message(invite);
+
+  s2_respond_to(cancel, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(cancel);
+}
+END_TEST
+
+
+START_TEST(destroy_4_3_2)
+{
+  nua_handle_t *nh;
+  struct message *invite, *cancel;
+
+  s2_case("4.3.2", "Destroy handle in calling state",
+	  "NUA sends INVITE, receives 180, handle gets destroyed.");
+
+  nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END());
+
+  invite = invite_sent_by_nua(nh, TAG_END());
+  process_offer(invite);
+  s2_respond_to(invite, dialog, SIP_180_RINGING, TAG_END());
+  fail_unless(s2_check_event(nua_r_invite, 180));
+  fail_unless(s2_check_callstate(nua_callstate_proceeding));
+
+  nua_handle_destroy(nh);
+
+  cancel = s2_wait_for_request(SIP_METHOD_CANCEL);
+  fail_if(!cancel);
+  s2_respond_to(invite, dialog, SIP_487_REQUEST_CANCELLED, TAG_END());
+  s2_free_message(invite);
+
+  s2_respond_to(cancel, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(cancel);
+}
+END_TEST
+
+START_TEST(destroy_4_3_3)
+{
+  nua_handle_t *nh;
+  struct message *invite, *ack, *bye;
+
+  s2_case("4.3.3", "Destroy handle in completing state",
+	  "NUA sends INVITE, receives 200, handle gets destroyed.");
+
+  nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END());
+
+  invite = invite_sent_by_nua(nh, NUTAG_AUTOACK(0), TAG_END());
+  process_offer(invite);
+  s2_respond_to(invite, dialog, SIP_180_RINGING, TAG_END());
+  fail_unless(s2_check_event(nua_r_invite, 180));
+  fail_unless(s2_check_callstate(nua_callstate_proceeding));
+
+  respond_with_sdp(invite, dialog, SIP_200_OK, TAG_END());
+  fail_unless(s2_check_event(nua_r_invite, 200));
+  fail_unless(s2_check_callstate(nua_callstate_completing));
+
+  nua_handle_destroy(nh);
+
+  ack = s2_wait_for_request(SIP_METHOD_ACK);
+  fail_if(!ack);
+  s2_free_message(ack);
+
+  bye = s2_wait_for_request(SIP_METHOD_BYE);
+  fail_if(!bye);
+  s2_respond_to(bye, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(bye);
+
+  s2_free_message(invite);
+}
+END_TEST
+
+
+START_TEST(destroy_4_3_4)
+{
+  nua_handle_t *nh;
+  struct message *invite, *ack, *bye;
+
+  s2_case("4.3.3", "Destroy handle in ready state ",
+	  "NUA sends INVITE, receives 200, handle gets destroyed.");
+
+  nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END());
+
+  invite = invite_sent_by_nua(nh, NUTAG_AUTOACK(0), TAG_END());
+  process_offer(invite);
+  s2_respond_to(invite, dialog, SIP_180_RINGING, TAG_END());
+  fail_unless(s2_check_event(nua_r_invite, 180));
+  fail_unless(s2_check_callstate(nua_callstate_proceeding));
+
+  respond_with_sdp(invite, dialog, SIP_200_OK, TAG_END());
+  fail_unless(s2_check_event(nua_r_invite, 200));
+  fail_unless(s2_check_callstate(nua_callstate_completing));
+
+  nua_ack(nh, TAG_END());
+  ack = s2_wait_for_request(SIP_METHOD_ACK);
+  fail_if(!ack);
+  s2_free_message(ack);
+
+  fail_unless(s2_check_callstate(nua_callstate_ready));
+
+  nua_handle_destroy(nh);
+
+  bye = s2_wait_for_request(SIP_METHOD_BYE);
+  fail_if(!bye);
+  s2_respond_to(bye, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(bye);
+
+  s2_free_message(invite);
+}
+END_TEST
+
+
+START_TEST(destroy_4_3_5)
+{
+  nua_handle_t *nh;
+  struct message *invite, *cancel;
+
+  s2_case("4.3.5", "Destroy handle in re-INVITE calling state",
+	  "NUA sends re-INVITE, handle gets destroyed.");
+
+  nh = invite_to_nua(TAG_END());
+
+  invite = invite_sent_by_nua(nh, TAG_END());
+  process_offer(invite);
+
+  nua_handle_destroy(nh);
+
+  s2_respond_to(invite, dialog, SIP_100_TRYING, TAG_END());
+
+  cancel = s2_wait_for_request(SIP_METHOD_CANCEL);
+  fail_if(!cancel);
+  s2_respond_to(invite, dialog, SIP_487_REQUEST_CANCELLED, TAG_END());
+  s2_free_message(invite);
+
+  s2_respond_to(cancel, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(cancel);
+}
+END_TEST
+
+
+START_TEST(destroy_4_3_6)
+{
+  nua_handle_t *nh;
+  struct message *invite, *cancel;
+
+  s2_case("4.3.6", "Destroy handle in calling state of re-INVITE",
+	  "NUA sends re-INVITE, receives 180, handle gets destroyed.");
+
+  nh = invite_to_nua(TAG_END());
+
+  invite = invite_sent_by_nua(nh, TAG_END());
+  process_offer(invite);
+  s2_respond_to(invite, dialog, SIP_180_RINGING, TAG_END());
+  fail_unless(s2_check_event(nua_r_invite, 180));
+  fail_unless(s2_check_callstate(nua_callstate_proceeding));
+
+  nua_handle_destroy(nh);
+
+  cancel = s2_wait_for_request(SIP_METHOD_CANCEL);
+  fail_if(!cancel);
+  s2_respond_to(invite, dialog, SIP_487_REQUEST_CANCELLED, TAG_END());
+  s2_free_message(invite);
+
+  s2_respond_to(cancel, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(cancel);
+}
+END_TEST
+
+
+START_TEST(destroy_4_3_7)
+{
+  nua_handle_t *nh;
+  struct message *invite, *ack, *bye;
+
+  s2_case("4.3.7", "Destroy handle in completing state of re-INVITE",
+	  "NUA sends INVITE, receives 200, handle gets destroyed.");
+
+  nh = invite_to_nua(TAG_END());
+
+  invite = invite_sent_by_nua(nh, NUTAG_AUTOACK(0), TAG_END());
+  process_offer(invite);
+  s2_respond_to(invite, dialog, SIP_180_RINGING, TAG_END());
+  fail_unless(s2_check_event(nua_r_invite, 180));
+  fail_unless(s2_check_callstate(nua_callstate_proceeding));
+
+  respond_with_sdp(invite, dialog, SIP_200_OK, TAG_END());
+  fail_unless(s2_check_event(nua_r_invite, 200));
+  fail_unless(s2_check_callstate(nua_callstate_completing));
+
+  nua_handle_destroy(nh);
+
+  ack = s2_wait_for_request(SIP_METHOD_ACK);
+  fail_if(!ack);
+  s2_free_message(ack);
+
+  bye = s2_wait_for_request(SIP_METHOD_BYE);
+  fail_if(!bye);
+  s2_respond_to(bye, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(bye);
+
+  s2_free_message(invite);
+}
+END_TEST
+
+
+START_TEST(destroy_4_3_8)
+{
+  nua_handle_t *nh;
+  struct message *invite, *ack, *bye;
+
+  tport_set_params(s2->master, TPTAG_LOG(1), TAG_END());
+  s2_setup_logs(7);
+
+  s2_case("4.3.8", "Destroy handle after INVITE sent",
+	  "NUA sends INVITE, handle gets destroyed, "
+	  "but remote end returns 200 OK. "
+	  "Make sure nua tries to release call properly.");
+
+  nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END());
+
+  invite = invite_sent_by_nua(nh, TAG_END());
+  process_offer(invite);
+
+  nua_handle_destroy(nh);
+
+  respond_with_sdp(invite, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(invite);
+
+  ack = s2_wait_for_request(SIP_METHOD_ACK);
+  fail_if(!ack);
+  s2_free_message(ack);
+
+  bye = s2_wait_for_request(SIP_METHOD_BYE);
+  fail_if(!bye);
+  s2_respond_to(bye, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(bye);
+}
+END_TEST
+
+
+START_TEST(destroy_4_3_9)
+{
+  nua_handle_t *nh;
+  struct message *invite, *cancel, *ack, *bye;
+
+  tport_set_params(s2->master, TPTAG_LOG(1), TAG_END());
+  s2_setup_logs(7);
+
+  s2_case("4.3.9", "Destroy handle in calling state",
+	  "NUA sends INVITE, receives 180, handle gets destroyed, "
+	  "but remote end returns 200 OK. "
+	  "Make sure nua tries to release call properly.");
+
+  nh = nua_handle(nua, NULL, SIPTAG_TO(s2->local), TAG_END());
+
+  invite = invite_sent_by_nua(nh, TAG_END());
+  process_offer(invite);
+  s2_respond_to(invite, dialog, SIP_180_RINGING, TAG_END());
+  fail_unless(s2_check_event(nua_r_invite, 180));
+  fail_unless(s2_check_callstate(nua_callstate_proceeding));
+
+  nua_handle_destroy(nh);
+
+  cancel = s2_wait_for_request(SIP_METHOD_CANCEL);
+  fail_if(!cancel);
+  s2_respond_to(cancel, dialog, SIP_481_NO_TRANSACTION, TAG_END());
+  s2_free_message(cancel);
+
+  respond_with_sdp(invite, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(invite);
+
+  ack = s2_wait_for_request(SIP_METHOD_ACK);
+  fail_if(!ack);
+  s2_free_message(ack);
+
+  bye = s2_wait_for_request(SIP_METHOD_BYE);
+  fail_if(!bye);
+  s2_respond_to(bye, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(bye);
+}
+END_TEST
+
+
+START_TEST(destroy_4_4_1)
+{
+  nua_handle_t *nh;
+  struct event *invite;
+  struct message *response;
+
+  s2_case("4.4.1", "Destroy handle while call is on-going",
+	  "NUA is callee, sends 100, destroys handle");
+
+  soa_generate_offer(soa, 1, NULL);
+  request_with_sdp(dialog, SIP_METHOD_INVITE, NULL, TAG_END());
+
+  invite = s2_wait_for_event(nua_i_invite, 100); fail_unless(invite != NULL);
+  fail_unless(s2_check_callstate(nua_callstate_received));
+
+  nh = invite->nh; fail_if(!nh);
+
+  s2_free_event(invite);
+
+  response = s2_wait_for_response(100, SIP_METHOD_INVITE);
+  fail_if(!response);
+  s2_free_message(response);
+
+  nua_handle_destroy(nh);
+
+  response = s2_wait_for_response(480, SIP_METHOD_INVITE);
+  fail_if(!response);
+  fail_if(s2_request_to(dialog, SIP_METHOD_ACK, NULL,
+			SIPTAG_VIA(sip_object(dialog->invite)->sip_via),
+			TAG_END()));
+  s2_free_message(response);
+}
+END_TEST
+
+
+START_TEST(destroy_4_4_2)
+{
+  nua_handle_t *nh;
+  struct event *invite;
+  struct message *response;
+
+  s2_case("4.4.1", "Destroy handle while call is on-going",
+	  "NUA is callee, sends 180, destroys handle");
+
+  soa_generate_offer(soa, 1, NULL);
+  request_with_sdp(dialog, SIP_METHOD_INVITE, NULL, TAG_END());
+
+  invite = s2_wait_for_event(nua_i_invite, 100); fail_unless(invite != NULL);
+  fail_unless(s2_check_callstate(nua_callstate_received));
+
+  nh = invite->nh; fail_if(!nh);
+
+  s2_free_event(invite);
+
+  response = s2_wait_for_response(100, SIP_METHOD_INVITE);
+  fail_if(!response);
+  s2_free_message(response);
+
+  nua_respond(nh, SIP_180_RINGING, TAG_END());
+
+  response = s2_wait_for_response(180, SIP_METHOD_INVITE);
+  fail_if(!response);
+  s2_free_message(response);
+
+  nua_handle_destroy(nh);
+
+  response = s2_wait_for_response(480, SIP_METHOD_INVITE);
+  fail_if(!response);
+  fail_if(s2_request_to(dialog, SIP_METHOD_ACK, NULL,
+			SIPTAG_VIA(sip_object(dialog->invite)->sip_via),
+			TAG_END()));
+  s2_free_message(response);
+}
+END_TEST
+
+
+START_TEST(destroy_4_4_3_1)
+{
+  nua_handle_t *nh;
+  struct event *invite;
+  struct message *response, *bye;
+
+  s2_case("4.4.3.1", "Destroy handle while call is on-going",
+	  "NUA is callee, sends 200, destroys handle");
+
+  soa_generate_offer(soa, 1, NULL);
+  request_with_sdp(dialog, SIP_METHOD_INVITE, NULL, TAG_END());
+
+  invite = s2_wait_for_event(nua_i_invite, 100); fail_unless(invite != NULL);
+  fail_unless(s2_check_callstate(nua_callstate_received));
+
+  nh = invite->nh; fail_if(!nh);
+
+  s2_free_event(invite);
+
+  response = s2_wait_for_response(100, SIP_METHOD_INVITE);
+  fail_if(!response);
+  s2_free_message(response);
+
+  nua_respond(nh, SIP_180_RINGING,
+	      SOATAG_USER_SDP_STR("m=audio 5004 RTP/AVP 0 8"),
+	      TAG_END());
+
+  response = s2_wait_for_response(180, SIP_METHOD_INVITE);
+  fail_if(!response);
+  s2_free_message(response);
+
+  fail_unless(s2_check_callstate(nua_callstate_early));
+
+  nua_respond(nh, SIP_200_OK, TAG_END());
+  fail_unless(s2_check_callstate(nua_callstate_completed));
+
+  response = s2_wait_for_response(200, SIP_METHOD_INVITE);
+  fail_if(!response);
+
+  nua_handle_destroy(nh);
+
+  fail_if(s2_request_to(dialog, SIP_METHOD_ACK, NULL,
+			SIPTAG_VIA(sip_object(dialog->invite)->sip_via),
+			TAG_END()));
+  s2_free_message(response);
+
+  bye = s2_wait_for_request(SIP_METHOD_BYE);
+  fail_if(!bye);
+  s2_respond_to(bye, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(bye);
+}
+END_TEST
+
+
+START_TEST(destroy_4_4_3_2)
+{
+  nua_handle_t *nh;
+  struct event *invite;
+  struct message *response, *bye;
+
+  s2_case("4.4.3.1", "Destroy handle while call is on-going",
+	  "NUA is callee, sends 200, destroys handle");
+
+  soa_generate_offer(soa, 1, NULL);
+  request_with_sdp(dialog, SIP_METHOD_INVITE, NULL, TAG_END());
+
+  invite = s2_wait_for_event(nua_i_invite, 100); fail_unless(invite != NULL);
+  fail_unless(s2_check_callstate(nua_callstate_received));
+
+  nh = invite->nh; fail_if(!nh);
+
+  s2_free_event(invite);
+
+  response = s2_wait_for_response(100, SIP_METHOD_INVITE);
+  fail_if(!response);
+  s2_free_message(response);
+
+  nua_respond(nh, SIP_180_RINGING,
+	      SOATAG_USER_SDP_STR("m=audio 5004 RTP/AVP 0 8"),
+	      TAG_END());
+
+  response = s2_wait_for_response(180, SIP_METHOD_INVITE);
+  fail_if(!response);
+  s2_free_message(response);
+
+  fail_unless(s2_check_callstate(nua_callstate_early));
+
+  nua_respond(nh, SIP_200_OK, TAG_END());
+  fail_unless(s2_check_callstate(nua_callstate_completed));
+
+  response = s2_wait_for_response(200, SIP_METHOD_INVITE);
+  fail_if(!response);
+
+  nua_handle_destroy(nh);
+
+  bye = s2_wait_for_request(SIP_METHOD_BYE);
+  fail_if(!bye);
+  s2_respond_to(bye, dialog, SIP_200_OK, TAG_END());
+  s2_free_message(bye);
+
+  fail_if(s2_request_to(dialog, SIP_METHOD_ACK, NULL,
+			SIPTAG_VIA(sip_object(dialog->invite)->sip_via),
+			TAG_END()));
+  s2_free_message(response);
+}
+END_TEST
+
+TCase *destroy_tcase(void)
+{
+  TCase *tc = tcase_create("4.3 - Destroying Handle");
+
+  tcase_add_checked_fixture(tc, call_setup, call_teardown);
+
+  {
+    tcase_add_test(tc, destroy_4_3_1);
+    tcase_add_test(tc, destroy_4_3_2);
+    tcase_add_test(tc, destroy_4_3_3);
+    tcase_add_test(tc, destroy_4_3_4);
+    tcase_add_test(tc, destroy_4_3_5);
+    tcase_add_test(tc, destroy_4_3_6);
+    tcase_add_test(tc, destroy_4_3_7);
+    if (XXX) {
+      tcase_add_test(tc, destroy_4_3_8);
+      tcase_add_test(tc, destroy_4_3_9);
+    }
+
+    tcase_add_test(tc, destroy_4_4_1);
+    tcase_add_test(tc, destroy_4_4_2);
+    tcase_add_test(tc, destroy_4_4_3_1);
+    tcase_add_test(tc, destroy_4_4_3_2);
+
+    tcase_set_timeout(tc, 5);
+  }
+  return tc;
+}
+
+/* ====================================================================== */
+
+static void options_setup(void), options_teardown(void);
+
+START_TEST(options_5_1_1)
+{
+  struct event *options;
+  nua_handle_t *nh;
+  struct message *response;
+
+  s2_case("5.1.1", "Test nua_respond() API",
+	  "Test nua_respond() API with OPTIONS.");
+
+  s2_request_to(dialog, SIP_METHOD_OPTIONS, NULL, TAG_END());
+
+  options = s2_wait_for_event(nua_i_options, 200);
+  fail_unless(options != NULL);
+  nh = options->nh; fail_if(!nh);
+
+  response = s2_wait_for_response(200, SIP_METHOD_OPTIONS);
+
+  fail_if(!response);
+  s2_free_message(response);
+
+  nua_handle_destroy(nh);
+
+  nua_set_params(nua, NUTAG_APPL_METHOD("OPTIONS"), TAG_END());
+  fail_unless(s2_check_event(nua_r_set_params, 200));
+
+  s2_request_to(dialog, SIP_METHOD_OPTIONS, NULL, TAG_END());
+
+  options = s2_wait_for_event(nua_i_options, 100);
+  fail_unless(options != NULL);
+  nh = options->nh; fail_if(!nh);
+
+  nua_respond(nh, 202, "okok", NUTAG_WITH_SAVED(options->event), TAG_END());
+
+  response = s2_wait_for_response(202, SIP_METHOD_OPTIONS);
+  fail_if(!response);
+  s2_free_message(response);
+
+  nua_handle_destroy(nh);
+}
+END_TEST
+
+
+#if HAVE_LIBPTHREAD
+#include <pthread.h>
+
+void *respond_to_options(void *arg)
+{
+  struct event *options = (struct event *)arg;
+
+  nua_respond(options->nh, 202, "ok ok",
+	      NUTAG_WITH_SAVED(options->event),
+	      TAG_END());
+
+  pthread_exit(arg);
+  return NULL;
+}
+
+START_TEST(options_5_1_2)
+{
+  struct event *options;
+  nua_handle_t *nh;
+  struct message *response;
+  pthread_t tid;
+  void *thread_return = NULL;
+
+  s2_case("5.1.2", "Test nua_respond() API with another thread",
+	  "Test multithreading nua_respond() API with OPTIONS.");
+
+  nua_set_params(nua, NUTAG_APPL_METHOD("OPTIONS"), TAG_END());
+  fail_unless(s2_check_event(nua_r_set_params, 200));
+
+  s2_request_to(dialog, SIP_METHOD_OPTIONS, NULL, TAG_END());
+
+  options = s2_wait_for_event(nua_i_options, 100);
+  fail_unless(options != NULL);
+  nh = options->nh; fail_if(!nh);
+
+  fail_if(pthread_create(&tid, NULL, respond_to_options, (void *)options));
+  pthread_join(tid, &thread_return);
+  fail_unless(thread_return == (void *)options);
+
+  response = s2_wait_for_response(202, SIP_METHOD_OPTIONS);
+  fail_if(!response);
+  s2_free_message(response);
+
+  nua_handle_destroy(nh);
+}
+END_TEST
+#else
+START_TEST(options_5_1_2)
+{
+}
+END_TEST
+#endif
+
+TCase *options_tcase(void)
+{
+  TCase *tc = tcase_create("5 - OPTIONS, etc");
+
+  tcase_add_checked_fixture(tc, options_setup, options_teardown);
+
+  tcase_add_test(tc, options_5_1_1);
+  tcase_add_test(tc, options_5_1_2);
+
+  return tc;
+}
+
+
+static void options_setup(void)
+{
+  s2_nua_thread = 1;
+  call_setup();
+}
+
+static void options_teardown(void)
+{
+  call_teardown();
+}
+
+
+/* ====================================================================== */
+
 /* Test case template */
 
 START_TEST(empty)
@@ -2221,6 +2861,8 @@
   suite_add_tcase(suite, invite_precondition_tcase());
   suite_add_tcase(suite, invite_error_tcase());
   suite_add_tcase(suite, termination_tcase());
+  suite_add_tcase(suite, destroy_tcase());
+  suite_add_tcase(suite, options_tcase());
 
   if (0)			/* Template */
     suite_add_tcase(suite, empty_tcase());



More information about the Freeswitch-svn mailing list