X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Ftest_support.c;h=084256f482ed4fd9c29d283ccec6112937b974c8;hb=20829ec38b851e7894883ba6b1711ccf8d05c3f4;hp=49012c4e18c42cf9c0f888de37ac1f26410e990d;hpb=d710957ed5d73bf2da2ceea3f5a1a3c509275c30;p=ric-plt%2Flib%2Frmr.git

diff --git a/test/test_support.c b/test/test_support.c
index 49012c4..084256f 100644
--- a/test/test_support.c
+++ b/test/test_support.c
@@ -1,14 +1,14 @@
 // : vi ts=4 sw=4 noet :
 /*
 ==================================================================================
-        Copyright (c) 2019 Nokia 
-        Copyright (c) 2018-2019 AT&T Intellectual Property.
+	    Copyright (c) 2019 Nokia
+	    Copyright (c) 2018-2019 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.
    You may obtain a copy of the License at
 
-       http://www.apache.org/licenses/LICENSE-2.0
+	   http://www.apache.org/licenses/LICENSE-2.0
 
    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
@@ -65,7 +65,7 @@ void sig_clean_exit( int sign ) {
 	exit( 0 );
 }
 
-/*	
+/*
 	Setup all of the signal handling for signals that we want to force a clean exit:
 	term, intr, hup, quit, usr1/2 alarm, etc.  All others we'll let default.
 */
@@ -74,7 +74,7 @@ static void set_signals( void ) {
 	int	sig_list[] = { SIGINT, SIGQUIT, SIGILL, SIGALRM, SIGTERM, SIGUSR1 , SIGUSR2 };
 	int i;
 	int nele;		// number of elements in the list
-	
+
 	nele = (int) ( sizeof( sig_list )/sizeof( int ) );		// convert raw size to the number of elements
 	for( i = 0; i < nele; i ++ ) {
 		memset( &sa, 0, sizeof( sa ) );
@@ -138,17 +138,36 @@ static int fail_if_equal( int a, int b, char* what ) {
 	return a != b ? GOOD : BAD;			// user may override good/bad so do NOT return a==b directly!
 }
 
+static int fail_not_equalp( void* a, void* b, char* what ) {
+	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_if_equalp( void* a, void* b, char* what ) {
+	if( a == b ) {
+		fprintf( stderr, "<FAIL> %s pointers were 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!
+}
+
 
+// 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
 */
+#ifndef MSG_VER
+#define MSG_VER 3
+#endif
+
 static rmr_mbuf_t* test_mk_msg( int len, int tr_len ) {
 	rmr_mbuf_t*	new_msg;
 	uta_mhdr_t* hdr;
 	size_t	alen;
 
-	alen = sizeof( *hdr ) + tr_len + len;
+	alen = sizeof( *hdr ) + tr_len + len;	// this does no support allocating len2 and len3 data fields
 
 	new_msg = (rmr_mbuf_t *) malloc( sizeof *new_msg );
 	new_msg->tp_buf = (void *) malloc( alen );
@@ -157,14 +176,77 @@ static rmr_mbuf_t* test_mk_msg( int len, int tr_len ) {
 	hdr = (uta_mhdr_t*) new_msg->tp_buf;
 	SET_HDR_LEN( hdr );
 	SET_HDR_TR_LEN( hdr, tr_len );
+	hdr->rmr_ver = htonl( MSG_VER );
+	strcpy( hdr->src, "dummyhost:1111" );
+	strcpy( hdr->srcip, "30.4.19.86:1111" );
 
 	new_msg->header = new_msg->tp_buf;
 	new_msg->payload =  new_msg->header + PAYLOAD_OFFSET( hdr );
 	new_msg->alloc_len = alen;
 	new_msg->len = 0;
-	
+
 	return new_msg;
 }
+
+static void test_set_ver( rmr_mbuf_t* msg, int ver ) {
+	uta_mhdr_t* hdr;
+
+	hdr = (uta_mhdr_t*) msg->tp_buf;
+	hdr->rmr_ver = htonl( ver );
+	strcpy( hdr->src, "dummyhost-v2:1111" );
+	strcpy( hdr->srcip, "30.4.19.86:2222" );
+
+	return;
+}
+
+/*
+	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;
+}
+
+
 #endif
 
 #endif