X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Frmr%2Fsi%2Finclude%2Frmr_si_private.h;fp=src%2Frmr%2Fsi%2Finclude%2Frmr_si_private.h;h=c816486b3abd89f4096e586ace22313f5d967332;hb=a1575dacc478b945ea63f5d0cc3db3d66dcb5983;hp=132873c61b38cb4befe33a007b657de852c7329c;hpb=bc3de17c3b959fcc6a5ba42f5d3b09402bf89687;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 132873c..c816486 100644
--- a/src/rmr/si/include/rmr_si_private.h
+++ b/src/rmr/si/include/rmr_si_private.h
@@ -48,6 +48,9 @@
 #define RS_GOOD		1		// flow is in progress
 #define RS_RESET	2		// flow was interrupted; reset on next receive
 
+#define RF_NOTIFIED	0x01	// notification made about river issue
+#define RF_DROP		0x02	// this message is large and being dropped
+
 #define SI_MAX_ADDR_LEN		512
 
 /*
@@ -58,9 +61,8 @@ typedef struct {
 	char*	accum;		// bytes being accumulated
 	int		nbytes;		// allocated size of accumulator
 	int		ipt;		// insertion point in accumulator
-	//int		max;		// size of accum
-	//int		expected;	// expected for a complete message
 	int		msg_size;	// size of the message being accumulated
+	int		flags;		// RF_* constants
 } river_t;