ngap_gNB.c 23 KB
Newer Older
zhenghuangkun's avatar
zhenghuangkun committed
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62
/*
 * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The OpenAirInterface Software Alliance licenses this file to You under
 * the OAI Public License, Version 1.1  (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.openairinterface.org/?page_id=698
 *
 * 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.
 *-------------------------------------------------------------------------------
 * For more information about the OpenAirInterface (OAI) Software Alliance:
 *      contact@openairinterface.org
 */

/*! \file ngap_gNB.c
 * \brief NGAP gNB task
 * \author  S. Roux and Navid Nikaein
 * \date 2010 - 2015
 * \email: navid.nikaein@eurecom.fr
 * \version 1.0
 * @ingroup _ngap
 */

#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include <crypt.h>

#include "tree.h"
#include "queue.h"

#include "intertask_interface.h"

#include "ngap_gNB_default_values.h"

#include "ngap_common.h"

#include "ngap_gNB_defs.h"
#include "ngap_gNB.h"
#include "ngap_gNB_encoder.h"
#include "ngap_gNB_handlers.h"
#include "ngap_gNB_nnsf.h"

#include "ngap_gNB_nas_procedures.h"
#include "ngap_gNB_management_procedures.h"
#include "ngap_gNB_context_management_procedures.h"

#include "ngap_gNB_itti_messaging.h"

#include "ngap_gNB_ue_context.h" // test, to be removed
#include "msc.h"

#include "assertions.h"
#include "conversions.h"
zhenghuangkun's avatar
zhenghuangkun committed
63 64
#if defined(TEST_S1C_AMF)
  #include "oaisim_amf_test_s1c.h"
zhenghuangkun's avatar
zhenghuangkun committed
65 66 67
#endif


zhenghuangkun's avatar
zhenghuangkun committed
68 69
static int ngap_gNB_generate_ng_setup_request(
  ngap_gNB_instance_t *instance_p, ngap_gNB_amf_data_t *ngap_amf_data_p);
zhenghuangkun's avatar
zhenghuangkun committed
70

zhenghuangkun's avatar
zhenghuangkun committed
71
void ngap_gNB_handle_register_gNB(instance_t instance, ngap_register_gnb_req_t *ngap_register_gNB);
zhenghuangkun's avatar
zhenghuangkun committed
72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88

void ngap_gNB_handle_sctp_association_resp(instance_t instance, sctp_new_association_resp_t *sctp_new_association_resp);

uint32_t ngap_generate_gNB_id(void) {
  char    *out;
  char     hostname[50];
  int      ret;
  uint32_t gNB_id;
  /* Retrieve the host name */
  ret = gethostname(hostname, sizeof(hostname));
  DevAssert(ret == 0);
  out = crypt(hostname, "eurecom");
  DevAssert(out != NULL);
  gNB_id = ((out[0] << 24) | (out[1] << 16) | (out[2] << 8) | out[3]);
  return gNB_id;
}

zhenghuangkun's avatar
zhenghuangkun committed
89 90
static void ngap_gNB_register_amf(ngap_gNB_instance_t *instance_p,
                                  net_ip_address_t    *amf_ip_address,
zhenghuangkun's avatar
zhenghuangkun committed
91 92 93 94 95 96 97
                                  net_ip_address_t    *local_ip_addr,
                                  uint16_t             in_streams,
                                  uint16_t             out_streams,
                                  uint8_t              broadcast_plmn_num,
                                  uint8_t              broadcast_plmn_index[PLMN_LIST_MAX_SIZE]) {
  MessageDef                 *message_p                   = NULL;
  sctp_new_association_req_t *sctp_new_association_req_p  = NULL;
zhenghuangkun's avatar
zhenghuangkun committed
98 99
  ngap_gNB_amf_data_t        *ngap_amf_data_p             = NULL;
  struct ngap_gNB_amf_data_s *amf                         = NULL;
zhenghuangkun's avatar
zhenghuangkun committed
100
  DevAssert(instance_p != NULL);
zhenghuangkun's avatar
zhenghuangkun committed
101
  DevAssert(amf_ip_address != NULL);
zhenghuangkun's avatar
zhenghuangkun committed
102 103 104 105 106 107 108
  message_p = itti_alloc_new_message(TASK_NGAP, SCTP_NEW_ASSOCIATION_REQ);
  sctp_new_association_req_p = &message_p->ittiMsg.sctp_new_association_req;
  sctp_new_association_req_p->port = NGAP_PORT_NUMBER;
  sctp_new_association_req_p->ppid = NGAP_SCTP_PPID;
  sctp_new_association_req_p->in_streams  = in_streams;
  sctp_new_association_req_p->out_streams = out_streams;
  memcpy(&sctp_new_association_req_p->remote_address,
zhenghuangkun's avatar
zhenghuangkun committed
109 110
         amf_ip_address,
         sizeof(*amf_ip_address));
zhenghuangkun's avatar
zhenghuangkun committed
111 112 113
  memcpy(&sctp_new_association_req_p->local_address,
         local_ip_addr,
         sizeof(*local_ip_addr));
zhenghuangkun's avatar
zhenghuangkun committed
114 115 116 117 118 119 120 121 122 123 124 125 126 127
  NGAP_INFO("[gNB %d] check the amf registration state\n",instance_p->instance);
  amf = NULL;

  if ( amf == NULL ) {
    /* Create new AMF descriptor */
    ngap_amf_data_p = calloc(1, sizeof(*ngap_amf_data_p));
    DevAssert(ngap_amf_data_p != NULL);
    ngap_amf_data_p->cnx_id                = ngap_gNB_fetch_add_global_cnx_id();
    sctp_new_association_req_p->ulp_cnx_id = ngap_amf_data_p->cnx_id;
    ngap_amf_data_p->assoc_id          = -1;
    ngap_amf_data_p->broadcast_plmn_num = broadcast_plmn_num;
    memcpy(&ngap_amf_data_p->amf_s1_ip,
    	   amf_ip_address,
    	   sizeof(*amf_ip_address));
zhenghuangkun's avatar
zhenghuangkun committed
128
    for (int i = 0; i < broadcast_plmn_num; ++i)
zhenghuangkun's avatar
zhenghuangkun committed
129
      ngap_amf_data_p->broadcast_plmn_index[i] = broadcast_plmn_index[i];
zhenghuangkun's avatar
zhenghuangkun committed
130

zhenghuangkun's avatar
zhenghuangkun committed
131 132 133
    ngap_amf_data_p->ngap_gNB_instance = instance_p;
    STAILQ_INIT(&ngap_amf_data_p->served_guami);
    /* Insert the new descriptor in list of known AMF
zhenghuangkun's avatar
zhenghuangkun committed
134 135
     * but not yet associated.
     */
zhenghuangkun's avatar
zhenghuangkun committed
136 137 138 139 140 141 142 143
    RB_INSERT(ngap_amf_map, &instance_p->ngap_amf_head, ngap_amf_data_p);
    ngap_amf_data_p->state = NGAP_GNB_STATE_WAITING;
    instance_p->ngap_amf_nb ++;
    instance_p->ngap_amf_pending_nb ++;
  } else if (amf->state == NGAP_GNB_STATE_WAITING) {
    instance_p->ngap_amf_pending_nb ++;
    sctp_new_association_req_p->ulp_cnx_id = amf->cnx_id;
    NGAP_INFO("[gNB %d] AMF already registered, retrive the data (state %d, cnx %d, amf_nb %d, amf_pending_nb %d)\n",
zhenghuangkun's avatar
zhenghuangkun committed
144
              instance_p->instance,
zhenghuangkun's avatar
zhenghuangkun committed
145 146 147 148
              amf->state, amf->cnx_id,
              instance_p->ngap_amf_nb, instance_p->ngap_amf_pending_nb);
    /*ngap_amf_data_p->cnx_id                = amf->cnx_id;
    sctp_new_association_req_p->ulp_cnx_id = amf->cnx_id;
zhenghuangkun's avatar
zhenghuangkun committed
149

zhenghuangkun's avatar
zhenghuangkun committed
150 151
    ngap_amf_data_p->assoc_id          = -1;
    ngap_amf_data_p->ngap_gNB_instance = instance_p;
zhenghuangkun's avatar
zhenghuangkun committed
152 153
    */
  } else {
zhenghuangkun's avatar
zhenghuangkun committed
154
    NGAP_WARN("[gNB %d] AMF already registered but not in the waiting state, retrive the data (state %d, cnx %d, amf_nb %d, amf_pending_nb %d)\n",
zhenghuangkun's avatar
zhenghuangkun committed
155
              instance_p->instance,
zhenghuangkun's avatar
zhenghuangkun committed
156 157
              amf->state, amf->cnx_id,
              instance_p->ngap_amf_nb, instance_p->ngap_amf_pending_nb);
zhenghuangkun's avatar
zhenghuangkun committed
158 159 160 161 162 163
  }

  itti_send_msg_to_task(TASK_SCTP, instance_p->instance, message_p);
}


zhenghuangkun's avatar
zhenghuangkun committed
164
void ngap_gNB_handle_register_gNB(instance_t instance, ngap_register_gnb_req_t *ngap_register_gNB) {
zhenghuangkun's avatar
zhenghuangkun committed
165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188
  ngap_gNB_instance_t *new_instance;
  uint8_t index;
  DevAssert(ngap_register_gNB != NULL);
  /* Look if the provided instance already exists */
  new_instance = ngap_gNB_get_instance(instance);

  if (new_instance != NULL) {
    /* Checks if it is a retry on the same gNB */
    DevCheck(new_instance->gNB_id == ngap_register_gNB->gNB_id, new_instance->gNB_id, ngap_register_gNB->gNB_id, 0);
    DevCheck(new_instance->cell_type == ngap_register_gNB->cell_type, new_instance->cell_type, ngap_register_gNB->cell_type, 0);
    DevCheck(new_instance->num_plmn == ngap_register_gNB->num_plmn, new_instance->num_plmn, ngap_register_gNB->num_plmn, 0);
    DevCheck(new_instance->tac == ngap_register_gNB->tac, new_instance->tac, ngap_register_gNB->tac, 0);

    for (int i = 0; i < new_instance->num_plmn; i++) {
      DevCheck(new_instance->mcc[i] == ngap_register_gNB->mcc[i], new_instance->mcc[i], ngap_register_gNB->mcc[i], 0);
      DevCheck(new_instance->mnc[i] == ngap_register_gNB->mnc[i], new_instance->mnc[i], ngap_register_gNB->mnc[i], 0);
      DevCheck(new_instance->mnc_digit_length[i] == ngap_register_gNB->mnc_digit_length[i], new_instance->mnc_digit_length[i], ngap_register_gNB->mnc_digit_length[i], 0);
    }

    DevCheck(new_instance->default_drx == ngap_register_gNB->default_drx, new_instance->default_drx, ngap_register_gNB->default_drx, 0);
  } else {
    new_instance = calloc(1, sizeof(ngap_gNB_instance_t));
    DevAssert(new_instance != NULL);
    RB_INIT(&new_instance->ngap_ue_head);
zhenghuangkun's avatar
zhenghuangkun committed
189
    RB_INIT(&new_instance->ngap_amf_head);
zhenghuangkun's avatar
zhenghuangkun committed
190 191 192 193 194 195 196
    /* Copy usefull parameters */
    new_instance->instance         = instance;
    new_instance->gNB_name         = ngap_register_gNB->gNB_name;
    new_instance->gNB_id           = ngap_register_gNB->gNB_id;
    new_instance->cell_type        = ngap_register_gNB->cell_type;
    new_instance->tac              = ngap_register_gNB->tac;
    
zhenghuangkun's avatar
zhenghuangkun committed
197
    memcpy(&new_instance->gNB_ng_ip,
zhenghuangkun's avatar
zhenghuangkun committed
198 199
       &ngap_register_gNB->gnb_ip_address,
       sizeof(ngap_register_gNB->gnb_ip_address));
zhenghuangkun's avatar
zhenghuangkun committed
200 201 202 203 204

    for (int i = 0; i < ngap_register_gNB->num_plmn; i++) {
      new_instance->mcc[i]              = ngap_register_gNB->mcc[i];
      new_instance->mnc[i]              = ngap_register_gNB->mnc[i];
      new_instance->mnc_digit_length[i] = ngap_register_gNB->mnc_digit_length[i];
205 206
      
      new_instance->num_nssai[i]        = ngap_register_gNB->num_nssai[i];
zhenghuangkun's avatar
zhenghuangkun committed
207 208 209 210
    }

    new_instance->num_plmn         = ngap_register_gNB->num_plmn;
    new_instance->default_drx      = ngap_register_gNB->default_drx;
211 212 213 214 215 216 217 218 219 220 221 222 223

    memcpy(new_instance->s_nssai, ngap_register_gNB->s_nssai, sizeof(ngap_register_gNB->s_nssai));

    // config add? TBD
    if(1) {
      new_instance->num_nssai[0] = 1;
      new_instance->s_nssai[0][0].sST = 1;
      new_instance->s_nssai[0][0].sD_flag = 1;
      new_instance->s_nssai[0][0].sD[0] = 1;
      new_instance->s_nssai[0][0].sD[1] = 2;
      new_instance->s_nssai[0][0].sD[2] = 3;
    }
    
zhenghuangkun's avatar
zhenghuangkun committed
224 225 226 227 228 229 230 231
    /* Add the new instance to the list of gNB (meaningfull in virtual mode) */
    ngap_gNB_insert_new_instance(new_instance);
    NGAP_INFO("Registered new gNB[%d] and %s gNB id %u\n",
              instance,
              ngap_register_gNB->cell_type == CELL_MACRO_GNB ? "macro" : "home",
              ngap_register_gNB->gNB_id);
  }

zhenghuangkun's avatar
zhenghuangkun committed
232 233
  DevCheck(ngap_register_gNB->nb_amf <= NGAP_MAX_NB_AMF_IP_ADDRESS,
           NGAP_MAX_NB_AMF_IP_ADDRESS, ngap_register_gNB->nb_amf, 0);
zhenghuangkun's avatar
zhenghuangkun committed
234

zhenghuangkun's avatar
zhenghuangkun committed
235 236 237 238 239
  /* Trying to connect to provided list of AMF ip address */
  for (index = 0; index < ngap_register_gNB->nb_amf; index++) {
    net_ip_address_t *amf_ip = &ngap_register_gNB->amf_ip_address[index];
    struct ngap_gNB_amf_data_s *amf = NULL;
    RB_FOREACH(amf, ngap_amf_map, &new_instance->ngap_amf_head) {
zhenghuangkun's avatar
zhenghuangkun committed
240 241
      /* Compare whether IPv4 and IPv6 information is already present, in which
       * wase we do not register again */
zhenghuangkun's avatar
zhenghuangkun committed
242 243 244 245
      if (amf->amf_s1_ip.ipv4 == amf_ip->ipv4 && (!amf_ip->ipv4
              || strncmp(amf->amf_s1_ip.ipv4_address, amf_ip->ipv4_address, 16) == 0)
          && amf->amf_s1_ip.ipv6 == amf_ip->ipv6 && (!amf_ip->ipv6
              || strncmp(amf->amf_s1_ip.ipv6_address, amf_ip->ipv6_address, 46) == 0))
zhenghuangkun's avatar
zhenghuangkun committed
246 247
        break;
    }
zhenghuangkun's avatar
zhenghuangkun committed
248
    if (amf)
zhenghuangkun's avatar
zhenghuangkun committed
249
      continue;
zhenghuangkun's avatar
zhenghuangkun committed
250 251 252
    ngap_gNB_register_amf(new_instance,
                          amf_ip,
                          &ngap_register_gNB->gnb_ip_address,
zhenghuangkun's avatar
zhenghuangkun committed
253 254 255 256 257 258 259 260 261
                          ngap_register_gNB->sctp_in_streams,
                          ngap_register_gNB->sctp_out_streams,
                          ngap_register_gNB->broadcast_plmn_num[index],
                          ngap_register_gNB->broadcast_plmn_index[index]);
  }
}

void ngap_gNB_handle_sctp_association_resp(instance_t instance, sctp_new_association_resp_t *sctp_new_association_resp) {
  ngap_gNB_instance_t *instance_p;
zhenghuangkun's avatar
zhenghuangkun committed
262
  ngap_gNB_amf_data_t *ngap_amf_data_p;
zhenghuangkun's avatar
zhenghuangkun committed
263 264 265
  DevAssert(sctp_new_association_resp != NULL);
  instance_p = ngap_gNB_get_instance(instance);
  DevAssert(instance_p != NULL);
zhenghuangkun's avatar
zhenghuangkun committed
266
  ngap_amf_data_p = ngap_gNB_get_AMF(instance_p, -1,
zhenghuangkun's avatar
zhenghuangkun committed
267
                                     sctp_new_association_resp->ulp_cnx_id);
zhenghuangkun's avatar
zhenghuangkun committed
268
  DevAssert(ngap_amf_data_p != NULL);
zhenghuangkun's avatar
zhenghuangkun committed
269 270 271 272 273 274

  if (sctp_new_association_resp->sctp_state != SCTP_STATE_ESTABLISHED) {
    NGAP_WARN("Received unsuccessful result for SCTP association (%u), instance %d, cnx_id %u\n",
              sctp_new_association_resp->sctp_state,
              instance,
              sctp_new_association_resp->ulp_cnx_id);
zhenghuangkun's avatar
zhenghuangkun committed
275
    ngap_handle_ng_setup_message(ngap_amf_data_p, sctp_new_association_resp->sctp_state == SCTP_STATE_SHUTDOWN);
zhenghuangkun's avatar
zhenghuangkun committed
276 277 278 279
    return;
  }

  /* Update parameters */
zhenghuangkun's avatar
zhenghuangkun committed
280 281 282 283 284
  ngap_amf_data_p->assoc_id    = sctp_new_association_resp->assoc_id;
  ngap_amf_data_p->in_streams  = sctp_new_association_resp->in_streams;
  ngap_amf_data_p->out_streams = sctp_new_association_resp->out_streams;
  /* Prepare new NG Setup Request */
  ngap_gNB_generate_ng_setup_request(instance_p, ngap_amf_data_p);
zhenghuangkun's avatar
zhenghuangkun committed
285 286 287 288 289 290
}

static
void ngap_gNB_handle_sctp_data_ind(sctp_data_ind_t *sctp_data_ind) {
  int result;
  DevAssert(sctp_data_ind != NULL);
zhenghuangkun's avatar
zhenghuangkun committed
291 292
#if defined(TEST_S1C_AMF)
  amf_test_s1_notify_sctp_data_ind(sctp_data_ind->assoc_id, sctp_data_ind->stream,
zhenghuangkun's avatar
zhenghuangkun committed
293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365
                                   sctp_data_ind->buffer, sctp_data_ind->buffer_length);
#else
  ngap_gNB_handle_message(sctp_data_ind->assoc_id, sctp_data_ind->stream,
                          sctp_data_ind->buffer, sctp_data_ind->buffer_length);
#endif
  result = itti_free(TASK_UNKNOWN, sctp_data_ind->buffer);
  AssertFatal (result == EXIT_SUCCESS, "Failed to free memory (%d)!\n", result);
}

void ngap_gNB_init(void) {
  NGAP_DEBUG("Starting NGAP layer\n");
  ngap_gNB_prepare_internal_data();
  itti_mark_task_ready(TASK_NGAP);
  MSC_START_USE();
}

void *ngap_gNB_process_itti_msg(void *notUsed) {
  MessageDef *received_msg = NULL;
  int         result;
  itti_receive_msg(TASK_NGAP, &received_msg);

  switch (ITTI_MSG_ID(received_msg)) {
    case TERMINATE_MESSAGE:
      NGAP_WARN(" *** Exiting NGAP thread\n");
      itti_exit_task();
      break;

    case NGAP_REGISTER_GNB_REQ: {
      /* Register a new gNB.
       * in Virtual mode gNBs will be distinguished using the mod_id/
       * Each gNB has to send an NGAP_REGISTER_GNB message with its
       * own parameters.
       */
      ngap_gNB_handle_register_gNB(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                   &NGAP_REGISTER_GNB_REQ(received_msg));
    }
    break;

    case SCTP_NEW_ASSOCIATION_RESP: {
      ngap_gNB_handle_sctp_association_resp(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                            &received_msg->ittiMsg.sctp_new_association_resp);
    }
    break;

    case SCTP_DATA_IND: {
      ngap_gNB_handle_sctp_data_ind(&received_msg->ittiMsg.sctp_data_ind);
    }
    break;

    case NGAP_NAS_FIRST_REQ: {
      ngap_gNB_handle_nas_first_req(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                    &NGAP_NAS_FIRST_REQ(received_msg));
    }
    break;

    case NGAP_UPLINK_NAS: {
      ngap_gNB_nas_uplink(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                          &NGAP_UPLINK_NAS(received_msg));
    }
    break;

    case NGAP_UE_CAPABILITIES_IND: {
      ngap_gNB_ue_capabilities(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                               &NGAP_UE_CAPABILITIES_IND(received_msg));
    }
    break;

    case NGAP_INITIAL_CONTEXT_SETUP_RESP: {
      ngap_gNB_initial_ctxt_resp(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                 &NGAP_INITIAL_CONTEXT_SETUP_RESP(received_msg));
    }
    break;

zhenghuangkun's avatar
zhenghuangkun committed
366 367 368
    case NGAP_PDUSESSION_SETUP_RESP: {
      ngap_gNB_pdusession_setup_resp(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                &NGAP_PDUSESSION_SETUP_RESP(received_msg));
zhenghuangkun's avatar
zhenghuangkun committed
369 370 371
    }
    break;

zhenghuangkun's avatar
zhenghuangkun committed
372 373 374
    case NGAP_PDUSESSION_MODIFY_RESP: {
      ngap_gNB_pdusession_modify_resp(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                 &NGAP_PDUSESSION_MODIFY_RESP(received_msg));
zhenghuangkun's avatar
zhenghuangkun committed
375 376 377 378 379 380 381 382 383 384 385 386 387 388 389
    }
    break;

    case NGAP_NAS_NON_DELIVERY_IND: {
      ngap_gNB_nas_non_delivery_ind(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                    &NGAP_NAS_NON_DELIVERY_IND(received_msg));
    }
    break;

    case NGAP_PATH_SWITCH_REQ: {
      ngap_gNB_path_switch_req(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                               &NGAP_PATH_SWITCH_REQ(received_msg));
    }
    break;

zhenghuangkun's avatar
zhenghuangkun committed
390 391 392
    case NGAP_PDUSESSION_MODIFICATION_IND: {
    	ngap_gNB_generate_PDUSESSION_Modification_Indication(ITTI_MESSAGE_GET_INSTANCE(received_msg),
    	                               &NGAP_PDUSESSION_MODIFICATION_IND(received_msg));
zhenghuangkun's avatar
zhenghuangkun committed
393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418
    }
    break;

    case NGAP_UE_CONTEXT_RELEASE_COMPLETE: {
      ngap_ue_context_release_complete(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                       &NGAP_UE_CONTEXT_RELEASE_COMPLETE(received_msg));
    }
    break;

    case NGAP_UE_CONTEXT_RELEASE_REQ: {
      ngap_gNB_instance_t               *ngap_gNB_instance_p           = NULL; // test
      struct ngap_gNB_ue_context_s      *ue_context_p                  = NULL; // test
      ngap_ue_context_release_req(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                  &NGAP_UE_CONTEXT_RELEASE_REQ(received_msg));
      ngap_gNB_instance_p = ngap_gNB_get_instance(ITTI_MESSAGE_GET_INSTANCE(received_msg)); // test
      DevAssert(ngap_gNB_instance_p != NULL); // test

      if ((ue_context_p = ngap_gNB_get_ue_context(ngap_gNB_instance_p,
                          NGAP_UE_CONTEXT_RELEASE_REQ(received_msg).gNB_ue_ngap_id)) == NULL) { // test
        /* The context for this gNB ue ngap id doesn't exist in the map of gNB UEs */
        NGAP_ERROR("Failed to find ue context associated with gNB ue ngap id: %u\n",
                   NGAP_UE_CONTEXT_RELEASE_REQ(received_msg).gNB_ue_ngap_id); // test
      }  // test
    }
    break;

zhenghuangkun's avatar
zhenghuangkun committed
419 420 421
    case NGAP_PDUSESSION_RELEASE_RESPONSE: {
      ngap_gNB_pdusession_release_resp(ITTI_MESSAGE_GET_INSTANCE(received_msg),
                                  &NGAP_PDUSESSION_RELEASE_RESPONSE(received_msg));
zhenghuangkun's avatar
zhenghuangkun committed
422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449
    }
    break;

    default:
      NGAP_ERROR("Received unhandled message: %d:%s\n",
                 ITTI_MSG_ID(received_msg), ITTI_MSG_NAME(received_msg));
      break;
  }

  result = itti_free (ITTI_MSG_ORIGIN_ID(received_msg), received_msg);
  AssertFatal (result == EXIT_SUCCESS, "Failed to free memory (%d)!\n", result);
  received_msg = NULL;
  return NULL;
}


void *ngap_gNB_task(void *arg) {
  ngap_gNB_init();

  while (1) {
    (void) ngap_gNB_process_itti_msg(NULL);
  }

  return NULL;
}

//-----------------------------------------------------------------------------
/*
zhenghuangkun's avatar
zhenghuangkun committed
450
* gNB generate a NG setup request towards AMF
zhenghuangkun's avatar
zhenghuangkun committed
451
*/
zhenghuangkun's avatar
zhenghuangkun committed
452
static int ngap_gNB_generate_ng_setup_request(
zhenghuangkun's avatar
zhenghuangkun committed
453
  ngap_gNB_instance_t *instance_p,
zhenghuangkun's avatar
zhenghuangkun committed
454
  ngap_gNB_amf_data_t *ngap_amf_data_p)
zhenghuangkun's avatar
zhenghuangkun committed
455 456 457
//-----------------------------------------------------------------------------
{
  NGAP_NGAP_PDU_t            pdu;
zhenghuangkun's avatar
zhenghuangkun committed
458 459 460 461 462
  NGAP_NGSetupRequest_t      *out = NULL;
  NGAP_NGSetupRequestIEs_t   *ie = NULL;
  NGAP_SupportedTAItem_t     *ta = NULL;
  NGAP_BroadcastPLMNItem_t   *plmn = NULL;
  NGAP_SliceSupportItem_t    *ssi = NULL;
zhenghuangkun's avatar
zhenghuangkun committed
463 464 465 466
  uint8_t  *buffer = NULL;
  uint32_t  len = 0;
  int       ret = 0;
  DevAssert(instance_p != NULL);
zhenghuangkun's avatar
zhenghuangkun committed
467 468
  DevAssert(ngap_amf_data_p != NULL);
  ngap_amf_data_p->state = NGAP_GNB_STATE_WAITING;
zhenghuangkun's avatar
zhenghuangkun committed
469 470 471
  /* Prepare the NGAP message to encode */
  memset(&pdu, 0, sizeof(pdu));
  pdu.present = NGAP_NGAP_PDU_PR_initiatingMessage;
zhenghuangkun's avatar
zhenghuangkun committed
472
  pdu.choice.initiatingMessage.procedureCode = NGAP_ProcedureCode_id_NGSetup;
zhenghuangkun's avatar
zhenghuangkun committed
473
  pdu.choice.initiatingMessage.criticality = NGAP_Criticality_reject;
zhenghuangkun's avatar
zhenghuangkun committed
474 475
  pdu.choice.initiatingMessage.value.present = NGAP_InitiatingMessage__value_PR_NGSetupRequest;
  out = &pdu.choice.initiatingMessage.value.choice.NGSetupRequest;
zhenghuangkun's avatar
zhenghuangkun committed
476
  /* mandatory */
zhenghuangkun's avatar
zhenghuangkun committed
477 478
  ie = (NGAP_NGSetupRequestIEs_t *)calloc(1, sizeof(NGAP_NGSetupRequestIEs_t));
  ie->id = NGAP_ProtocolIE_ID_id_GlobalRANNodeID;
zhenghuangkun's avatar
zhenghuangkun committed
479
  ie->criticality = NGAP_Criticality_reject;
zhenghuangkun's avatar
zhenghuangkun committed
480 481 482 483 484 485 486
  ie->value.present = NGAP_NGSetupRequestIEs__value_PR_GlobalRANNodeID;
  ie->value.choice.GlobalRANNodeID.present = NGAP_GlobalRANNodeID_PR_globalGNB_ID;
  MCC_MNC_TO_PLMNID(instance_p->mcc[ngap_amf_data_p->broadcast_plmn_index[0]],
                    instance_p->mnc[ngap_amf_data_p->broadcast_plmn_index[0]],
                    instance_p->mnc_digit_length[ngap_amf_data_p->broadcast_plmn_index[0]],
                    &ie->value.choice.GlobalRANNodeID.choice.globalGNB_ID.pLMNIdentity);
  ie->value.choice.GlobalRANNodeID.choice.globalGNB_ID.gNB_ID.present = NGAP_GNB_ID_PR_gNB_ID;
zhenghuangkun's avatar
zhenghuangkun committed
487
  MACRO_GNB_ID_TO_BIT_STRING(instance_p->gNB_id,
zhenghuangkun's avatar
zhenghuangkun committed
488
                             &ie->value.choice.GlobalRANNodeID.choice.globalGNB_ID.gNB_ID.choice.gNB_ID);
zhenghuangkun's avatar
zhenghuangkun committed
489
  NGAP_INFO("%u -> %02x%02x%02x%02x\n", instance_p->gNB_id,
zhenghuangkun's avatar
zhenghuangkun committed
490 491
            ie->value.choice.GlobalRANNodeID.choice.globalGNB_ID.gNB_ID.choice.gNB_ID.buf[0],
            ie->value.choice.GlobalRANNodeID.choice.globalGNB_ID.gNB_ID.choice.gNB_ID.buf[1],
zhenghuangkun's avatar
zhenghuangkun committed
492 493
            ie->value.choice.GlobalRANNodeID.choice.globalGNB_ID.gNB_ID.choice.gNB_ID.buf[2],
            ie->value.choice.GlobalRANNodeID.choice.globalGNB_ID.gNB_ID.choice.gNB_ID.buf[3]);
zhenghuangkun's avatar
zhenghuangkun committed
494 495 496 497
  ASN_SEQUENCE_ADD(&out->protocolIEs.list, ie);

  /* optional */
  if (instance_p->gNB_name) {
zhenghuangkun's avatar
zhenghuangkun committed
498 499
    ie = (NGAP_NGSetupRequestIEs_t *)calloc(1, sizeof(NGAP_NGSetupRequestIEs_t));
    ie->id = NGAP_ProtocolIE_ID_id_RANNodeName;
zhenghuangkun's avatar
zhenghuangkun committed
500
    ie->criticality = NGAP_Criticality_ignore;
zhenghuangkun's avatar
zhenghuangkun committed
501 502
    ie->value.present = NGAP_NGSetupRequestIEs__value_PR_RANNodeName;
    OCTET_STRING_fromBuf(&ie->value.choice.RANNodeName, instance_p->gNB_name,
zhenghuangkun's avatar
zhenghuangkun committed
503 504 505 506 507
                         strlen(instance_p->gNB_name));
    ASN_SEQUENCE_ADD(&out->protocolIEs.list, ie);
  }

  /* mandatory */
zhenghuangkun's avatar
zhenghuangkun committed
508 509
  ie = (NGAP_NGSetupRequestIEs_t *)calloc(1, sizeof(NGAP_NGSetupRequestIEs_t));
  ie->id = NGAP_ProtocolIE_ID_id_SupportedTAList;
zhenghuangkun's avatar
zhenghuangkun committed
510
  ie->criticality = NGAP_Criticality_reject;
zhenghuangkun's avatar
zhenghuangkun committed
511
  ie->value.present = NGAP_NGSetupRequestIEs__value_PR_SupportedTAList;
zhenghuangkun's avatar
zhenghuangkun committed
512
  {
zhenghuangkun's avatar
zhenghuangkun committed
513
    ta = (NGAP_SupportedTAItem_t *)calloc(1, sizeof(NGAP_SupportedTAItem_t));
514
    INT24_TO_OCTET_STRING(instance_p->tac, &ta->tAC);
zhenghuangkun's avatar
zhenghuangkun committed
515
    {
zhenghuangkun's avatar
zhenghuangkun committed
516 517 518 519 520
      for (int i = 0; i < ngap_amf_data_p->broadcast_plmn_num; ++i) {
        plmn = (NGAP_BroadcastPLMNItem_t *)calloc(1, sizeof(NGAP_BroadcastPLMNItem_t));
        MCC_MNC_TO_TBCD(instance_p->mcc[ngap_amf_data_p->broadcast_plmn_index[i]],
                        instance_p->mnc[ngap_amf_data_p->broadcast_plmn_index[i]],
                        instance_p->mnc_digit_length[ngap_amf_data_p->broadcast_plmn_index[i]],
heshanyun's avatar
heshanyun committed
521
                        &plmn->pLMNIdentity);
zhenghuangkun's avatar
zhenghuangkun committed
522 523 524 525 526

        for(int si = 0; si < instance_p->num_nssai[i]; si++) {
          ssi = (NGAP_SliceSupportItem_t *)calloc(1, sizeof(NGAP_SliceSupportItem_t));
          INT8_TO_OCTET_STRING(instance_p->s_nssai[i][si].sST, &ssi->s_NSSAI.sST);

heshanyun's avatar
heshanyun committed
527
          if(instance_p->s_nssai[i]->sD_flag) {
zhenghuangkun's avatar
zhenghuangkun committed
528 529 530 531 532 533 534 535 536 537 538 539 540
            ssi->s_NSSAI.sD = calloc(1, sizeof(NGAP_SD_t));
            ssi->s_NSSAI.sD->buf = calloc(3, sizeof(uint8_t));
            ssi->s_NSSAI.sD->size = 3;
            ssi->s_NSSAI.sD->buf[0] = instance_p->s_nssai[i][si].sD[0];
            ssi->s_NSSAI.sD->buf[1] = instance_p->s_nssai[i][si].sD[1];
            ssi->s_NSSAI.sD->buf[2] = instance_p->s_nssai[i][si].sD[2];
          }
          

          ASN_SEQUENCE_ADD(&plmn->tAISliceSupportList.list, ssi);
        }
        
        ASN_SEQUENCE_ADD(&ta->broadcastPLMNList.list, plmn);
zhenghuangkun's avatar
zhenghuangkun committed
541 542
      }
    }
zhenghuangkun's avatar
zhenghuangkun committed
543
    ASN_SEQUENCE_ADD(&ie->value.choice.SupportedTAList.list, ta);
zhenghuangkun's avatar
zhenghuangkun committed
544 545
  }
  ASN_SEQUENCE_ADD(&out->protocolIEs.list, ie);
zhenghuangkun's avatar
zhenghuangkun committed
546
  
zhenghuangkun's avatar
zhenghuangkun committed
547
  /* mandatory */
zhenghuangkun's avatar
zhenghuangkun committed
548
  ie = (NGAP_NGSetupRequestIEs_t *)calloc(1, sizeof(NGAP_NGSetupRequestIEs_t));
zhenghuangkun's avatar
zhenghuangkun committed
549 550
  ie->id = NGAP_ProtocolIE_ID_id_DefaultPagingDRX;
  ie->criticality = NGAP_Criticality_ignore;
zhenghuangkun's avatar
zhenghuangkun committed
551
  ie->value.present = NGAP_NGSetupRequestIEs__value_PR_PagingDRX;
zhenghuangkun's avatar
zhenghuangkun committed
552 553 554 555 556
  ie->value.choice.PagingDRX = instance_p->default_drx;
  ASN_SEQUENCE_ADD(&out->protocolIEs.list, ie);


  if (ngap_gNB_encode_pdu(&pdu, &buffer, &len) < 0) {
zhenghuangkun's avatar
zhenghuangkun committed
557
    NGAP_ERROR("Failed to encode NG setup request\n");
zhenghuangkun's avatar
zhenghuangkun committed
558 559 560 561
    return -1;
  }

  /* Non UE-Associated signalling -> stream = 0 */
zhenghuangkun's avatar
zhenghuangkun committed
562
  ngap_gNB_itti_send_sctp_data_req(instance_p->instance, ngap_amf_data_p->assoc_id, buffer, len, 0);
zhenghuangkun's avatar
zhenghuangkun committed
563 564 565 566 567 568
  return ret;
}