fix(test): Fix command line opt in run all script
[ric-plt/lib/rmr.git] / test / mbuf_api_static_test.c
index 4c0cd5e..8b17968 100644 (file)
@@ -1,14 +1,14 @@
 // : vi ts=4 sw=4 noet :
 /*
 ==================================================================================
 // : vi ts=4 sw=4 noet :
 /*
 ==================================================================================
-        Copyright (c) 2019 Nokia 
-        Copyright (c) 2018-2019 AT&T Intellectual Property.
+           Copyright (c) 2019 Nokia
+           Copyright (c) 2018-2019 AT&T Intellectual Property.
 
    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.
    You may obtain a copy of the License at
 
 
    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.
    You may obtain a copy of the License at
 
-       http://www.apache.org/licenses/LICENSE-2.0
+          http://www.apache.org/licenses/LICENSE-2.0
 
    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
 
    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
@@ -21,7 +21,7 @@
 /*
        Mmemonic:       mbuf_api_static_test.c
        Abstract:       Test the message buffer  funcitons. These are meant to be included at compile
 /*
        Mmemonic:       mbuf_api_static_test.c
        Abstract:       Test the message buffer  funcitons. These are meant to be included at compile
-                               time by the test driver.  
+                               time by the test driver.
 
        Author:         E. Scott Daniels
        Date:           3 April 2019
 
        Author:         E. Scott Daniels
        Date:           3 April 2019
 #include <errno.h>
 #include <string.h>
 #include <stdint.h>
 #include <errno.h>
 #include <string.h>
 #include <stdint.h>
+#include <pthread.h>
+#include <semaphore.h>
 
 
-#include "../src/common/include/rmr.h"
-#include "../src/common/include/rmr_agnostic.h"
+#include "rmr.h"
+#include "rmr_agnostic.h"
 
 
 int mbuf_api_test( ) {
        unsigned char* c;
        int i;
 
 
 int mbuf_api_test( ) {
        unsigned char* c;
        int i;
+       int state;
        int errors = 0;
        int errors = 0;
+       char*   buf;
        rmr_mbuf_t*     mbuf;
        unsigned char src_buf[256];
 
        rmr_mbuf_t*     mbuf;
        unsigned char src_buf[256];
 
@@ -57,6 +61,7 @@ int mbuf_api_test( ) {
        mbuf->header = mbuf->payload;
        mbuf->alloc_len = 1024;
 
        mbuf->header = mbuf->payload;
        mbuf->alloc_len = 1024;
 
+       // --- test payload field  access functions ---------------------------------------------------
        memset( src_buf, 0, sizeof( src_buf ) );
        rmr_bytes2payload( mbuf, NULL, strlen( src_buf) );                              // errno should be set on return
        errors += fail_if( errno == 0, "buf copy to payload with nil src returned good errno" );
        memset( src_buf, 0, sizeof( src_buf ) );
        rmr_bytes2payload( mbuf, NULL, strlen( src_buf) );                              // errno should be set on return
        errors += fail_if( errno == 0, "buf copy to payload with nil src returned good errno" );
@@ -71,11 +76,13 @@ int mbuf_api_test( ) {
        rmr_bytes2payload( mbuf, src_buf, 8192 );                                               // bust the limit
        errors += fail_if( mbuf->state == RMR_OK, "huge buf copy to payload returned good state in mbuf" );
        errors += fail_if( errno == 0, "huge buf copy to payload returned good state in errno" );
        rmr_bytes2payload( mbuf, src_buf, 8192 );                                               // bust the limit
        errors += fail_if( mbuf->state == RMR_OK, "huge buf copy to payload returned good state in mbuf" );
        errors += fail_if( errno == 0, "huge buf copy to payload returned good state in errno" );
-       
+
 
        snprintf( src_buf, sizeof( src_buf ), "This is some text in the buffer" );
        rmr_str2payload( mbuf, src_buf );                                                       // this uses bytes2payload, so only one invocation needed
 
 
        snprintf( src_buf, sizeof( src_buf ), "This is some text in the buffer" );
        rmr_str2payload( mbuf, src_buf );                                                       // this uses bytes2payload, so only one invocation needed
 
+
+       // --- test meid field  access functions ---------------------------------------------------
        errno = 0;
        i = rmr_bytes2meid( NULL, src_buf, RMR_MAX_MEID );
        errors += fail_if( errno == 0, "(errno) attempt to copy bytes to meid with nil message" );
        errno = 0;
        i = rmr_bytes2meid( NULL, src_buf, RMR_MAX_MEID );
        errors += fail_if( errno == 0, "(errno) attempt to copy bytes to meid with nil message" );
@@ -121,6 +128,24 @@ int mbuf_api_test( ) {
        errors += fail_if( i == RMR_OK, "(rv) attempt to copy string to meid with large source buffer" );
 
 
        errors += fail_if( i == RMR_OK, "(rv) attempt to copy string to meid with large source buffer" );
 
 
+       snprintf( src_buf, sizeof( src_buf ), "test-meid" );
+       rmr_str2meid( mbuf, src_buf );
+
+       errno = 0;
+       c = rmr_get_meid( NULL, NULL );
+       errors += fail_if( c != NULL, "get meid with nil message buffer" );
+       errors += fail_if( errno == 0, "(errno bad) get meid with nil msg buffer" );
+
+       c = rmr_get_meid( mbuf, NULL );                 // should allocate and return c
+       errors += fail_if( c == NULL, "get meid with nil dest pointer (did not allocate a buffer)" );
+       errors += fail_if( strcmp( c, "test-meid" ) != 0, "did not get expected meid from mbuffer" );
+
+       c = rmr_get_meid( mbuf, c );
+       errors += fail_if( c == NULL, "get meid with a dest pointer returned no pointer" );
+       errors += fail_if( strcmp( c, "test-meid" ) != 0, "did not get expected meid from mbuffer" );
+
+
+       // --- test transaction field  access functions ---------------------------------------------------
        errno = 0;
        i = rmr_bytes2xact( NULL, src_buf, RMR_MAX_XID );
        errors += fail_if( errno == 0, "(errno) attempt to copy bytes to xact with nil message" );
        errno = 0;
        i = rmr_bytes2xact( NULL, src_buf, RMR_MAX_XID );
        errors += fail_if( errno == 0, "(errno) attempt to copy bytes to xact with nil message" );
@@ -165,24 +190,93 @@ int mbuf_api_test( ) {
        errors += fail_if( errno == 0, "(errno) attempt to copy string to xact with large source buffer" );
        errors += fail_if( i == RMR_OK, "(rv) attempt to copy string to xact with large source buffer" );
 
        errors += fail_if( errno == 0, "(errno) attempt to copy string to xact with large source buffer" );
        errors += fail_if( i == RMR_OK, "(rv) attempt to copy string to xact with large source buffer" );
 
-       
-       snprintf( src_buf, sizeof( src_buf ), "test-meid" );
-       rmr_str2meid( mbuf, src_buf );
 
 
-       errno = 0;
-       c = rmr_get_meid( NULL, NULL );
-       errors += fail_if( c != NULL, "get meid with nil message buffer" );
-       errors += fail_if( errno == 0, "(errno bad) get meid with nil msg buffer" ); 
 
 
-       
-       c = rmr_get_meid( mbuf, NULL );                 // should allocate and return c
-       errors += fail_if( c == NULL, "get meid with nil dest pointer (did not allocate a buffer)" );
-       errors += fail_if( strcmp( c, "test-meid" ) != 0, "did not get expected meid from mbuffer" );
+       // ------------ trace data tests ----------------------------------------------------------------
+       // CAUTION: to support standalone mbuf api tests, the underlying buffer reallocation functions are NOT used
+       //                      if this is driven by the mbuf_api_test.c driver
 
 
-       c = rmr_get_meid( mbuf, c );
-       errors += fail_if( c == NULL, "get meid with a dest pointer returned no pointer" );
-       errors += fail_if( strcmp( c, "test-meid" ) != 0, "did not get expected meid from mbuffer" );
-       
+       mbuf = test_mk_msg( 2048, 0 );          // initially no trace size to force realloc
+
+       state = TRACE_OFFSET( mbuf->header ) - PAYLOAD_OFFSET( mbuf->header );          // no trace data, payload and trace offset should be the same
+       errors += fail_not_equal( state, 0, "trace offset and payload offset do NOT match when trace data is absent" );
+
+       state = rmr_get_trlen( mbuf );
+       errors += fail_not_equal( state, 0, "initial trace len reported (a) does not match expected (b)" );
+
+       state = rmr_set_trace( NULL, src_buf, 100 );                            // coverage test on nil check
+       errors += fail_not_equal( state, 0, "set trace with nil msg didn't return expected 0 status" );
+
+       state = rmr_set_trace( mbuf, src_buf, 0 );                              // coverage test on length check
+       errors += fail_not_equal( state, 0, "set trace with 0 len didn't return expected 0 status" );
+
+       state = rmr_get_trace( NULL, src_buf, 100 );                            // coverage test on nil check
+       errors += fail_not_equal( state, 0, "get trace with nil msg didn't return expected 0 status" );
+
+       state = rmr_get_trace( mbuf, NULL, 100 );                                       // coverage test on nil check
+       errors += fail_not_equal( state, 0, "get trace with nil dest didn't return expected 0 status" );
+
+       state = rmr_get_trlen( NULL );                                                          // coverage test on nil check
+       errors += fail_not_equal( state, 0, "get trace length with nil msg didn't return expected 0 status" );
+
+
+       src_buf[0] = 0;
+       state = rmr_set_trace( mbuf, "foo bar was here", 17 );          // should force a realloc
+       errors += fail_not_equal( state, 17, "bytes copied to trace (a) did not match expected size (b)" );
+
+       state = rmr_get_trace( mbuf, src_buf, 17 );
+       errors += fail_not_equal( state, 17, "bytes retrieved from trace (a) did not match expected size (b)" );
+
+       state = rmr_get_trlen( mbuf );
+       errors += fail_not_equal( state, 17, "trace len reported (a) does not match expected (b)" );
+       state = strcmp( src_buf, "foo bar was here" );
+       errors+= fail_not_equal( state, 0, "compare of pulled trace info did not match" );
+
+       state = TRACE_OFFSET( mbuf->header ) - PAYLOAD_OFFSET( mbuf->header );          // when there is a trace area these should NOT be the same
+       errors += fail_if_equal( state, 0, "trace offset and payload offset match when trace data is present" );
+
+
+                                                                                       // second round of trace testing, allocating a message with a trace size that matches
+       mbuf = test_mk_msg( 2048, 17 );                 // trace size that matches what we'll stuff in, no realloc
+       state = rmr_get_trlen( mbuf );
+       errors += fail_not_equal( state, 17, "alloc with trace size: initial trace len reported (a) does not match expected (b)" );
+
+       src_buf[0] = 0;
+       state = rmr_set_trace( mbuf, "foo bar was here", 17 );          // should force a realloc
+       errors += fail_not_equal( state, 17, "bytes copied to trace (a) did not match expected size (b)" );
+
+       state = rmr_get_trace( mbuf, src_buf, 17 );
+       errors += fail_not_equal( state, 17, "bytes retrieved from trace (a) did not match expected size (b)" );
+       state = strcmp( src_buf, "foo bar was here" );
+       errors+= fail_not_equal( state, 0, "compare of pulled trace info did not match" );
+
+       i = rmr_get_trlen( mbuf );
+
+
+       // ------------- source field tests ------------------------------------------------------------
+       // we cannot force anything into the message source field, so no way to test the content, but we
+       // can test pointers and expected nils
+
+       buf = rmr_get_src( NULL, src_buf );                                     // coverage test for nil msg check
+       errors += fail_not_nil( buf, "rmr_get_src returned a pointer when given a nil message" );
+
+       buf = rmr_get_src( mbuf, NULL );                                        // coverage test for nil dst check
+       errors += fail_not_nil( buf, "rmr_get_src returned a pointer when given a nil dest buffer" );
+
+       buf = rmr_get_src( mbuf, src_buf );
+       errors += fail_not_equalp( buf, src_buf, "rmr_get_src didn't return expexted buffer pointer" );
+
+       buf = rmr_get_srcip( NULL, NULL );
+       errors += fail_not_nil( buf, "get_srcip did not return nil when given nil pointers" );
+
+       buf = rmr_get_srcip( mbuf, NULL );
+       errors += fail_not_nil( buf, "get_srcip did not return nil when given nil destination" );
+
+       buf = rmr_get_srcip( mbuf, src_buf );
+       errors += fail_not_equalp( buf, src_buf, "rmr_get_srcip didn't return expexted buffer pointer" );
+
+       test_set_ver( mbuf, 2 );                                                        // set older message version to ensure properly handled
+       buf = rmr_get_srcip( mbuf, src_buf );
 
        return errors > 0;                      // overall exit code bad if errors
 }
 
        return errors > 0;                      // overall exit code bad if errors
 }