X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Ftest_nng_em.c;h=fc6030146a352c2ff2c8c4d0cce9fcbe8cd80a87;hb=ab6d04ce30514b16ba5821fcc788157b4779a4a3;hp=f1976b91cb8dfa6ddcb8b2ad53ba18de5dc133e2;hpb=5efb1e608cf966752c02b676d6fae09f951f71e9;p=ric-plt%2Flib%2Frmr.git diff --git a/test/test_nng_em.c b/test/test_nng_em.c index f1976b9..fc60301 100644 --- a/test/test_nng_em.c +++ b/test/test_nng_em.c @@ -29,19 +29,58 @@ Author: E. Scott Daniels */ + +#include "rmr.h" // we use some of rmr defs in building dummy messages, so we need these +#include "rmr_agnostic.h" + // ---------------------- emulated nng functions --------------------------- #ifndef _em_nn #define _em_nn +#include + static int em_send_failures = 0; // test programme can set this to emulate eagain send failures static int em_timeout = -1; // set by set socket option +static int em_mtc_msgs = 0; // set to generate 'received' messages with mt-call header data +static int return_value = 0; // functions should return this value +static int rcv_count = 0; // receive counter for transaction id to allow test to rest +static int rcv_delay = 0; // forced delay before call to rcvmsg starts to work + +static int gates_ok = 0; +static pthread_mutex_t rcv_gate; +static int em_gen_long_hostname = 0; // if set the emulated hostname generates a longer name (>40 char) + + +// ----------- gethostname emulation --------------------------------------- +#define gethostname em_gethostname +static int em_gethostname( char* buf, size_t len ) { + if( len < 1 ) { + errno = EINVAL; + return 1; + } + + if( em_gen_long_hostname ) { + snprintf( buf, len, "hostname-which-is-long-a860430b890219-dfw82" ); + } else { + snprintf( buf, len, "em-hostname" ); + } + + return 0; +} + +static int em_set_long_hostname( int v ) { + em_gen_long_hostname = !!v; +} // ----------- epoll emulation --------------------------------------------- -// CAUTION: sys/epoll.h must be included before this define and function will properly compile. +// CAUTION: sys/epoll.h must be included before these define and function will properly compile. #define epoll_wait em_wait +#define epoll_ctl em_ep_ctl +#define epoll_create em_ep_create + /* Every other call returns 1 ready; alternate calls return 0 ready. Mostly for testing the timeout receive call. First call should return @@ -55,6 +94,14 @@ static int em_wait( int fd, void* events, int n, int to ) { return ready; } +int em_ep_ctl( int epfd, int op, int fd, struct epoll_event *event ) { + return 0; +} + +int em_ep_create( int size ) { + return 0; +} + /* @@ -78,7 +125,7 @@ struct em_msg { we don't add a payload even if setting a v1 type. */ #define ALT_MSG_VER 1 // alternate every so often -#define MSG_VER 2 // default version to insert +#define MSG_VER 3 // default version to insert struct em_msg { int32_t mtype; // message type ("long" network integer) int32_t plen; // payload length @@ -95,17 +142,15 @@ struct em_msg { int32_t len1; // length of the tracing data int32_t len2; // length of data 1 (d1) int32_t len3; // length of data 2 (d2) + int32_t sub_id; // subscription id (-1 invalid) + // V3 stuff + unsigned char srcip[64]; // sender ID for return to sender needs }; -static int return_value = 0; -//-------------------------------------------------------------------------- -#ifdef EMULATE_NNG -struct nn_msghdr { - int boo; -}; +// -- emulation control functions ------------------------------------------------------ /* Test app can call this to have all emulated functions return failure instead @@ -122,38 +167,119 @@ static int em_nng_foo() { } +/* + Turns on/off the generation of multi-threaded call messages +*/ +static int em_set_mtc_msgs( int state ) { + em_mtc_msgs = state; +} + +/* + Returns the size of the header we inserted +*/ +static int em_hdr_size() { + if( em_mtc_msgs ) { + return (int) sizeof( struct em_msg ) + 4; + } + + return (int) sizeof( struct em_msg ); +} + +static void em_set_rcvcount( int v ) { + rcv_count = v; +} + +static void em_set_rcvdelay( int v ) { + if( v < 0 ) { + fprintf( stderr, " ##ERR## attempt to set receive delay with invalid value was ignored: %d seconds\n", v ); + return; + } + fprintf( stderr, " receive delay is now %d seconds\n", v ); + rcv_delay = v; +} + +static void em_start() { + if( ! gates_ok ) { + pthread_mutex_init( &rcv_gate, NULL ); + gates_ok = 1; + } +} + +//-------------------------------------------------------------------------- +#ifdef EMULATE_NNG +struct nn_msghdr { + int boo; +}; + + /* Receive message must allocate a new buffer and return the pointer into *m. Every 9 messages or so we'll simulate an old version message + + If em_mtc_msgs is set, then we add a non-zero d1 field with + the call-id set to 2, and alternate the call flag */ static int em_nng_recvmsg( nng_socket s, nng_msg ** m, int i ) { + static int call_flag = 0; + void* b; struct em_msg* msg; - static int count = 0; // we'll simulate a message going in by dropping an rmr-ish msg with transaction id only int trace_size = 0; + int d1_size = 0; + unsigned char* d1; - //sleep( 1 ); + if( rcv_delay > 0 ) { + sleep( rcv_delay ); + } + + if( em_mtc_msgs ) { + d1_size = 4; + } - b = (void *) malloc( 2048 ); if( m != NULL ) { + b = (void *) malloc( 2048 ); memset( b, 0, 2048 ); + *m = (nng_msg *) b; msg = (struct em_msg *) b; - if( count % 10 == 9 ) { - //msg->rmr_ver = htonl( MSG_VER ); - msg->rmr_ver = ALT_MSG_VER; // emulate the bug in RMr v1 + if( ! em_mtc_msgs && (rcv_count % 10) == 9 ) { + msg->rmr_ver = ALT_MSG_VER; // allow emulation the bug in RMr v1 } else { msg->rmr_ver = htonl( MSG_VER ); } + msg->mtype = htonl( 1 ); msg->plen = htonl( 220 ); msg->len0 = htonl( sizeof( struct em_msg ) ); msg->len1 = htonl( trace_size ); - snprintf( msg->xid, 32, "%015d", count++ ); // simple transaction id so we can test receive specific and ring stuff - snprintf( msg->src, 16, "localhost:4562" ); // set src id (unrealistic) so that rts() can be tested + msg->len2 = htonl( d1_size ); + msg->len3 = htonl( 0 ); + + pthread_mutex_lock( &rcv_gate ); // hold lock to update counter/flag + if( em_mtc_msgs ) { + d1 = DATA1_ADDR( msg ); + d1[0] = 2; // simulated msgs always on chute 2 + if( call_flag ) { + rcv_count++; + msg->flags |= HFL_CALL_MSG; + } + if( rcv_delay > 0 ) { + fprintf( stderr, " count=%d flag=%d %02x \n", rcv_count, call_flag, msg->flags ); + } + call_flag = !call_flag; + } else { + rcv_count++; + } + pthread_mutex_unlock( &rcv_gate ); + snprintf( msg->xid, 32, "%015d", rcv_count ); // simple transaction id so we can test receive specific and ring stuff + snprintf( msg->src, 64, "localhost:4562" ); // set src id (unrealistic) so that rts() can be tested + snprintf( msg->srcip, 64, "89.2.19.19:4562" ); // set src ip for rts testing + + //fprintf( stderr, ">>> simulated received message: %s %s p=%p len0=%d\n", msg->src, msg->srcip, msg, (int) ntohl( msg->len0 ) ); + } else { + fprintf( stderr, " em: simulated receive no msg pointer provided\n" ); } - //fprintf( stderr, ">>> simulated received message: %s\n", msg->xid ); return return_value; } @@ -199,10 +325,10 @@ static int em_nng_sub0_open(nng_socket * s ) { return return_value; } static int em_nng_recv(nng_socket s, void * v, size_t * t, int i ) { - return return_value; } static int em_nng_send( nng_socket s, void* m, int l, int f ) { + free( m ); // we must ditch the message as nng does (or reuses) return return_value; } @@ -244,13 +370,11 @@ static int em_nng_msg_alloc( nng_msg** mp, size_t l ) { */ static void em_nng_free( void* p, size_t l ) { if( p ) { - //fprintf( stderr, ">>>>> not freed: %p\n", p ); free( p ); } } static void em_nng_msg_free( void* p ) { if( p ) { - //fprintf( stderr, ">>>>> not freed: %p\n", p ); free( p ); } } @@ -371,6 +495,7 @@ static int em_nn_recv (int s, void *m, size_t len, int flags ) { static int count = 0; // we'll simulate a message going in by dropping an rmr-ish msg with transaction id only int trace_size = 0; static int counter = 0; // if timeout value is set; we return timeout (eagain) every 3 calls + int d1_size = 0; if( em_timeout > 0 ) { counter++; @@ -379,6 +504,10 @@ static int em_nn_recv (int s, void *m, size_t len, int flags ) { } } + if( em_mtc_msgs ) { + d1_size = 4; + } + b = (void *) malloc( 2048 ); if( m != NULL ) { // blindly we assume this is 2k or bigger memset( m, 0, 2048 ); @@ -393,14 +522,17 @@ static int em_nn_recv (int s, void *m, size_t len, int flags ) { msg->plen = htonl( 220 ); msg->len0 = htonl( sizeof( struct em_msg ) ); msg->len1 = htonl( trace_size ); + msg->len2 = htonl( d1_size ); + msg->len3 = htonl( 0 ); snprintf( msg->xid, 32, "%015d", count++ ); // simple transaction id so we can test receive specific and ring stuff - snprintf( msg->src, 16, "localhost:4562" ); // set src id (unrealistic) so that rts() can be tested + snprintf( msg->src, 64, "localhost:4562" ); // set src id (unrealistic) so that rts() can be tested + snprintf( msg->srcip, 64, "89.2.19.19:4562" ); // set src ip for rts testing //fprintf( stderr, " returning message len=%d\n\n", ntohl( msg->plen ) ); } else { fprintf( stderr, " message was nil\n\n" ); } - //fprintf( stderr, ">>> simulated received message: %s len=%d\n", msg->xid, msg->plen ); + //fprintf( stderr, ">>> simulated received message: %s %s len=%d p=%p\n", msg->src, msg->srcip, ntohl( msg->plen ), m ); return 2048; } @@ -413,6 +545,7 @@ static int em_nn_recvmsg (int s, struct nn_msghdr *msghdr, int flags ) { } static void em_nn_freemsg( void* ptr ) { + free( ptr ); return; }