blob: 1ebdb94e308ac6798e8ffd8e4bf640376726fc8c [file] [log] [blame]
E. Scott Daniels8dd46412019-04-16 20:47:54 +00001// :vi sw=4 ts=4 noet:
2/*
3==================================================================================
4 Copyright (c) 2019 Nokia
5 Copyright (c) 2018-2019 AT&T Intellectual Property.
6
7 Licensed under the Apache License, Version 2.0 (the "License");
8 you may not use this file except in compliance with the License.
9 You may obtain a copy of the License at
10
11 http://www.apache.org/licenses/LICENSE-2.0
12
13 Unless required by applicable law or agreed to in writing, software
14 distributed under the License is distributed on an "AS IS" BASIS,
15 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 See the License for the specific language governing permissions and
17 limitations under the License.
18==================================================================================
19*/
20
21/*
22 Mmemonic: rmr_nng_test.c
23 Abstract: This tests the whole rmr nng implementation. This driver
24 includes all of the module specific unit test static files
25 (e.g. wormhole_static_test.c) and drives the tests contained
26 there. The individual modules allow them to be driven by
27 a standalone driver, and to be maintained separately. We must
28 test by inclusion because of the static nature of the internal
29 functions of the library.
30
31 Author: E. Scott Daniels
32 Date: 18 January 2018 (IMO HRTL)
33*/
34
35#include <stdio.h>
36#include <stdlib.h>
37#include <netdb.h>
38#include <errno.h>
39#include <string.h>
40#include <errno.h>
41#include <pthread.h>
42#include <ctype.h>
43
44
45#include <unistd.h>
46#include <stdio.h>
47#include <stdlib.h>
48#include <strings.h>
49#include <errno.h>
50#include <string.h>
51#include <stdint.h>
52#include <ctype.h>
53#include <sys/epoll.h>
54
55#define DEBUG 1
56
57#include <nng/nng.h>
58#include <nng/protocol/pubsub0/pub.h>
59#include <nng/protocol/pubsub0/sub.h>
60#include <nng/protocol/pipeline0/push.h>
61#include <nng/protocol/pipeline0/pull.h>
62
63#define EMULATE_NNG
64#include "test_nng_em.c" // nng/nn emulation (before including things under test)
65
66
67#include "../src/common/include/rmr.h" // things the users see
68#include "../src/common/include/rmr_symtab.h"
69#include "../src/common/include/rmr_agnostic.h" // transport agnostic header
70#include "../src/nng/include/rmr_nng_private.h" // transport specific
71
72#include "../src/common/src/symtab.c"
73#include "../src/nng/src/rmr_nng.c"
74
75static void gen_rt( uta_ctx_t* ctx ); // defined in sr_nng_static_test, but used by a few others (eliminate order requirement below)
76
77 // specific test tools in this directory
78#include "test_support.c" // things like fail_if()
79 // and finally....
80#include "tools_static_test.c" // local test functions pulled directly because of static nature of things
81#include "symtab_static_test.c"
82#include "ring_static_test.c"
83#include "rt_static_test.c"
84#include "sr_nng_static_test.c"
85#include "wormhole_static_test.c"
86#include "rmr_nng_api_static_test.c"
87
88
89/*
90 Drive each of the separate tests and report.
91*/
92int main() {
93 int errors = 0;
94
95 fprintf( stderr, "<INFO> starting tool tests\n" );
96 errors += tools_test();
97 fprintf( stderr, "<INFO> error count: %d\n", errors );
98
99 fprintf( stderr, "<INFO> starting ring tests (%d)\n", errors );
100 errors += ring_test();
101 fprintf( stderr, "<INFO> error count: %d\n", errors );
102
103 fprintf( stderr, "<INFO> starting symtab tests\n" );
104 errors += symtab_test( );
105 fprintf( stderr, "<INFO> error count: %d\n", errors );
106
107 fprintf( stderr, "<INFO> starting rtable tests\n" );
108 errors += rt_test(); // route table tests
109 fprintf( stderr, "<INFO> error count: %d\n", errors );
110
111 fprintf( stderr, "<INFO> starting RMr API tests\n" );
112 errors += rmr_api_test();
113 fprintf( stderr, "<INFO> error count: %d\n", errors );
114
115 fprintf( stderr, "<INFO> starting wormhole tests\n" );
116 errors += worm_test(); // test wormhole funcitons
117 fprintf( stderr, "<INFO> error count: %d\n", errors );
118
119 fprintf( stderr, "<INFO> starting send/receive tests\n" );
120 errors += sr_nng_test(); // test the send/receive static functions
121 fprintf( stderr, "<INFO> error count: %d\n", errors );
122
123 if( errors == 0 ) {
124 fprintf( stderr, "<PASS> all tests were OK\n" );
125 } else {
126 fprintf( stderr, "<FAIL> %d modules reported errors\n", errors );
127 }
128
129 return !!errors;
130}