1 // vim: ts=4 sw=4 noet:
3 --------------------------------------------------------------------------------
4 Copyright (c) 2018-2019 AT&T Intellectual Property.
6 Licensed under the Apache License, Version 2.0 (the "License");
7 you may not use this file except in compliance with the License.
8 You may obtain a copy of the License at
10 http://www.apache.org/licenses/LICENSE-2.0
12 Unless required by applicable law or agreed to in writing, software
13 distributed under the License is distributed on an "AS IS" BASIS,
14 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 See the License for the specific language governing permissions and
16 limitations under the License.
17 --------------------------------------------------------------------------------
21 Mnemonic: pipe_reader.c
22 Abstract: Read a single pipe which was associated with a message type. This
23 programme is primarily for verification or example of how to use the
24 read1() function in the mc-listener library.
27 Author: E. Scott Daniels
40 //---- support -----------------------------------------------------------------------------
42 static void bad_arg( char* what ) {
43 fprintf( stderr, "[ERR] option is unrecognised or isn't followed by meaningful data: %s\n", what );
46 static void usage( char* argv0 ) {
47 fprintf( stderr, "usage: %s [-d fifo-dir] [-e] [-m msg-type] [-s]\n", argv0 );
48 fprintf( stderr, " -d dir (default is /tmp/mcl/fifos)\n" );
49 fprintf( stderr, " -e disable extended headers expectation in FIFO data\n" );
50 fprintf( stderr, " -m msg-type (default is 0)\n" );
51 fprintf( stderr, " -s stats only mode\n" );
54 //------------------------------------------------------------------------------------------
55 int main( int argc, char** argv ) {
56 void* ctx; // the mc listener library context
57 char* dname = "/tmp/mcl/fifos"; // default directory where we open fifos
58 int pidx = 1; // parameter index
64 int long_hdrs = 1; // -e is on command line turns this off, by default we expect long headers
66 char timestamp[MCL_TSTAMP_SIZE]; // we'll get the timestamp from this
70 while( pidx < argc && argv[pidx][0] == '-' ) { // simple argument parsing (-x or -x value)
71 switch( argv[pidx][1] ) {
74 dname = strdup( argv[pidx+1] );
77 bad_arg( argv[pidx] );
92 mtype = atoi( argv[pidx+1] );
95 bad_arg( argv[pidx] );
111 bad_arg( argv[pidx] );
124 ctx = mcl_mk_context( dname ); // initialise the library context
126 fprintf( stderr, "[FAIL] couldn't initialise the mc listener library" );
131 len = mcl_fifo_tsread1( ctx, mtype, buf, sizeof( buf ) -1, long_hdrs, timestamp );
134 if( time( NULL ) > blabber ) {
135 fprintf( stdout, "[%d] %ld messages received\n", mtype, count );
136 blabber = time( NULL ) + 2;
140 fprintf( stdout, "[%d] ts=%s count=%ld len=%d msg=%s\n", mtype, timestamp, count, len, buf );
150 fprintf( stderr, "[INFO] mc listener is finished.\n" );