1 // : vi ts=4 sw=4 noet :
3 ==================================================================================
4 Copyright (c) 2019 Nokia
5 Copyright (c) 2018-2019 AT&T Intellectual Property.
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
11 http://www.apache.org/licenses/LICENSE-2.0
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 ==================================================================================
22 Mmemonic: rt_static_test.c
23 Abstract: Test the route table funcitons. These are meant to be included at compile
24 time by the test driver.
26 Author: E. Scott Daniels
38 #include "../src/common/include/rmr.h"
39 #include "../src/common/include/rmr_agnostic.h"
41 typedef struct entry_info {
48 This is the main route table test. It sets up a very specific table
49 for testing (not via the generic setup function for other test
52 static int rt_test( ) {
53 uta_ctx_t* ctx; // context needed to test load static rt
54 route_table_t* rt; // route table
55 route_table_t* crt; // cloned route table
56 rtable_ent_t* rte; // entry in the table
57 endpoint_t* ep; // endpoint added
58 int more = 0; // more flag from round robin
59 int errors = 0; // number errors found
65 ei_t entries[50]; // end point information
66 int gcounts[5]; // number of groups in this set
67 int ecounts[5]; // number of elements per group
68 int mtypes[5]; // msg type for each group set
74 char* seed_fname; // seed file
75 nng_socket nn_sock; // this is a struct in nng, so difficult to validate
77 setenv( "ENV_VERBOSE_FILE", ".ut_rmr_verbose", 1 ); // allow for verbose code in rtc to be driven
78 i = open( ".ut_rmr_verbose", O_RDWR | O_CREAT, 0644 );
84 gcounts[0] = 1; // build entry info -- this is hackish, but saves writing another parser
87 entries[enu].group = 0; entries[enu].ep_name = "yahoo.com:4561"; enu++; // use a dns resolvable name to test that
88 entries[enu].group = 0; entries[enu].ep_name = "localhost:4562"; enu++; // rest can default to some dummy ip
93 entries[enu].group = 0; entries[enu].ep_name = "localhost:4561"; enu++;
94 entries[enu].group = 0; entries[enu].ep_name = "localhost:4568"; enu++;
95 entries[enu].group = 0; entries[enu].ep_name = "localhost:4569"; enu++;
97 gcounts[2] = 0; // 0 groups means use same rte, this is the next gropup
100 entries[enu].group = 1; entries[enu].ep_name = "localhost:4561"; enu++;
101 entries[enu].group = 1; entries[enu].ep_name = "localhost:4562"; enu++;
103 gcounts[3] = 1; // 0 groups means use same rte, this is the next gropup
106 entries[enu].group = 0; entries[enu].ep_name = "localhost:4563"; enu++;
107 entries[enu].group = 0; entries[enu].ep_name = "localhost:4564"; enu++;
109 gcounts[4] = 1; // 0 groups means use same rte, this is the next gropup
112 entries[enu].group = 0; entries[enu].ep_name = "localhost:4565"; enu++;
116 rt = uta_rt_init( ); // get us a route table
117 if( (errors += fail_if_nil( rt, "pointer to route table" )) ) {
118 fprintf( stderr, "<FAIL> abort: cannot continue without a route table\n" );
124 for( i = 0; i < sizeof( gcounts )/sizeof( int ); i++ ) { // add entries defined above
126 rte = uta_add_rte( rt, mtypes[i], gcounts[i] ); // get/create entry for message type
127 if( (errors += fail_if_nil( rte, "route table entry" )) ) {
128 fprintf( stderr, "<FAIL> abort: cannot continue without a route table entry\n" );
133 fprintf( stderr, "<SNAFU> internal testing error -- rte was nil for gcount == 0\n" );
138 for( k = 0; k < ecounts[i]; k++ ) {
139 ep = uta_add_ep( rt, rte, entries[enu].ep_name, entries[enu].group );
140 errors += fail_if_nil( ep, "endpoint" );
145 crt = uta_rt_clone( rt );
146 errors += fail_if_nil( crt, "cloned route table" );
148 ep = uta_get_ep( rt, "localhost:4561" );
149 errors += fail_if_nil( ep, "end point (fetch by name)" );
150 ep = uta_get_ep( rt, "bad_name:4560" );
151 errors += fail_not_nil( ep, "end point (fetch by name with bad name)" );
153 state = uta_epsock_byname( rt, "localhost:4561", &nn_sock ); // this should be found
154 errors += fail_if_equal( state, 0, "socket (by name)" );
155 //alt_value = uta_epsock_byname( rt, "localhost:4562" ); // we might do a memcmp on the two structs, but for now nothing
156 //errors += fail_if_equal( value, alt_value, "app1/app2 sockets" );
159 for( i = 0; i < 10; i++ ) { // round robin return value should be different each time
160 value = uta_epsock_rr( rt, 1, 0, &more, &nn_sock ); // msg type 1, group 1
161 errors += fail_if_equal( value, alt_value, "round robiin sockets with multiple end points" );
162 errors += fail_if_false( more, "more for mtype==1" );
167 for( i = 0; i < 10; i++ ) { // this mtype has only one endpoint, so rr should be same each time
168 value = uta_epsock_rr( rt, 3, 0, NULL, &nn_sock ); // also test ability to deal properly with nil more pointer
170 errors += fail_not_equal( value, alt_value, "round robin sockets with one endpoint" );
171 errors += fail_not_equal( more, -1, "more value changed in single group instance" );
176 value = uta_epsock_rr( rt, 9, 0, &more, &nn_sock ); // non-existant message type; should return false (0)
177 errors += fail_not_equal( value, 0, "socket for bad mtype was valid" );
179 uta_rt_clone( NULL ); // verify null parms don't crash things
181 uta_epsock_rr( NULL, 1, 0, &more, &nn_sock ); // drive null case for coverage
182 uta_add_rte( NULL, 99, 1 );
184 fprintf( stderr, "[INFO] test: adding end points with nil data; warnings expected\n" );
185 uta_add_ep( NULL, NULL, "foo", 1 );
186 uta_add_ep( rt, NULL, "foo", 1 );
188 buf = uta_fib( ".gitignore" );
189 errors += fail_if_nil( buf, "buffer from read file into buffer" );
193 buf = uta_fib( "no-file" );
194 errors += fail_if_nil( buf, "buffer from read file into buffer (no file)" );
203 if( (ctx = (uta_ctx_t *) malloc( sizeof( uta_ctx_t ) )) != NULL ) {
204 memset( ctx, 0, sizeof( *ctx ) );
206 if( (seed_fname = getenv( "RMR_SEED_RT" )) != NULL ) {
207 if( ! (fail_if_nil( rt, "pointer to rt for load test" )) ) {
209 read_static_rt( ctx, 0 );
210 unsetenv( "RMR_SEED_RT" ); // unset to test the does not exist condition
211 read_static_rt( ctx, 0 );
213 fprintf( stderr, "<FAIL> cannot gen rt for load test\n" );
216 read_static_rt( ctx, 0 ); // not defined, just drive for that one case
220 uta_fib( "no-suhch-file" ); // drive some error checking for coverage
224 if( ctx->rtg_addr ) {
225 free( ctx->rtg_addr );
231 return !!errors; // 1 or 0 regardless of count