Mercurial Mercurial > oss > FCL > sf > mw > gstreamer / diff
summary | shortlog | changelog | graph | tags | bookmarks | branches | files | changeset | file | latest | revisions | annotate | diff | comparison | raw | help
Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
gst_plugins_base/tsrc/check/libs/rtp/src/rtp.c
branchRCL_3
changeset 30 7e817e7e631c
parent 29 567bb019e3e3 
--- a/gst_plugins_base/tsrc/check/libs/rtp/src/rtp.c	Tue Aug 31 15:30:33 2010 +0300
+++ b/gst_plugins_base/tsrc/check/libs/rtp/src/rtp.c	Wed Sep 01 12:16:41 2010 +0100
@@ -28,54 +28,37 @@
 
 
 
-#define LOG_FILE "c:\\logs\\gstrtp_logs.txt" 
+#define LOG_FILE "c:\\logs\\gstpad_logs.txt" 
 #include "std_log_result.h" 
 #define LOG_FILENAME_LINE __FILE__, __LINE__
 
 
 void create_xml(int result)
 {
-
     if(result)
-    {
         assert_failed = 1;
-    } 
-
+    
     testResultXml(xmlfile);
     close_log_file();
-
-    if(result)
-    {
-        exit (-1);
-    }    
-
 }
 
 #include "libgstreamer_wsd_solution.h" 
 
 #include <gst/rtp/gstrtpbuffer.h>
-#include <gst/rtp/gstrtcpbuffer.h>
 #include <string.h>
 
 #if EMULATOR
 static GET_GLOBAL_VAR_FROM_TLS(raised_critical,gstcheck,gboolean)
 #define _gst_check_raised_critical (*GET_GSTREAMER_WSD_VAR_NAME(raised_critical,gstcheck,g)())
 #else 
-IMPORT_C extern gboolean _gst_check_raised_critical;
-#endif
-
-#if EMULATOR
-static GET_GLOBAL_VAR_FROM_TLS(raised_warning,gstcheck,gboolean)
-#define _gst_check_raised_warning (*GET_GSTREAMER_WSD_VAR_NAME(raised_warning,gstcheck,g)())
-#else 
-IMPORT_C extern gboolean _gst_check_raised_warning;
+extern gboolean _gst_check_raised_critical;
 #endif
 
 #if EMULATOR
 static GET_GLOBAL_VAR_FROM_TLS(expecting_log,gstcheck,gboolean)
 #define _gst_check_expecting_log (*GET_GSTREAMER_WSD_VAR_NAME(expecting_log,gstcheck,g)())
 #else 
-IMPORT_C extern gboolean _gst_check_expecting_log;
+extern gboolean _gst_check_expecting_log;
 #endif
 
 
@@ -204,8 +187,8 @@
   data = GST_BUFFER_DATA (buf);
 
   /* should be impossible to set the extension data */
-  ASSERT_WARNING (fail_unless (gst_rtp_buffer_set_extension_data (buf, 0, 4) == FALSE));
-  fail_unless (gst_rtp_buffer_get_extension (buf) == FALSE);
+  fail_unless (gst_rtp_buffer_set_extension_data (buf, 0, 4) == FALSE);
+  fail_unless (gst_rtp_buffer_get_extension (buf) == TRUE);
 
   /* should be possible to set the extension data */
   fail_unless (gst_rtp_buffer_set_extension_data (buf, 270, 0) == TRUE);
@@ -234,301 +217,27 @@
       create_xml(0);
 }
 
-void test_rtp_seqnum_compare()
-{
-    xmlfile = "test_rtp_seqnum_compare";
-    std_log(LOG_FILENAME_LINE, "Test Started test_rtp_seqnum_compare");
-    
-#define ASSERT_COMP(a,b,c) fail_unless (gst_rtp_buffer_compare_seqnum ((guint16)a,(guint16)b) == c);
-  ASSERT_COMP (0xfffe, 0xfffd, -1);
-  ASSERT_COMP (0xffff, 0xfffe, -1);
-  ASSERT_COMP (0x0000, 0xffff, -1);
-  ASSERT_COMP (0x0001, 0x0000, -1);
-  ASSERT_COMP (0x0002, 0x0001, -1);
-
-  ASSERT_COMP (0xffff, 0xfffd, -2);
-  ASSERT_COMP (0x0000, 0xfffd, -3);
-  ASSERT_COMP (0x0001, 0xfffd, -4);
-  ASSERT_COMP (0x0002, 0xfffd, -5);
-
-  ASSERT_COMP (0x7ffe, 0x7ffd, -1);
-  ASSERT_COMP (0x7fff, 0x7ffe, -1);
-  ASSERT_COMP (0x8000, 0x7fff, -1);
-  ASSERT_COMP (0x8001, 0x8000, -1);
-  ASSERT_COMP (0x8002, 0x8001, -1);
-
-  ASSERT_COMP (0x7fff, 0x7ffd, -2);
-  ASSERT_COMP (0x8000, 0x7ffd, -3);
-  ASSERT_COMP (0x8001, 0x7ffd, -4);
-  ASSERT_COMP (0x8002, 0x7ffd, -5);
-
-  ASSERT_COMP (0x7ffd, 0xffff, -0x7ffe);
-  ASSERT_COMP (0x7ffe, 0x0000, -0x7ffe);
-  ASSERT_COMP (0x7fff, 0x0001, -0x7ffe);
-  ASSERT_COMP (0x7fff, 0x0000, -0x7fff);
-  ASSERT_COMP (0x8000, 0x0001, -0x7fff);
-  ASSERT_COMP (0x8001, 0x0002, -0x7fff);
-
-  ASSERT_COMP (0xfffd, 0x7ffe, -0x7fff);
-  ASSERT_COMP (0xfffe, 0x7fff, -0x7fff);
-  ASSERT_COMP (0xffff, 0x8000, -0x7fff);
-  ASSERT_COMP (0x0000, 0x8001, -0x7fff);
-  ASSERT_COMP (0x0001, 0x8002, -0x7fff);
-
-  ASSERT_COMP (0xfffe, 0x7ffe, -0x8000);
-  ASSERT_COMP (0xffff, 0x7fff, -0x8000);
-  ASSERT_COMP (0x0000, 0x8000, -0x8000);
-  ASSERT_COMP (0x0001, 0x8001, -0x8000);
-
-  ASSERT_COMP (0x7ffe, 0xfffe, -0x8000);
-  ASSERT_COMP (0x7fff, 0xffff, -0x8000);
-  ASSERT_COMP (0x8000, 0x0000, -0x8000);
-  ASSERT_COMP (0x8001, 0x0001, -0x8000);
-
-  ASSERT_COMP (0x0001, 0x0002, 1);
-  ASSERT_COMP (0x0000, 0x0001, 1);
-  ASSERT_COMP (0xffff, 0x0000, 1);
-  ASSERT_COMP (0xfffe, 0xffff, 1);
-  ASSERT_COMP (0xfffd, 0xfffe, 1);
-
-  ASSERT_COMP (0x0000, 0x0002, 2);
-  ASSERT_COMP (0xffff, 0x0002, 3);
-  ASSERT_COMP (0xfffe, 0x0002, 4);
-  ASSERT_COMP (0xfffd, 0x0002, 5);
-
-  ASSERT_COMP (0x8001, 0x8002, 1);
-  ASSERT_COMP (0x8000, 0x8001, 1);
-  ASSERT_COMP (0x7fff, 0x8000, 1);
-  ASSERT_COMP (0x7ffe, 0x7fff, 1);
-  ASSERT_COMP (0x7ffd, 0x7ffe, 1);
-
-  ASSERT_COMP (0x8000, 0x8002, 2);
-  ASSERT_COMP (0x7fff, 0x8002, 3);
-  ASSERT_COMP (0x7ffe, 0x8002, 4);
-  ASSERT_COMP (0x7ffd, 0x8002, 5);
-
-  ASSERT_COMP (0xfffe, 0x7ffd, 0x7fff);
-  ASSERT_COMP (0xffff, 0x7ffe, 0x7fff);
-  ASSERT_COMP (0x0000, 0x7fff, 0x7fff);
-  ASSERT_COMP (0x0001, 0x8000, 0x7fff);
-  ASSERT_COMP (0x0002, 0x8001, 0x7fff);
-
-  ASSERT_COMP (0x7ffe, 0xfffd, 0x7fff);
-  ASSERT_COMP (0x7fff, 0xfffe, 0x7fff);
-  ASSERT_COMP (0x8000, 0xffff, 0x7fff);
-  ASSERT_COMP (0x8001, 0x0000, 0x7fff);
-  ASSERT_COMP (0x8002, 0x0001, 0x7fff);
-#undef ASSERT_COMP
-  
-  std_log(LOG_FILENAME_LINE, "Test Successful");
-    create_xml(0);
-}
 
 
-void test_rtcp_buffer()
+void
+rtp_suite (void)
 {
-  GstBuffer *buf;
-  GstRTCPPacket packet;
-  guint8 *data;
-  
-  xmlfile = "test_rtcp_buffer";
-  std_log(LOG_FILENAME_LINE, "Test Started test_rtcp_buffer");
-
-  buf = gst_rtcp_buffer_new (1400);
-  fail_unless (buf != NULL);
-  fail_unless_equals_int (GST_BUFFER_SIZE (buf), 1400);
-  data = GST_BUFFER_DATA (buf);
-
-  fail_unless (gst_rtcp_buffer_get_first_packet (buf, &packet) == FALSE);
-  fail_unless (gst_rtcp_buffer_get_packet_count (buf) == 0);
-  fail_unless (gst_rtcp_buffer_validate (buf) == FALSE);
-
-  /* add an SR packet */
-  fail_unless (gst_rtcp_buffer_add_packet (buf, GST_RTCP_TYPE_SR,
-          &packet) == TRUE);
-
-  fail_unless (gst_rtcp_packet_get_padding (&packet) == 0);
-  fail_unless (gst_rtcp_packet_get_count (&packet) == 0);
-  fail_unless (gst_rtcp_packet_get_type (&packet) == GST_RTCP_TYPE_SR);
-  fail_unless (gst_rtcp_packet_get_length (&packet) == 6);
-
-  gst_rtcp_packet_sr_set_sender_info (&packet, 0x44556677,
-      G_GUINT64_CONSTANT (1), 0x11111111, 101, 123456);
-  {
-    guint32 ssrc;
-    guint64 ntptime;
-    guint32 rtptime;
-    guint32 packet_count;
-    guint32 octet_count;
-
-    gst_rtcp_packet_sr_get_sender_info (&packet, &ssrc, &ntptime, &rtptime,
-        &packet_count, &octet_count);
-
-    fail_unless (ssrc == 0x44556677);
-    fail_unless (ntptime == G_GUINT64_CONSTANT (1));
-    fail_unless (rtptime == 0x11111111);
-    fail_unless (packet_count == 101);
-    fail_unless (octet_count == 123456);
-  }
-
-  /* go to first packet, this should be the packet we just added */
-  fail_unless (gst_rtcp_buffer_get_first_packet (buf, &packet) == TRUE);
-
-  fail_unless (gst_rtcp_packet_get_padding (&packet) == 0);
-  fail_unless (gst_rtcp_packet_get_count (&packet) == 0);
-  fail_unless (gst_rtcp_packet_get_type (&packet) == GST_RTCP_TYPE_SR);
-  fail_unless (gst_rtcp_packet_get_length (&packet) == 6);
-
-  fail_unless (gst_rtcp_packet_move_to_next (&packet) == FALSE);
-
-  /* add some SDES */
-  fail_unless (gst_rtcp_buffer_add_packet (buf, GST_RTCP_TYPE_SDES,
-          &packet) == TRUE);
-  fail_unless (gst_rtcp_packet_sdes_add_item (&packet, 0xff658743) == TRUE);
-  fail_unless (gst_rtcp_packet_sdes_add_entry (&packet, GST_RTCP_SDES_CNAME,
-          sizeof ("test@foo.bar"), (guint8 *) "test@foo.bar") == TRUE);
-
-  /* add some BYE */
-  fail_unless (gst_rtcp_buffer_add_packet (buf, GST_RTCP_TYPE_BYE,
-          &packet) == TRUE);
-  fail_unless (gst_rtcp_packet_bye_add_ssrc (&packet, 0x5613212f) == TRUE);
-  fail_unless (gst_rtcp_packet_bye_add_ssrc (&packet, 0x00112233) == TRUE);
-  fail_unless (gst_rtcp_packet_bye_get_ssrc_count (&packet) == 2);
-
-  fail_unless (gst_rtcp_packet_get_padding (&packet) == 0);
-  fail_unless (gst_rtcp_packet_get_count (&packet) == 2);
-  fail_unless (gst_rtcp_packet_get_type (&packet) == GST_RTCP_TYPE_BYE);
-  fail_unless (gst_rtcp_packet_get_length (&packet) == 2);
-
-  /* move to SDES */
-  fail_unless (gst_rtcp_buffer_get_first_packet (buf, &packet) == TRUE);
-  fail_unless (gst_rtcp_packet_move_to_next (&packet) == TRUE);
-
-  fail_unless (gst_rtcp_packet_get_padding (&packet) == 0);
-  fail_unless (gst_rtcp_packet_get_count (&packet) == 1);
-  fail_unless (gst_rtcp_packet_get_type (&packet) == GST_RTCP_TYPE_SDES);
-  fail_unless (gst_rtcp_packet_get_length (&packet) == 5);
-
-  /* remove the SDES */
-  fail_unless (gst_rtcp_packet_remove (&packet) == TRUE);
-
-  /* we are now at the BYE packet */
-  fail_unless (gst_rtcp_packet_get_padding (&packet) == 0);
-  fail_unless (gst_rtcp_packet_get_count (&packet) == 2);
-  fail_unless (gst_rtcp_packet_get_type (&packet) == GST_RTCP_TYPE_BYE);
-  fail_unless (gst_rtcp_packet_get_length (&packet) == 2);
-
-  /* close and validate */
-  gst_rtcp_buffer_end (buf);
-  fail_unless (gst_rtcp_buffer_validate (buf) == TRUE);
-  gst_buffer_unref (buf);
-  
-  std_log(LOG_FILENAME_LINE, "Test Successful");
-    create_xml(0);
+test_rtp_buffer();
+test_rtp_buffer_set_extension_data();
 }
 
-void test_rtp_buffer_validate_corrupt()
-{
-  GstBuffer *buf;
-  guint8 corrupt_rtp_packet[58] = {
-    0x90, 0x7a, 0xbf, 0x28, 0x3a, 0x8a, 0x0a, 0xf4, 0x69, 0x6b, 0x76, 0xc0,
-    0x21, 0xe0, 0xe0, 0x60, 0x81, 0x10, 0x84, 0x30, 0x21, 0x52, 0x06, 0xc2,
-    0xb8, 0x30, 0x10, 0x4c, 0x08, 0x62, 0x67, 0xc2, 0x6e, 0x1a, 0x53, 0x3f,
-    0xaf, 0xd6, 0x1b, 0x29, 0x40, 0xe0, 0xa5, 0x83, 0x01, 0x4b, 0x04, 0x02,
-    0xb0, 0x97, 0x63, 0x08, 0x10, 0x4b, 0x43, 0x85, 0x37, 0x2c
-  };
-
-  xmlfile = "test_rtp_buffer_validate_corrupt";
-  std_log(LOG_FILENAME_LINE, "Test Started test_rtp_buffer_validate_corrupt");
-  buf = gst_buffer_new ();
-  GST_BUFFER_DATA (buf) = corrupt_rtp_packet;
-  GST_BUFFER_SIZE (buf) = sizeof (corrupt_rtp_packet);
-  fail_if (gst_rtp_buffer_validate (buf));
-  gst_buffer_unref (buf);
-  
-  std_log(LOG_FILENAME_LINE, "Test Successful");
-    create_xml(0);
-}
-
-
-void test_rtp_buffer_list()
-{
-  GstBuffer *rtp_header;
-  GstBuffer *rtp_payload;
-  GstBufferList *list = NULL;
-  GstBufferListIterator *it;
-  guint i;
-
-  xmlfile = "test_rtp_buffer_list";
-  std_log(LOG_FILENAME_LINE, "Test Started test_rtp_buffer_list");
-  
-  list = gst_buffer_list_new ();
-  it = gst_buffer_list_iterate (list);
-
-  /* Creating a list of two RTP packages */
-
-  /* Create first group to hold the rtp header and the payload */
-  gst_buffer_list_iterator_add_group (it);
-  rtp_header = gst_rtp_buffer_new_allocate (0, 0, 0);
-  gst_buffer_list_iterator_add (it, rtp_header);
-  rtp_payload = gst_buffer_new_and_alloc (42);
-  gst_buffer_list_iterator_add (it, rtp_payload);
-
-  /* Create second group to hold an rtp header and a payload */
-  gst_buffer_list_iterator_add_group (it);
-  rtp_header = gst_rtp_buffer_new_allocate (0, 0, 0);
-  gst_buffer_list_iterator_add (it, rtp_header);
-  rtp_payload = gst_buffer_new_and_alloc (42);
-  gst_buffer_list_iterator_add (it, rtp_payload);
-
-  gst_buffer_list_iterator_free (it);
-
-  /* Test SEQ number */
-  i = gst_rtp_buffer_list_set_seq (list, 1024);
-  fail_if (1026 != i);
-  fail_if (!gst_rtp_buffer_list_validate (list));
-
-  /* Timestamp */
-  gst_rtp_buffer_list_set_timestamp (list, 432191);
-  fail_unless_equals_int (gst_rtp_buffer_list_get_timestamp (list), 432191);
-
-  /* SSRC */
-  gst_rtp_buffer_list_set_ssrc (list, 0xf04043C2);
-  fail_unless_equals_int (gst_rtp_buffer_list_get_ssrc (list),
-      (gint) 0xf04043c2);
-
-  /* Payload type */
-  gst_rtp_buffer_list_set_payload_type (list, 127);
-  fail_unless_equals_int (gst_rtp_buffer_list_get_payload_type (list), 127);
-
-  gst_buffer_list_unref (list);
-  
-  std_log(LOG_FILENAME_LINE, "Test Successful");
-    create_xml(0);
-}
-
-
 void (*fn[]) (void) = {
 test_rtp_buffer,
-test_rtp_buffer_set_extension_data,
-test_rtp_buffer_validate_corrupt,
-test_rtp_seqnum_compare,
-test_rtp_buffer_list,
-test_rtcp_buffer
+test_rtp_buffer_set_extension_data
 };
 
 char *args[] = {
 "test_rtp_buffer",
-"test_rtp_buffer_set_extension_data",
-"test_rtp_buffer_validate_corrupt",
-"test_rtp_seqnum_compare",
-"test_rtp_buffer_list",
-"test_rtcp_buffer"
+"test_rtp_buffer_set_extension_data"
 };
 
 GST_CHECK_MAIN (gst_rtp);
 
-
 #if 0
 void main()
     {
FCL/sf/mw/gstreamer