add error handling to TTCN3 socket handlers

srsue/test/ttcn3/hdr/ttcn3_ip_ctrl_interface.h

@@ -118,7 +118,9 @@ private:
     std::string resp = ttcn3_helpers::get_drbmux_common_ind_cnf();
 
     log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-    srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+    if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+      log->error("Error sending message to tester.\n");
+    };
   }
 };
 

srsue/test/ttcn3/hdr/ttcn3_ip_sock_interface.h

@@ -127,7 +127,9 @@ private:
     string resp = ttcn3_helpers::get_ctrl_cnf(protocol.GetString(), ip_version, addr.GetString());
 
     log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-    srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+    if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+      log->error("Error sending message to tester.\n");
+    }
   }
 };
 

srsue/test/ttcn3/hdr/ttcn3_srb_interface.h

@@ -52,7 +52,9 @@ public:
   {
     if (running) {
       log->info_hex(pdu->msg, pdu->N_bytes, "Sending %d B to Titan\n", pdu->N_bytes);
-      srslte_netsource_write(&net_source, (void*)pdu->msg, pdu->N_bytes);
+      if (srslte_netsource_write(&net_source, (void*)pdu->msg, pdu->N_bytes) != SRSLTE_SUCCESS) {
+        log->error("Error sending message to tester.\n");
+      };
     } else {
       log->error("Trying to transmit but port not connected.\n");
     }

srsue/test/ttcn3/hdr/ttcn3_sys_interface.h

@@ -113,7 +113,9 @@ private:
       std::string resp = ttcn3_helpers::get_basic_sys_req_cnf(cell_name.GetString(), "Cell");
 
       log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-      srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+      if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+        log->error("Error sending message to tester.\n");
+      }
     }
   }
 
@@ -125,7 +127,9 @@ private:
     std::string resp = ttcn3_helpers::get_basic_sys_req_cnf(cell_id, "Cell");
 
     log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-    srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+    if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+      log->error("Error sending message to tester.\n");
+    }
   }
 
   void handle_request_cell(Document& document, const uint8_t* payload, const uint16_t len)
@@ -183,7 +187,9 @@ private:
       std::string resp = ttcn3_helpers::get_basic_sys_req_cnf(cell_id.GetString(), "L1MacIndCtrl");
 
       log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-      srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+      if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+        log->error("Error sending message to tester.\n");
+      }
     }
   }
 
@@ -242,7 +248,9 @@ private:
     std::string resp = ttcn3_helpers::get_basic_sys_req_cnf(cell_id.GetString(), "RadioBearerList");
 
     log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-    srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+    if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+      log->error("Error sending message to tester.\n");
+    }
   }
 
   void handle_request_cell_attenuation_list(Document& document)
@@ -291,7 +299,9 @@ private:
     std::string resp = ttcn3_helpers::get_basic_sys_req_cnf(cell_id.GetString(), "CellAttenuationList");
 
     log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-    srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+    if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+      log->error("Error sending message to tester.\n");
+    }
   }
 
   void handle_request_pdcp_count(Document& document)
@@ -328,7 +338,9 @@ private:
     std::string resp = ttcn3_helpers::get_pdcp_count_response(cell_id.GetString(), bearers);
 
     log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-    srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+    if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+      log->error("Error sending message to tester.\n");
+    }
   }
 
   void handle_request_as_security(Document& document)
@@ -417,7 +429,9 @@ private:
     if (config_flag.GetBool() == true) {
       std::string resp = ttcn3_helpers::get_basic_sys_req_cnf(cell_id.GetString(), "AS_Security");
       log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-      srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+      if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+        log->error("Error sending message to tester.\n");
+      }
     } else {
       log->info("Skipping response for AS_Security message.\n");
     }
@@ -455,7 +469,9 @@ private:
         ttcn3_helpers::get_sys_req_cnf_with_time(cell_id.GetString(), "EnquireTiming", syssim->get_tti());
 
     log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-    srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+    if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+      log->error("Error sending message to tester.\n");
+    }
   }
 
   void handle_request_paging(Document& document, const uint8_t* payload, const uint16_t len)
@@ -496,7 +512,9 @@ private:
       std::string resp = ttcn3_helpers::get_sys_req_cnf_with_time(cell_id.GetString(), "Paging", syssim->get_tti());
 
       log->info("Sending %s to tester (%zd B)\n", resp.c_str(), resp.length());
-      srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length());
+      if (srslte_netsource_write(&net_source, (char*)resp.c_str(), resp.length()) != SRSLTE_SUCCESS) {
+        log->error("Error sending message to tester.\n");
+      }
     } else {
       log->info("Skipping response for Paging message.\n");
     }

srsue/test/ttcn3/hdr/ttcn3_ut_interface.h

@@ -161,7 +161,9 @@ private:
     resp.Accept(writer);
 
     log->info("Sending %s to tester (%zd B)\n", buffer.GetString(), buffer.GetSize());
-    srslte_netsource_write(&net_source, (char*)buffer.GetString(), buffer.GetSize());
+    if (srslte_netsource_write(&net_source, (char*)buffer.GetString(), buffer.GetSize()) != SRSLTE_SUCCESS) {
+      log->error("Error sending message to tester.\n");
+    }
   }
 
   void handle_at_command(Document& document)