9e2c889dba
Issue: unforeseen capability of having the same RAN Parameter ID across different REPORT service styles. Solution: keep only RAN Parameter IDs from REPORT styles that are supported by OAI. Implement sequence array where each element is combination of RIC request ID (unique per RIC SUBSCRIPTION) and Event Trigger Definition. This way we can properly check further conditions for a certain RAN Parameter ID. (e.g. if xApp is subscribed to RRC Connected and/or other modes, for "RRC State Changed To" RAN Parameter ID) Next steps: for new RAN Parameter ID, add new sequence array. Co-authored-by: Bischoff <tano.bischoff@hhi.fraunhofer.de> Co-authored-by: Shrinish Donde <shrinish.donde@hhi.fraunhofer.de> Co-authored-by: Khanh Toan Pham <khanh.toan.pham@hhi.fraunhofer.de>
66 lines
2.4 KiB
C
66 lines
2.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_rc_subs.h"
|
|
#include "common/utils/assertions.h"
|
|
#include "common/utils/alg/find.h"
|
|
|
|
#include <assert.h>
|
|
#include <pthread.h>
|
|
|
|
#define MAX_NUM_RIC_REQ_ID 64
|
|
|
|
static pthread_mutex_t rc_mutex = PTHREAD_MUTEX_INITIALIZER;
|
|
|
|
static bool eq_int(const void* value, const void* it)
|
|
{
|
|
const uint32_t ric_req_id = *(uint32_t *)value;
|
|
const ran_param_data_t *dit = (const ran_param_data_t *)it;
|
|
return ric_req_id == dit->ric_req_id;
|
|
}
|
|
|
|
void init_rc_subs_data(rc_subs_data_t *rc_subs_data)
|
|
{
|
|
pthread_mutex_lock(&rc_mutex);
|
|
// Initialize sequence array
|
|
seq_arr_init(&rc_subs_data->rs4_param202, sizeof(ran_param_data_t));
|
|
pthread_mutex_unlock(&rc_mutex);
|
|
}
|
|
|
|
void insert_rc_subs_data(seq_arr_t *seq_arr, ran_param_data_t *data)
|
|
{
|
|
pthread_mutex_lock(&rc_mutex);
|
|
// Insert (RIC request ID + Event Trigger Definition) in specific RAN Parameter ID sequence
|
|
seq_arr_push_back(seq_arr, data, sizeof(*data));
|
|
pthread_mutex_unlock(&rc_mutex);
|
|
}
|
|
|
|
void remove_rc_subs_data(rc_subs_data_t *rc_subs_data, uint32_t ric_req_id)
|
|
{
|
|
pthread_mutex_lock(&rc_mutex);
|
|
/* find the sequence element that matches RIC request ID */
|
|
elm_arr_t elm = find_if(&rc_subs_data->rs4_param202, (void *)&ric_req_id, eq_int);
|
|
ran_param_data_t *data = elm.it;
|
|
free_e2sm_rc_event_trigger(&data->ev_tr);
|
|
seq_arr_erase(&rc_subs_data->rs4_param202, elm.it);
|
|
pthread_mutex_unlock(&rc_mutex);
|
|
}
|