-// : 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-2020 Nokia
+ Copyright (c) 2018-2020 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.
#include <fcntl.h>
#include <unistd.h>
+/*
+ This is ugly, but needed to allow for component testing.
+
+ The test code (e.g. foo_test.c and not foo_static_test.c) can include these
+ constants to turn off the import of test support files:
+ NO_EMULATION -- the transport emulation will not be included
+ NO_PRIVATE_HEADERS -- the private headers for the transport component of RMR
+ (e.g. si) will not be included.
+*/
+#ifndef NO_EMULATION // assume emulation unless specifically put off (love double negatives)
+ #ifdef NNG_UNDER_TEST
+ #define TP_HDR_LEN 0 // needed for support functions but nonexistant in nng world
+ #include "test_nng_em.c" // nano/ngg emulation functions
+ #else
+ #include "test_si95_em.c" // si emulation functions
+ #endif
+#endif
+
+#ifndef NO_PRIVATE_HEADERS // include transport headers unless specifically turned off
+ #ifdef NNG_UNDER_TEST
+ #include <rmr_nng_private.h> // context things are type sensitive
+ #else
+ #include "si95/socket_if.h" // need to have the si context more than anything else
+ #include <rmr_si_private.h>
+ #endif
+#endif
+
#ifndef BAD
#define BAD 1 // these are exit codes unless user overrides
#define GOOD 0
#endif
+// ----------- a couple of globals make it easier ---------------------------------------
+static int ts_tests_driven = 0; // number of fail_if calls made == numer of tests driven
+
+// ---------------------------------------------------------------------------------------
+
+/*
+ Support test counting, reset and summary.
+*/
+static int test_get_attempted() {
+ return ts_tests_driven;
+}
+
+static void test_reset_attempted() {
+ ts_tests_driven = 0;
+}
+
+static void test_summary( int ecount, char* tag ) {
+ fprintf( stderr, "<SUMMARY> %s completed; %d total tests, %d passed, %d failed\n",
+ tag, ts_tests_driven, ts_tests_driven - ecount, ecount );
+}
+
/*
Snag the optional positional parameter at pp, return defval if not there.
*/
}
+/*
+ Assert like logic except these just record the test and return state so that we
+ can attempt all tests and not abort on the first failure as an assert would do.
+*/
static int fail_if_nil( void* p, char* what ) {
+ ts_tests_driven++;
+
if( !p ) {
fprintf( stderr, "<FAIL> %s: pointer was nil\n", what );
}
}
static int fail_not_nil( void* p, char* what ) {
+ ts_tests_driven++;
+
if( p ) {
fprintf( stderr, "<FAIL> %s: pointer was not nil\n", what );
}
}
static int fail_if_false( int bv, char* what ) {
+ ts_tests_driven++;
+
if( !bv ) {
fprintf( stderr, "<FAIL> %s: expected true, boolean test was false (%d)\n", what, bv );
}
}
static int fail_if_true( int bv, char* what ) {
+ ts_tests_driven++;
+
if( bv ) {
fprintf( stderr, "<FAIL> %s: expected false, boolean test was true (%d)\n", what, bv );
}
Same as fail_if_true(), but reads easier in the test code.
*/
static int fail_if( int bv, char* what ) {
+ ts_tests_driven++;
+
if( bv ) {
fprintf( stderr, "<FAIL> %s: expected false, boolean test was true (%d)\n", what, bv );
return bv ? BAD : GOOD;
}
+static int fail_pequal( void* a, void* b, char* what ) {
+ ts_tests_driven++;
+
+ if( a == b ) {
+ fprintf( stderr, "<FAIL> %s: pointers were not equal a=%p b=%p\n", what, a, b );
+ }
+ return a == b ? GOOD : BAD; // user may override good/bad so do NOT return a==b directly!
+}
+
+static int fail_not_pequal( void* a, void* b, char* what ) {
+ ts_tests_driven++;
+
+ if( a != b ) {
+ fprintf( stderr, "<FAIL> %s: pointers were not equal a=%p b=%p\n", what, a, b );
+ }
+ return a == b ? GOOD : BAD; // user may override good/bad so do NOT return a==b directly!
+}
+
static int fail_not_equal( int a, int b, char* what ) {
+ ts_tests_driven++;
+
if( a != b ) {
fprintf( stderr, "<FAIL> %s: values were not equal a=%d b=%d\n", what, a, b );
}
}
static int fail_if_equal( int a, int b, char* what ) {
+ ts_tests_driven++;
+
if( a == b ) {
fprintf( stderr, "<FAIL> %s values were equal a=%d b=%d\n", what, a, b );
}
}
static int fail_not_equalp( void* a, void* b, char* what ) {
+ ts_tests_driven++;
+
if( a != b ) {
fprintf( stderr, "<FAIL> %s: pointers were not equal a=%p b=%p\n", what, a, b );
}
}
static int fail_if_equalp( void* a, void* b, char* what ) {
+ ts_tests_driven++;
+
if( a == b ) {
fprintf( stderr, "<FAIL> %s pointers were equal a=%p b=%p\n", what, a, b );
}
}
+// for symtab and other non-message things this allows them to exclude by setting
#ifndef NO_DUMMY_RMR
/*
Dummy message allocator for testing without sr_static functions
uta_mhdr_t* hdr;
size_t alen;
- alen = sizeof( *hdr ) + tr_len + len;
+ alen = sizeof( *hdr ) + tr_len + len + TP_HDR_LEN; // this does no support allocating len2 and len3 data fields
new_msg = (rmr_mbuf_t *) malloc( sizeof *new_msg );
+ memset( new_msg, 0, sizeof( *new_msg ) );
new_msg->tp_buf = (void *) malloc( alen );
memset( new_msg->tp_buf, 0, alen );
return;
}
-#endif
+/*
+ These allow values to be pushed deep into the real RMR header allocated
+ at the front of the transport buffer. These are needed to simulate
+ the actions of rmr_send() which pushes the values from the message buffer
+ just before putting them on the wire.
+*/
+static void test_set_mtype( rmr_mbuf_t* msg, int mtype ) {
+ uta_mhdr_t* hdr;
+
+ msg->mtype = mtype;
+ hdr = (uta_mhdr_t*) msg->tp_buf;
+ hdr->mtype = htonl( mtype );
+}
+
+static void test_set_sid( rmr_mbuf_t* msg, int sid ) {
+ uta_mhdr_t* hdr;
+
+ msg->sub_id = sid;
+ hdr = (uta_mhdr_t*) msg->tp_buf;
+ hdr->sub_id = htonl( sid );
+}
+
+static void test_set_plen( rmr_mbuf_t* msg, int plen ) {
+ uta_mhdr_t* hdr;
+
+ msg->len = plen;
+ hdr = (uta_mhdr_t*) msg->tp_buf;
+ hdr->plen = htonl( plen );
+}
+
+/*
+ Build a message and populate both the msg buffer and the tranport header
+ with mid, sid, and payload len. Tr_len causes that much space in the
+ header for trace info to be reserved.
+*/
+static rmr_mbuf_t* mk_populated_msg( int alloc_len, int tr_len, int mtype, int sid, int plen ) {
+ uta_mhdr_t* hdr;
+ rmr_mbuf_t* mbuf;
+
+ mbuf = test_mk_msg( alloc_len, tr_len );
+ test_set_mtype( mbuf, mtype );
+ test_set_sid( mbuf, sid );
+ test_set_plen( mbuf, plen );
+
+ return mbuf;
+}
+
+
+// end no dummy rmr
+#endif
#endif
Code Review / ric-plt / lib / rmr.git / blobdiff