/*
 * SPDX-License-Identifier: Apache-2.0
 *
 * Copyright 2017 Cisco Systems, Inc.
 */


#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);
	
}
