X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Frmr%2Fnng%2Fsrc%2Fmt_call_nng_static.c;h=325b313cd0a60e951fe4f64e9bf6425fad61d8b0;hb=f68c2ced7de2bdfc475a9282cde91a67d83325de;hp=2ef21f67066bde68c8fc1308817edb721fc62f78;hpb=412d53dfa2f9b5b56a448797d0dfec3b0f11f666;p=ric-plt%2Flib%2Frmr.git

diff --git a/src/rmr/nng/src/mt_call_nng_static.c b/src/rmr/nng/src/mt_call_nng_static.c
index 2ef21f6..325b313 100644
--- a/src/rmr/nng/src/mt_call_nng_static.c
+++ b/src/rmr/nng/src/mt_call_nng_static.c
@@ -91,13 +91,8 @@ static void* mt_receive( void* vctx ) {
 						queue_normal( ctx, mbuf );
 					} else {
 						chute = &ctx->chutes[call_id];
-						if( memcmp( mbuf->xaction, chute->expect, RMR_MAX_XID ) == 0 ) {		// match
-							chute->mbuf = mbuf;
-							sem_post( &chute->barrier );
-						} else {
-							rmr_free_msg( mbuf );
-							mbuf = NULL;
-						}
+						chute->mbuf = mbuf;
+						sem_post( &chute->barrier );				// the call function can vet xaction id in their own thread
 					}
 				}
 			}