X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=src%2Fhw_xapp_main.cc;h=aa51d201e78e657fee9b07125f5749900baf4223;hb=91d30a6530398a9c7e50a15ea1cf9a027953bd39;hp=624d88fc467aa22e429e7a0a5d2620614eef5d42;hpb=b85024cd183a527cd8d61353637850cb6d30cf36;p=ric-app%2Fhw.git diff --git a/src/hw_xapp_main.cc b/src/hw_xapp_main.cc index 624d88f..aa51d20 100644 --- a/src/hw_xapp_main.cc +++ b/src/hw_xapp_main.cc @@ -61,35 +61,16 @@ int main(int argc, char *argv[]){ std::unique_ptr hw_xapp = std::make_unique(std::ref(config),std::ref(*rmr)); + //hw_xapp->startup(); - //register MsgHandler plugin for a received rmr_buffer - std::unique_ptr mp_handler = std::make_unique(); - hw_xapp->register_handler(std::bind(&XappMsgHandler::operator (),mp_handler.get(),std::placeholders::_1,std::placeholders::_2)); - - rmr->set_listen(true); - hw_xapp->start_xapp_receiver(std::ref(*mp_handler)); - - sleep(5); - + std::unique_ptr mp_handler = std::make_unique(config[XappSettings::SettingName::XAPP_ID]); + //hw_xapp->register_handler(std::bind(&XappMsgHandler::operator (),mp_handler.get(),std::placeholders::_1,std::placeholders::_2)); + hw_xapp->start_xapp_receiver(std::ref(*mp_handler)); //Delete all subscriptions if any based on Xapp Mode. //xapp->shutdown(); - xapp_rmr_header hdr; - hdr.message_type = RIC_HEALTH_CHECK_REQ; - - char *strMsg = "HelloWorld: RMR Health Check\0"; - - clock_gettime(CLOCK_REALTIME, &(hdr.ts)); - hdr.payload_length = strlen(strMsg); - - bool res = rmr->xapp_rmr_send(&hdr,(void*)strMsg); - - if (!res){ - std::cout << "Xapp RMR Send Failure"; - } - usleep(10); - while(1){ + while(1){ sleep(1); }