X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Frmr%2Fsi%2Finclude%2Frmr_si_private.h;h=86dea8838f48de59d48fbd199545d65034b454d5;hb=refs%2Fchanges%2F34%2F6934%2F3;hp=ff5b502d2ab6d1b178c1c7d5f1fe38f6123053b4;hpb=26864559bd7ae1b0fd2054ae07c3080fa9121e08;p=ric-plt%2Flib%2Frmr.git

diff --git a/src/rmr/si/include/rmr_si_private.h b/src/rmr/si/include/rmr_si_private.h
index ff5b502..86dea88 100644
--- a/src/rmr/si/include/rmr_si_private.h
+++ b/src/rmr/si/include/rmr_si_private.h
@@ -75,7 +75,7 @@ typedef struct {
 	Callback context.
 typedef struct {
 	uta_ctx_t*	ctx;
-	
+
 } cbctx_t;
 */
 
@@ -122,7 +122,7 @@ struct uta_ctx {
 	int	shutdown;				// thread notification if we need to tell them to stop
 	int max_mlen;				// max message length payload+header
 	int	max_plen;				// max payload length
-	int	flags;					// CTXFL_ constants
+	int	flags;					// CFL_ constants
 	int nrtele;					// number of elements in the routing table
 	int send_retries;			// number of retries send_msg() should attempt if eagain/timeout indicated by nng
 	int	trace_data_len;			// number of bytes to allocate in header for trace data
@@ -130,7 +130,13 @@ struct uta_ctx {
 	int d2_len;					// extra header data 2 length	(future)
 	int	nn_sock;				// our general listen socket
 	int rtable_ready;			// set to true when rt is received or loaded
+	int snarf_rt_fd;			// the file des where we save the last rt from RM
 	int dcount;					// drop counter when app is slow
+
+	uint64_t acc_dcount;		// accumulated drop counter when app is slow
+	uint64_t acc_ecount;		// accumulated enqueue counter
+
+	char*	seed_rt_fname;		// the static/seed route table; name captured at start
 	route_table_t* rtable;		// the active route table
 	route_table_t* old_rtable;	// the previously used rt, sits here to allow for draining
 	route_table_t* new_rtable;	// route table under construction
@@ -208,4 +214,7 @@ static endpoint_t*  fd2ep_get( uta_ctx_t* ctx, int fd );
 static void fd2ep_init( uta_ctx_t* ctx );
 static void fd2ep_add( uta_ctx_t* ctx, int fd, endpoint_t* ep );
 
+// ------ misc ---------------------------------------------------
+static inline void incr_ep_counts( int state, endpoint_t* ep );		// must declare for static includes, but after headers
+
 #endif