e2sim/src/E2AP/e2ap_message_handler.cpp

   1 /*****************************************************************************\r
   2 #                                                                            *\r
   3 # Copyright 2019 AT&T Intellectual Property                                  *\r
   4 # Copyright 2019 Nokia                                                       *\r
   5 #                                                                            *\r
   6 # Licensed under the Apache License, Version 2.0 (the "License");            *\r
   7 # you may not use this file except in compliance with the License.           *\r
   8 # You may obtain a copy of the License at                                    *\r
   9 #                                                                            *\r
  10 #      http://www.apache.org/licenses/LICENSE-2.0                            *\r
  11 #                                                                            *\r
  12 # Unless required by applicable law or agreed to in writing, software        *\r
  13 # distributed under the License is distributed on an "AS IS" BASIS,          *\r
  14 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   *\r
  15 # See the License for the specific language governing permissions and        *\r
  16 # limitations under the License.                                             *\r
  17 #                                                                            *\r
  18 ******************************************************************************/\r
  19 #include "e2ap_message_handler.hpp"\r
  20 #include <unistd.h>\r
  21 \r
  22 void e2ap_handle_sctp_data(int &socket_fd, sctp_buffer_t &data)\r
  23 {\r
  24   //decode the data into E2AP-PDU\r
  25   E2AP_PDU_t* pdu = new E2AP_PDU_t();\r
  26 \r
  27   e2ap_asn1c_decode_pdu(pdu, data.buffer, data.len);\r
  28 \r
  29   e2ap_asn1c_print_pdu(pdu);\r
  30 \r
  31   int procedureCode = e2ap_asn1c_get_procedureCode(pdu);\r
  32   int index = (int)pdu->present;\r
  33 \r
  34   LOG_D("[E2AP] Unpacked E2AP-PDU: index = %d, procedureCode = %d\n",\r
  35                             index, procedureCode);\r
  36 \r
  37   switch(procedureCode)\r
  38   {\r
  39     case ProcedureCode_id_x2Setup: //X2Setup = 6\r
  40       switch(index)\r
  41       {\r
  42         case E2AP_PDU_PR_initiatingMessage: //initiatingMessage\r
  43           LOG_I("[E2AP] Received X2-SETUP-REQUEST");\r
  44           e2ap_handle_X2SetupRequest(pdu, socket_fd);\r
  45           break;\r
  46 \r
  47         case E2AP_PDU_PR_successfulOutcome: //successfulOutcome\r
  48           LOG_I("[E2AP] Received X2-SETUP-RESPONSE");\r
  49           e2ap_handle_X2SetupResponse(pdu, socket_fd);\r
  50           break;\r
  51 \r
  52         case E2AP_PDU_PR_unsuccessfulOutcome:\r
  53           break;\r
  54 \r
  55         default:\r
  56           LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU", index);\r
  57           break;\r
  58       }\r
  59       break;\r
  60 \r
  61     case ProcedureCode_id_endcX2Setup: //ENDCX2Setup = 36\r
  62       switch(index)\r
  63       {\r
  64         case E2AP_PDU_PR_initiatingMessage: //initiatingMessage\r
  65           LOG_I("[E2AP] Received ENDC-X2-SETUP-REQUEST");\r
  66           e2ap_handle_ENDCX2SetupRequest(pdu, socket_fd);\r
  67           break;\r
  68 \r
  69         case E2AP_PDU_PR_successfulOutcome: //successfulOutcome\r
  70           LOG_I("[E2AP] Received ENDC-X2-SETUP-RESPONSE");\r
  71           //no handler yet\r
  72           break;\r
  73 \r
  74         case E2AP_PDU_PR_unsuccessfulOutcome:\r
  75           LOG_I("[E2AP] Received ENDC-X2-SETUP-FAILURE");\r
  76           //no handler yet\r
  77           break;\r
  78 \r
  79         default:\r
  80           LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU", index);\r
  81           break;\r
  82       }\r
  83       break;\r
  84 \r
  85     case ProcedureCode_id_reset: //reset = 7\r
  86       switch(index)\r
  87       {\r
  88         case E2AP_PDU_PR_initiatingMessage:\r
  89           LOG_I("[E2AP] Received RESET-REQUEST");\r
  90           break;\r
  91 \r
  92         case E2AP_PDU_PR_successfulOutcome:\r
  93           break;\r
  94 \r
  95         case E2AP_PDU_PR_unsuccessfulOutcome:\r
  96           break;\r
  97 \r
  98         default:\r
  99           LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU", index);\r
 100           break;\r
 101       }\r
 102       break;\r
 103 \r
 104     case ProcedureCode_id_ricSubscription: //RIC SUBSCRIPTION = 201\r
 105       switch(index)\r
 106       {\r
 107         case E2AP_PDU_PR_initiatingMessage: //initiatingMessage\r
 108           LOG_I("[E2AP] Received RIC-SUBSCRIPTION-REQUEST");\r
 109           //e2ap_handle_RICSubscriptionRequest(pdu, socket_fd);\r
 110           e2ap_handle_RICSubscriptionRequest_securityDemo(pdu, socket_fd);\r
 111           break;\r
 112 \r
 113         case E2AP_PDU_PR_successfulOutcome:\r
 114           LOG_I("[E2AP] Received RIC-SUBSCRIPTION-RESPONSE");\r
 115           break;\r
 116 \r
 117         case E2AP_PDU_PR_unsuccessfulOutcome:\r
 118           LOG_I("[E2AP] Received RIC-SUBSCRIPTION-FAILURE");\r
 119           break;\r
 120 \r
 121         default:\r
 122           LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU", index);\r
 123           break;\r
 124       }\r
 125       break;\r
 126 \r
 127     case ProcedureCode_id_ricIndication: // 205\r
 128       switch(index)\r
 129       {\r
 130         case E2AP_PDU_PR_initiatingMessage: //initiatingMessage\r
 131           LOG_I("[E2AP] Received RIC-INDICATION");\r
 132           // e2ap_handle_RICSubscriptionRequest(pdu, socket_fd);\r
 133           break;\r
 134 \r
 135         default:\r
 136           LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU %d", index,\r
 137                                     (int)ProcedureCode_id_ricIndication);\r
 138           break;\r
 139       }\r
 140       break;\r
 141 \r
 142     case ProcedureCode_id_resourceStatusReportingInitiation: //9\r
 143       switch(index)\r
 144       {\r
 145         case E2AP_PDU_PR_initiatingMessage: //initiatingMessage\r
 146           LOG_I("[E2AP] Received RESOURCE-STATUS-REQUEST");\r
 147           e2ap_handle_ResourceStatusRequest(pdu, socket_fd);\r
 148           break;\r
 149 \r
 150         case E2AP_PDU_PR_successfulOutcome: //successfulOutcome\r
 151           LOG_I("[E2AP] Received RESOURCE-STATUS-RESPONSE");\r
 152           break;\r
 153 \r
 154         case E2AP_PDU_PR_unsuccessfulOutcome:\r
 155           LOG_I("[E2AP] Received RESOURCE-STATUS-FAILURE");\r
 156           break;\r
 157 \r
 158         default:\r
 159           LOG_E("[E2AP] Invalid message index=%d in E2AP-PDU %d", index,\r
 160                     (int)ProcedureCode_id_resourceStatusReportingInitiation);\r
 161           break;\r
 162       }\r
 163       break;\r
 164 \r
 165     case ProcedureCode_id_resourceStatusReporting: // 10\r
 166       switch(index)\r
 167       {\r
 168         case E2AP_PDU_PR_initiatingMessage: //initiatingMessage\r
 169           LOG_I("[E2AP] Received RESOURCE-STATUS-UPDATE");\r
 170           break;\r
 171 \r
 172         default:\r
 173           LOG_E("[E2AP] Unable to process message index=%d in E2AP-PDU %d", index,\r
 174                     (int)ProcedureCode_id_resourceStatusReporting);\r
 175           break;\r
 176       }\r
 177       break;\r
 178 \r
 179     default:\r
 180       LOG_E("[E2AP] No available handler for procedureCode=%d", procedureCode);\r
 181       break;\r
 182   }\r
 183 }\r
 184 \r
 185 /*\r
 186 Simply send back X2SetupResponse\r
 187 Todo: add more handling options (failure, duplicated request, etc.)\r
 188 */\r
 189 void e2ap_handle_X2SetupRequest(E2AP_PDU_t* pdu, int &socket_fd)\r
 190 {\r
 191   E2AP_PDU_t* res_pdu = e2ap_xml_to_pdu("E2AP_X2SetupResponse.xml");\r
 192 \r
 193   LOG_D("[E2AP] Created X2-SETUP-RESPONSE");\r
 194 \r
 195   e2ap_asn1c_print_pdu(res_pdu);\r
 196 \r
 197   uint8_t       *buf;\r
 198   sctp_buffer_t data;\r
 199 \r
 200   data.len = e2ap_asn1c_encode_pdu(res_pdu, &buf);\r
 201   memcpy(data.buffer, buf, min(data.len, MAX_SCTP_BUFFER));\r
 202 \r
 203   //send response data over sctp\r
 204   if(sctp_send_data(socket_fd, data) > 0) {\r
 205     LOG_I("[SCTP] Sent X2-SETUP-RESPONSE");\r
 206   } else {\r
 207     LOG_E("[SCTP] Unable to send X2-SETUP-RESPONSE to peer");\r
 208   }\r
 209 }\r
 210 \r
 211 void e2ap_handle_X2SetupResponse(E2AP_PDU_t* pdu, int &socket_fd)\r
 212 {\r
 213   E2AP_PDU_t* req_pdu = e2ap_xml_to_pdu("E2AP_ResourceStatusRequest.xml");\r
 214   // E2AP_PDU_t* req_pdu = e2ap_xml_to_pdu("E2AP_ResourceStatusRequest_bad.xml");\r
 215 \r
 216   LOG_D("[E2AP] Created RESOURCE-STATUS-REQUEST");\r
 217 \r
 218   e2ap_asn1c_print_pdu(req_pdu);\r
 219 \r
 220   uint8_t       *buf;\r
 221   sctp_buffer_t data;\r
 222 \r
 223   data.len = e2ap_asn1c_encode_pdu(req_pdu, &buf);\r
 224   memcpy(data.buffer, buf, min(data.len, MAX_SCTP_BUFFER));\r
 225 \r
 226   //send response data over sctp\r
 227   if(sctp_send_data(socket_fd, data) > 0) {\r
 228     LOG_I("[SCTP] Sent RESOURCE-STATUS-REQUEST");\r
 229   } else {\r
 230     LOG_E("[SCTP] Unable to send RESOURCE-STATUS-REQUEST to peer");\r
 231   }\r
 232 \r
 233 }\r
 234 \r
 235 /*\r
 236 Simply send back ENDCX2SetupResponse\r
 237 Todo: add more handling options (failure, duplicated request, etc.)\r
 238 */\r
 239 void e2ap_handle_ENDCX2SetupRequest(E2AP_PDU_t* pdu, int &socket_fd)\r
 240 {\r
 241   E2AP_PDU_t* res_pdu = e2ap_xml_to_pdu("E2AP_ENDCX2SetupResponse.xml");\r
 242 \r
 243   LOG_D("[E2AP] Created ENDC-X2-SETUP-RESPONSE");\r
 244 \r
 245   e2ap_asn1c_print_pdu(res_pdu);\r
 246 \r
 247   uint8_t       *buf;\r
 248   sctp_buffer_t data;\r
 249 \r
 250   data.len = e2ap_asn1c_encode_pdu(res_pdu, &buf);\r
 251   memcpy(data.buffer, buf, min(data.len, MAX_SCTP_BUFFER));\r
 252 \r
 253   //send response data over sctp\r
 254   if(sctp_send_data(socket_fd, data) > 0) {\r
 255     LOG_I("[SCTP] Sent ENDC-X2-SETUP-RESPONSE");\r
 256   } else {\r
 257     LOG_E("[SCTP] Unable to send ENDC-X2-SETUP-RESPONSE to peer");\r
 258   }\r
 259 }\r
 260 \r
 261 /*\r
 262 Simply send back hard-coded RICSubscriptionResponse\r
 263 Todo: add more handling options (failure, duplicated request, etc.)\r
 264 */\r
 265 void e2ap_handle_RICSubscriptionRequest(E2AP_PDU_t* pdu, int &socket_fd)\r
 266 {\r
 267   E2AP_PDU_t* res_pdu = e2ap_xml_to_pdu("E2AP_RICsubscriptionResponse.xml");\r
 268 \r
 269   LOG_D("[E2AP] Created RIC-SUBSCRIPTION-RESPONSE");\r
 270 \r
 271   e2ap_asn1c_print_pdu(res_pdu);\r
 272 \r
 273   uint8_t       *buf;\r
 274   sctp_buffer_t data;\r
 275 \r
 276   data.len = e2ap_asn1c_encode_pdu(res_pdu, &buf);\r
 277   memcpy(data.buffer, buf, min(data.len, MAX_SCTP_BUFFER));\r
 278 \r
 279   //send response data over sctp\r
 280   if(sctp_send_data(socket_fd, data) > 0) {\r
 281     LOG_I("[SCTP] Sent RIC-SUBSCRIPTION-RESPONSE");\r
 282   } else {\r
 283     LOG_E("[SCTP] Unable to send RIC-SUBSCRIPTION-RESPONSE to peer");\r
 284   }\r
 285 }\r
 286 \r
 287 void e2ap_handle_RICSubscriptionRequest_securityDemo(E2AP_PDU_t* pdu, int &socket_fd)\r
 288 {\r
 289   E2AP_PDU_t* res_pdu = e2ap_xml_to_pdu("E2AP_RICsubscriptionResponse.xml");\r
 290 \r
 291   LOG_D("[E2AP] Created RIC-SUBSCRIPTION-RESPONSE");\r
 292 \r
 293   e2ap_asn1c_print_pdu(res_pdu);\r
 294 \r
 295   uint8_t       *buf;\r
 296   sctp_buffer_t data;\r
 297 \r
 298   data.len = e2ap_asn1c_encode_pdu(res_pdu, &buf);\r
 299   memcpy(data.buffer, buf, min(data.len, MAX_SCTP_BUFFER));\r
 300 \r
 301   //send response data over sctp\r
 302   if(sctp_send_data(socket_fd, data) > 0) {\r
 303     LOG_I("[SCTP] Sent RIC-SUBSCRIPTION-RESPONSE");\r
 304   } else {\r
 305     LOG_E("[SCTP] Unable to send RIC-SUBSCRIPTION-RESPONSE to peer");\r
 306   }\r
 307 \r
 308   //Start sending RIC Indication\r
 309   int count1 = 0, count2 = 0;\r
 310 \r
 311   E2AP_PDU_t* indication_type1 = e2ap_xml_to_pdu("E2AP_RICindication_type1.xml");\r
 312   E2AP_PDU_t* indication_type2 = e2ap_xml_to_pdu("E2AP_RICindication_type2.xml");\r
 313 \r
 314   uint8_t *buf1, *buf2;\r
 315   sctp_buffer_t data1, data2;\r
 316   data1.len = e2ap_asn1c_encode_pdu(indication_type1, &buf1);\r
 317   memcpy(data1.buffer, buf1, min(data1.len, MAX_SCTP_BUFFER));\r
 318 \r
 319   data2.len = e2ap_asn1c_encode_pdu(indication_type2, &buf2);\r
 320   memcpy(data2.buffer, buf2, min(data2.len, MAX_SCTP_BUFFER));\r
 321 \r
 322   while(1){\r
 323     sleep(1);\r
 324     //type1\r
 325     if(sctp_send_data(socket_fd, data1) > 0) {\r
 326       count1++;\r
 327       LOG_I("[SCTP] Sent RIC-INDICATION SgNBAdditionRequest Type 1, count1 = %d", count1);\r
 328     } else {\r
 329       LOG_E("[SCTP] Unable to send RIC-INDICATION to peer");\r
 330     }\r
 331 \r
 332     sleep(1);\r
 333     //type2\r
 334     if(sctp_send_data(socket_fd, data2) > 0) {\r
 335       count2++;\r
 336       LOG_I("[SCTP] Sent RIC-INDICATION SgNBAdditionRequest Type 2, count2 = %d", count2);\r
 337     } else {\r
 338       LOG_E("[SCTP] Unable to send RIC-INDICATION to peer");\r
 339     }\r
 340   } //end while\r
 341 \r
 342 }\r
 343 \r
 344 void e2ap_handle_ResourceStatusRequest(E2AP_PDU_t* pdu, int &socket_fd)\r
 345 {\r
 346   //send back ResourceStatusResponse, followed by resource status update\r
 347   E2AP_PDU_t* res_pdu = e2ap_xml_to_pdu("E2AP_ResourceStatusResponse.xml");\r
 348 \r
 349   LOG_D("[E2AP] Created RESOURCE-STATUS-RESPONSE");\r
 350 \r
 351   e2ap_asn1c_print_pdu(res_pdu);\r
 352 \r
 353   uint8_t       *buf;\r
 354   sctp_buffer_t data;\r
 355 \r
 356   data.len = e2ap_asn1c_encode_pdu(res_pdu, &buf);\r
 357   memcpy(data.buffer, buf, min(data.len, MAX_SCTP_BUFFER));\r
 358 \r
 359   //send response data over sctp\r
 360   if(sctp_send_data(socket_fd, data) > 0) {\r
 361     LOG_I("[SCTP] Sent RESOURCE-STATUS-RESPONSE");\r
 362   } else {\r
 363     LOG_E("[SCTP] Unable to send RESOURCE-STATUS-RESPONSE to peer");\r
 364   }\r
 365 \r
 366 \r
 367   //send ResourceStatusUpdate periodically\r
 368   E2AP_PDU_t* update_pdu = e2ap_xml_to_pdu("E2AP_ResourceStatusUpdate.xml");\r
 369 \r
 370   uint8_t       *update_buf;\r
 371   sctp_buffer_t update_data;\r
 372 \r
 373   update_data.len = e2ap_asn1c_encode_pdu(update_pdu, &update_buf);\r
 374   memcpy(update_data.buffer, update_buf, min(update_data.len, MAX_SCTP_BUFFER));\r
 375 \r
 376   while(1) {\r
 377     // e2ap_asn1c_print_pdu(update_pdu);\r
 378 \r
 379     if(sctp_send_data(socket_fd, update_data) > 0) {\r
 380       LOG_I("[SCTP] Sent RESOURCE-STATUS-UPDATE");\r
 381     } else {\r
 382       LOG_E("[SCTP] Unable to send RESOURCE-STATUS-UPDATE to peer");\r
 383     }\r
 384 \r
 385     sleep(1);\r
 386 \r
 387   }\r
 388 }\r