/* * 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. */ #ifndef _PNF_P7_H_ #define _PNF_P7_H_ #define TIMEHR_SEC(_time_hr) ((uint32_t)(_time_hr) >> 20) #define TIMEHR_USEC(_time_hr) ((uint32_t)(_time_hr) & 0xFFFFF) #define TIME2TIMEHR(_time) (((uint32_t)(_time.tv_sec) & 0xFFF) << 20 | ((uint32_t)(_time.tv_usec) & 0xFFFFF)) #include "nfapi_pnf_interface.h" #define NFAPI_MAX_PACKED_MESSAGE_SIZE 4096 typedef struct { uint16_t dl_conf_ontime; uint16_t dl_conf_late; uint16_t ul_conf_ontime; uint16_t ul_conf_late; uint16_t hi_dci0_ontime; uint16_t hi_dci0_late; uint16_t tx_ontime; uint16_t tx_late; } pnf_p7_stats_t; typedef struct { uint8_t* buffer; uint16_t length; } pnf_p7_rx_message_segment_t; typedef struct pnf_p7_rx_message pnf_p7_rx_message_t; typedef struct pnf_p7_rx_message { uint8_t sequence_number; uint8_t num_segments_received; uint8_t num_segments_expected; // the spec allows of upto 128 segments, this does seem excessive pnf_p7_rx_message_segment_t segments[128]; uint32_t rx_hr_time; pnf_p7_rx_message_t* next; } pnf_p7_rx_message_t; typedef struct { pnf_p7_rx_message_t* msg_queue; } pnf_p7_rx_reassembly_queue_t; typedef struct { nfapi_pnf_p7_config_t _public; //private data int p7_sock; uint8_t terminate; uint8_t tx_message_buffer[NFAPI_MAX_PACKED_MESSAGE_SIZE]; uint8_t* rx_message_buffer; uint16_t rx_message_buffer_size; pthread_mutex_t mutex; // should we allow the client to specifiy pthread_mutex_t pack_mutex; // should we allow the client to specifiy nfapi_pnf_p7_subframe_buffer_t subframe_buffer[30/*NFAPI_MAX_TIMING_WINDOW_SIZE*/]; uint32_t sequence_number; uint16_t max_num_segments; pnf_p7_rx_reassembly_queue_t reassembly_queue; uint8_t* reassemby_buffer; uint32_t reassemby_buffer_size; uint16_t sfn_sf; uint32_t sf_start_time_hr; int32_t sfn_sf_shift; uint8_t timing_info_period_counter; uint8_t timing_info_aperiodic_send; // 0:false 1:true uint32_t timing_info_ms_counter; // number of ms since last timing info uint32_t dl_config_jitter; uint32_t ul_config_jitter; uint32_t hi_dci0_jitter; uint32_t tx_jitter; uint32_t tick; pnf_p7_stats_t stats; } pnf_p7_t; int pnf_p7_message_pump(pnf_p7_t* pnf_p7); int pnf_p7_pack_and_send_p7_message(pnf_p7_t* pnf_p7, nfapi_p7_message_header_t* msg, uint32_t msg_len); int pnf_p7_send_message(pnf_p7_t* pnf_p7, uint8_t* msg, uint32_t msg_len); int pnf_p7_subframe_ind(pnf_p7_t* config, uint16_t phy_id, uint16_t sfn_sf); pnf_p7_rx_message_t* pnf_p7_rx_reassembly_queue_add_segment(pnf_p7_t* pnf_p7, pnf_p7_rx_reassembly_queue_t* queue, uint32_t rx_hr_time, uint16_t sequence_number, uint16_t segment_number, uint8_t m, uint8_t* data, uint16_t data_len); void pnf_p7_rx_reassembly_queue_remove_msg(pnf_p7_t* pnf_p7, pnf_p7_rx_reassembly_queue_t* queue, pnf_p7_rx_message_t* msg); void pnf_p7_rx_reassembly_queue_remove_old_msgs(pnf_p7_t* pnf_p7, pnf_p7_rx_reassembly_queue_t* queue, uint32_t rx_hr_time, uint32_t delta); #endif /* _PNF_P7_H_ */