X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=Bouncer%2Fsrc%2Fxapp-mgmt%2Fsubs_mgmt.cc;fp=Bouncer%2Fsrc%2Fxapp-mgmt%2Fsubs_mgmt.cc;h=dc6416e19946b81b020dc0b9d1c51ec35672f84f;hb=eb27c05c05b5042d115480c40cffa16e7d473d80;hp=931453f5af35994fc4977f38adb745fa6ba2ff30;hpb=c87d0bba9607c802e025053ba4cf59c5b3841ca0;p=ric-app%2Fbouncer.git diff --git a/Bouncer/src/xapp-mgmt/subs_mgmt.cc b/Bouncer/src/xapp-mgmt/subs_mgmt.cc index 931453f..dc6416e 100644 --- a/Bouncer/src/xapp-mgmt/subs_mgmt.cc +++ b/Bouncer/src/xapp-mgmt/subs_mgmt.cc @@ -116,26 +116,33 @@ bool SubscriptionHandler::is_request_entry(transaction_identifier id){ // Handles subscription responses -void SubscriptionHandler::manage_subscription_response(int message_type, transaction_identifier id){ +void SubscriptionHandler::manage_subscription_response(int message_type, transaction_identifier id) +{ // Make This Thread sleep for 1 Second - std::this_thread::sleep_for(std::chrono::milliseconds(1000)); - { - std::unique_lock _local_lock(*(_data_lock.get())); - mdclog_write(MDCLOG_INFO,"Subscription Handler: Status for meid %s WAS: %d",id.c_str(),this->get_request_status(id)); - - //from the message type we can know if its a success/failure etc. - if(message_type==RIC_SUB_RESP) - this->set_request_status(id, request_success); - - if(message_type==RIC_SUB_FAILURE) - this->set_request_status(id,request_failed); - - mdclog_write(MDCLOG_INFO,"Subscription Handler: Status for meid %s IS: %d",id.c_str(),this->get_request_status(id)); - - - //this->print_subscription_status(); - } - //_cv.get()->notify_all(); + std::this_thread::sleep_for(std::chrono::milliseconds(1000)); + { + std::unique_lock _local_lock(*(_data_lock.get())); + mdclog_write(MDCLOG_INFO,"Subscription Handler: Status for meid %s WAS: %d",id.c_str(),this->get_request_status(id)); + + //from the message type we can know if its a success/failure etc. + if(message_type==RIC_SUB_RESP) + this->set_request_status(id, request_success); + + if(message_type==RIC_SUB_DEL_RESP) + this->set_request_status(id, request_success); + + if(message_type==RIC_SUB_FAILURE) + this->set_request_status(id,request_failed); + + if(message_type==RIC_SUB_DEL_FAILURE) + this->set_request_status(id,request_failed); + + mdclog_write(MDCLOG_INFO,"Subscription Handler: Status for meid %s IS: %d",id.c_str(),this->get_request_status(id)); + + + //this->print_subscription_status(); + } + //_cv.get()->notify_all(); }