Guido Casati
4ec498c996
Motivation: Clarify the role of GTP tunnel endpoint IDs in PDU session handling. Previously, the struct members (gNB_teid_N3, UPF_teid_N3, etc.) were confusingly named and duplicated with separate transport-layer address fields. This refactoring replaces these with explicit n3_incoming and n3_outgoing members using gtpu_tunnel_t. This aligns with GTP conventions: "incoming TEID" refers to the TEID received from the remote peer (UPF on N3), while "outgoing TEID" is the TEID sent by the local entity (NG-RAN on N3) to the remote peer. Benefits: * Improves readability and clarity of the code * Reduces redundant struct members, i.e. remove UPF_teid_N3, UPF_addr_N3 * Aligns naming with 3GPP conventions for transport layer tunnels Changes: * Replace gtp_addr_N3, gNB_teid_N3, gtp_teid, upf_addr with n3_incoming and n3_outgoing * Update all related code to use the new struct members * Aligns naming with 3GPP conventions for transport layer tunnels
100 lines
3.4 KiB
C
100 lines
3.4 KiB
C
/*
|
|
* 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
|
|
*/
|
|
|
|
#include "ran_func_gtp.h"
|
|
|
|
#include <assert.h>
|
|
|
|
#include "common/ran_context.h"
|
|
#include "openair2/LAYER2/NR_MAC_gNB/mac_proto.h"
|
|
#include "openair2/E2AP/flexric/src/util/time_now_us.h"
|
|
#include "openair2/LAYER2/nr_pdcp/nr_pdcp_oai_api.h"
|
|
|
|
|
|
#if defined (NGRAN_GNB_CUCP)
|
|
#include "openair2/RRC/NR/rrc_gNB_UE_context.h"
|
|
#endif
|
|
|
|
bool read_gtp_sm(void * data)
|
|
{
|
|
assert(data != NULL);
|
|
|
|
gtp_ind_data_t* gtp = (gtp_ind_data_t*)(data);
|
|
//fill_gtp_ind_data(gtp);
|
|
|
|
gtp->msg.tstamp = time_now_us();
|
|
|
|
uint64_t ue_id_list[MAX_MOBILES_PER_GNB];
|
|
size_t num_ues = nr_pdcp_get_num_ues(ue_id_list, MAX_MOBILES_PER_GNB);
|
|
|
|
gtp->msg.len = num_ues;
|
|
if(gtp->msg.len > 0){
|
|
gtp->msg.ngut = calloc(gtp->msg.len, sizeof(gtp_ngu_t_stats_t) );
|
|
assert(gtp->msg.ngut != NULL);
|
|
}
|
|
else {
|
|
return false;
|
|
}
|
|
|
|
#if defined (NGRAN_GNB_CUCP) && defined (NGRAN_GNB_CUUP)
|
|
if (RC.nrrrc[0]->node_type == ngran_gNB_DU || RC.nrrrc[0]->node_type == ngran_gNB_CUCP) return false;
|
|
assert((RC.nrrrc[0]->node_type == ngran_gNB_CU || RC.nrrrc[0]->node_type == ngran_gNB) && "Expected node types: CU or gNB-mono");
|
|
|
|
for (size_t i = 0; i < num_ues; i++) {
|
|
rrc_gNB_ue_context_t *ue_context_p = rrc_gNB_get_ue_context(RC.nrrrc[0], ue_id_list[i]);
|
|
|
|
gtp->msg.ngut[i].rnti = ue_id_list[i];
|
|
int nb_pdu_session = ue_context_p->ue_context.nb_of_pdusessions;
|
|
if (nb_pdu_session > 0) {
|
|
int nb_pdu_idx = nb_pdu_session - 1;
|
|
gtp->msg.ngut[i].teidgnb = ue_context_p->ue_context.pduSession[nb_pdu_idx].param.n3_outgoing.teid;
|
|
gtp->msg.ngut[i].teidupf = ue_context_p->ue_context.pduSession[nb_pdu_idx].param.n3_incoming.teid;
|
|
// TODO: one PDU session has multiple QoS Flow
|
|
int nb_qos_flow = ue_context_p->ue_context.pduSession[nb_pdu_idx].param.nb_qos;
|
|
if (nb_qos_flow > 0) {
|
|
gtp->msg.ngut[i].qfi = ue_context_p->ue_context.pduSession[nb_pdu_idx].param.qos[nb_qos_flow - 1].qfi;
|
|
}
|
|
}
|
|
}
|
|
|
|
return true;
|
|
|
|
#elif defined (NGRAN_GNB_CUUP)
|
|
// For the moment, CU-UP doesn't store PDU session information
|
|
printf("GTP SM not yet implemented in CU-UP\n");
|
|
return false;
|
|
#endif
|
|
}
|
|
|
|
void read_gtp_setup_sm(void* data)
|
|
{
|
|
assert(data != NULL);
|
|
assert(0 !=0 && "Not supported");
|
|
}
|
|
|
|
sm_ag_if_ans_t write_ctrl_gtp_sm(void const* src)
|
|
{
|
|
assert(src != NULL);
|
|
printf("write_ctrl callback for GTP SM: operation not supported\n");
|
|
sm_ag_if_ans_t ans = {0};
|
|
return ans;
|
|
}
|