Code Review
/
ric-plt
/
lib
/
rmr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Prevent message truncation by populate function
[ric-plt/lib/rmr.git]
/
test
/
rmr_nng_test.c
diff --git
a/test/rmr_nng_test.c
b/test/rmr_nng_test.c
index
5dbeb21
..
fb12ec2
100644
(file)
--- a/
test/rmr_nng_test.c
+++ b/
test/rmr_nng_test.c
@@
-51,6
+51,8
@@
#include <stdint.h>
#include <ctype.h>
#include <sys/epoll.h>
#include <stdint.h>
#include <ctype.h>
#include <sys/epoll.h>
+#include <pthread.h>
+#include <semaphore.h>
#define DEBUG 1
#define DEBUG 1
@@
-64,14
+66,14
@@
#include "test_nng_em.c" // nng/nn emulation (before including things under test)
#include "test_nng_em.c" // nng/nn emulation (before including things under test)
-#include "
../src/common/include/rmr.h"
// things the users see
-#include "
../src/common/include/
rmr_symtab.h"
-#include "
../src/common/include/rmr_agnostic.h"
// transport agnostic header
-#include "
../src/nng/include/rmr_nng_private.h"
// transport specific
+#include "
rmr.h"
// things the users see
+#include "rmr_symtab.h"
+#include "
rmr_agnostic.h"
// transport agnostic header
+#include "
rmr_nng_private.h"
// transport specific
-#include "
../src/common/src/
symtab.c"
-#include "
../src/nng/src/
rmr_nng.c"
-#include "
../src/common/src/
mbuf_api.c"
+#include "symtab.c"
+#include "rmr_nng.c"
+#include "mbuf_api.c"
static void gen_rt( uta_ctx_t* ctx ); // defined in sr_nng_static_test, but used by a few others (eliminate order requirement below)
static void gen_rt( uta_ctx_t* ctx ); // defined in sr_nng_static_test, but used by a few others (eliminate order requirement below)
@@
-94,42
+96,46
@@
static void gen_rt( uta_ctx_t* ctx ); // defined in sr_nng_static_test, but use
int main() {
int errors = 0;
int main() {
int errors = 0;
- fprintf( stderr, "<INFO> starting tool tests\n" );
+ fprintf( stderr, "
\n
<INFO> starting tool tests\n" );
errors += tools_test();
fprintf( stderr, "<INFO> error count: %d\n", errors );
errors += tools_test();
fprintf( stderr, "<INFO> error count: %d\n", errors );
- fprintf( stderr, "<INFO> starting ring tests (%d)\n", errors );
+ fprintf( stderr, "
\n
<INFO> starting ring tests (%d)\n", errors );
errors += ring_test();
fprintf( stderr, "<INFO> error count: %d\n", errors );
errors += ring_test();
fprintf( stderr, "<INFO> error count: %d\n", errors );
- fprintf( stderr, "<INFO> starting symtab tests\n" );
+ fprintf( stderr, "
\n
<INFO> starting symtab tests\n" );
errors += symtab_test( );
fprintf( stderr, "<INFO> error count: %d\n", errors );
errors += symtab_test( );
fprintf( stderr, "<INFO> error count: %d\n", errors );
- fprintf( stderr, "<INFO> starting rtable tests\n" );
+ fprintf( stderr, "
\n
<INFO> starting rtable tests\n" );
errors += rt_test(); // route table tests
fprintf( stderr, "<INFO> error count: %d\n", errors );
errors += rt_test(); // route table tests
fprintf( stderr, "<INFO> error count: %d\n", errors );
- fprintf( stderr, "<INFO> starting RMr API tests\n" );
+ fprintf( stderr, "\n<INFO> starting RMr API tests\n" );
+ errors += rmr_api_test();
+
+ fprintf( stderr, "\n<INFO> run RMr API tests with src name only env var set\n" );
+ setenv( "RMR_SRC_NAMEONLY", "1", 1 );
errors += rmr_api_test();
fprintf( stderr, "<INFO> error count: %d\n", errors );
errors += rmr_api_test();
fprintf( stderr, "<INFO> error count: %d\n", errors );
- fprintf( stderr, "<INFO> starting wormhole tests\n" );
+ fprintf( stderr, "
\n
<INFO> starting wormhole tests\n" );
errors += worm_test(); // test wormhole funcitons
fprintf( stderr, "<INFO> error count: %d\n", errors );
errors += worm_test(); // test wormhole funcitons
fprintf( stderr, "<INFO> error count: %d\n", errors );
- fprintf( stderr, "<INFO> starting send/receive tests\n" );
+ fprintf( stderr, "
\n
<INFO> starting send/receive tests\n" );
errors += sr_nng_test(); // test the send/receive static functions
fprintf( stderr, "<INFO> error count: %d\n", errors );
errors += sr_nng_test(); // test the send/receive static functions
fprintf( stderr, "<INFO> error count: %d\n", errors );
- fprintf( stderr, "<INFO> starting mbuf api tests\n" );
+ fprintf( stderr, "
\n
<INFO> starting mbuf api tests\n" );
errors += mbuf_api_test( );
fprintf( stderr, "<INFO> error count: %d\n", errors );
if( errors == 0 ) {
errors += mbuf_api_test( );
fprintf( stderr, "<INFO> error count: %d\n", errors );
if( errors == 0 ) {
- fprintf( stderr, "<PASS> all tests were OK\n" );
+ fprintf( stderr, "<PASS> all tests were OK\n
\n
" );
} else {
} else {
- fprintf( stderr, "<FAIL> %d modules reported errors\n", errors );
+ fprintf( stderr, "<FAIL> %d modules reported errors\n
\n
", errors );
}
return !!errors;
}
return !!errors;