X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Fcu_stub%2Fcu_xnap_msg_hdl.c;fp=src%2Fcu_stub%2Fcu_xnap_msg_hdl.c;h=26d7329bd2b34aeee76efb76f6d8606583e2c73f;hb=91e620505c094c9e194453e2865a6e414930446c;hp=0000000000000000000000000000000000000000;hpb=07b4db8181733867f44499f5ad6980ac981e26ea;p=o-du%2Fl2.git

diff --git a/src/cu_stub/cu_xnap_msg_hdl.c b/src/cu_stub/cu_xnap_msg_hdl.c
new file mode 100644
index 000000000..26d7329bd
--- /dev/null
+++ b/src/cu_stub/cu_xnap_msg_hdl.c
@@ -0,0 +1,286 @@
+/*******************************************************************************
+################################################################################
+#   Copyright (c) [2017-2019] [Radisys]                                        #
+#                                                                              #
+#   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.                                             #
+################################################################################
+*******************************************************************************/
+
+/* This file contains F1AP message handler functions */
+#include "common_def.h"
+#include "cu_stub_sctp.h"
+#include "cu_stub_egtp.h"
+#include "OCTET_STRING.h"
+#include "cu_f1ap_msg_hdl.h"
+#include "cu_stub.h"
+
+/*******************************************************************
+ *
+ * @brief Build And send dummy Xn Setup request
+ *
+ * @details
+ *
+ *    Function : BuildAndSendXnSetupReq
+ *
+ *    Functionality:
+ *       Build And send dummy Xn Setup request
+ *
+ * @params[in]
+ * @return void
+ *
+ ******************************************************************/
+void BuildAndSendXnSetupReq()
+{
+   uint8_t assocIdx = 0;
+   Buffer *mBuf = NULLP;
+   CuSctpAssocCb *assocCb = NULLP;
+
+   for(assocIdx = 0; assocIdx < sctpCb.numAssoc; assocIdx++)
+   {
+      assocCb = &sctpCb.assocCb[assocIdx];
+      if(assocCb->connUp && assocCb->intf == XN_INTERFACE && assocCb->destId == 0)
+      {
+         if(ODU_GET_MSG_BUF(1, 1, &mBuf) == ROK)
+         {
+            CMCHKPK(oduUnpackUInt8,(Data *)CU_ID, mBuf);
+            CMCHKPK(oduUnpackUInt8,XN_SETUP_REQ, mBuf);
+            ODU_PRINT_MSG(mBuf, 0,0);
+            if(sendOnSctpAssoc(assocCb, mBuf) != ROK)
+            {
+               DU_LOG("\nERROR  -->  CU_STUB: Failed to send XN setup request to peer CU");
+            }
+         }
+         break;
+      }
+   }
+}
+
+/*******************************************************************
+ *
+ * @brief Process received Xn Setup request
+ *
+ * @details
+ *
+ *    Function : XNAPProcXnSetupReq
+ *
+ *    Functionality:
+ *       Fetch peer CU ID and store in assocCb
+ *
+ * @params[in] Pointer to destination Id
+ *             Pointer to message buffer
+ * @return void
+ *
+ ******************************************************************/
+void XNAPProcXnSetupReq(uint32_t *destId, Buffer *mBuf)
+{
+   uint8_t cuId;
+
+   DU_LOG("\nINFO  -->  CU STUB : Received XN Setup Request");
+   CMCHKUNPK(oduPackUInt8, &(cuId), mBuf)
+   *destId = cuId;
+
+   BuildAndSendXnSetupRsp(*destId);
+}
+
+/*******************************************************************
+ *
+ * @brief Build And send dummy Xn Setup response
+ *
+ * @details
+ *
+ *    Function : BuildAndSendXnSetupRsp
+ *
+ *    Functionality:
+ *       Build And send dummy Xn Setup response
+ *
+ * @params[in]
+ * @return void
+ *
+ ******************************************************************/
+void BuildAndSendXnSetupRsp(uint32_t destId)
+{
+   Buffer *mBuf = NULLP;
+
+   if(ODU_GET_MSG_BUF(1, 1, &mBuf) == ROK)
+   {
+      CMCHKPK(oduUnpackUInt8, CU_ID, mBuf);
+      CMCHKPK(oduUnpackUInt8, XN_SETUP_RSP, mBuf);
+      if(sctpSend(XN_INTERFACE, destId, mBuf))
+      {
+         DU_LOG("\nERROR  -->  CU_STUB: Failed to send XN setup response to peer CU");
+      }   
+   }   
+}
+
+/*******************************************************************
+ *
+ * @brief Process received Xn Setup response
+ *
+ * @details
+ *
+ *    Function : XNAPProcXnSetupRsp
+ *
+ *    Functionality:
+ *       Fetch peer CU ID and store in assocCb
+ *
+ * @params[in] Pointer to destination Id
+ *             Pointer to message buffer
+ * @return void
+ *
+ ******************************************************************/
+void XNAPProcXnSetupRsp(uint32_t *destId, Buffer *mBuf)
+{
+   uint8_t cuId;
+
+   DU_LOG("\nINFO  -->  CU STUB : Received XN Setup Response");
+   CMCHKUNPK(oduPackUInt8, &(cuId), mBuf)
+   *destId = cuId;
+}
+
+/*******************************************************************
+ *
+ * @brief Build And send dummy Handover request to Peer CU
+ *
+ * @details
+ *
+ *    Function : BuildAndSendHOReq
+ *
+ *    Functionality:
+ *       Build And send dummy Handover request to Peer CU
+ *
+ * @params[in] Pointer to UE Cb
+ *             Event type
+ *             Message to be sent
+ *             Message Length
+ * @return void
+ *
+ ******************************************************************/
+void BuildAndSendHOReq(CuUeCb *ueCb, XnEventType event, char *xnMsg, MsgLen xnMsgLen)
+{
+   Buffer *mBuf = NULLP;
+
+   if(ODU_GET_MSG_BUF(1, 1, &mBuf) == ROK)
+   {
+      if(ODU_ADD_POST_MSG_MULT((Data *)xnMsg, xnMsgLen, mBuf) == ROK)
+      {     
+         CMCHKPK(oduUnpackUInt8, event, mBuf);
+         if(sctpSend(XN_INTERFACE, ueCb->hoInfo.targetId, mBuf) != ROK)
+         {
+            DU_LOG("\nERROR  -->  CU_STUB: Failed to send handover request to peer CU");
+            ueCb->state = UE_ACTIVE;
+            memset(&ueCb->hoInfo, 0, sizeof(HandoverInfo));
+         }
+      }     
+   }
+}
+
+/*******************************************************************
+ *
+ * @brief Handle incoming messages at Xn interface
+ *
+ * @details
+ *
+ *    Function : XNAPMsgHdlr
+ *
+ *    Functionality:
+ *       Fetch event type from message buffer and call appropriate
+ *       handler
+ *
+ * @params[in] Pointer to destination Id
+ *             Pointer to message buffer
+ * @return void
+ *
+ ******************************************************************/
+void XNAPMsgHdlr(uint32_t *destId, Buffer *mBuf)
+{
+   XnEventType event;
+
+   CMCHKUNPK(oduPackUInt8, &event, mBuf);
+
+   switch(event)
+   {
+      case XN_SETUP_REQ:
+         {
+             XNAPProcXnSetupReq(destId, mBuf);
+             break;
+         }
+
+    case XN_SETUP_RSP:
+         {
+             XNAPProcXnSetupRsp(destId, mBuf);
+             break;
+         }
+
+      case HO_REQ:
+         {
+            DU_LOG("\nINFO  -->  CU STUB : Received Handover Request at XNAP");
+
+//Handling of HO Request to be added in next gerrit
+#if 0
+            char *recvBuf;
+            MsgLen copyCnt;
+            MsgLen recvBufLen;
+            F1AP_PDU_t *f1apMsg = NULLP;
+            asn_dec_rval_t rval; /* Decoder return value */
+            F1AP_PDU_t f1apasnmsg ;
+
+            ODU_PRINT_MSG(mBuf, 0,0); 
+
+            /* Copy mBuf into char array to decode it */
+            ODU_GET_MSG_LEN(mBuf, &recvBufLen);
+            CU_ALLOC(recvBuf, (Size)recvBufLen);
+
+            if(recvBuf == NULLP)
+            {
+               DU_LOG("\nERROR  -->  F1AP : Memory allocation failed");
+               return;
+            }
+            if(ODU_COPY_MSG_TO_FIX_BUF(mBuf, 0, recvBufLen, (Data *)recvBuf, &copyCnt) != ROK)
+            {
+               DU_LOG("\nERROR  -->  F1AP : Failed while copying %d", copyCnt);
+               return;
+            }
+
+            DU_LOG("\nDEBUG  -->  F1AP : Received flat buffer to be decoded : ");
+            for(i=0; i< recvBufLen; i++)
+            {
+               DU_LOG("%x",recvBuf[i]);
+            }
+
+            /* Decoding flat buffer into F1AP messsage */
+            f1apMsg = &f1apasnmsg;
+            memset(f1apMsg, 0, sizeof(F1AP_PDU_t));
+            rval = aper_decode(0, &asn_DEF_F1AP_PDU, (void **)&f1apMsg, recvBuf, recvBufLen, 0, 0);
+            CU_FREE(recvBuf, (Size)recvBufLen);
+
+            if(rval.code == RC_FAIL || rval.code == RC_WMORE)
+            {
+               DU_LOG("\nERROR  -->  F1AP : ASN decode failed");
+               return;
+            }
+            DU_LOG("\n");
+            xer_fprint(stdout, &asn_DEF_F1AP_PDU, f1apMsg);
+
+            procUeContextModificationResponse(0, f1apMsg, recvBuf, recvBufLen);      
+#endif            
+            break;
+         }
+      default:
+         DU_LOG("\nERROR  --> CU_STUB : Invalid event [%d] received at XN interface", event);
+         break;
+   }
+}
+
+/**********************************************************************
+  End of file
+ **********************************************************************/