X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Fhdr_static_test.c;fp=test%2Fhdr_static_test.c;h=9d7a38c39c0fb6bc4eef5e750f2de6cce0af1ef2;hb=8dd46415b94b33fa960bdd5732e909ffc4859520;hp=0000000000000000000000000000000000000000;hpb=68c5cf1104e89f5c43786a3e48f5c6a1e757f59f;p=ric-plt%2Flib%2Frmr.git

diff --git a/test/hdr_static_test.c b/test/hdr_static_test.c
new file mode 100644
index 0000000..9d7a38c
--- /dev/null
+++ b/test/hdr_static_test.c
@@ -0,0 +1,112 @@
+// : vi ts=4 sw=4 noet :
+/*
+==================================================================================
+        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
+
+   Unless required by applicable law or agreed to in writing, software
+   distributed under the License is distributed on an "AS IS" BASIS,
+   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+   See the License for the specific language governing permissions and
+   limitations under the License.
+==================================================================================
+*/
+
+/*
+	Mmemonic:	hdr_static_test.c
+	Abstract:	This tests specific properties of the message header
+
+	Author:		E. Scott Daniels
+	Date:		12 April 2019
+*/
+
+#include <unistd.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <strings.h>
+#include <errno.h>
+#include <string.h>
+#include <stdint.h>
+#include <netdb.h>
+
+#include <nng/nng.h>
+#include <nng/protocol/pubsub0/pub.h>
+#include <nng/protocol/pubsub0/sub.h>
+#include <nng/protocol/pipeline0/push.h>
+#include <nng/protocol/pipeline0/pull.h>
+
+#include "../src/common/include/rmr.h"
+#include "../src/common/include/rmr_agnostic.h"
+#include "../src/nng/include/rmr_nng_private.h"
+
+#define EMULATE_NNG
+#include "test_nng_em.c"
+#include "../src/nng/src/sr_nng_static.c"
+
+#include "test_support.c"
+
+/*
+	Dummy for testing here
+*/
+extern void rmr_free_msg( rmr_mbuf_t* mbuf ) {
+}
+
+static int hdr_test( ) {
+	int errors = 0;
+	uta_ctx_t*	ctx;
+	rmr_mbuf_t*	msg;
+	uta_mhdr_t*	hdr;
+	int hlen;
+	int len;
+	int	payload_len = 2049;
+	int trace_len = 37;
+
+	ctx = (uta_ctx_t *) malloc( sizeof( *ctx ) );
+	ctx->trace_data_len = 0;
+	ctx->my_name = strdup( "my-dummy-host-name-and-port:xxxx" );
+
+	msg = alloc_zcmsg( ctx, NULL, payload_len, 0 );				// header len here should just be len of our struct
+	hdr = (uta_mhdr_t *) msg->header;
+	hlen = RMR_HDR_LEN( hdr );
+
+	fprintf( stderr, "<INFO> struct len= %d  msg len= %d %d\n", (int) sizeof( uta_mhdr_t ), hlen, htonl( hlen ) );
+	errors += fail_not_equal( hlen, (int) sizeof( uta_mhdr_t ), "header len (a) not size of struct when no trace data is present" );
+
+	len = (int) sizeof( uta_mhdr_t ) + payload_len;					// expected size of transport buffer allocated
+	errors += fail_not_equal( len, msg->alloc_len, "alloc len (a)  not expected size" );
+
+
+	ctx->trace_data_len = trace_len;		// alloc messages with tracing buffer in place
+	msg = alloc_zcmsg( ctx, NULL, payload_len, 0 );				// header len here should just be len of our struct
+	hdr = (uta_mhdr_t *) msg->header;
+	hlen = RMR_HDR_LEN( hdr );
+	fprintf( stderr, "<INFO> with trace data: struct+trace len= %d  msg len= %d %d\n", (int) sizeof( uta_mhdr_t )+trace_len, hlen, htonl( hlen ) );
+	errors += fail_not_equal( hlen, (int) sizeof( uta_mhdr_t ) + trace_len, "header len (a) was not header + trace data size (b)" );
+
+	len = RMR_TR_LEN( hdr );
+	errors += fail_not_equal( len, trace_len, "trace len in header (a) not expected value (b)" );
+
+	len = RMR_D1_LEN( hdr );
+	errors += fail_not_equal( len, 0, "d1 len in header (a) not expected value (b)" );
+
+	len = RMR_D2_LEN( hdr );
+	errors += fail_not_equal( len, 0, "d2 len in header (a) not expected value (b)" );
+
+
+	// -------------------------------------------------------------------------------------------
+
+	if( ! errors ) {
+		fprintf( stderr, "<INFO> all msg header tests pass\n" );
+	}
+	return !! errors;
+}
+
+int main() {
+	return hdr_test();
+}