X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fsidecars%2Flistener%2Fmcl.h;fp=src%2Fsidecars%2Flistener%2Fmcl.h;h=249e851e28a1fa6dc8bcff8118696c801e61045e;hb=5f75c08e01fa73a8f54dd0d474c0a50b8dd23845;hp=0000000000000000000000000000000000000000;hpb=59f84608ec15c016958a6e0e0ddd813f376c0925;p=ric-app%2Fmc.git

diff --git a/src/sidecars/listener/mcl.h b/src/sidecars/listener/mcl.h
new file mode 100644
index 0000000..249e851
--- /dev/null
+++ b/src/sidecars/listener/mcl.h
@@ -0,0 +1,57 @@
+// 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:	mcl.h
+	Abstract:	Header file for the mc listener library.
+	Date:		22 August 2019
+	Author:		E. Scott Daniels
+	
+*/
+
+#ifndef mcl_h
+#define mcl_h
+
+#include <rmr/rmr.h>
+#include <rmr/rmr_symtab.h>
+
+// ------- public constants and structs -------------------------------------------------
+
+#define MCL_LEN_SIZE 8		// number of bytes the length has in both short and extended header
+#define MCL_DELIM_SIZE	4	// number of bytes in extended header delimiter
+#define MCL_TSTAMP_SIZE	16	// number of bytes in extended header timestamp
+#define MCL_EXHDR_SIZE	(MCL_DELIM_SIZE+MCL_LEN_SIZE+MCL_TSTAMP_SIZE)	// total size of extended header
+
+#define MCL_DELIM		"@MCL"		// delimeter to synch msgs in fifo
+
+#define MCL_TSTAMP_OFF	(MCL_DELIM_SIZE+MCL_LEN_SIZE)					// offsets in header
+#define MCL_LEN_OFF		MCL_DELIM_SIZE
+
+#define MCL_NOWAIT	0	// do not wait for RMR route table to arrive
+#define MCL_WAIT	1	// block reader start until RMR route table is initialised
+
+//------------ prototypes --------------------------------------------------------------
+extern void mcl_fifo_fanout( void* ctx, int report, int long_hdrs );
+extern rmr_mbuf_t* mcl_get_msg( void* vctx, rmr_mbuf_t* msg, int timeout );
+extern	void* mcl_mk_context( char* dir );
+extern int mcl_fifo_read1( void* vctx, int mtype, char* ubuf, int ublen, int long_hdr );
+extern int mcl_fifo_tsread1( void* vctx, int mtype, char* ubuf, int ublen, int long_hdr, char* timestamp );
+extern int mcl_set_sigh( );
+extern int mcl_start_listening( void* vctx, char* port, int wait4ready );
+
+#endif