--- /dev/null
+// vim: ts=4 sw=4 noet:
+/*
+--------------------------------------------------------------------------------
+ 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: pipe_reader.c
+ Abstract: Read a single pipe which was associated with a message type. This
+ programme is primarily for verification or example of how to use the
+ read1() function in the mc-listener library.
+
+ Date: 22 August 2019
+ Author: E. Scott Daniels
+*/
+
+#include <unistd.h>
+#include <errno.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <time.h>
+#include <string.h>
+
+
+#include "mcl.h"
+
+//---- support -----------------------------------------------------------------------------
+
+static void bad_arg( char* what ) {
+ fprintf( stderr, "[ERR] option is unrecognised or isn't followed by meaningful data: %s\n", what );
+}
+
+static void usage( char* argv0 ) {
+ fprintf( stderr, "usage: %s [-d fifo-dir] [-e] [-m msg-type] [-s]\n", argv0 );
+ fprintf( stderr, " -d dir (default is /tmp/mcl/fifos)\n" );
+ fprintf( stderr, " -e disable extended headers expectation in FIFO data\n" );
+ fprintf( stderr, " -m msg-type (default is 0)\n" );
+ fprintf( stderr, " -s stats only mode\n" );
+}
+
+//------------------------------------------------------------------------------------------
+int main( int argc, char** argv ) {
+ void* ctx; // the mc listener library context
+ char* dname = "/tmp/mcl/fifos"; // default directory where we open fifos
+ int pidx = 1; // parameter index
+ int error = 0;
+ int len;
+ int mtype = 0;
+ char buf[4096];
+ int flush_often = 0;
+ int long_hdrs = 1; // -e is on command line turns this off, by default we expect long headers
+ int stats_only = 0;
+ char timestamp[MCL_TSTAMP_SIZE]; // we'll get the timestamp from this
+ long count = 0;
+ int blabber = 0;
+
+ while( pidx < argc && argv[pidx][0] == '-' ) { // simple argument parsing (-x or -x value)
+ switch( argv[pidx][1] ) {
+ case 'd':
+ if( pidx+1 < argc ) {
+ dname = strdup( argv[pidx+1] );
+ pidx++;
+ } else {
+ bad_arg( argv[pidx] );
+ error = 1;
+ }
+ break;
+
+ case 'e':
+ long_hdrs = 0;
+ break;
+
+ case 'f':
+ flush_often = 1;
+ break;
+
+ case 'm':
+ if( pidx+1 < argc ) {
+ mtype = atoi( argv[pidx+1] );
+ pidx++;
+ } else {
+ bad_arg( argv[pidx] );
+ error = 1;
+ }
+ break;
+
+ case 's':
+ stats_only = 1;
+ break;
+
+ case 'h':
+ case '?':
+ usage( argv[0] );
+ exit( 0 );
+ break;
+
+ default:
+ bad_arg( argv[pidx] );
+ error = 1;
+ break;
+ }
+
+ pidx++;
+ }
+
+ if( error ) {
+ usage( argv[0] );
+ exit( 1 );
+ }
+
+ ctx = mcl_mk_context( dname ); // initialise the library context
+ if( ctx == NULL ) {
+ fprintf( stderr, "[FAIL] couldn't initialise the mc listener library" );
+ exit( 1 );
+ }
+
+ while( 1 ) {
+ len = mcl_fifo_tsread1( ctx, mtype, buf, sizeof( buf ) -1, long_hdrs, timestamp );
+ if( len > 0 ) {
+ if( stats_only ) {
+ if( time( NULL ) > blabber ) {
+ fprintf( stdout, "[%d] %ld messages received\n", mtype, count );
+ blabber = time( NULL ) + 2;
+ }
+ } else {
+ buf[len] = 0;
+ fprintf( stdout, "[%d] ts=%s count=%ld len=%d msg=%s\n", mtype, timestamp, count, len, buf );
+ if( flush_often ) {
+ fflush( stdout );
+ }
+ }
+
+ count++;
+ }
+ }
+
+ fprintf( stderr, "[INFO] mc listener is finished.\n" );
+}
+
Code Review / ric-app / mc.git / blobdiff