X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=examples%2Freceiver.c;h=215fd54cd100bcadcb7d06acb0cb76dae806f285;hb=69d7bfd7bbe046dda3afa50e0362448d60301258;hp=1808f330a66dcc890a39231979fd16b27a9dbeee;hpb=d52954976038217d6067bc6e8e83d0ca882f9b6b;p=ric-plt%2Flib%2Frmr.git diff --git a/examples/receiver.c b/examples/receiver.c index 1808f33..215fd54 100644 --- a/examples/receiver.c +++ b/examples/receiver.c @@ -1,14 +1,14 @@ // :vim 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, @@ -49,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; @@ -68,7 +68,7 @@ int main( int argc, char** argv ) { fprintf( stderr, " listening on port: %s\n", listen_port ); fprintf( stderr, " 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, " ABORT: unable to initialise RMr\n" ); exit( 1 ); @@ -80,7 +80,7 @@ int main( int argc, char** argv ) { } fprintf( stderr, " 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 ) { @@ -97,6 +97,6 @@ int main( int argc, char** argv ) { fprintf( stderr, " total msg received: %lld errors: %lld empty: %lld\n", count, bad, empty ); } - } + } }