Add User-level metrics

[sim/e2-interface.git] / e2sim / e2apv1sim / src / E2AP / e2ap_message_handler.cpp

diff --git a/e2sim/e2apv1sim/src/E2AP/e2ap_message_handler.cpp b/e2sim/e2apv1sim/src/E2AP/e2ap_message_handler.cpp
index efdf175..44f028d 100644 (file)
--- a/e2sim/e2apv1sim/src/E2AP/e2ap_message_handler.cpp
+++ b/e2sim/e2apv1sim/src/E2AP/e2ap_message_handler.cpp
@@ -19,12 +19,13 @@
 #                                                                            *\r
 ******************************************************************************/\r
 #include "e2ap_message_handler.hpp"\r
-#include <unistd.h>\r
+\r
 //#include <iostream>\r
 //#include <vector>\r
 #include "encode_e2apv1.hpp"\r
+#include "kpm_callbacks.hpp"\r
 \r
-\r
+#include <unistd.h>\r
 \r
 void e2ap_handle_sctp_data(int &socket_fd, sctp_buffer_t &data, bool xmlenc)\r
 {\r
@@ -37,11 +38,11 @@ void e2ap_handle_sctp_data(int &socket_fd, sctp_buffer_t &data, bool xmlenc)
 \r
   asn_transfer_syntax syntax;\r
   \r
-  if (!xmlenc) \r
-    syntax = ATS_ALIGNED_BASIC_PER;\r
-  else\r
-    syntax = ATS_BASIC_XER;\r
 \r
+  syntax = ATS_ALIGNED_BASIC_PER;\r
+  \r
+\r
+  fprintf(stderr, "full buffer\n%s\n", data.buffer);\r
   //  e2ap_asn1c_decode_pdu(pdu, data.buffer, data.len);\r
 \r
   auto rval = asn_decode(nullptr, syntax, &asn_DEF_E2AP_PDU, (void **) &pdu,\r
@@ -70,7 +71,7 @@ void e2ap_handle_sctp_data(int &socket_fd, sctp_buffer_t &data, bool xmlenc)
       switch(index)\r
        {\r
         case E2AP_PDU_PR_initiatingMessage:\r
-         e2ap_handle_E2SetupRequest(pdu, socket_fd);     \r
+         e2ap_handle_E2SetupRequest(pdu, socket_fd);\r
           LOG_I("[E2AP] Received SETUP-REQUEST");\r
           break;\r
          \r
@@ -112,7 +113,8 @@ void e2ap_handle_sctp_data(int &socket_fd, sctp_buffer_t &data, bool xmlenc)
        {\r
         case E2AP_PDU_PR_initiatingMessage: //initiatingMessage\r
           LOG_I("[E2AP] Received RIC-SUBSCRIPTION-REQUEST");\r
-          e2ap_handle_RICSubscriptionRequest(pdu, socket_fd);\r
+         //          e2ap_handle_RICSubscriptionRequest(pdu, socket_fd);\r
+         callback_kpm_subscription_request(pdu, socket_fd);\r
          //          e2ap_handle_RICSubscriptionRequest_securityDemo(pdu, socket_fd);\r
           break;\r
          \r