X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=examples%2Freceiver.c;h=215fd54cd100bcadcb7d06acb0cb76dae806f285;hb=ec88d3c0563eeb6ae5f73427edb0b3c4d7acf299;hp=c78c710981bcc4d70a3305fff94deaa2caafd7b3;hpb=fd9cc7a5b3355146388ebdf4d558cb284c66c5f1;p=ric-plt%2Flib%2Frmr.git

diff --git a/examples/receiver.c b/examples/receiver.c
index c78c710..215fd54 100644
--- a/examples/receiver.c
+++ b/examples/receiver.c
@@ -1,4 +1,23 @@
 // :vim 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.
+==================================================================================
+*/
+
 /*
 	Mnemonic:	rmr_rcvr.c
 	Abstract:	This is a very simple receiver that does nothing but listen
@@ -30,12 +49,12 @@
 
 
 int main( int argc, char** argv ) {
-    void* mrc;      					// msg router context
+	void* mrc;      					// msg router context
 	long long total = 0;
-    rmr_mbuf_t* msg = NULL;				// message received
+	rmr_mbuf_t* msg = NULL;				// message received
 	int stat_freq = 10;				// write stats after reciving this many messages
 	int i;
-	char*	listen_port;
+	char*	listen_port = "4560";		// default to what has become the standard RMR port
 	long long count = 0;
 	long long bad = 0;
 	long long empty = 0;
@@ -49,7 +68,7 @@ int main( int argc, char** argv ) {
 	fprintf( stderr, "<DEMO> listening on port: %s\n", listen_port );
 	fprintf( stderr, "<DEMO> stats will be reported every %d messages\n", stat_freq );
 
-    mrc = rmr_init( listen_port, RMR_MAX_RCV_BYTES, RMRFL_NONE );	// start your engines!
+	mrc = rmr_init( listen_port, RMR_MAX_RCV_BYTES, RMRFL_NONE );	// start your engines!
 	if( mrc == NULL ) {
 		fprintf( stderr, "<DEMO> ABORT:  unable to initialise RMr\n" );
 		exit( 1 );
@@ -61,7 +80,7 @@ int main( int argc, char** argv ) {
 	}
 	fprintf( stderr, "<DEMO> rmr now shows ready\n" );
 
-    while( 1 ) {											// forever; ctl-c, kill -15, etc to end
+	while( 1 ) {											// forever; ctl-c, kill -15, etc to end
 		msg = rmr_rcv_msg( mrc, msg );						// block until one arrives
 		
 		if( msg ) {
@@ -78,6 +97,6 @@ int main( int argc, char** argv ) {
 			fprintf( stderr, "<DEMO> total msg received: %lld  errors: %lld   empty: %lld\n", count, bad, empty );
 		}
 
-    }
+	}
 }