--- /dev/null
+/*
+# ==================================================================================
+# Copyright (c) 2020 HCL Technologies Limited.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ==================================================================================
+*/
+
+#include "xapp.hpp"
+#define BUFFER_SIZE 1024
+
+ Xapp::Xapp(XappSettings &config, XappRmr &rmr){
+
+ rmr_ref = &rmr;
+ config_ref = &config;
+ xapp_mutex = NULL;
+ subhandler_ref = NULL;
+ return;
+ }
+
+Xapp::~Xapp(void){
+
+ //Joining the threads
+ int threadcnt = xapp_rcv_thread.size();
+ for(int i=0; i<threadcnt; i++){
+ if(xapp_rcv_thread[i].joinable())
+ xapp_rcv_thread[i].join();
+ }
+ xapp_rcv_thread.clear();
+
+ if(xapp_mutex!=NULL){
+ xapp_mutex->~mutex();
+ delete xapp_mutex;
+ }
+};
+
+//Stop the xapp. Note- To be run only from unit test scripts.
+void Xapp::stop(void){
+ // Get the mutex lock
+ std::lock_guard<std::mutex> guard(*xapp_mutex);
+ rmr_ref->set_listen(false);
+ rmr_ref->~XappRmr();
+
+ //Detaching the threads....not sure if this is the right way to stop the receiver threads.
+ //Hence function should be called only in Unit Tests
+ int threadcnt = xapp_rcv_thread.size();
+ for(int i=0; i<threadcnt; i++){
+ xapp_rcv_thread[i].detach();
+ }
+ sleep(10);
+}
+
+void Xapp::startup(SubscriptionHandler &sub_ref) {
+
+ subhandler_ref = &sub_ref;
+ set_rnib_gnblist();
+
+ sleep(70);
+
+ //send subscriptions.
+ startup_subscribe_requests();
+
+ //read A1 policies
+ //startup_get_policies();
+ return;
+}
+void Xapp::Run(){
+ rmr_ref->set_listen(true);
+ if(xapp_mutex == NULL){
+ xapp_mutex = new std::mutex();
+ }
+ std::lock_guard<std::mutex> guard(*xapp_mutex);
+
+ for(int j=0; j < _callbacks.size(); j++){
+ std::thread th_recv([&](){ rmr_ref->xapp_rmr_receive(std::move(_callbacks[j]), rmr_ref);});
+ xapp_rcv_thread.push_back(std::move(th_recv));
+ }
+
+ return;
+}
+
+//Starting a seperate single receiver
+void Xapp::start_xapp_receiver(XappMsgHandler& mp_handler){
+ //start a receiver thread. Can be multiple receiver threads for more than 1 listening port.
+ rmr_ref->set_listen(true);
+ if(xapp_mutex == NULL){
+ xapp_mutex = new std::mutex();
+ }
+
+ mdclog_write(MDCLOG_INFO,"Receiver Thread file= %s, line=%d",__FILE__,__LINE__);
+ std::lock_guard<std::mutex> guard(*xapp_mutex);
+ std::thread th_recv([&](){ rmr_ref->xapp_rmr_receive(std::move(mp_handler), rmr_ref);});
+ xapp_rcv_thread.push_back(std::move(th_recv));
+ return;
+}
+
+void Xapp::shutdown(){
+ return;
+}
+
+
+void Xapp::startup_subscribe_requests(void ){
+
+ bool res;
+ size_t data_size = ASN_BUFF_MAX_SIZE;
+ unsigned char data[data_size];
+ unsigned char meid[RMR_MAX_MEID];
+ std::string xapp_id = config_ref->operator [](XappSettings::SettingName::XAPP_ID);
+
+ mdclog_write(MDCLOG_INFO,"Preparing to send subscription in file= %s, line=%d",__FILE__,__LINE__);
+
+ auto gnblist = get_rnib_gnblist();
+
+ int sz = gnblist.size();
+
+ if(sz <= 0)
+ mdclog_write(MDCLOG_INFO,"Subscriptions cannot be sent as GNBList in RNIB is NULL");
+
+ for(int i = 0; i<sz; i++){
+
+ //give the message to subscription handler, along with the transmitter.
+ strcpy((char*)meid,gnblist[i].c_str());
+
+
+ subscription_helper din;
+ subscription_helper dout;
+
+ subscription_request sub_req;
+ subscription_request sub_recv;
+
+ unsigned char buf[BUFFER_SIZE];
+ size_t buf_size = BUFFER_SIZE;
+ bool res;
+
+
+ //Random Data for request
+ int request_id = 1;
+ int function_id = 0;
+ std::string event_def = "01";
+
+ din.set_request(request_id);
+ din.set_function_id(function_id);
+ din.set_event_def(event_def.c_str(), event_def.length());
+
+ std::string act_def = "01";
+
+ din.add_action(1,0,(void*)act_def.c_str(), act_def.length(), 0);
+
+ res = sub_req.encode_e2ap_subscription(&buf[0], &buf_size, din);
+
+ xapp_rmr_header rmr_header;
+ rmr_header.message_type = RIC_SUB_REQ;
+ rmr_header.payload_length = buf_size; //data_size
+ strcpy((char*)rmr_header.meid,gnblist[i].c_str());
+
+ mdclog_write(MDCLOG_INFO,"Sending subscription in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
+
+ auto transmitter = std::bind(&XappRmr::xapp_rmr_send,rmr_ref, &rmr_header, (void*)buf );//(void*)data);
+
+ int result = subhandler_ref->manage_subscription_request(gnblist[i], transmitter);
+
+ if(result==SUBSCR_SUCCESS){
+ mdclog_write(MDCLOG_INFO,"Subscription SUCCESSFUL in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
+ }
+ else {
+ mdclog_write(MDCLOG_ERR,"Subscription FAILED in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
+ }
+ }
+
+}
+
+void Xapp::startup_get_policies(void){
+
+ int policy_id = BOUNCER_POLICY_ID;
+
+ std::string policy_query = "{\"policy_type_id\":" + std::to_string(policy_id) + "}";
+ unsigned char * message = (unsigned char *)calloc(policy_query.length(), sizeof(unsigned char));
+ memcpy(message, policy_query.c_str(), policy_query.length());
+ xapp_rmr_header header;
+ header.payload_length = policy_query.length();
+ header.message_type = A1_POLICY_QUERY;
+ mdclog_write(MDCLOG_INFO, "Sending request for policy id %d\n", policy_id);
+ rmr_ref->xapp_rmr_send(&header, (void *)message);
+ free(message);
+
+}
+
+void Xapp::set_rnib_gnblist(void) {
+
+ openSdl();
+
+ void *result = getListGnbIds();
+ if(strlen((char*)result) < 1){
+ mdclog_write(MDCLOG_ERR, "ERROR: no data from getListGnbIds\n");
+ return;
+ }
+
+ mdclog_write(MDCLOG_INFO, "GNB List in R-NIB %s\n", (char*)result);
+
+
+ Document doc;
+ ParseResult parseJson = doc.Parse<kParseStopWhenDoneFlag>((char*)result);
+ if (!parseJson) {
+ std::cerr << "JSON parse error: %s (%u)", GetParseErrorFunc(parseJson.Code());
+ return;
+ }
+
+ if(!doc.HasMember("gnb_list")){
+ mdclog_write(MDCLOG_INFO, "JSON Has No GNB List Object");
+ return;
+ }
+ assert(doc.HasMember("gnb_list"));
+
+ const Value& gnblist = doc["gnb_list"];
+ if (gnblist.IsNull())
+ return;
+
+ if(!gnblist.IsArray()){
+ mdclog_write(MDCLOG_INFO, "GNB List is not an array");
+ return;
+ }
+
+
+ assert(gnblist.IsArray());
+ for (SizeType i = 0; i < gnblist.Size(); i++) // Uses SizeType instead of size_t
+ {
+ assert(gnblist[i].IsObject());
+ const Value& gnbobj = gnblist[i];
+ assert(gnbobj.HasMember("inventory_name"));
+ assert(gnbobj["inventory_name"].IsString());
+ std::string name = gnbobj["inventory_name"].GetString();
+ rnib_gnblist.push_back(name);
+
+ }
+ closeSdl();
+ return;
+
+}
+
+
+
+
+
+
Code Review / ric-app / bouncer.git / blobdiff