X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=Bouncer%2Fsrc%2Fxapp-utils%2Fxapp_rmr.cc;fp=Bouncer%2Fsrc%2Fxapp-utils%2Fxapp_rmr.cc;h=d31a54fcf407633534b378f8b459629642f53f42;hb=beb35192344dcb74d0cf98ecc22645827d74871f;hp=31cf774a68e7ed442b4a0d9065e138d69fb28bce;hpb=ff20129c8f517cca6e0b4de6544ff64aebe7c171;p=ric-app%2Fbouncer.git diff --git a/Bouncer/src/xapp-utils/xapp_rmr.cc b/Bouncer/src/xapp-utils/xapp_rmr.cc index 31cf774..d31a54f 100644 --- a/Bouncer/src/xapp-utils/xapp_rmr.cc +++ b/Bouncer/src/xapp-utils/xapp_rmr.cc @@ -19,6 +19,8 @@ #include "xapp_rmr.hpp" +#include +#define RMR_MAX_XID 32 XappRmr::XappRmr(std::string port, int rmrattempts){ @@ -74,7 +76,9 @@ bool XappRmr::rmr_header(xapp_rmr_header *hdr){ _xapp_send_buff->len = hdr->payload_length; _xapp_send_buff->sub_id = -1; rmr_str2meid(_xapp_send_buff, hdr->meid); - + rmr_str2xact(_xapp_send_buff, hdr->meid); + + mdclog_write(MDCLOG_INFO,"hdr->meid = %s",hdr->meid); return true; } @@ -103,6 +107,17 @@ bool XappRmr::xapp_rmr_send(xapp_rmr_header *hdr, void *payload){ return false; } + mdclog_write(MDCLOG_INFO,"------ start of Xid updated, file= %s, line=%d",__FILE__,__LINE__); + int test_support_xact_count = rand(); + char *xid = (char *) malloc( sizeof( char ) * RMR_MAX_SRC ); + memset(xid, '\0',RMR_MAX_SRC); + snprintf(xid, RMR_MAX_XID, "%010d", test_support_xact_count ); + + mdclog_write(MDCLOG_INFO,"before xapp_send_buff Xid=%s, file= %s, line=%d",xid,__FILE__,__LINE__); + memcpy(_xapp_send_buff->xaction, xid, RMR_MAX_XID); + + mdclog_write(MDCLOG_INFO,"Xid=%s, file= %s, line=%d",_xapp_send_buff->xaction,__FILE__,__LINE__); + memcpy(_xapp_send_buff->payload, payload, hdr->payload_length); _xapp_send_buff->len = hdr->payload_length; @@ -120,6 +135,7 @@ bool XappRmr::xapp_rmr_send(xapp_rmr_header *hdr, void *payload){ } else if (_xapp_send_buff->state == RMR_OK){ mdclog_write(MDCLOG_INFO,"Message Sent: RMR State = RMR_OK"); + mdclog_write(MDCLOG_INFO,"_xapp_send_buff->xaction: %s",_xapp_send_buff->xaction); rmr_attempts = 0; _xapp_send_buff = NULL; return true;