2be3a45ea640c4b8272b4e29bec2e5789ab6ce1f
[o-du/l2.git] / src / cu_stub / cu_stub.c
1 /*******************************************************************************
2 ################################################################################
3 #   Copyright (c) [2017-2019] [Radisys]                                        #
4 #                                                                              #
5 #   Licensed under the Apache License, Version 2.0 (the "License");            #
6 #   you may not use this file except in compliance with the License.           #
7 #   You may obtain a copy of the License at                                    #
8 #                                                                              #
9 #       http://www.apache.org/licenses/LICENSE-2.0                             #
10 #                                                                              #
11 #   Unless required by applicable law or agreed to in writing, software        #
12 #   distributed under the License is distributed on an "AS IS" BASIS,          #
13 #   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #
14 #   See the License for the specific language governing permissions and        #
15 #   limitations under the License.                                             #
16 ################################################################################
17 *******************************************************************************/
18
19 /* This functions contains main() for cu_app */
20 #include "common_def.h"
21 #include "cu_stub_sctp.h"
22 #include "cu_stub_egtp.h"
23 #include "OCTET_STRING.h"
24 #include "cu_f1ap_msg_hdl.h"
25 #include "cu_stub.h"
26
27 #ifdef O1_ENABLE
28 #include "CmInterface.h"
29 #endif
30
31
32 #ifdef O1_ENABLE
33 extern StartupConfig g_cfg;
34 #endif
35
36 /*******************************************************************
37  *
38  * @brief Handles SCTP notification 
39  *
40  * @details
41  *
42  *    Function : sctpNtfyInd
43  *
44  *    Functionality:
45  *         Handles SCTP notification
46  *
47  * @params[in] sctp notification
48  * @return void
49  *
50  ******************************************************************/
51 void sctpNtfyInd(CmInetSctpNotification *ntfy)
52 {
53 //TODO
54 }
55
56 void init_log()
57 {
58     openlog("CU_STUB",LOG_CONS | LOG_PID | LOG_NDELAY, LOG_LOCAL1);
59 }
60 /*******************************************************************
61  *
62  * @brief Main function of CU APP
63  *
64  * @details
65  *
66  *    Function : main
67  *
68  *    Functionality:
69  *         - Reads CU related configurations
70  *         - Initialize SCTP Parameters
71  *         - Start SCTP receiver thread
72  *
73  * @params[in] 
74  * @return ROK     - success
75  *         RFAILED - failure
76  *
77  * ****************************************************************/
78
79 uint8_t tst()
80 {
81    int retVal=0;
82    pthread_t conThrdId;
83    pthread_attr_t attr;
84
85    init_log();   
86    DU_LOG("\nINFO   -->  CU_STUB : Starting CU_STUB\n");
87
88    /* Start thread to receive console input */
89    pthread_attr_init(&attr);
90    pthread_attr_setstacksize(&attr, (size_t)NULLD);
91    pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM);
92    pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
93    retVal = pthread_create(&conThrdId, &attr, cuConsoleHandler, NULLP);
94    if(retVal != 0)
95    {
96       DU_LOG("\nERROR  -->  CU_STUB :  Thread creation failed. Cause %d", retVal);
97    }
98    pthread_attr_destroy(&attr);
99
100    /* Read CU configurations */
101    readCuCfg();
102
103    /* Start CU-EGTP */
104    egtpActvInit();
105    egtpInitReq();
106
107    /* Initializing SCTP global parameters */
108    sctpActvInit();
109  
110    /* Start CU-SCTP to listen on incoming connection */
111    sctpCfgReq();
112    sctpStartReq();
113
114    return ROK;
115 }
116
117 /*******************************************************************
118  *
119  * @brief Read CU related configuration
120  *
121  * @details
122  *
123  *    Function : readCuCfg
124  *
125  *    Functionality:
126  *            - RRead CU related configuration
127  *
128  * @params[in] 
129  * @return ROK     - success
130  *         RFAILED - failure
131  *
132  * ****************************************************************/
133
134 void readCuCfg()
135 {
136    uint8_t  numDu;
137    uint32_t ipv4_du, ipv4_cu;
138
139    DU_LOG("\nDEBUG  -->  CU_STUB : Reading CU configurations");
140
141    cuCb.cuCfgParams.cuId = CU_ID;
142    strcpy(cuCb.cuCfgParams.cuName, CU_NAME);
143
144 #ifdef O1_ENABLE
145    if( getStartupConfigForStub(&g_cfg) != ROK )
146    {
147       DU_LOG("\nError  -->  CU_STUB : Could not fetch startup "\
148              "configurations from Netconf interface\n");
149       exit(1);
150    }
151    
152    cmInetAddr((S8*)g_cfg.DU_IPV4_Addr, &ipv4_du);
153    cuCb.cuCfgParams.sctpParams.sctpAssoc[0].duIpAddr.ipV4Addr = ipv4_du;
154    cuCb.cuCfgParams.sctpParams.sctpAssoc[0].duIpAddr.ipV6Pres = false;
155    
156    cmInetAddr((S8*)g_cfg.CU_IPV4_Addr, &ipv4_cu);
157    cuCb.cuCfgParams.sctpParams.sctpAssoc[0].cuIpAddr.ipV4Addr = ipv4_cu;
158    cuCb.cuCfgParams.sctpParams.sctpAssoc[0].cuIpAddr.ipV6Pres = false;
159    
160    cuCb.cuCfgParams.sctpParams.sctpAssoc[0].duPort = g_cfg.DU_Port;
161    cuCb.cuCfgParams.sctpParams.sctpAssoc[0].cuPort = g_cfg.CU_Port; 
162    cuCb.cuCfgParams.sctpParams.numDu = 1;
163 #else
164    cuCb.cuCfgParams.sctpParams.numDu = 0;
165    cuCb.cuCfgParams.egtpParams.numDu = 0;
166    numDu = 0;
167    while(numDu < MAX_DU_SUPPORTED)
168    {
169       /* DU IP Address and Port*/
170       memset(&ipv4_du, 0, sizeof(uint32_t));
171       cmInetAddr((S8*)DU_IP_V4_ADDR[numDu], &ipv4_du);
172       cuCb.cuCfgParams.sctpParams.sctpAssoc[numDu].duIpAddr.ipV4Addr = ipv4_du;
173       cuCb.cuCfgParams.sctpParams.sctpAssoc[numDu].duIpAddr.ipV6Pres = false;
174       cuCb.cuCfgParams.sctpParams.sctpAssoc[numDu].duPort = DU_SCTP_PORT[numDu];
175
176       /* CU IP Address and Port*/
177       memset(&ipv4_du, 0, sizeof(uint32_t));
178       cmInetAddr((S8*)CU_IP_V4_ADDR, &ipv4_cu);
179       cuCb.cuCfgParams.sctpParams.sctpAssoc[numDu].cuIpAddr.ipV4Addr = ipv4_cu;
180       cuCb.cuCfgParams.sctpParams.sctpAssoc[numDu].cuIpAddr.ipV6Pres = false;
181       cuCb.cuCfgParams.sctpParams.sctpAssoc[numDu].cuPort = CU_SCTP_PORT_TO_DU[numDu];
182
183       /* EGTP Parameters */
184       memset(&ipv4_du, 0, sizeof(uint32_t));
185       cmInetAddr((S8*)DU_IP_V4_ADDR[numDu], &ipv4_du);
186       cuCb.cuCfgParams.egtpParams.egtpAssoc[numDu].localIp.ipV4Pres = TRUE;
187       cuCb.cuCfgParams.egtpParams.egtpAssoc[numDu].localIp.ipV4Addr = ipv4_cu;
188       cuCb.cuCfgParams.egtpParams.egtpAssoc[numDu].localPort = CU_EGTP_PORT[numDu];
189       cuCb.cuCfgParams.egtpParams.egtpAssoc[numDu].destIp.ipV4Pres = TRUE;
190       cuCb.cuCfgParams.egtpParams.egtpAssoc[numDu].destIp.ipV4Addr = ipv4_du;
191       cuCb.cuCfgParams.egtpParams.egtpAssoc[numDu].destPort = DU_EGTP_PORT[numDu];
192       
193       (numDu)++;
194    }
195
196    cuCb.cuCfgParams.egtpParams.minTunnelId = MIN_TEID;
197    cuCb.cuCfgParams.egtpParams.currTunnelId = cuCb.cuCfgParams.egtpParams.minTunnelId;
198    cuCb.cuCfgParams.egtpParams.maxTunnelId = MAX_TEID;
199    cuCb.cuCfgParams.egtpParams.numDu = numDu;
200    cuCb.cuCfgParams.sctpParams.numDu = numDu;
201 #endif
202
203    /*PLMN*/
204    cuCb.cuCfgParams.plmn.mcc[0] = PLMN_MCC0;
205    cuCb.cuCfgParams.plmn.mcc[1] = PLMN_MCC1;
206    cuCb.cuCfgParams.plmn.mcc[2] = PLMN_MCC2;
207    cuCb.cuCfgParams.plmn.mnc[0] = PLMN_MNC0;
208    cuCb.cuCfgParams.plmn.mnc[1] = PLMN_MNC1;
209    cuCb.cuCfgParams.plmn.mnc[2] = PLMN_MNC2;
210
211    /*RRC Version*/
212    cuCb.cuCfgParams.rrcVersion.rrcVer = RRC_VER;
213    cuCb.cuCfgParams.rrcVersion.extRrcVer = EXT_RRC_VER;
214
215
216
217 } /* End of readCuCfg */
218
219 /*******************************************************************
220  *
221  * @brief Initiates inter DU handover
222  *
223  * @details
224  *
225  *    Function : initiateInterDuHandover
226  *
227  *    Functionality: Initiates the first procedure of inter-DU
228  *    handover i.eG GNB-DU configuration query to source DU
229  *
230  * @params[in] Source DU Id
231  *             Target DU Id
232  *             UE Id to be handed off 
233  * @return ROK     - success
234  *         RFAILED - failure
235  *
236  * ****************************************************************/
237 void initiateInterDuHandover(uint32_t sourceDuId, uint32_t targetDuId, uint32_t ueId)
238 {
239     uint8_t duIdx = 0;
240     DuDb *duDb = NULLP;
241     CuUeCb *ueCb = NULLP;
242    
243     SEARCH_DU_DB(duIdx, sourceDuId, duDb); 
244     if(duDb)
245        ueCb = &duDb->ueCb[ueId-1];
246     if(ueCb)
247     {
248        ueCb->state = UE_HANDOVER_IN_PROGRESS;
249        ueCb->hoInfo.sourceDuId = sourceDuId;
250        ueCb->hoInfo.targetDuId = targetDuId;
251     }
252
253     DU_LOG("\nINFO  --> CU_STUB: Inter-DU Handover Started for ueId [%d] from DU ID [%d] to DU ID [%d]", \
254           ueId, sourceDuId, targetDuId);
255     BuildAndSendUeContextModificationReq(sourceDuId, ueCb, QUERY_CONFIG);
256 }
257
258 /*******************************************************************
259  *
260  * @brief Handles Console input
261  *
262  * @details
263  *
264  *    Function : cuConsoleHandler
265  *
266  *    Functionality: Handles Console input
267  *
268  * @params[in] 
269  * @return ROK     - success
270  *         RFAILED - failure
271  *
272  * ****************************************************************/
273 void *cuConsoleHandler(void *args)
274 {
275    char ch;
276    uint32_t teId = 0;
277    uint32_t duId;
278    uint8_t ret = ROK;
279    uint8_t cnt = 0;
280    EgtpTeIdCb *teidCb = NULLP;
281
282    while(true) 
283    {
284       ch = getchar();
285       /* Send DL user data to CU when user enters 'd' on console */
286       if(ch == 'd')
287       {
288
289          /* Change #if 0 to #if 1 to take input from user */
290 #if 0
291          DU_LOG("\n EGTP --> : Enter TEID id(1..10) where DL Data to be sent\n");
292          scanf("%d",&teId);
293
294          if(teId > MAX_TEID || teId < MIN_TEID)
295          {
296             DU_LOG("\nERROR  -->  EGTP : TEID(%x) OUT Of Range",teId);
297             printf("\n");
298             continue;
299          }
300          /* Start Pumping data from CU to DU */
301          DU_LOG("\nDEBUG  -->  EGTP: Sending DL User Data(teId:%d)\n",teId);
302
303          cnt =0;
304          while(cnt < NUM_DL_PACKETS)
305          {
306             ret =  cuEgtpDatReq(teId);
307             if(ret != ROK)
308             {
309                DU_LOG("\nERROR --> EGTP: Issue with teid=%d\n",teId);
310                break;
311             }
312             cnt++;
313          }
314 #else
315
316          /* This variable is taken for sending specific number of downlink data packet. 
317           * Presently the code is supporting total 4500 data packets trasfer for 3 UEs only with sleep(1).
318           * If you wants to pump data for 3 UE change the following macro values
319           * NUM_TUNNEL_TO_PUMP_DATA = 9, NUM_DL_PACKETS = 1.
320           * totalDataPacket = totalNumOfTestFlow * NUM_TUNNEL_TO_PUMP_DATA * NUM_DL_PACKETS 
321           * totalDataPacket = [500*9*1] */
322          int32_t totalNumOfTestFlow = 2; 
323
324          while(totalNumOfTestFlow)
325          {
326             for(duId = 1; duId<=MAX_DU_SUPPORTED; duId++)
327             {
328                for(teId = 1; teId <= NUM_TUNNEL_TO_PUMP_DATA; teId++)
329                {
330                   teidCb = NULLP;
331                   cmHashListFind(&(egtpCb.dstCb[duId-1].teIdLst), (uint8_t *)&(teId), sizeof(uint32_t), 0, (PTR *)&teidCb);
332                   if(teidCb)
333                   {
334                      cnt =0;
335                      DU_LOG("\nDEBUG  -->  EGTP: Sending DL User Data(duId %d, teId:%d)\n", duId, teId);
336                      while(cnt < NUM_DL_PACKETS)
337                      {
338                         ret =  cuEgtpDatReq(duId, teId);      
339                         if(ret != ROK)
340                         {
341                            DU_LOG("\nERROR --> EGTP: Issue with teid=%d\n",teId);
342                            break;
343                         }
344                         /* TODO : sleep(1) will be removed later once we will be able to
345                          * support the continuous data pack transfer */
346                         sleep(1);
347                         cnt++;
348                      }
349                   }
350                   else
351                   {
352                      DU_LOG("\nDEBUG  -->  EGTP: TunnelId Not Found for (duId %d, teId:%d)\n", duId, teId);
353                   }
354                }
355             }
356             totalNumOfTestFlow--;
357          }
358 #endif
359          continue;
360       } 
361
362       /* Start Handover procedure towards DU when 'h' is received from console input */
363       else if(ch == 'h')
364       {
365          uint32_t sourceDuId, targetDuId, ueId;
366
367          DU_LOG("\nEnter Source DU ID for Inter-DU Handover");
368          scanf("%d", &sourceDuId);
369          DU_LOG("\nEnter Target DU ID for Inter-DU Handover");
370          scanf("%d", &targetDuId);
371          DU_LOG("\nEnter DU UE F1AP ID to be handed over");
372          scanf("%d", &ueId);
373
374          initiateInterDuHandover(sourceDuId, targetDuId, ueId);
375       }
376       /* Start Idle mode paging when 'p' is received from console input */
377       else if(ch == 'p')
378       {
379          uint64_t sTmsi = 0;
380          uint8_t duId = 0;
381
382          DU_LOG("\nEnter DU ID on which this UE to be pagged");
383          scanf("%d", &duId);
384          DU_LOG("\nEnter 5g-S-TMSI");
385          scanf("%lu", &sTmsi);
386
387          if(BuildAndSendPagingMsg(sTmsi, duId) != ROK)
388          {
389             DU_LOG("\nERROR --> EGTP: Failed to build and send paging message for 5gsTmsi[%lu]\n", sTmsi);   
390          }
391          continue;
392       }
393    }
394 }
395 /**********************************************************************
396          End of file
397 **********************************************************************/