maki/openairinterface5g
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
Files
279d49415f0de4aa8c9e6cd561dd0a355f57eae6
openairinterface5g/nfapi/open-nFAPI/pnf_sim/src/main.cpp
T

2283 lines
75 KiB
C++
Raw Blame History

/*
* Copyright 2017 Cisco Systems, Inc.
*
* 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.
*/
#include <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
#include <string.h>
#include <unistd.h>
#include "debug.h"
#include "nfapi_pnf_interface.h"
#include "nfapi.h"
#include <sys/socket.h>
#include <sys/time.h>
#include <netinet/in.h>
#include <assert.h>
#include <arpa/inet.h>
#include <boost/foreach.hpp>
#include <boost/property_tree/xml_parser.hpp>
#include <boost/property_tree/ptree.hpp>
#include <boost/exception/diagnostic_information.hpp>
#include <boost/exception_ptr.hpp>
#include <vendor_ext.h>
#include "fapi_stub.h"
#include "pool.h"
#include <mutex>
#include <list>
#include <queue>
#include <map>
#include <vector>
#include <algorithm>
#include <stdlib.h>
#define NUM_P5_PHY 2
uint16_t phy_antenna_capability_values[] = { 1, 2, 4, 8, 16 };
static uint32_t rand_range(uint32_t min, uint32_t max)
{
return ((rand() % (max + 1 - min)) + min);
}
extern "C" {
void* pnf_allocate(size_t size)
{
return (void*)memory_pool::allocate(size);
}
void pnf_deallocate(void* ptr)
{
memory_pool::deallocate((uint8_t*)ptr);
}
int read_xml(const char *xml_file);
};
class udp_data
{
public:
bool enabled;
uint32_t rx_port;
uint32_t tx_port;
std::string tx_addr;
};
class phy_info
{
public:
phy_info()
: first_subframe_ind(0), fapi(0),
dl_ues_per_subframe(0), ul_ues_per_subframe(0),
timing_window(0), timing_info_mode(0), timing_info_period(0)
{
index = 0;
id = 0;
udp = 0;
local_port = 0;
remote_addr = 0;
remote_port = 0;
duplex_mode = 0;
dl_channel_bw_support = 0;
ul_channel_bw_support = 0;
num_dl_layers_supported = 0;
num_ul_layers_supported = 0;
release_supported = 0;
nmm_modes_supported = 0;
}
uint16_t index;
uint16_t id;
std::vector<uint8_t> rfs;
std::vector<uint8_t> excluded_rfs;
udp_data udp;
std::string local_addr;
int local_port;
char* remote_addr;
int remote_port;
uint8_t duplex_mode;
uint16_t dl_channel_bw_support;
uint16_t ul_channel_bw_support;
uint8_t num_dl_layers_supported;
uint8_t num_ul_layers_supported;
uint16_t release_supported;
uint8_t nmm_modes_supported;
uint8_t dl_ues_per_subframe;
uint8_t ul_ues_per_subframe;
uint8_t first_subframe_ind;
// timing information recevied from the vnf
uint8_t timing_window;
uint8_t timing_info_mode;
uint8_t timing_info_period;
fapi_t* fapi;
};
class rf_info
{
public:
uint16_t index;
uint16_t band;
int16_t max_transmit_power;
int16_t min_transmit_power;
uint8_t num_antennas_supported;
uint32_t min_downlink_frequency;
uint32_t max_downlink_frequency;
uint32_t max_uplink_frequency;
uint32_t min_uplink_frequency;
};
class pnf_info
{
public:
pnf_info()
: release(13), wireshark_test_mode(0),
max_total_power(0), oui(0)
{
release = 0;
sync_mode = 0;
location_mode = 0;
location_coordinates = 0;
dl_config_timing = 0;
ul_config_timing = 0;
tx_timing = 0;
hi_dci0_timing = 0;
max_phys = 0;
max_total_bw = 0;
max_total_dl_layers = 0;
max_total_ul_layers = 0;
shared_bands = 0;
shared_pa = 0;
}
int release;
std::vector<phy_info> phys;
std::vector<rf_info> rfs;
uint8_t sync_mode;
uint8_t location_mode;
uint8_t location_coordinates[6];
uint32_t dl_config_timing;
uint32_t ul_config_timing;
uint32_t tx_timing;
uint32_t hi_dci0_timing;
uint16_t max_phys;
uint16_t max_total_bw;
uint16_t max_total_dl_layers;
uint16_t max_total_ul_layers;
uint8_t shared_bands;
uint8_t shared_pa;
int16_t max_total_power;
uint8_t oui;
uint8_t wireshark_test_mode;
};
struct pnf_phy_user_data_t
{
uint16_t phy_id;
nfapi_pnf_config_t* config;
phy_info* phy;
nfapi_pnf_p7_config_t* p7_config;
};
int read_pnf_xml(pnf_info& pnf, const char* xml_file)
{
try
{
std::ifstream input(xml_file);
using boost::property_tree::ptree;
ptree pt;
read_xml(input, pt);
pnf.wireshark_test_mode = pt.get<unsigned>("pnf.wireshark_test_mode", 0);
pnf.sync_mode = pt.get<unsigned>("pnf.sync_mode");
pnf.location_mode= pt.get<unsigned>("pnf.location_mode");
//pnf.sync_mode = pt.get<unsigned>("pnf.location_coordinates");
pnf.dl_config_timing= pt.get<unsigned>("pnf.dl_config_timing");
pnf.ul_config_timing = pt.get<unsigned>("pnf.ul_config_timing");
pnf.tx_timing = pt.get<unsigned>("pnf.tx_timing");
pnf.hi_dci0_timing = pt.get<unsigned>("pnf.hi_dci0_timing");
pnf.max_phys = pt.get<unsigned>("pnf.max_phys");
pnf.max_total_bw = pt.get<unsigned>("pnf.max_total_bandwidth");
pnf.max_total_dl_layers = pt.get<unsigned>("pnf.max_total_num_dl_layers");
pnf.max_total_ul_layers = pt.get<unsigned>("pnf.max_total_num_ul_layers");
pnf.shared_bands = pt.get<unsigned>("pnf.shared_bands");
pnf.shared_pa = pt.get<unsigned>("pnf.shared_pas");
pnf.max_total_power = pt.get<signed>("pnf.maximum_total_power");
//"oui");
for(const auto& v : pt.get_child("pnf.phys"))
{
if(v.first == "phy")
{
phy_info phy;
phy.index = v.second.get<unsigned>("index");
phy.local_port = v.second.get<unsigned>("port");
phy.local_addr = v.second.get<std::string>("address");
phy.duplex_mode = v.second.get<unsigned>("duplex_mode");
phy.dl_channel_bw_support = v.second.get<unsigned>("downlink_channel_bandwidth_support");
phy.ul_channel_bw_support = v.second.get<unsigned>("uplink_channel_bandwidth_support");
phy.num_dl_layers_supported = v.second.get<unsigned>("number_of_dl_layers");
phy.num_ul_layers_supported = v.second.get<unsigned>("number_of_ul_layers");
phy.release_supported = v.second.get<unsigned>("3gpp_release_supported");
phy.nmm_modes_supported = v.second.get<unsigned>("nmm_modes_supported");
for(const auto& v2 : v.second.get_child("rfs"))
{
if(v2.first == "index")
phy.rfs.push_back(v2.second.get_value<unsigned>());
}
for(const auto& v2 : v.second.get_child("excluded_rfs"))
{
if(v2.first == "index")
phy.excluded_rfs.push_back(v2.second.get_value<unsigned>());
}
boost::optional<const boost::property_tree::ptree&> d = v.second.get_child_optional("data.udp");
if(d.is_initialized())
{
phy.udp.enabled = true;
phy.udp.rx_port = d.get().get<unsigned>("rx_port");
phy.udp.tx_port = d.get().get<unsigned>("tx_port");
phy.udp.tx_addr = d.get().get<std::string>("tx_addr");
}
else
{
phy.udp.enabled = false;
}
phy.dl_ues_per_subframe = v.second.get<unsigned>("dl_ues_per_subframe");
phy.ul_ues_per_subframe = v.second.get<unsigned>("ul_ues_per_subframe");
pnf.phys.push_back(phy);
}
}
for(const auto& v : pt.get_child("pnf.rfs"))
{
if(v.first == "rf")
{
rf_info rf;
rf.index = v.second.get<unsigned>("index");
rf.band = v.second.get<unsigned>("band");
rf.max_transmit_power = v.second.get<signed>("max_transmit_power");
rf.min_transmit_power = v.second.get<signed>("min_transmit_power");
rf.num_antennas_supported = v.second.get<unsigned>("num_antennas_supported");
rf.min_downlink_frequency = v.second.get<unsigned>("min_downlink_frequency");
rf.max_downlink_frequency = v.second.get<unsigned>("max_downlink_frequency");
rf.min_uplink_frequency = v.second.get<unsigned>("max_uplink_frequency");
rf.max_uplink_frequency = v.second.get<unsigned>("min_uplink_frequency");
pnf.rfs.push_back(rf);
}
}
}
catch(std::exception& e)
{
printf("%s", e.what());
return -1;
}
catch(boost::exception& e)
{
printf("%s", boost::diagnostic_information(e).c_str());
return -1;
}
return 0;
}
void pnf_sim_trace(nfapi_trace_level_t level, const char* message, ...)
{
va_list args;
va_start(args, message);
vprintf(message, args);
va_end(args);
}
void set_thread_priority(int priority)
{
//printf("%s(priority:%d)\n", __FUNCTION__, priority);
pthread_attr_t ptAttr;
struct sched_param schedParam;
schedParam.__sched_priority = priority; //79;
if(sched_setscheduler(0, SCHED_RR, &schedParam) != 0)
{
printf("failed to set SCHED_RR\n");
}
if(pthread_attr_setschedpolicy(&ptAttr, SCHED_RR) != 0)
{
printf("failed to set pthread SCHED_RR %d\n", errno);
}
pthread_attr_setinheritsched(&ptAttr, PTHREAD_EXPLICIT_SCHED);
struct sched_param thread_params;
thread_params.sched_priority = 20;
if(pthread_attr_setschedparam(&ptAttr, &thread_params) != 0)
{
printf("failed to set sched param\n");
}
}
void* pnf_p7_thread_start(void* ptr)
{
set_thread_priority(79);
nfapi_pnf_p7_config_t* config = (nfapi_pnf_p7_config_t*)ptr;
nfapi_pnf_p7_start(config);
return 0;
}
int pnf_param_request(nfapi_pnf_config_t* config, nfapi_pnf_param_request_t* req)
{
printf("[PNF_SIM] pnf param request\n");
nfapi_pnf_param_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_PNF_PARAM_RESPONSE;
resp.error_code = NFAPI_MSG_OK;
pnf_info* pnf = (pnf_info*)(config->user_data);
resp.pnf_param_general.tl.tag = NFAPI_PNF_PARAM_GENERAL_TAG;
resp.pnf_param_general.nfapi_sync_mode = pnf->sync_mode;
resp.pnf_param_general.location_mode = pnf->location_mode;
//uint8_t location_coordinates[NFAPI_PNF_PARAM_GENERAL_LOCATION_LENGTH];
resp.pnf_param_general.dl_config_timing = pnf->dl_config_timing;
resp.pnf_param_general.tx_timing = pnf->tx_timing;
resp.pnf_param_general.ul_config_timing = pnf->ul_config_timing;
resp.pnf_param_general.hi_dci0_timing = pnf->hi_dci0_timing;
resp.pnf_param_general.maximum_number_phys = pnf->max_phys;
resp.pnf_param_general.maximum_total_bandwidth = pnf->max_total_bw;
resp.pnf_param_general.maximum_total_number_dl_layers = pnf->max_total_dl_layers;
resp.pnf_param_general.maximum_total_number_ul_layers = pnf->max_total_ul_layers;
resp.pnf_param_general.shared_bands = pnf->shared_bands;
resp.pnf_param_general.shared_pa = pnf->shared_pa;
resp.pnf_param_general.maximum_total_power = pnf->max_total_power;
//uint8_t oui[NFAPI_PNF_PARAM_GENERAL_OUI_LENGTH];
resp.pnf_phy.tl.tag = NFAPI_PNF_PHY_TAG;
resp.pnf_phy.number_of_phys = pnf->phys.size();
for(int i = 0; i < pnf->phys.size(); ++i)
{
resp.pnf_phy.phy[i].phy_config_index = pnf->phys[i].index;
resp.pnf_phy.phy[i].downlink_channel_bandwidth_supported = pnf->phys[i].dl_channel_bw_support;
resp.pnf_phy.phy[i].uplink_channel_bandwidth_supported = pnf->phys[i].ul_channel_bw_support;
resp.pnf_phy.phy[i].number_of_dl_layers_supported = pnf->phys[i].num_dl_layers_supported;
resp.pnf_phy.phy[i].number_of_ul_layers_supported = pnf->phys[i].num_ul_layers_supported;
resp.pnf_phy.phy[i].maximum_3gpp_release_supported = pnf->phys[i].release_supported;
resp.pnf_phy.phy[i].nmm_modes_supported = pnf->phys[i].nmm_modes_supported;
resp.pnf_phy.phy[i].number_of_rfs = pnf->phys[i].rfs.size();
for(int j = 0; j < pnf->phys[i].rfs.size(); ++j)
{
resp.pnf_phy.phy[i].rf_config[j].rf_config_index = pnf->phys[i].rfs[j];
}
resp.pnf_phy.phy[i].number_of_rf_exclusions = pnf->phys[i].excluded_rfs.size();
for(int j = 0; j < pnf->phys[i].excluded_rfs.size(); ++j)
{
resp.pnf_phy.phy[i].excluded_rf_config[j].rf_config_index = pnf->phys[i].excluded_rfs[j];
}
}
resp.pnf_rf.tl.tag = NFAPI_PNF_RF_TAG;
resp.pnf_rf.number_of_rfs = pnf->rfs.size();
for(int i = 0; i < pnf->rfs.size(); ++i)
{
resp.pnf_rf.rf[i].rf_config_index = pnf->rfs[i].index;
resp.pnf_rf.rf[i].band = pnf->rfs[i].band;
resp.pnf_rf.rf[i].maximum_transmit_power = pnf->rfs[i].max_transmit_power;
resp.pnf_rf.rf[i].minimum_transmit_power = pnf->rfs[i].min_transmit_power;
resp.pnf_rf.rf[i].number_of_antennas_suppported = pnf->rfs[i].num_antennas_supported;
resp.pnf_rf.rf[i].minimum_downlink_frequency = pnf->rfs[i].min_downlink_frequency;
resp.pnf_rf.rf[i].maximum_downlink_frequency = pnf->rfs[i].max_downlink_frequency;
resp.pnf_rf.rf[i].minimum_uplink_frequency = pnf->rfs[i].min_uplink_frequency;
resp.pnf_rf.rf[i].maximum_uplink_frequency = pnf->rfs[i].max_uplink_frequency;
}
if(pnf->release >= 10)
{
resp.pnf_phy_rel10.tl.tag = NFAPI_PNF_PHY_REL10_TAG;
resp.pnf_phy_rel10.number_of_phys = pnf->phys.size();
for(int i = 0; i < pnf->phys.size(); ++i)
{
resp.pnf_phy_rel10.phy[i].phy_config_index = pnf->phys[i].index;
resp.pnf_phy_rel10.phy[i].transmission_mode_7_supported = 0;
resp.pnf_phy_rel10.phy[i].transmission_mode_8_supported = 1;
resp.pnf_phy_rel10.phy[i].two_antenna_ports_for_pucch = 0;
resp.pnf_phy_rel10.phy[i].transmission_mode_9_supported = 1;
resp.pnf_phy_rel10.phy[i].simultaneous_pucch_pusch = 0;
resp.pnf_phy_rel10.phy[i].four_layer_tx_with_tm3_and_tm4 = 1;
}
}
if(pnf->release >= 11)
{
resp.pnf_phy_rel11.tl.tag = NFAPI_PNF_PHY_REL11_TAG;
resp.pnf_phy_rel11.number_of_phys = pnf->phys.size();
for(int i = 0; i < pnf->phys.size(); ++i)
{
resp.pnf_phy_rel11.phy[i].phy_config_index = pnf->phys[i].index;
resp.pnf_phy_rel11.phy[i].edpcch_supported = 0;
resp.pnf_phy_rel11.phy[i].multi_ack_csi_reporting = 1;
resp.pnf_phy_rel11.phy[i].pucch_tx_diversity = 0;
resp.pnf_phy_rel11.phy[i].ul_comp_supported = 1;
resp.pnf_phy_rel11.phy[i].transmission_mode_5_supported = 0;
}
}
if(pnf->release >= 12)
{
resp.pnf_phy_rel12.tl.tag = NFAPI_PNF_PHY_REL12_TAG;
resp.pnf_phy_rel12.number_of_phys = pnf->phys.size();
for(int i = 0; i < pnf->phys.size(); ++i)
{
resp.pnf_phy_rel12.phy[i].phy_config_index = pnf->phys[i].index;
resp.pnf_phy_rel12.phy[i].csi_subframe_set = 0;
resp.pnf_phy_rel12.phy[i].enhanced_4tx_codebook = 2; // yes this is invalid
resp.pnf_phy_rel12.phy[i].drs_supported = 0;
resp.pnf_phy_rel12.phy[i].ul_64qam_supported = 1;
resp.pnf_phy_rel12.phy[i].transmission_mode_10_supported = 0;
resp.pnf_phy_rel12.phy[i].alternative_bts_indices = 1;
}
}
if(pnf->release >= 13)
{
resp.pnf_phy_rel13.tl.tag = NFAPI_PNF_PHY_REL13_TAG;
resp.pnf_phy_rel13.number_of_phys = pnf->phys.size();
for(int i = 0; i < pnf->phys.size(); ++i)
{
resp.pnf_phy_rel13.phy[i].phy_config_index = pnf->phys[i].index;
resp.pnf_phy_rel13.phy[i].pucch_format4_supported = 0;
resp.pnf_phy_rel13.phy[i].pucch_format5_supported = 1;
resp.pnf_phy_rel13.phy[i].more_than_5_ca_support = 0;
resp.pnf_phy_rel13.phy[i].laa_supported = 1;
resp.pnf_phy_rel13.phy[i].laa_ending_in_dwpts_supported = 0;
resp.pnf_phy_rel13.phy[i].laa_starting_in_second_slot_supported = 1;
resp.pnf_phy_rel13.phy[i].beamforming_supported = 0;
resp.pnf_phy_rel13.phy[i].csi_rs_enhancement_supported = 1;
resp.pnf_phy_rel13.phy[i].drms_enhancement_supported = 0;
resp.pnf_phy_rel13.phy[i].srs_enhancement_supported = 1;
}
resp.pnf_phy_rel13_nb_iot.tl.tag = NFAPI_PNF_PHY_REL13_NB_IOT_TAG;
resp.pnf_phy_rel13_nb_iot.number_of_phys = pnf->phys.size();
for(int i = 0; i < pnf->phys.size(); ++i)
{
resp.pnf_phy_rel13_nb_iot.phy[i].phy_config_index = pnf->phys[i].index;
resp.pnf_phy_rel13_nb_iot.phy[i].number_of_rfs = pnf->phys[i].rfs.size();
for(int j = 0; j < pnf->phys[i].rfs.size(); ++j)
{
resp.pnf_phy_rel13_nb_iot.phy[i].rf_config[j].rf_config_index = pnf->phys[i].rfs[j];
}
resp.pnf_phy_rel13_nb_iot.phy[i].number_of_rf_exclusions = pnf->phys[i].excluded_rfs.size();
for(int j = 0; j < pnf->phys[i].excluded_rfs.size(); ++j)
{
resp.pnf_phy_rel13_nb_iot.phy[i].excluded_rf_config[j].rf_config_index = pnf->phys[i].excluded_rfs[j];
}
resp.pnf_phy_rel13_nb_iot.phy[i].number_of_dl_layers_supported = pnf->phys[i].num_dl_layers_supported;
resp.pnf_phy_rel13_nb_iot.phy[i].number_of_ul_layers_supported = pnf->phys[i].num_ul_layers_supported;
resp.pnf_phy_rel13_nb_iot.phy[i].maximum_3gpp_release_supported = pnf->phys[i].release_supported;
resp.pnf_phy_rel13_nb_iot.phy[i].nmm_modes_supported = pnf->phys[i].nmm_modes_supported;
}
}
nfapi_pnf_pnf_param_resp(config, &resp);
return 0;
}
int pnf_config_request(nfapi_pnf_config_t* config, nfapi_pnf_config_request_t* req)
{
printf("[PNF_SIM] pnf config request\n");
pnf_info* pnf = (pnf_info*)(config->user_data);
for(int i = 0; i < req->pnf_phy_rf_config.number_phy_rf_config_info; ++i)
{
auto found = std::find_if(pnf->phys.begin(), pnf->phys.end(), [&](phy_info& item)
{ return item.index == req->pnf_phy_rf_config.phy_rf_config[i].phy_config_index; });
if(found != pnf->phys.end())
{
phy_info& phy = (*found);
phy.id = req->pnf_phy_rf_config.phy_rf_config[i].phy_id;
printf("[PNF_SIM] pnf config request assigned phy_id %d to phy_config_index %d\n", phy.id, req->pnf_phy_rf_config.phy_rf_config[i].phy_config_index);
}
else
{
// did not find the phy
printf("[PNF_SIM] pnf config request did not find phy_config_index %d\n", req->pnf_phy_rf_config.phy_rf_config[i].phy_config_index);
}
}
nfapi_pnf_config_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_PNF_CONFIG_RESPONSE;
resp.error_code = NFAPI_MSG_OK;
nfapi_pnf_pnf_config_resp(config, &resp);
return 0;
}
int fapi_param_response(fapi_t* fapi, fapi_param_resp_t* resp)
{
printf("[PNF_SIM] fapi param response\n");
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_param_response_t nfapi_resp;
memset(&nfapi_resp, 0, sizeof(nfapi_resp));
nfapi_resp.header.message_id = NFAPI_PARAM_RESPONSE;
nfapi_resp.header.phy_id = data->phy_id;
nfapi_resp.error_code = resp->error_code;
for(int i = 0; i < resp->number_of_tlvs; ++i)
{
switch(resp->tlvs[i].tag)
{
case FAPI_PHY_STATE_TAG:
nfapi_resp.l1_status.phy_state.tl.tag = NFAPI_L1_STATUS_PHY_STATE_TAG;
nfapi_resp.l1_status.phy_state.value = resp->tlvs[i].value;
nfapi_resp.num_tlv++;
break;
case FAPI_PHY_CAPABILITIES_DL_BANDWIDTH_SUPPORT_TAG:
nfapi_resp.phy_capabilities.dl_bandwidth_support.tl.tag = NFAPI_PHY_CAPABILITIES_DL_BANDWIDTH_SUPPORT_TAG;
nfapi_resp.phy_capabilities.dl_bandwidth_support.value = resp->tlvs[i].value;
nfapi_resp.num_tlv++;
break;
case FAPI_PHY_CAPABILITIES_UL_BANDWIDTH_SUPPORT_TAG:
nfapi_resp.phy_capabilities.ul_bandwidth_support.tl.tag = NFAPI_PHY_CAPABILITIES_UL_BANDWIDTH_SUPPORT_TAG;
nfapi_resp.phy_capabilities.ul_bandwidth_support.value = resp->tlvs[i].value;
nfapi_resp.num_tlv++;
break;
}
}
if(1)
{
// just code to populate all the tlv for testing with wireshark
// todo : these should be move up so that they are populated by fapi
nfapi_resp.phy_capabilities.dl_modulation_support.tl.tag = NFAPI_PHY_CAPABILITIES_DL_MODULATION_SUPPORT_TAG;
nfapi_resp.phy_capabilities.dl_modulation_support.value = rand_range(0, 0x0F);
nfapi_resp.num_tlv++;
nfapi_resp.phy_capabilities.ul_modulation_support.tl.tag = NFAPI_PHY_CAPABILITIES_UL_MODULATION_SUPPORT_TAG;
nfapi_resp.phy_capabilities.ul_modulation_support.value = rand_range(0, 0x07);
nfapi_resp.num_tlv++;
nfapi_resp.phy_capabilities.phy_antenna_capability.tl.tag = NFAPI_PHY_CAPABILITIES_PHY_ANTENNA_CAPABILITY_TAG;
nfapi_resp.phy_capabilities.phy_antenna_capability.value = phy_antenna_capability_values[rand_range(0, 4)];
nfapi_resp.num_tlv++;
nfapi_resp.phy_capabilities.release_capability.tl.tag = NFAPI_PHY_CAPABILITIES_RELEASE_CAPABILITY_TAG;
nfapi_resp.phy_capabilities.release_capability.value = rand_range(0, 0x3F);
nfapi_resp.num_tlv++;
nfapi_resp.phy_capabilities.mbsfn_capability.tl.tag = NFAPI_PHY_CAPABILITIES_MBSFN_CAPABILITY_TAG;
nfapi_resp.phy_capabilities.mbsfn_capability.value = rand_range(0, 1);
nfapi_resp.num_tlv++;
nfapi_resp.laa_capability.laa_support.tl.tag = NFAPI_LAA_CAPABILITY_LAA_SUPPORT_TAG;
nfapi_resp.laa_capability.laa_support.value = rand_range(0, 1);
nfapi_resp.num_tlv++;
nfapi_resp.laa_capability.pd_sensing_lbt_support.tl.tag = NFAPI_LAA_CAPABILITY_PD_SENSING_LBT_SUPPORT_TAG;
nfapi_resp.laa_capability.pd_sensing_lbt_support.value = rand_range(0, 1);
nfapi_resp.num_tlv++;
nfapi_resp.laa_capability.multi_carrier_lbt_support.tl.tag = NFAPI_LAA_CAPABILITY_MULTI_CARRIER_LBT_SUPPORT_TAG;
nfapi_resp.laa_capability.multi_carrier_lbt_support.value = rand_range(0, 0x0F);
nfapi_resp.num_tlv++;
nfapi_resp.laa_capability.partial_sf_support.tl.tag = NFAPI_LAA_CAPABILITY_PARTIAL_SF_SUPPORT_TAG;
nfapi_resp.laa_capability.partial_sf_support.value = rand_range(0, 1);
nfapi_resp.num_tlv++;
nfapi_resp.nb_iot_capability.nb_iot_support.tl.tag = NFAPI_LAA_CAPABILITY_NB_IOT_SUPPORT_TAG;
nfapi_resp.nb_iot_capability.nb_iot_support.value = rand_range(0, 2);
nfapi_resp.num_tlv++;
nfapi_resp.nb_iot_capability.nb_iot_operating_mode_capability.tl.tag = NFAPI_LAA_CAPABILITY_NB_IOT_OPERATING_MODE_CAPABILITY_TAG;
nfapi_resp.nb_iot_capability.nb_iot_operating_mode_capability.value = rand_range(0, 1);
nfapi_resp.num_tlv++;
nfapi_resp.subframe_config.duplex_mode.tl.tag = NFAPI_SUBFRAME_CONFIG_DUPLEX_MODE_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.subframe_config.pcfich_power_offset.tl.tag = NFAPI_SUBFRAME_CONFIG_PCFICH_POWER_OFFSET_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.subframe_config.pb.tl.tag = NFAPI_SUBFRAME_CONFIG_PB_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.subframe_config.dl_cyclic_prefix_type.tl.tag = NFAPI_SUBFRAME_CONFIG_DL_CYCLIC_PREFIX_TYPE_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.subframe_config.ul_cyclic_prefix_type.tl.tag = NFAPI_SUBFRAME_CONFIG_UL_CYCLIC_PREFIX_TYPE_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.rf_config.dl_channel_bandwidth.tl.tag = NFAPI_RF_CONFIG_DL_CHANNEL_BANDWIDTH_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.rf_config.ul_channel_bandwidth.tl.tag = NFAPI_RF_CONFIG_UL_CHANNEL_BANDWIDTH_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.rf_config.reference_signal_power.tl.tag = NFAPI_RF_CONFIG_REFERENCE_SIGNAL_POWER_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.rf_config.tx_antenna_ports.tl.tag = NFAPI_RF_CONFIG_TX_ANTENNA_PORTS_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.rf_config.rx_antenna_ports.tl.tag = NFAPI_RF_CONFIG_RX_ANTENNA_PORTS_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.phich_config.phich_resource.tl.tag = NFAPI_PHICH_CONFIG_PHICH_RESOURCE_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.phich_config.phich_duration.tl.tag = NFAPI_PHICH_CONFIG_PHICH_DURATION_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.phich_config.phich_power_offset.tl.tag = NFAPI_PHICH_CONFIG_PHICH_POWER_OFFSET_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.sch_config.primary_synchronization_signal_epre_eprers.tl.tag = NFAPI_SCH_CONFIG_PRIMARY_SYNCHRONIZATION_SIGNAL_EPRE_EPRERS_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.sch_config.secondary_synchronization_signal_epre_eprers.tl.tag = NFAPI_SCH_CONFIG_SECONDARY_SYNCHRONIZATION_SIGNAL_EPRE_EPRERS_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.sch_config.physical_cell_id.tl.tag = NFAPI_SCH_CONFIG_PHYSICAL_CELL_ID_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.prach_config.configuration_index.tl.tag = NFAPI_PRACH_CONFIG_CONFIGURATION_INDEX_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.prach_config.root_sequence_index.tl.tag = NFAPI_PRACH_CONFIG_ROOT_SEQUENCE_INDEX_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.prach_config.zero_correlation_zone_configuration.tl.tag = NFAPI_PRACH_CONFIG_ZERO_CORRELATION_ZONE_CONFIGURATION_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.prach_config.high_speed_flag.tl.tag = NFAPI_PRACH_CONFIG_HIGH_SPEED_FLAG_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.prach_config.frequency_offset.tl.tag = NFAPI_PRACH_CONFIG_FREQUENCY_OFFSET_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.pusch_config.hopping_mode.tl.tag = NFAPI_PUSCH_CONFIG_HOPPING_MODE_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.pusch_config.hopping_offset.tl.tag = NFAPI_PUSCH_CONFIG_HOPPING_OFFSET_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.pusch_config.number_of_subbands.tl.tag = NFAPI_PUSCH_CONFIG_NUMBER_OF_SUBBANDS_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.pucch_config.delta_pucch_shift.tl.tag = NFAPI_PUCCH_CONFIG_DELTA_PUCCH_SHIFT_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.pucch_config.n_cqi_rb.tl.tag = NFAPI_PUCCH_CONFIG_N_CQI_RB_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.pucch_config.n_an_cs.tl.tag = NFAPI_PUCCH_CONFIG_N_AN_CS_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.pucch_config.n1_pucch_an.tl.tag = NFAPI_PUCCH_CONFIG_N1_PUCCH_AN_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.srs_config.bandwidth_configuration.tl.tag = NFAPI_SRS_CONFIG_BANDWIDTH_CONFIGURATION_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.srs_config.max_up_pts.tl.tag = NFAPI_SRS_CONFIG_MAX_UP_PTS_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.srs_config.srs_subframe_configuration.tl.tag = NFAPI_SRS_CONFIG_SRS_SUBFRAME_CONFIGURATION_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.srs_config.srs_acknack_srs_simultaneous_transmission.tl.tag = NFAPI_SRS_CONFIG_SRS_ACKNACK_SRS_SIMULTANEOUS_TRANSMISSION_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.uplink_reference_signal_config.uplink_rs_hopping.tl.tag = NFAPI_UPLINK_REFERENCE_SIGNAL_CONFIG_UPLINK_RS_HOPPING_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.uplink_reference_signal_config.group_assignment.tl.tag = NFAPI_UPLINK_REFERENCE_SIGNAL_CONFIG_GROUP_ASSIGNMENT_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.uplink_reference_signal_config.cyclic_shift_1_for_drms.tl.tag = NFAPI_UPLINK_REFERENCE_SIGNAL_CONFIG_CYCLIC_SHIFT_1_FOR_DRMS_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.tdd_frame_structure_config.subframe_assignment.tl.tag = NFAPI_TDD_FRAME_STRUCTURE_SUBFRAME_ASSIGNMENT_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.tdd_frame_structure_config.special_subframe_patterns.tl.tag = NFAPI_TDD_FRAME_STRUCTURE_SPECIAL_SUBFRAME_PATTERNS_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.l23_config.data_report_mode.tl.tag = NFAPI_L23_CONFIG_DATA_REPORT_MODE_TAG;
nfapi_resp.num_tlv++;
nfapi_resp.l23_config.sfnsf.tl.tag = NFAPI_L23_CONFIG_SFNSF_TAG;
nfapi_resp.num_tlv++;
}
{
//if(phy->state == NFAPI_PNF_PHY_IDLE)
//if(nfapi_resp.l1_status.phy_state.value == NFAPI_PNF_PHY_IDLE)
{
// -- NFAPI
// Downlink UEs per Subframe
nfapi_resp.nfapi_config.dl_ue_per_sf.tl.tag = NFAPI_NFAPI_DOWNLINK_UES_PER_SUBFRAME_TAG;
nfapi_resp.nfapi_config.dl_ue_per_sf.value = data->phy->dl_ues_per_subframe;
nfapi_resp.num_tlv++;
// Uplink UEs per Subframe
nfapi_resp.nfapi_config.ul_ue_per_sf.tl.tag = NFAPI_NFAPI_UPLINK_UES_PER_SUBFRAME_TAG;
nfapi_resp.nfapi_config.ul_ue_per_sf.value = data->phy->ul_ues_per_subframe;
nfapi_resp.num_tlv++;
// nFAPI RF Bands
nfapi_resp.nfapi_config.rf_bands.tl.tag = NFAPI_PHY_RF_BANDS_TAG;
nfapi_resp.nfapi_config.rf_bands.number_rf_bands = 2;
nfapi_resp.nfapi_config.rf_bands.rf_band[0] = 23;
nfapi_resp.nfapi_config.rf_bands.rf_band[1] = 7;
// P7 PNF Address IPv4
nfapi_resp.nfapi_config.p7_pnf_address_ipv4.tl.tag = NFAPI_NFAPI_P7_PNF_ADDRESS_IPV4_TAG;
struct sockaddr_in pnf_p7_sockaddr;
pnf_p7_sockaddr.sin_addr.s_addr = inet_addr(data->phy->local_addr.c_str());
memcpy(&(nfapi_resp.nfapi_config.p7_pnf_address_ipv4.address[0]), &pnf_p7_sockaddr.sin_addr.s_addr, 4);
nfapi_resp.num_tlv++;
// P7 PNF Address IPv6
// P7 PNF Port
nfapi_resp.nfapi_config.p7_pnf_port.tl.tag = NFAPI_NFAPI_P7_PNF_PORT_TAG;
nfapi_resp.nfapi_config.p7_pnf_port.value = data->phy->local_port;
nfapi_resp.num_tlv++;
// NMM GSM Frequency Bands
nfapi_resp.nfapi_config.nmm_gsm_frequency_bands.tl.tag = NFAPI_NFAPI_NMM_GSM_FREQUENCY_BANDS_TAG;
nfapi_resp.nfapi_config.nmm_gsm_frequency_bands.number_of_rf_bands = 1;
nfapi_resp.nfapi_config.nmm_gsm_frequency_bands.bands[0] = 23;
nfapi_resp.num_tlv++;
// NMM UMTS Frequency Bands
nfapi_resp.nfapi_config.nmm_umts_frequency_bands.tl.tag = NFAPI_NFAPI_NMM_UMTS_FREQUENCY_BANDS_TAG;
nfapi_resp.nfapi_config.nmm_umts_frequency_bands.number_of_rf_bands = 1;
nfapi_resp.nfapi_config.nmm_umts_frequency_bands.bands[0] = 23;
nfapi_resp.num_tlv++;
// NMM LTE Frequency Bands
nfapi_resp.nfapi_config.nmm_lte_frequency_bands.tl.tag = NFAPI_NFAPI_NMM_LTE_FREQUENCY_BANDS_TAG;
nfapi_resp.nfapi_config.nmm_lte_frequency_bands.number_of_rf_bands = 1;
nfapi_resp.nfapi_config.nmm_lte_frequency_bands.bands[0] = 23;
nfapi_resp.num_tlv++;
// NMM Uplink RSSI supported
nfapi_resp.nfapi_config.nmm_uplink_rssi_supported.tl.tag = NFAPI_NFAPI_NMM_UPLINK_RSSI_SUPPORTED_TAG;
nfapi_resp.nfapi_config.nmm_uplink_rssi_supported.value = 1;
nfapi_resp.num_tlv++;
}
}
nfapi_pnf_param_resp(data->config, &nfapi_resp);
return 0;
}
int fapi_config_response(fapi_t* fapi, fapi_config_resp_t* resp)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_config_response_t nfapi_resp;
memset(&nfapi_resp, 0, sizeof(nfapi_resp));
nfapi_resp.header.message_id = NFAPI_CONFIG_RESPONSE;
nfapi_resp.header.phy_id = data->phy_id;
nfapi_resp.error_code = resp->error_code;
nfapi_pnf_config_resp(data->config, &nfapi_resp);
return 0;
}
int fapi_subframe_ind(fapi_t* fapi, fapi_subframe_ind_t* resp)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
if(data->phy->first_subframe_ind == 0)
{
printf("Sending nfapi_pnf_start_resp phy_id:%d\n", data->phy_id);
nfapi_start_response_t start_resp;
memset(&start_resp, 0, sizeof(start_resp));
start_resp.header.message_id = NFAPI_START_RESPONSE;
start_resp.header.phy_id = data->phy_id;
start_resp.error_code = NFAPI_MSG_OK;
nfapi_pnf_start_resp(data->config, &start_resp);
data->phy->first_subframe_ind = 1;
if(data->phy->udp.enabled)
{
fapi_start_data(fapi,
data->phy->udp.rx_port,
data->phy->udp.tx_addr.c_str(),
data->phy->udp.tx_port);
}
}
nfapi_pnf_p7_subframe_ind(data->p7_config, data->phy_id, resp->sfn_sf);
return 0;
}
int fapi_harq_ind(fapi_t* fapi, fapi_harq_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_harq_indication_t harq_ind;
memset(&harq_ind, 0, sizeof(harq_ind));
harq_ind.header.message_id = NFAPI_HARQ_INDICATION;
harq_ind.header.phy_id = data->p7_config->phy_id;
harq_ind.sfn_sf = ind->sfn_sf;
if(((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
harq_ind.harq_indication_body.tl.tag = NFAPI_HARQ_INDICATION_BODY_TAG;
harq_ind.harq_indication_body.number_of_harqs = 1;
nfapi_harq_indication_pdu_t pdus[harq_ind.harq_indication_body.number_of_harqs];
memset(&pdus, 0, sizeof(pdus));
pdus[0].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
pdus[0].rx_ue_information.handle = rand_range(0, 9999);
pdus[0].rx_ue_information.rnti = rand_range(1, 65535);
pdus[0].harq_indication_tdd_rel8.tl.tag = NFAPI_HARQ_INDICATION_TDD_REL8_TAG;
pdus[0].harq_indication_tdd_rel8.mode = rand_range(0, 4);
pdus[0].harq_indication_tdd_rel8.number_of_ack_nack = rand_range(1, 4);
switch(pdus[0].harq_indication_tdd_rel8.mode)
{
case 0:
{
pdus[0].harq_indication_tdd_rel8.harq_data.bundling.value_0 = rand_range(1, 7);
pdus[0].harq_indication_tdd_rel8.harq_data.bundling.value_1 = rand_range(1, 7);
}
break;
case 1:
{
pdus[0].harq_indication_tdd_rel8.harq_data.multiplex.value_0 = rand_range(1, 7);
pdus[0].harq_indication_tdd_rel8.harq_data.multiplex.value_1 = rand_range(1, 7);
pdus[0].harq_indication_tdd_rel8.harq_data.multiplex.value_2 = rand_range(1, 7);
pdus[0].harq_indication_tdd_rel8.harq_data.multiplex.value_3 = rand_range(1, 7);
}
break;
case 2:
{
pdus[0].harq_indication_tdd_rel8.harq_data.special_bundling.value_0 = rand_range(1, 7);
}
break;
};
pdus[0].harq_indication_tdd_rel9.tl.tag = NFAPI_HARQ_INDICATION_TDD_REL9_TAG;
pdus[0].harq_indication_tdd_rel9.mode = rand_range(0, 4);
pdus[0].harq_indication_tdd_rel9.number_of_ack_nack = 1;
switch(pdus[0].harq_indication_tdd_rel9.mode)
{
case 0:
{
pdus[0].harq_indication_tdd_rel9.harq_data[0].bundling.value_0 = rand_range(1, 7);
}
break;
case 1:
{
pdus[0].harq_indication_tdd_rel9.harq_data[0].multiplex.value_0 = rand_range(1, 7);
}
break;
case 2:
{
pdus[0].harq_indication_tdd_rel9.harq_data[0].special_bundling.value_0 = rand_range(1, 7);
}
break;
case 3:
{
pdus[0].harq_indication_tdd_rel9.harq_data[0].channel_selection.value_0 = rand_range(1, 7);
}
break;
case 4:
{
pdus[0].harq_indication_tdd_rel9.harq_data[0].format_3.value_0 = rand_range(1, 7);
}
break;
};
pdus[0].harq_indication_tdd_rel13.tl.tag = NFAPI_HARQ_INDICATION_TDD_REL13_TAG;
pdus[0].harq_indication_tdd_rel13.mode = rand_range(0, 6);
pdus[0].harq_indication_tdd_rel13.number_of_ack_nack = 1;
switch(pdus[0].harq_indication_tdd_rel13.mode)
{
case 0:
{
pdus[0].harq_indication_tdd_rel13.harq_data[0].bundling.value_0 = rand_range(1, 7);
}
break;
case 1:
{
pdus[0].harq_indication_tdd_rel13.harq_data[0].multiplex.value_0 = rand_range(1, 7);
}
break;
case 2:
{
pdus[0].harq_indication_tdd_rel13.harq_data[0].special_bundling.value_0 = rand_range(1, 7);
}
break;
case 3:
{
pdus[0].harq_indication_tdd_rel13.harq_data[0].channel_selection.value_0 = rand_range(1, 7);
}
break;
case 4:
{
pdus[0].harq_indication_tdd_rel13.harq_data[0].format_3.value_0 = rand_range(1, 7);
}
break;
case 5:
{
pdus[0].harq_indication_tdd_rel13.harq_data[0].format_4.value_0 = rand_range(1, 7);
}
break;
case 6:
{
pdus[0].harq_indication_tdd_rel13.harq_data[0].format_5.value_0 = rand_range(1, 7);
}
break;
};
pdus[0].harq_indication_fdd_rel8.tl.tag = NFAPI_HARQ_INDICATION_FDD_REL8_TAG;
pdus[0].harq_indication_fdd_rel8.harq_tb1 = rand_range(1, 7);
pdus[0].harq_indication_fdd_rel8.harq_tb2 = rand_range(1, 7);
pdus[0].harq_indication_fdd_rel9.tl.tag = NFAPI_HARQ_INDICATION_FDD_REL9_TAG;
pdus[0].harq_indication_fdd_rel9.mode = rand_range(0, 2);
pdus[0].harq_indication_fdd_rel9.number_of_ack_nack = 2;
pdus[0].harq_indication_fdd_rel9.harq_tb_n[0] = rand_range(1, 7);
pdus[0].harq_indication_fdd_rel9.harq_tb_n[1] = rand_range(1, 7);
pdus[0].harq_indication_fdd_rel13.tl.tag = NFAPI_HARQ_INDICATION_FDD_REL13_TAG;
pdus[0].harq_indication_fdd_rel13.mode = rand_range(0, 2);
pdus[0].harq_indication_fdd_rel13.number_of_ack_nack = 2;
pdus[0].harq_indication_fdd_rel13.harq_tb_n[0] = rand_range(1, 7);
pdus[0].harq_indication_fdd_rel13.harq_tb_n[1] = rand_range(1, 7);
pdus[0].ul_cqi_information.tl.tag = NFAPI_UL_CQI_INFORMATION_TAG;
pdus[0].ul_cqi_information.ul_cqi = rand_range(0,255);
pdus[0].ul_cqi_information.channel = rand_range(0, 1);
harq_ind.harq_indication_body.harq_pdu_list = pdus;
nfapi_pnf_p7_harq_ind(data->p7_config, &harq_ind);
}
else
{
harq_ind.harq_indication_body.tl.tag = NFAPI_HARQ_INDICATION_BODY_TAG;
harq_ind.harq_indication_body.number_of_harqs = 8;
nfapi_harq_indication_pdu_t pdus[8];
memset(&pdus, 0, sizeof(pdus));
for(int i = 0; i < 8; ++i)
{
pdus[i].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
pdus[i].rx_ue_information.handle = 0xFF;
pdus[i].rx_ue_information.rnti = i;
pdus[i].harq_indication_fdd_rel8.tl.tag = NFAPI_HARQ_INDICATION_FDD_REL8_TAG;
pdus[i].harq_indication_fdd_rel8.harq_tb1 = 1;
pdus[i].harq_indication_fdd_rel8.harq_tb2 = 2;
}
harq_ind.harq_indication_body.harq_pdu_list = pdus;
nfapi_pnf_p7_harq_ind(data->p7_config, &harq_ind);
}
return 0;
}
int fapi_crc_ind(fapi_t* fapi, fapi_crc_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_crc_indication_t crc_ind;
memset(&crc_ind, 0, sizeof(crc_ind));
crc_ind.header.message_id = NFAPI_CRC_INDICATION;
crc_ind.header.phy_id = data->p7_config->phy_id;
crc_ind.sfn_sf = ind->sfn_sf;
if(((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
crc_ind.crc_indication_body.tl.tag = NFAPI_CRC_INDICATION_BODY_TAG;
crc_ind.crc_indication_body.number_of_crcs = 1;
nfapi_crc_indication_pdu_t pdus[crc_ind.crc_indication_body.number_of_crcs];
memset(&pdus, 0, sizeof(pdus));
pdus[0].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
pdus[0].rx_ue_information.handle = rand_range(0, 9999);
pdus[0].rx_ue_information.rnti = rand_range(1, 65535);
pdus[0].crc_indication_rel8.tl.tag = NFAPI_CRC_INDICATION_REL8_TAG;
pdus[0].crc_indication_rel8.crc_flag = rand_range(0, 1);
crc_ind.crc_indication_body.crc_pdu_list = pdus;
nfapi_pnf_p7_crc_ind(data->p7_config, &crc_ind);
}
else
{
crc_ind.crc_indication_body.tl.tag = NFAPI_CRC_INDICATION_BODY_TAG;
crc_ind.crc_indication_body.number_of_crcs = ind->body.number_of_crcs;
crc_ind.crc_indication_body.crc_pdu_list = (nfapi_crc_indication_pdu_t*)malloc(sizeof(nfapi_crc_indication_pdu_t) * ind->body.number_of_crcs);
for(int i = 0; i < ind->body.number_of_crcs; ++i)
{
crc_ind.crc_indication_body.crc_pdu_list[i].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
crc_ind.crc_indication_body.crc_pdu_list[i].rx_ue_information.handle = ind->body.pdus[i].rx_ue_info.handle;
crc_ind.crc_indication_body.crc_pdu_list[i].rx_ue_information.rnti = ind->body.pdus[i].rx_ue_info.rnti;
crc_ind.crc_indication_body.crc_pdu_list[i].crc_indication_rel8.tl.tag = NFAPI_CRC_INDICATION_REL8_TAG;
crc_ind.crc_indication_body.crc_pdu_list[i].crc_indication_rel8.crc_flag = ind->body.pdus[i].rel8_pdu.crc_flag;
}
nfapi_pnf_p7_crc_ind(data->p7_config, &crc_ind);
free(crc_ind.crc_indication_body.crc_pdu_list);
}
return 0;
}
int fapi_rx_ulsch_ind(fapi_t* fapi, fapi_rx_ulsch_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_rx_indication_t rx_ind;
memset(&rx_ind, 0, sizeof(rx_ind));
rx_ind.header.message_id = NFAPI_RX_ULSCH_INDICATION;
rx_ind.header.phy_id = data->p7_config->phy_id;
rx_ind.sfn_sf = ind->sfn_sf;
if(1)//((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
rx_ind.rx_indication_body.tl.tag = NFAPI_RX_INDICATION_BODY_TAG;
rx_ind.rx_indication_body.number_of_pdus = 1;
uint8_t rx_data[1024];
nfapi_rx_indication_pdu_t pdus[rx_ind.rx_indication_body.number_of_pdus];
memset(&pdus, 0, sizeof(pdus));
strcpy((char*)rx_data, (char*)"123456789");
for(int i = 0; i < rx_ind.rx_indication_body.number_of_pdus;++i)
{
pdus[i].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
pdus[i].rx_ue_information.handle = rand_range(0, 9999);
pdus[i].rx_ue_information.rnti = rand_range(1, 65535);
pdus[i].rx_indication_rel8.tl.tag = NFAPI_RX_INDICATION_REL8_TAG;
pdus[i].rx_indication_rel8.length = 10;//rand_range(0, 1024);
pdus[i].rx_indication_rel8.offset = 0;//djp - 1;
pdus[i].rx_indication_rel8.ul_cqi = rand_range(0, 255);
pdus[i].rx_indication_rel8.timing_advance = rand_range(0, 63);
//pdus[i].rx_indication_rel9.tl.tag = NFAPI_RX_INDICATION_REL9_TAG;
//pdus[i].rx_indication_rel9.timing_advance_r9 = rand_range(0, 7690);
pdus[i].data = &rx_data[0];
}
rx_ind.rx_indication_body.rx_pdu_list = pdus;
nfapi_pnf_p7_rx_ind(data->p7_config, &rx_ind);
}
else
{
rx_ind.rx_indication_body.tl.tag = NFAPI_RX_INDICATION_BODY_TAG;
rx_ind.rx_indication_body.number_of_pdus = ind->body.number_of_pdus;
rx_ind.rx_indication_body.rx_pdu_list = (nfapi_rx_indication_pdu_t*)malloc(sizeof(nfapi_rx_indication_pdu_t) * ind->body.number_of_pdus);
for(int i = 0; i < ind->body.number_of_pdus; ++i)
{
rx_ind.rx_indication_body.rx_pdu_list[i].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
rx_ind.rx_indication_body.rx_pdu_list[i].rx_ue_information.handle = ind->body.pdus[i].rx_ue_info.handle;
rx_ind.rx_indication_body.rx_pdu_list[i].rx_indication_rel8.tl.tag = NFAPI_RX_INDICATION_REL8_TAG;
rx_ind.rx_indication_body.rx_pdu_list[i].rx_indication_rel8.length = ind->body.pdus[i].rel8_pdu.length;
rx_ind.rx_indication_body.rx_pdu_list[i].rx_indication_rel8.offset = 1;
rx_ind.rx_indication_body.rx_pdu_list[i].rx_indication_rel9.tl.tag = 0;
rx_ind.rx_indication_body.rx_pdu_list[i].data = (uint8_t*)ind->body.data[i];
}
nfapi_pnf_p7_rx_ind(data->p7_config, &rx_ind);
free(rx_ind.rx_indication_body.rx_pdu_list);
}
return 0;
}
int fapi_rx_cqi_ind(fapi_t* fapi, fapi_rx_cqi_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_cqi_indication_t cqi_ind;
memset(&cqi_ind, 0, sizeof(cqi_ind));
cqi_ind.header.message_id = NFAPI_RX_CQI_INDICATION;
cqi_ind.header.phy_id = data->p7_config->phy_id;
cqi_ind.sfn_sf = ind->sfn_sf;
if(((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
cqi_ind.cqi_indication_body.tl.tag = NFAPI_CQI_INDICATION_BODY_TAG;
cqi_ind.cqi_indication_body.number_of_cqis = 3;
nfapi_cqi_indication_pdu_t cqi_pdu_list[cqi_ind.cqi_indication_body.number_of_cqis];
memset(&cqi_pdu_list, 0, sizeof(cqi_pdu_list));
nfapi_cqi_indication_raw_pdu_t cqi_raw_pdu_list[cqi_ind.cqi_indication_body.number_of_cqis];
//memset(&cqi_raw_pdu_list, 0, sizeof(cqi_raw_pdu_list));
for(int i = 0; i < cqi_ind.cqi_indication_body.number_of_cqis; ++i)
{
cqi_pdu_list[i].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
cqi_pdu_list[i].rx_ue_information.handle = rand_range(0, 9999);
cqi_pdu_list[i].rx_ue_information.rnti = rand_range(1, 65535);
uint8_t rel8_or_9 = rand_range(0, 1);
if(rel8_or_9)
{
cqi_pdu_list[i].cqi_indication_rel8.tl.tag = NFAPI_CQI_INDICATION_REL8_TAG;
cqi_pdu_list[i].cqi_indication_rel8.length = 8; //rand_range(1, 12);
cqi_pdu_list[i].cqi_indication_rel8.data_offset = 1; //rand_range(0, 1);
cqi_pdu_list[i].cqi_indication_rel8.ul_cqi = 0;
cqi_pdu_list[i].cqi_indication_rel8.ri = rand_range(0, 4);
cqi_pdu_list[i].cqi_indication_rel8.timing_advance = rand_range(0, 63);
}
else
{
cqi_pdu_list[i].cqi_indication_rel9.tl.tag = NFAPI_CQI_INDICATION_REL9_TAG;
cqi_pdu_list[i].cqi_indication_rel9.length = 8; //rand_range(1, 12);
cqi_pdu_list[i].cqi_indication_rel9.data_offset = 1; //rand_range(0, 1);
cqi_pdu_list[i].cqi_indication_rel9.ul_cqi = 0; //rand_range(0, 1);
cqi_pdu_list[i].cqi_indication_rel9.number_of_cc_reported = 1;
cqi_pdu_list[i].cqi_indication_rel9.ri[0] = rand_range(0, 8);
cqi_pdu_list[i].cqi_indication_rel9.timing_advance = rand_range(0, 63);
cqi_pdu_list[i].cqi_indication_rel9.timing_advance_r9 = rand_range(0, 7690);
}
cqi_pdu_list[i].ul_cqi_information.tl.tag = NFAPI_UL_CQI_INFORMATION_TAG;
cqi_pdu_list[i].ul_cqi_information.ul_cqi = rand_range(0,255);
cqi_pdu_list[i].ul_cqi_information.channel = rand_range(0, 1);
}
cqi_ind.cqi_indication_body.cqi_pdu_list = cqi_pdu_list;
cqi_ind.cqi_indication_body.cqi_raw_pdu_list = cqi_raw_pdu_list;
nfapi_pnf_p7_cqi_ind(data->p7_config, &cqi_ind);
}
else
{
nfapi_pnf_p7_cqi_ind(data->p7_config, &cqi_ind);
}
return 0;
}
int fapi_rx_sr_ind(fapi_t* fapi, fapi_rx_sr_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_sr_indication_t sr_ind;
memset(&sr_ind, 0, sizeof(sr_ind));
sr_ind.header.message_id = NFAPI_RX_SR_INDICATION;
sr_ind.header.phy_id = data->p7_config->phy_id;
sr_ind.sfn_sf = ind->sfn_sf;
if(((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
sr_ind.sr_indication_body.tl.tag = NFAPI_SR_INDICATION_BODY_TAG;
sr_ind.sr_indication_body.number_of_srs = 1;
nfapi_sr_indication_pdu_t pdus[sr_ind.sr_indication_body.number_of_srs];
memset(&pdus, 0, sizeof(pdus));
pdus[0].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
pdus[0].rx_ue_information.handle = rand_range(0, 9999);
pdus[0].rx_ue_information.rnti = rand_range(1, 65535);
pdus[0].ul_cqi_information.tl.tag = NFAPI_UL_CQI_INFORMATION_TAG;
pdus[0].ul_cqi_information.ul_cqi = rand_range(0,255);
pdus[0].ul_cqi_information.channel = rand_range(0, 1);
sr_ind.sr_indication_body.sr_pdu_list = pdus;
nfapi_pnf_p7_sr_ind(data->p7_config, &sr_ind);
}
else
{
nfapi_pnf_p7_sr_ind(data->p7_config, &sr_ind);
}
return 0;
}
int fapi_rach_ind(fapi_t* fapi, fapi_rach_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_rach_indication_t rach_ind;
memset(&rach_ind, 0, sizeof(rach_ind));
rach_ind.header.message_id = NFAPI_RACH_INDICATION;
rach_ind.header.phy_id = data->p7_config->phy_id;
rach_ind.sfn_sf = ind->sfn_sf;
if(((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
rach_ind.rach_indication_body.tl.tag = NFAPI_RACH_INDICATION_BODY_TAG;
rach_ind.rach_indication_body.number_of_preambles = 1;
nfapi_preamble_pdu_t pdus[rach_ind.rach_indication_body.number_of_preambles];
memset(&pdus, 0, sizeof(pdus));
pdus[0].preamble_rel8.tl.tag = NFAPI_PREAMBLE_REL8_TAG;
pdus[0].preamble_rel8.rnti = rand_range(1, 65535);
pdus[0].preamble_rel8.preamble = rand_range(0, 63);
pdus[0].preamble_rel8.timing_advance = rand_range(0, 1282);
pdus[0].preamble_rel9.tl.tag = NFAPI_PREAMBLE_REL9_TAG;
pdus[0].preamble_rel9.timing_advance_r9 = rand_range(0, 7690);
pdus[0].preamble_rel13.tl.tag = NFAPI_PREAMBLE_REL13_TAG;
pdus[0].preamble_rel13.rach_resource_type = rand_range(0, 4);
rach_ind.rach_indication_body.preamble_list = pdus;
nfapi_pnf_p7_rach_ind(data->p7_config, &rach_ind);
}
else
{
nfapi_pnf_p7_rach_ind(data->p7_config, &rach_ind);
}
return 0;
}
int fapi_srs_ind(fapi_t* fapi, fapi_srs_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_srs_indication_t srs_ind;
memset(&srs_ind, 0, sizeof(srs_ind));
srs_ind.header.message_id = NFAPI_SRS_INDICATION;
srs_ind.header.phy_id = data->p7_config->phy_id;
srs_ind.sfn_sf = ind->sfn_sf;
if(((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
srs_ind.srs_indication_body.tl.tag = NFAPI_SRS_INDICATION_BODY_TAG;
srs_ind.srs_indication_body.number_of_ues = 1;
nfapi_srs_indication_pdu_t pdus[srs_ind.srs_indication_body.number_of_ues];
memset(&pdus, 0, sizeof(pdus));
pdus[0].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
pdus[0].rx_ue_information.handle = rand_range(0, 9999);
pdus[0].rx_ue_information.rnti = rand_range(1, 65535);
pdus[0].srs_indication_fdd_rel8.tl.tag = NFAPI_SRS_INDICATION_FDD_REL8_TAG;
pdus[0].srs_indication_fdd_rel8.doppler_estimation = rand_range(0, 255);
pdus[0].srs_indication_fdd_rel8.timing_advance = rand_range(0, 63);
pdus[0].srs_indication_fdd_rel8.number_of_resource_blocks = 2; //rand_range(0, 255);
pdus[0].srs_indication_fdd_rel8.rb_start = rand_range(0, 245);
pdus[0].srs_indication_fdd_rel8.snr[0] = rand_range(0, 255);
pdus[0].srs_indication_fdd_rel8.snr[1] = rand_range(0, 255);
pdus[0].srs_indication_fdd_rel9.tl.tag = NFAPI_SRS_INDICATION_FDD_REL9_TAG;
pdus[0].srs_indication_fdd_rel9.timing_advance_r9 = rand_range(0, 7690);
pdus[0].srs_indication_tdd_rel10.tl.tag = NFAPI_SRS_INDICATION_TDD_REL10_TAG;
pdus[0].srs_indication_tdd_rel10.uppts_symbol = rand_range(0, 1);
pdus[0].srs_indication_fdd_rel11.tl.tag = NFAPI_SRS_INDICATION_FDD_REL11_TAG;
pdus[0].srs_indication_fdd_rel11.ul_rtoa;
pdus[0].tdd_channel_measurement.tl.tag = NFAPI_TDD_CHANNEL_MEASUREMENT_TAG;
pdus[0].tdd_channel_measurement.num_prb_per_subband = rand_range(0, 255);
pdus[0].tdd_channel_measurement.number_of_subbands = 1;
pdus[0].tdd_channel_measurement.num_atennas = 2;
pdus[0].tdd_channel_measurement.subands[0].subband_index = rand_range(0, 255);
pdus[0].tdd_channel_measurement.subands[0].channel[0] = rand_range(0, 9999);
pdus[0].tdd_channel_measurement.subands[0].channel[1] = rand_range(0, 9999);
srs_ind.srs_indication_body.srs_pdu_list = pdus;
nfapi_pnf_p7_srs_ind(data->p7_config, &srs_ind);
}
else
{
nfapi_pnf_p7_srs_ind(data->p7_config, &srs_ind);
}
return 0;
}
int fapi_lbt_dl_ind(fapi_t* fapi, fapi_lbt_dl_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_lbt_dl_indication_t lbt_dl_ind;
memset(&lbt_dl_ind, 0, sizeof(lbt_dl_ind));
lbt_dl_ind.header.message_id = NFAPI_LBT_DL_INDICATION;
lbt_dl_ind.header.phy_id = data->p7_config->phy_id;
lbt_dl_ind.sfn_sf = ind->sfn_sf;
if(((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
lbt_dl_ind.lbt_dl_indication_body.tl.tag = NFAPI_LBT_DL_INDICATION_BODY_TAG;
lbt_dl_ind.lbt_dl_indication_body.number_of_pdus = 2;
nfapi_lbt_dl_indication_pdu_t pdus[lbt_dl_ind.lbt_dl_indication_body.number_of_pdus];
memset(&pdus, 0, sizeof(pdus));
pdus[0].pdu_type = 0; // LBT_PDSCH_RSP PDU
pdus[0].pdu_size = 0;
pdus[0].lbt_pdsch_rsp_pdu.lbt_pdsch_rsp_pdu_rel13.tl.tag = NFAPI_LBT_PDSCH_RSP_PDU_REL13_TAG;
pdus[0].lbt_pdsch_rsp_pdu.lbt_pdsch_rsp_pdu_rel13.handle = 0xABCD;
pdus[0].lbt_pdsch_rsp_pdu.lbt_pdsch_rsp_pdu_rel13.result = rand_range(0, 1);
pdus[0].lbt_pdsch_rsp_pdu.lbt_pdsch_rsp_pdu_rel13.lte_txop_symbols = rand_range(0, 0xFFFF);
pdus[0].lbt_pdsch_rsp_pdu.lbt_pdsch_rsp_pdu_rel13.initial_partial_sf = rand_range(0, 1);
pdus[1].pdu_type = 1; // LBT_DRS_RSP PDU
pdus[1].pdu_size = 0;
pdus[1].lbt_drs_rsp_pdu.lbt_drs_rsp_pdu_rel13.tl.tag = NFAPI_LBT_DRS_RSP_PDU_REL13_TAG;
pdus[1].lbt_drs_rsp_pdu.lbt_drs_rsp_pdu_rel13.handle = 0xABCD;
pdus[1].lbt_drs_rsp_pdu.lbt_drs_rsp_pdu_rel13.result = rand_range(0, 1);
lbt_dl_ind.lbt_dl_indication_body.lbt_indication_pdu_list = pdus;
nfapi_pnf_p7_lbt_dl_ind(data->p7_config, &lbt_dl_ind);
}
else
{
nfapi_pnf_p7_lbt_dl_ind(data->p7_config, &lbt_dl_ind);
}
return 0;
}
int fapi_nb_harq_ind(fapi_t* fapi, fapi_nb_harq_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_nb_harq_indication_t nb_harq_ind;
memset(&nb_harq_ind, 0, sizeof(nb_harq_ind));
nb_harq_ind.header.message_id = NFAPI_NB_HARQ_INDICATION;
nb_harq_ind.header.phy_id = data->p7_config->phy_id;
nb_harq_ind.sfn_sf = ind->sfn_sf;
if(((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
nb_harq_ind.nb_harq_indication_body.tl.tag = NFAPI_NB_HARQ_INDICATION_BODY_TAG;
nb_harq_ind.nb_harq_indication_body.number_of_harqs = 1;
nfapi_nb_harq_indication_pdu_t pdus[nb_harq_ind.nb_harq_indication_body.number_of_harqs];
memset(&pdus, 0, sizeof(pdus));
pdus[0].rx_ue_information.tl.tag = NFAPI_RX_UE_INFORMATION_TAG;
pdus[0].rx_ue_information.handle = rand_range(0, 0xFFFF);
pdus[0].rx_ue_information.rnti = rand_range(0, 65535);
pdus[0].nb_harq_indication_fdd_rel13.tl.tag = NFAPI_NB_HARQ_INDICATION_FDD_REL13_TAG;
pdus[0].nb_harq_indication_fdd_rel13.harq_tb1 = rand_range(1, 7);
pdus[0].ul_cqi_information.tl.tag = NFAPI_UL_CQI_INFORMATION_TAG;
pdus[0].ul_cqi_information.ul_cqi = rand_range(0, 255);
pdus[0].ul_cqi_information.channel = rand_range(0, 1);
nb_harq_ind.nb_harq_indication_body.nb_harq_pdu_list = pdus;
nfapi_pnf_p7_nb_harq_ind(data->p7_config, &nb_harq_ind);
}
else
{
nfapi_pnf_p7_nb_harq_ind(data->p7_config, &nb_harq_ind);
}
return 0;
}
int fapi_nrach_ind(fapi_t* fapi, fapi_nrach_ind_t* ind)
{
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)(fapi->user_data);
nfapi_nrach_indication_t nrach_ind;
memset(&nrach_ind, 0, sizeof(nrach_ind));
nrach_ind.header.message_id = NFAPI_NRACH_INDICATION;
nrach_ind.header.phy_id = data->p7_config->phy_id;
nrach_ind.sfn_sf = ind->sfn_sf;
if(((pnf_info*)(data->config->user_data))->wireshark_test_mode)
{
nrach_ind.nrach_indication_body.tl.tag = NFAPI_NRACH_INDICATION_BODY_TAG;
nrach_ind.nrach_indication_body.number_of_initial_scs_detected = 1;
nfapi_nrach_indication_pdu_t pdus[nrach_ind.nrach_indication_body.number_of_initial_scs_detected];
memset(&pdus, 0, sizeof(pdus));
pdus[0].nrach_indication_rel13.tl.tag = NFAPI_NRACH_INDICATION_REL13_TAG;
pdus[0].nrach_indication_rel13.rnti = rand_range(1, 65535);
pdus[0].nrach_indication_rel13.initial_sc = rand_range(0, 47);
pdus[0].nrach_indication_rel13.timing_advance = rand_range(0, 3840);
pdus[0].nrach_indication_rel13.nrach_ce_level = rand_range(0, 2);
nrach_ind.nrach_indication_body.nrach_pdu_list = pdus;
nfapi_pnf_p7_nrach_ind(data->p7_config, &nrach_ind);
}
else
{
nfapi_pnf_p7_nrach_ind(data->p7_config, &nrach_ind);
}
return 0;
}
int pnf_start_request(nfapi_pnf_config_t* config, nfapi_pnf_start_request_t* req)
{
pnf_info* pnf = (pnf_info*)(config->user_data);
// start all phys that have been configured
for(phy_info& phy : pnf->phys)
{
if(phy.id != 0)
{
//auto found = std::find_if(pnf->phys.begin(), pnf->phys.end(), [&](phy_info& item)
// { return item.id == req->header.phy_id; });
//
// if(found != pnf->phys.end())
// {
// phy_info& phy = (*found);
fapi_cb_t cb;
cb.fapi_param_response = &fapi_param_response;
cb.fapi_config_response = &fapi_config_response;
cb.fapi_subframe_ind = &fapi_subframe_ind;
cb.fapi_harq_ind = fapi_harq_ind;
cb.fapi_crc_ind = fapi_crc_ind;
cb.fapi_rx_ulsch_ind = fapi_rx_ulsch_ind;
cb.fapi_rx_cqi_ind = fapi_rx_cqi_ind;
cb.fapi_rx_sr_ind = fapi_rx_sr_ind;
cb.fapi_rach_ind = fapi_rach_ind;
cb.fapi_srs_ind = fapi_srs_ind;
cb.fapi_lbt_dl_ind = fapi_lbt_dl_ind;
cb.fapi_nb_harq_ind = fapi_nb_harq_ind;
cb.fapi_nrach_ind = fapi_nrach_ind;
fapi_config_t c;
c.duplex_mode = phy.duplex_mode;
c.dl_channel_bw_support = phy.dl_channel_bw_support;
c.ul_channel_bw_support = phy.ul_channel_bw_support;
phy.fapi = fapi_create(&cb, &c);
printf("[PNF_SIM] staring fapi %p phy_id:%d\n", phy.fapi, phy.id);
pnf_phy_user_data_t* data = (pnf_phy_user_data_t*)malloc(sizeof(pnf_phy_user_data_t));
data->phy_id = phy.id;
data->config = config;
data->phy = &phy;
phy.fapi->user_data = data;
}
}
nfapi_pnf_start_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_PNF_START_RESPONSE;
resp.error_code = NFAPI_MSG_OK;
nfapi_pnf_pnf_start_resp(config, &resp);
return 0;
}
int pnf_stop_request(nfapi_pnf_config_t* config, nfapi_pnf_stop_request_t* req)
{
printf("[PNF_SIM] pnf stop request\n");
nfapi_pnf_stop_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_PNF_STOP_RESPONSE;
resp.error_code = NFAPI_MSG_OK;
nfapi_pnf_pnf_stop_resp(config, &resp);
return 0;
}
int param_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_param_request_t* req)
{
printf("[PNF_SIM] param request phy_id:%d\n", req->header.phy_id);
pnf_info* pnf = (pnf_info*)(config->user_data);
auto found = std::find_if(pnf->phys.begin(), pnf->phys.end(), [&](phy_info& item)
{ return item.id == req->header.phy_id; });
if(found != pnf->phys.end())
{
phy_info& phy_info = (*found);
fapi_param_req_t fapi_req;
fapi_req.header.message_id = req->header.message_id;
fapi_req.header.length = 0;
// convert nfapi to fapi
fapi_param_request(phy_info.fapi, &fapi_req);
}
else
{
// did not find the phy
}
printf("[PNF_SIM] param request .. exit\n");
return 0;
}
int config_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_config_request_t* req)
{
printf("[PNF_SIM] config request phy_id:%d\n", req->header.phy_id);
pnf_info* pnf = (pnf_info*)(config->user_data);
auto found = std::find_if(pnf->phys.begin(), pnf->phys.end(), [&](phy_info& item)
{ return item.id == req->header.phy_id; });
if(found != pnf->phys.end())
{
phy_info& phy_info = (*found);
if(req->nfapi_config.timing_window.tl.tag == NFAPI_NFAPI_TIMING_WINDOW_TAG)
{
phy_info.timing_window = req->nfapi_config.timing_window.value;
}
if(req->nfapi_config.timing_info_mode.tl.tag == NFAPI_NFAPI_TIMING_INFO_MODE_TAG)
{
printf("timing info mode provided\n");
phy_info.timing_info_mode = req->nfapi_config.timing_info_mode.value;
}
else
{
phy_info.timing_info_mode = 0;
printf("NO timing info mode provided\n");
}
if(req->nfapi_config.timing_info_period.tl.tag == NFAPI_NFAPI_TIMING_INFO_PERIOD_TAG)
{
printf("timing info period provided\n");
phy_info.timing_info_period = req->nfapi_config.timing_info_period.value;
}
else
{
phy_info.timing_info_period = 0;
}
phy_info.remote_port = req->nfapi_config.p7_vnf_port.value;
struct sockaddr_in vnf_p7_sockaddr;
memcpy(&vnf_p7_sockaddr.sin_addr.s_addr, &(req->nfapi_config.p7_vnf_address_ipv4.address[0]), 4);
phy_info.remote_addr = inet_ntoa(vnf_p7_sockaddr.sin_addr);
printf("[PNF_SIM] %d vnf p7 %s:%d timing %d %d %d\n", phy_info.id, phy_info.remote_addr, phy_info.remote_port,
phy_info.timing_window, phy_info.timing_info_mode, phy_info.timing_info_period);
fapi_config_req_t fapi_req;
fapi_config_request(phy_info.fapi, &fapi_req);
}
return 0;
}
nfapi_p7_message_header_t* phy_allocate_p7_vendor_ext(uint16_t message_id, uint16_t* msg_size)
{
if(message_id == P7_VENDOR_EXT_REQ)
{
(*msg_size) = sizeof(vendor_ext_p7_req);
return (nfapi_p7_message_header_t*)malloc(sizeof(vendor_ext_p7_req));
}
return 0;
}
void phy_deallocate_p7_vendor_ext(nfapi_p7_message_header_t* header)
{
free(header);
}
int phy_dl_config_req(nfapi_pnf_p7_config_t* pnf_p7, nfapi_dl_config_request_t* req)
{
//printf("[PNF_SIM] dl config request\n");
if(req->vendor_extension)
free(req->vendor_extension);
phy_info* phy = (phy_info*)(pnf_p7->user_data);
fapi_dl_config_req_t fapi_req;
// convert
fapi_dl_config_request(phy->fapi, &fapi_req);
return 0;
}
int phy_ul_config_req(nfapi_pnf_p7_config_t* pnf_p7, nfapi_ul_config_request_t* req)
{
//printf("[PNF_SIM] ul config request\n");
phy_info* phy = (phy_info*)(pnf_p7->user_data);
fapi_ul_config_req_t fapi_req;
// convert
fapi_ul_config_request(phy->fapi, &fapi_req);
return 0;
}
int phy_hi_dci0_req(nfapi_pnf_p7_config_t* pnf_p7, nfapi_hi_dci0_request_t* req)
{
//printf("[PNF_SIM] hi dci0 request\n");
phy_info* phy = (phy_info*)(pnf_p7->user_data);
fapi_hi_dci0_req_t fapi_req;
// convert
fapi_hi_dci0_request(phy->fapi, &fapi_req);
return 0;
}
int phy_tx_req(nfapi_pnf_p7_config_t* pnf_p7, nfapi_tx_request_t* req)
{
//printf("[PNF_SIM] tx request\n");
phy_info* phy = (phy_info*)(pnf_p7->user_data);
fapi_tx_req_t fapi_req;
fapi_req.header.message_id = FAPI_TX_REQUEST;
fapi_req.sfn_sf = req->sfn_sf;
fapi_req.body.number_of_pdus = req->tx_request_body.number_of_pdus;
fapi_tx_req_pdu_t pdus[8];
fapi_req.body.pdus = &pdus[0];
for(int i = 0; i < fapi_req.body.number_of_pdus; ++i)
{
fapi_req.body.pdus[i].pdu_length = req->tx_request_body.tx_pdu_list[i].pdu_length;
fapi_req.body.pdus[i].pdu_index = req->tx_request_body.tx_pdu_list[i].pdu_index;
fapi_req.body.pdus[i].num_tlv = 1;
fapi_req.body.pdus[i].tlvs[0].value = (uint32_t*)req->tx_request_body.tx_pdu_list[i].segments[0].segment_data;
//if the pnf wants to retain the pointer then req->tx_request_body.tx_pdu_list[i].segments[0].segment_data should be set to 0
}
fapi_tx_request(phy->fapi, &fapi_req);
/*
if(fapi_req.body.number_of_pdus > 0)
{
for(int i = 0; i < fapi_req.body.number_of_pdus; ++i)
{
//printf("freeing tx pdu %p\n", fapi_req.body.pdus[i].tlvs[0].value);
if(0)
{
free(fapi_req.body.pdus[i].tlvs[0].value);
}
else
{
pnf_deallocate(fapi_req.body.pdus[i].tlvs[0].value);
}
}
}
*/
return 0;
}
int phy_lbt_dl_config_req(nfapi_pnf_p7_config_t*, nfapi_lbt_dl_config_request_t* req)
{
//printf("[PNF_SIM] lbt dl config request\n");
return 0;
}
int phy_vendor_ext(nfapi_pnf_p7_config_t* config, nfapi_p7_message_header_t* msg)
{
if(msg->message_id == P7_VENDOR_EXT_REQ)
{
vendor_ext_p7_req* req = (vendor_ext_p7_req*)msg;
//printf("[PNF_SIM] vendor request (1:%d 2:%d)\n", req->dummy1, req->dummy2);
}
else
{
printf("[PNF_SIM] unknown vendor ext\n");
}
return 0;
}
int phy_pack_p7_vendor_extension(nfapi_p7_message_header_t* header, uint8_t** ppWritePackedMsg, uint8_t *end, nfapi_p7_codec_config_t* codex)
{
//NFAPI_TRACE(NFAPI_TRACE_INFO, "%s\n", __FUNCTION__);
if(header->message_id == P7_VENDOR_EXT_IND)
{
vendor_ext_p7_ind* ind = (vendor_ext_p7_ind*)(header);
if(!push16(ind->error_code, ppWritePackedMsg, end))
return 0;
return 1;
}
return -1;
}
int phy_unpack_p7_vendor_extension(nfapi_p7_message_header_t* header, uint8_t** ppReadPackedMessage, uint8_t *end, nfapi_p7_codec_config_t* codec)
{
if(header->message_id == P7_VENDOR_EXT_REQ)
{
//NFAPI_TRACE(NFAPI_TRACE_INFO, "%s\n", __FUNCTION__);
vendor_ext_p7_req* req = (vendor_ext_p7_req*)(header);
if(!(pull16(ppReadPackedMessage, &req->dummy1, end) &&
pull16(ppReadPackedMessage, &req->dummy2, end)))
return 0;
return 1;
}
return -1;
}
int phy_unpack_vendor_extension_tlv(nfapi_tl_t* tl, uint8_t **ppReadPackedMessage, uint8_t* end, void** ve, nfapi_p7_codec_config_t* config)
{
//NFAPI_TRACE(NFAPI_TRACE_INFO, "phy_unpack_vendor_extension_tlv\n");
switch(tl->tag)
{
case VENDOR_EXT_TLV_1_TAG:
*ve = malloc(sizeof(vendor_ext_tlv_1));
if(!pull32(ppReadPackedMessage, &((vendor_ext_tlv_1*)(*ve))->dummy, end))
return 0;
return 1;
break;
}
return -1;
}
int phy_pack_vendor_extention_tlv(void* ve, uint8_t **ppWritePackedMsg, uint8_t* end, nfapi_p7_codec_config_t* config)
{
//printf("%s\n", __FUNCTION__);
(void)ve;
(void)ppWritePackedMsg;
return -1;
}
int pnf_sim_unpack_vendor_extension_tlv(nfapi_tl_t* tl, uint8_t **ppReadPackedMessage, uint8_t *end, void** ve, nfapi_p4_p5_codec_config_t* config)
{
//NFAPI_TRACE(NFAPI_TRACE_INFO, "pnf_sim_unpack_vendor_extension_tlv\n");
switch(tl->tag)
{
case VENDOR_EXT_TLV_2_TAG:
*ve = malloc(sizeof(vendor_ext_tlv_2));
if(!pull32(ppReadPackedMessage, &((vendor_ext_tlv_2*)(*ve))->dummy, end))
return 0;
return 1;
break;
}
return -1;
}
int pnf_sim_pack_vendor_extention_tlv(void* ve, uint8_t **ppWritePackedMsg, uint8_t *end, nfapi_p4_p5_codec_config_t* config)
{
//printf("%s\n", __FUNCTION__);
(void)ve;
(void)ppWritePackedMsg;
return -1;
}
int start_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_start_request_t* req)
{
printf("[PNF_SIM] start request phy_id:%d\n", req->header.phy_id);
pnf_info* pnf = (pnf_info*)(config->user_data);
auto found = std::find_if(pnf->phys.begin(), pnf->phys.end(), [&](phy_info& item)
{ return item.id == req->header.phy_id; });
if(found != pnf->phys.end())
{
phy_info& phy_info = (*found);
nfapi_pnf_p7_config_t* p7_config = nfapi_pnf_p7_config_create();
p7_config->phy_id = phy->phy_id;
p7_config->remote_p7_port = phy_info.remote_port;
p7_config->remote_p7_addr = phy_info.remote_addr;
p7_config->local_p7_port = phy_info.local_port;
p7_config->local_p7_addr = (char*)phy_info.local_addr.c_str();
p7_config->user_data = &phy_info;
p7_config->malloc = &pnf_allocate;
p7_config->free = &pnf_deallocate;
p7_config->codec_config.allocate = &pnf_allocate;
p7_config->codec_config.deallocate = &pnf_deallocate;
p7_config->trace = &pnf_sim_trace;
phy->user_data = p7_config;
p7_config->subframe_buffer_size = phy_info.timing_window;
if(phy_info.timing_info_mode & 0x1)
{
p7_config->timing_info_mode_periodic = 1;
p7_config->timing_info_period = phy_info.timing_info_period;
}
if(phy_info.timing_info_mode & 0x2)
{
p7_config->timing_info_mode_aperiodic = 1;
}
p7_config->dl_config_req = &phy_dl_config_req;
p7_config->ul_config_req = &phy_ul_config_req;
p7_config->hi_dci0_req = &phy_hi_dci0_req;
p7_config->tx_req = &phy_tx_req;
p7_config->lbt_dl_config_req = &phy_lbt_dl_config_req;
p7_config->vendor_ext = &phy_vendor_ext;
p7_config->allocate_p7_vendor_ext = &phy_allocate_p7_vendor_ext;
p7_config->deallocate_p7_vendor_ext = &phy_deallocate_p7_vendor_ext;
p7_config->codec_config.unpack_p7_vendor_extension = &phy_unpack_p7_vendor_extension;
p7_config->codec_config.pack_p7_vendor_extension = &phy_pack_p7_vendor_extension;
p7_config->codec_config.unpack_vendor_extension_tlv = &phy_unpack_vendor_extension_tlv;
p7_config->codec_config.pack_vendor_extension_tlv = &phy_pack_vendor_extention_tlv;
pthread_t p7_thread;
pthread_create(&p7_thread, NULL, &pnf_p7_thread_start, p7_config);
((pnf_phy_user_data_t*)(phy_info.fapi->user_data))->p7_config = p7_config;
fapi_start_req_t fapi_req;
fapi_start_request(phy_info.fapi, &fapi_req);
}
return 0;
}
int measurement_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_measurement_request_t* req)
{
nfapi_measurement_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_MEASUREMENT_RESPONSE;
resp.header.phy_id = req->header.phy_id;
resp.error_code = NFAPI_MSG_OK;
nfapi_pnf_measurement_resp(config, &resp);
return 0;
}
int rssi_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_rssi_request_t* req)
{
nfapi_rssi_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_RSSI_RESPONSE;
resp.header.phy_id = req->header.phy_id;
resp.error_code = NFAPI_P4_MSG_OK;
nfapi_pnf_rssi_resp(config, &resp);
nfapi_rssi_indication_t ind;
memset(&ind, 0, sizeof(ind));
ind.header.message_id = NFAPI_RSSI_INDICATION;
ind.header.phy_id = req->header.phy_id;
ind.error_code = NFAPI_P4_MSG_OK;
ind.rssi_indication_body.tl.tag = NFAPI_RSSI_INDICATION_TAG;
ind.rssi_indication_body.number_of_rssi = 1;
ind.rssi_indication_body.rssi[0] = -42;
nfapi_pnf_rssi_ind(config, &ind);
return 0;
}
int cell_search_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_cell_search_request_t* req)
{
nfapi_cell_search_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_CELL_SEARCH_RESPONSE;
resp.header.phy_id = req->header.phy_id;
resp.error_code = NFAPI_P4_MSG_OK;
nfapi_pnf_cell_search_resp(config, &resp);
nfapi_cell_search_indication_t ind;
memset(&ind, 0, sizeof(ind));
ind.header.message_id = NFAPI_CELL_SEARCH_INDICATION;
ind.header.phy_id = req->header.phy_id;
ind.error_code = NFAPI_P4_MSG_OK;
switch(req->rat_type)
{
case NFAPI_RAT_TYPE_LTE:
{
ind.lte_cell_search_indication.tl.tag = NFAPI_LTE_CELL_SEARCH_INDICATION_TAG;
ind.lte_cell_search_indication.number_of_lte_cells_found = 1;
ind.lte_cell_search_indication.lte_found_cells[0].pci = 123;
ind.lte_cell_search_indication.lte_found_cells[0].rsrp = 123;
ind.lte_cell_search_indication.lte_found_cells[0].rsrq = 123;
ind.lte_cell_search_indication.lte_found_cells[0].frequency_offset = 123;
}
break;
case NFAPI_RAT_TYPE_UTRAN:
{
ind.utran_cell_search_indication.tl.tag = NFAPI_UTRAN_CELL_SEARCH_INDICATION_TAG;
ind.utran_cell_search_indication.number_of_utran_cells_found = 1;
ind.utran_cell_search_indication.utran_found_cells[0].psc = 89;
ind.utran_cell_search_indication.utran_found_cells[0].rscp = 89;
ind.utran_cell_search_indication.utran_found_cells[0].ecno = 89;
ind.utran_cell_search_indication.utran_found_cells[0].frequency_offset = -89;
}
break;
case NFAPI_RAT_TYPE_GERAN:
{
ind.geran_cell_search_indication.tl.tag = NFAPI_GERAN_CELL_SEARCH_INDICATION_TAG;
ind.geran_cell_search_indication.number_of_gsm_cells_found = 1;
ind.geran_cell_search_indication.gsm_found_cells[0].bsic = 23;
ind.geran_cell_search_indication.gsm_found_cells[0].rxlev = 23;
ind.geran_cell_search_indication.gsm_found_cells[0].rxqual = 23;
ind.geran_cell_search_indication.gsm_found_cells[0].frequency_offset = -23;
ind.geran_cell_search_indication.gsm_found_cells[0].sfn_offset = 230;
}
break;
}
ind.pnf_cell_search_state.tl.tag = NFAPI_PNF_CELL_SEARCH_STATE_TAG;
ind.pnf_cell_search_state.length = 3;
nfapi_pnf_cell_search_ind(config, &ind);
return 0;
}
int broadcast_detect_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_broadcast_detect_request_t* req)
{
nfapi_broadcast_detect_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_BROADCAST_DETECT_RESPONSE;
resp.header.phy_id = req->header.phy_id;
resp.error_code = NFAPI_P4_MSG_OK;
nfapi_pnf_broadcast_detect_resp(config, &resp);
nfapi_broadcast_detect_indication_t ind;
memset(&ind, 0, sizeof(ind));
ind.header.message_id = NFAPI_BROADCAST_DETECT_INDICATION;
ind.header.phy_id = req->header.phy_id;
ind.error_code = NFAPI_P4_MSG_OK;
switch(req->rat_type)
{
case NFAPI_RAT_TYPE_LTE:
{
ind.lte_broadcast_detect_indication.tl.tag = NFAPI_LTE_BROADCAST_DETECT_INDICATION_TAG;
ind.lte_broadcast_detect_indication.number_of_tx_antenna = 1;
ind.lte_broadcast_detect_indication.mib_length = 4;
//ind.lte_broadcast_detect_indication.mib...
ind.lte_broadcast_detect_indication.sfn_offset = 77;
}
break;
case NFAPI_RAT_TYPE_UTRAN:
{
ind.utran_broadcast_detect_indication.tl.tag = NFAPI_UTRAN_BROADCAST_DETECT_INDICATION_TAG;
ind.utran_broadcast_detect_indication.mib_length = 4;
//ind.utran_broadcast_detect_indication.mib...
ind.utran_broadcast_detect_indication.sfn_offset;
}
break;
}
ind.pnf_cell_broadcast_state.tl.tag = NFAPI_PNF_CELL_BROADCAST_STATE_TAG;
ind.pnf_cell_broadcast_state.length = 3;
nfapi_pnf_broadcast_detect_ind(config, &ind);
return 0;
}
int system_information_schedule_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_system_information_schedule_request_t* req)
{
nfapi_system_information_schedule_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_SYSTEM_INFORMATION_SCHEDULE_RESPONSE;
resp.header.phy_id = req->header.phy_id;
resp.error_code = NFAPI_P4_MSG_OK;
nfapi_pnf_system_information_schedule_resp(config, &resp);
nfapi_system_information_schedule_indication_t ind;
memset(&ind, 0, sizeof(ind));
ind.header.message_id = NFAPI_SYSTEM_INFORMATION_SCHEDULE_INDICATION;
ind.header.phy_id = req->header.phy_id;
ind.error_code = NFAPI_P4_MSG_OK;
ind.lte_system_information_indication.tl.tag = NFAPI_LTE_SYSTEM_INFORMATION_INDICATION_TAG;
ind.lte_system_information_indication.sib_type = 3;
ind.lte_system_information_indication.sib_length = 5;
//ind.lte_system_information_indication.sib...
nfapi_pnf_system_information_schedule_ind(config, &ind);
return 0;
}
int system_information_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_system_information_request_t* req)
{
nfapi_system_information_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_SYSTEM_INFORMATION_RESPONSE;
resp.header.phy_id = req->header.phy_id;
resp.error_code = NFAPI_P4_MSG_OK;
nfapi_pnf_system_information_resp(config, &resp);
nfapi_system_information_indication_t ind;
memset(&ind, 0, sizeof(ind));
ind.header.message_id = NFAPI_SYSTEM_INFORMATION_INDICATION;
ind.header.phy_id = req->header.phy_id;
ind.error_code = NFAPI_P4_MSG_OK;
switch(req->rat_type)
{
case NFAPI_RAT_TYPE_LTE:
{
ind.lte_system_information_indication.tl.tag = NFAPI_LTE_SYSTEM_INFORMATION_INDICATION_TAG;
ind.lte_system_information_indication.sib_type = 1;
ind.lte_system_information_indication.sib_length = 3;
//ind.lte_system_information_indication.sib...
}
break;
case NFAPI_RAT_TYPE_UTRAN:
{
ind.utran_system_information_indication.tl.tag = NFAPI_UTRAN_SYSTEM_INFORMATION_INDICATION_TAG;
ind.utran_system_information_indication.sib_length = 3;
//ind.utran_system_information_indication.sib...
}
break;
case NFAPI_RAT_TYPE_GERAN:
{
ind.geran_system_information_indication.tl.tag = NFAPI_GERAN_SYSTEM_INFORMATION_INDICATION_TAG;
ind.geran_system_information_indication.si_length = 3;
//ind.geran_system_information_indication.si...
}
break;
}
nfapi_pnf_system_information_ind(config, &ind);
return 0;
}
int nmm_stop_request(nfapi_pnf_config_t* config, nfapi_pnf_phy_config_t* phy, nfapi_nmm_stop_request_t* req)
{
nfapi_nmm_stop_response_t resp;
memset(&resp, 0, sizeof(resp));
resp.header.message_id = NFAPI_NMM_STOP_RESPONSE;
resp.header.phy_id = req->header.phy_id;
resp.error_code = NFAPI_P4_MSG_OK;
nfapi_pnf_nmm_stop_resp(config, &resp);
return 0;
}
int vendor_ext(nfapi_pnf_config_t* config, nfapi_p4_p5_message_header_t* msg)
{
NFAPI_TRACE(NFAPI_TRACE_INFO, "[PNF_SIM] P5 %s %p\n", __FUNCTION__, msg);
switch(msg->message_id)
{
case P5_VENDOR_EXT_REQ:
{
vendor_ext_p5_req* req = (vendor_ext_p5_req*)msg;
NFAPI_TRACE(NFAPI_TRACE_INFO, "[PNF_SIM] P5 Vendor Ext Req (%d %d)\n", req->dummy1, req->dummy2);
// send back the P5_VENDOR_EXT_RSP
vendor_ext_p5_rsp rsp;
memset(&rsp, 0, sizeof(rsp));
rsp.header.message_id = P5_VENDOR_EXT_RSP;
rsp.error_code = NFAPI_MSG_OK;
nfapi_pnf_vendor_extension(config, &rsp.header, sizeof(vendor_ext_p5_rsp));
}
break;
}
return 0;
}
nfapi_p4_p5_message_header_t* pnf_sim_allocate_p4_p5_vendor_ext(uint16_t message_id, uint16_t* msg_size)
{
if(message_id == P5_VENDOR_EXT_REQ)
{
(*msg_size) = sizeof(vendor_ext_p5_req);
return (nfapi_p4_p5_message_header_t*)malloc(sizeof(vendor_ext_p5_req));
}
return 0;
}
void pnf_sim_deallocate_p4_p5_vendor_ext(nfapi_p4_p5_message_header_t* header)
{
free(header);
}
int pnf_sim_pack_p4_p5_vendor_extension(nfapi_p4_p5_message_header_t* header, uint8_t** ppWritePackedMsg, uint8_t *end, nfapi_p4_p5_codec_config_t* config)
{
//NFAPI_TRACE(NFAPI_TRACE_INFO, "%s\n", __FUNCTION__);
if(header->message_id == P5_VENDOR_EXT_RSP)
{
vendor_ext_p5_rsp* rsp = (vendor_ext_p5_rsp*)(header);
return (!push16(rsp->error_code, ppWritePackedMsg, end));
}
return 0;
}
int pnf_sim_unpack_p4_p5_vendor_extension(nfapi_p4_p5_message_header_t* header, uint8_t** ppReadPackedMessage, uint8_t *end, nfapi_p4_p5_codec_config_t* codec)
{
//NFAPI_TRACE(NFAPI_TRACE_INFO, "%s\n", __FUNCTION__);
if(header->message_id == P5_VENDOR_EXT_REQ)
{
vendor_ext_p5_req* req = (vendor_ext_p5_req*)(header);
return (!(pull16(ppReadPackedMessage, &req->dummy1, end) &&
pull16(ppReadPackedMessage, &req->dummy2, end)));
//NFAPI_TRACE(NFAPI_TRACE_INFO, "%s (%d %d)\n", __FUNCTION__, req->dummy1, req->dummy2);
}
return 0;
}
int main(int argc, char *argv[])
{
if (argc < 3)
{
printf("Use parameters: <IP Address of VNF P5> <P5 Port> <Config File>\n");
return 0;
}
set_thread_priority(50);
pnf_info pnf;
if(read_pnf_xml(pnf, argv[3]) < 0)
{
printf("Failed to read xml file>\n");
return 0;
}
nfapi_pnf_config_t* config = nfapi_pnf_config_create();
config->vnf_ip_addr = argv[1];
config->vnf_p5_port = atoi(argv[2]);
config->pnf_param_req = &pnf_param_request;
config->pnf_config_req = &pnf_config_request;
config->pnf_start_req = &pnf_start_request;
config->pnf_stop_req = &pnf_stop_request;
config->param_req = &param_request;
config->config_req = &config_request;
config->start_req = &start_request;
config->measurement_req = &measurement_request;
config->rssi_req = &rssi_request;
config->cell_search_req = &cell_search_request;
config->broadcast_detect_req = &broadcast_detect_request;
config->system_information_schedule_req = &system_information_schedule_request;
config->system_information_req = &system_information_request;
config->nmm_stop_req = &nmm_stop_request;
config->vendor_ext = &vendor_ext;
config->trace = &pnf_sim_trace;
config->user_data = &pnf;
// To allow custom vendor extentions to be added to nfapi
config->codec_config.unpack_vendor_extension_tlv = &pnf_sim_unpack_vendor_extension_tlv;
config->codec_config.pack_vendor_extension_tlv = &pnf_sim_pack_vendor_extention_tlv;
config->allocate_p4_p5_vendor_ext = &pnf_sim_allocate_p4_p5_vendor_ext;
config->deallocate_p4_p5_vendor_ext = &pnf_sim_deallocate_p4_p5_vendor_ext;
config->codec_config.unpack_p4_p5_vendor_extension = &pnf_sim_unpack_p4_p5_vendor_extension;
config->codec_config.pack_p4_p5_vendor_extension = &pnf_sim_pack_p4_p5_vendor_extension;
return nfapi_pnf_start(config);
}
Reference in New Issue View Git Blame Copy Permalink