X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Frmr%2Fsi%2Fsrc%2Fsr_si_static.c;h=bc3b53ead9ab66e5aaa5217fc71aca2c58e2082a;hb=b4ed359628db76a6afe4758599dc9b6b32c6f34a;hp=b56b6dc77820ac6b577c3f8fc9748e9b636f71fd;hpb=5ec64c5253b3b7611ec69cc1487989fae45eca26;p=ric-plt%2Flib%2Frmr.git

diff --git a/src/rmr/si/src/sr_si_static.c b/src/rmr/si/src/sr_si_static.c
index b56b6dc..bc3b53e 100644
--- a/src/rmr/si/src/sr_si_static.c
+++ b/src/rmr/si/src/sr_si_static.c
@@ -673,11 +673,12 @@ static rmr_mbuf_t* send_msg( uta_ctx_t* ctx, rmr_mbuf_t* msg, int nn_sock, int r
 			rmr_free_msg( msg );						// not wanting a meessage back, trash this one
 			return NULL;
 		}
-	} else {											// send failed -- return original message
-		if( msg->state == 98 ) {		// FIX ME: this is just broken, but needs SI changes to work correctly for us
+	} else {											// send failed or would block -- return original message
+		if( state == SI_ERR_BLOCKED || errno == EAGAIN ) {
 			errno = EAGAIN;
-			msg->state = RMR_ERR_RETRY;					// errno will have nano reason
+			msg->state = RMR_ERR_RETRY;
 		} else {
+			rmr_vlog( RMR_VL_WARN, "send failed: mt=%d errno=%d %s\n", msg->mtype, errno, strerror( errno ) );
 			msg->state = RMR_ERR_SENDFAILED;
 		}