Incorporating RMR Health check code

[ric-app/hw.git] / src / xapp-utils / xapp_rmr.cc

diff --git a/src/xapp-utils/xapp_rmr.cc b/src/xapp-utils/xapp_rmr.cc
index f757667..c822e55 100755 (executable)
--- a/src/xapp-utils/xapp_rmr.cc
+++ b/src/xapp-utils/xapp_rmr.cc
@@ -20,15 +20,15 @@
 
 #include "xapp_rmr.hpp"
 
-XappRmr::XappRmr(std::string xname, std::string port, int rmrattempts){
+XappRmr::XappRmr(std::string port, int rmrattempts){
 
        _proto_port = port;
-       _xapp_name = xname;
        _nattempts = rmrattempts;
        _xapp_rmr_ctx = NULL;
        _xapp_received_buff = NULL;
        _xapp_send_buff =NULL;
        _rmr_is_ready = false;
+       _listen = false;
 
 };
 
@@ -65,57 +65,95 @@ void XappRmr::xapp_rmr_init(){
        return;
 
 }
-
+//RMR Returning to the sender.
 bool XappRmr::xapp_rmr_rts()
 {
-       _xapp_send_buff = rmr_realloc_payload( _xapp_send_buff, 128, false, false );  // ensure payload is large enough
-       strncpy( (char*)_xapp_send_buff->payload, "OK\n", rmr_payload_size( _xapp_send_buff) );
-       rmr_rts_msg(_xapp_rmr_ctx, _xapp_send_buff );
-       _xapp_send_buff = NULL;
+       mdclog_write(MDCLOG_INFO,"RMR Return to sender, file= %s, line=%d",__FILE__,__LINE__);
+       if ( _xapp_rmr_ctx == NULL){
+                       mdclog_write(MDCLOG_ERR,"Error Initializing RMR, file= %s, line=%d",__FILE__,__LINE__);
+       }
+       while( ! rmr_ready(_xapp_rmr_ctx) ) {
+                       mdclog_write(MDCLOG_INFO,">>> waiting for RMR, file= %s, line=%d",__FILE__,__LINE__);
+                       sleep(1);
+       }
+       rmr_rts_msg(_xapp_rmr_ctx, _xapp_received_buff );
+       sleep(1);
        return true;
 }
 
 //RMR Send with payload and header.
 bool XappRmr::xapp_rmr_send(xapp_rmr_header *hdr, void *payload){
 
+       int rmr_attempts = _nattempts;
+
        if( _xapp_send_buff == NULL ) {
                _xapp_send_buff = rmr_alloc_msg(_xapp_rmr_ctx, RMR_DEF_SIZE);
        }
-
-
        _xapp_send_buff->mtype  = hdr->message_type;
-
        memcpy(_xapp_send_buff->payload, payload, hdr->payload_length);
-
        _xapp_send_buff->len = hdr->payload_length;
+
        if(!_rmr_is_ready) {
                mdclog_write(MDCLOG_ERR,"RMR Context is Not Ready in SENDER, file= %s, line=%d",__FILE__,__LINE__);
                return false;
        }
-       if( _xapp_send_buff == NULL ) {
-               return false;
-       }
 
-
-       while(_nattempts > 0){
+       while(rmr_attempts > 0){
                _xapp_send_buff = rmr_send_msg(_xapp_rmr_ctx,_xapp_send_buff);
 
                if(!_xapp_send_buff) {
-                       mdclog_write(MDCLOG_ERR,"Error In Sending Message , file= %s, line=%d",__FILE__,__LINE__);
-                       _nattempts--;
+                       mdclog_write(MDCLOG_ERR,"Error In Sending Message , file= %s, line=%d, attempt=%d",__FILE__,__LINE__,rmr_attempts);
+                       rmr_attempts--;
                }
                else if (_xapp_send_buff->state == RMR_OK){
-                       mdclog_write(MDCLOG_INFO,"The okay message is %d, file= %s, line=%d", RMR_OK, __FILE__,__LINE__);
-                       _nattempts = 0;
+                       mdclog_write(MDCLOG_INFO,"Message Sent: RMR State = RMR_OK");
+                       rmr_attempts = 0;
+                       _xapp_send_buff = NULL;
                        return true;
                }
                else
                {
-                       mdclog_write(MDCLOG_INFO,"Need to retry RMR MSG NUM %d, file= %s, line=%d",_xapp_send_buff->state, __FILE__,__LINE__);
-                       _nattempts--;
+                       mdclog_write(MDCLOG_INFO,"Need to retry RMR: state=%d, attempt=%d, file=%s, line=%d",_xapp_send_buff->state, rmr_attempts,__FILE__,__LINE__);
+                       rmr_attempts--;
                }
                sleep(1);
        }
        return false;
 }
 
+//----------------------------------------
+// Some get/set methods
+//---------------------------------------
+bool XappRmr::get_listen(void){
+  return _listen;
+}
+
+
+void XappRmr::set_listen(bool listen){
+  _listen = listen;
+}
+
+int XappRmr::get_is_ready(void){
+  return _rmr_is_ready;
+}
+
+bool XappRmr::get_isRunning(void){
+  return _listen;
+}
+
+
+void * XappRmr::get_rmr_context(void){
+  return _xapp_rmr_ctx;
+}
+
+
+void init_logger(const char  *AppName, mdclog_severity_t log_level)
+{
+    mdclog_attr_t *attr;
+    mdclog_attr_init(&attr);
+    mdclog_attr_set_ident(attr, AppName);
+    mdclog_init(attr);
+    mdclog_level_set(log_level);
+    mdclog_attr_destroy(attr);
+}
+