debug: add more print

setup/xapp-sm-connector/src/hw_xapp_main.cc

@@ -30,6 +30,7 @@ void signalHandler( int signum ) {
 }
 
 int main(int argc, char *argv[]){
+	std::cout << "hw_xapp_main Running";
 
 	// Get the thread id
 	std::thread::id my_id = std::this_thread::get_id();
@@ -71,7 +72,9 @@ int main(int argc, char *argv[]){
 
 	sleep(1);
 	//Startup E2 subscription and A1 policy
-	//hw_xapp->startup(std::ref(*sub_handler));
+    std::cout << "Startup E2 subscription and A1 policy";
+
+	hw_xapp->startup(std::ref(*sub_handler));
 
 	//start listener threads and register message handlers.
 	int num_threads = std::stoi(config[XappSettings::SettingName::THREADS]);

setup/xapp-sm-connector/src/xapp.cc

@@ -87,6 +87,8 @@ void Xapp::stop(void){
 
 void Xapp::startup(SubscriptionHandler &sub_ref) {
 
+    std::cout << "Startup beeing called";
+
 	subhandler_ref = &sub_ref;
 
     if (GNB_ID == "") {
@@ -118,7 +120,15 @@ void Xapp::startup(SubscriptionHandler &sub_ref) {
         std::cout << "Querying target gNB" << std::endl;
         rnib_gnblist.push_back(GNB_ID);
     }
+    while (
+            true
+        )
+        {
+            std::cout << "Send sub. req.";
+            std::cout << "yeet";
 
+        	startup_subscribe_requests();
+        }
     // open external control socket in thread and wait for message
     ext_control_thr_rx = std::unique_ptr<std::thread>(new std::thread{&Xapp::handle_external_control_message, this, SOCKET_PORT_EXT});
 
@@ -135,7 +145,16 @@ void Xapp::startup(SubscriptionHandler &sub_ref) {
     // send_socket("Hello, Server!", AGENT_1);
 
 	//send subscriptions.
-	startup_subscribe_requests();
+    while (
+        true
+    )
+    {
+        std::cout << "Send sub. req.";
+        std::cout << "yeet";
+
+    	startup_subscribe_requests();
+    }
+    
 
 	//read A1 policies
 	// startup_get_policies();
@@ -417,7 +436,7 @@ void Xapp::send_ric_control_request(char* payload, std::string gnb_id) {
 }
 
 void Xapp::startup_subscribe_requests(void ){
-
+    std::cout << "Startup subscribe request \n";
     bool res;
     size_t data_size = ASN_BUFF_MAX_SIZE;
     unsigned char	data[data_size];
@@ -432,11 +451,12 @@ void Xapp::startup_subscribe_requests(void ){
 
     if(sz <= 0)
        mdclog_write(MDCLOG_INFO,"Subscriptions cannot be sent as GNBList in RNIB is NULL");
-
+    std::cout << "pre for loop \n";
     for(int i = 0; i<sz; i++){
         std::cout << "Sending subscriptions to: " << gnblist[i] << std::endl;
 
         // give the message to subscription handler, along with the transmitter.
+
         strcpy((char*)meid,gnblist[i].c_str());
 
         // char *strMsg = "Subscription Request from HelloWorld XApp\0";
@@ -483,6 +503,7 @@ void Xapp::startup_subscribe_requests(void ){
             mdclog_write(MDCLOG_INFO,"Subscription SUCCESSFUL in file= %s, line=%d for MEID %s",__FILE__,__LINE__, meid);
         }
     }
+    std::cout << "Finisched subscribe request \n";
 }
 
 void Xapp::startup_get_policies(void){