diff --git a/srsgnb/hdr/stack/ric/ric_subscription.h b/srsgnb/hdr/stack/ric/ric_subscription.h index adbec6e14..1f6b55797 100644 --- a/srsgnb/hdr/stack/ric/ric_subscription.h +++ b/srsgnb/hdr/stack/ric/ric_subscription.h @@ -31,8 +31,8 @@ public: uint32_t get_ric_requestor_id() { return ric_requestor_id; }; uint32_t get_ric_instance_id() { return ric_instance_id; }; - void start_ric_indication_reporting(); - void stop_ric_indication_reporting(); + void start_subscription(); + void delete_subscription(); private: void send_ric_indication(); diff --git a/srsgnb/src/stack/ric/ric_client.cc b/srsgnb/src/stack/ric/ric_client.cc index 7d5658bee..8765d0111 100644 --- a/srsgnb/src/stack/ric/ric_client.cc +++ b/srsgnb/src/stack/ric/ric_client.cc @@ -272,7 +272,7 @@ bool ric_client::handle_ric_subscription_request(ricsubscription_request_s ric_s std::unique_ptr new_ric_subs = std::make_unique(this, ric_subscription_request); - new_ric_subs->start_ric_indication_reporting(); + new_ric_subs->start_subscription(); active_subscriptions.push_back(std::move(new_ric_subs)); return true; } @@ -289,7 +289,7 @@ bool ric_client::handle_ric_subscription_delete_request(ricsubscription_delete_r if ((**it).get_ric_requestor_id() == ricsubscription_delete_request->ri_crequest_id->ric_requestor_id and (**it).get_ric_instance_id() == ricsubscription_delete_request->ri_crequest_id->ric_instance_id) { ric_subs_found = true; - (**it).stop_ric_indication_reporting(); + (**it).delete_subscription(); active_subscriptions.erase(it); break; } diff --git a/srsgnb/src/stack/ric/ric_subscription.cc b/srsgnb/src/stack/ric/ric_subscription.cc index 09d212783..0060f3ac8 100644 --- a/srsgnb/src/stack/ric/ric_subscription.cc +++ b/srsgnb/src/stack/ric/ric_subscription.cc @@ -64,7 +64,7 @@ ric_client::ric_subscription::ric_subscription(ric_client* ric_cli } } -void ric_client::ric_subscription::start_ric_indication_reporting() +void ric_client::ric_subscription::start_subscription() { parent->logger.debug("Send RIC Subscription Response to RIC Requestor ID: %i\n", ric_requestor_id); ric_subscription_reponse_t ric_subscription_reponse; @@ -91,7 +91,7 @@ void ric_client::ric_subscription::start_ric_indication_reporting() } } -void ric_client::ric_subscription::stop_ric_indication_reporting() +void ric_client::ric_subscription::delete_subscription() { if (reporting_timer.is_running()) { parent->logger.debug("Stop sending RIC indication msgs");