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=9816c16c8a9134166314d2c8660eac1508c02e57;hb=refs%2Fchanges%2F23%2F5523%2F1;hp=f125efb701cd16884b9991630b8a48909f4a57b1;hpb=f4a2227da63b7dd64310d24b285cffb44d159746;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 f125efb..9816c16 100644
--- a/src/rmr/si/include/rmr_si_private.h
+++ b/src/rmr/si/include/rmr_si_private.h
@@ -56,6 +56,7 @@
 
 
 #define SI_MAX_ADDR_LEN		512
+#define MAX_RIVERS			1024	// max number of directly mapped rivers
 
 /*
 	Manages a river of inbound bytes.
@@ -153,6 +154,7 @@ struct uta_ctx {
 	si_ctx_t*	si_ctx;			// the socket context
 	int			nrivers;		// allocated rivers
 	river_t*	rivers;			// inbound flows (index is the socket fd)
+	void*		river_hash;		// flows with fd values > nrivers must be mapped through the hash
 	int			max_ibm;		// max size of an inbound message (river accum alloc size)
 	void*		zcb_mring;		// zero copy buffer mbuf ring
 	void*		fd2ep;				// the symtab mapping file des to endpoints for cleanup on disconnect