1 /******************************************************************************
3 * Copyright (c) 2019 Intel.
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
9 * http://www.apache.org/licenses/LICENSE-2.0
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
17 *******************************************************************************/
20 * @file This file contains implementation of all the functions used
21 * to send APIs from FAPI to MAC
26 #include "nr5g_fapi_internal.h"
27 #include "gnb_l1_l2_api.h"
28 #include "nr5g_fapi_fapi2mac_api.h"
29 #include "nr5g_fapi_fapi2mac_wls.h"
30 #include "nr5g_fapi_log.h"
32 static nr5g_fapi_fapi2mac_queue_t fapi2mac_q[FAPI_MAX_PHY_INSTANCES];
33 static nr5g_fapi_fapi2mac_queue_t fapi2mac_urllc_q[FAPI_MAX_PHY_INSTANCES];
36 //------------------------------------------------------------------------------
37 /** @ingroup group_source_api_fapi2phy
39 * @param[in] phy_id Value of phy_id.
40 * @param[in] is_urllc True for urllc, false otherwise.
42 * @return Pointer to fapi2mac api queue.
44 * @description This function access proper instance of fapi2mac queue.
47 //------------------------------------------------------------------------------
48 static inline p_nr5g_fapi_fapi2mac_queue_t nr5g_fapi_fapi2mac_queue(
52 return is_urllc ? &fapi2mac_urllc_q[phy_id] : &fapi2mac_q[phy_id];
55 //------------------------------------------------------------------------------
56 /** @ingroup group_lte_source_phy_fapi
58 * @param[in] pListElem Pointer to the ListElement
62 * @description This function adds a ListElement API to a Linked list which will
63 * be sent to L1 once all APIs for a TTI are added
66 //------------------------------------------------------------------------------
67 void nr5g_fapi_fapi2mac_add_api_to_list(
69 p_fapi_api_queue_elem_t p_list_elem,
72 p_nr5g_fapi_fapi2mac_queue_t queue = NULL;
73 p_fapi_msg_header_t p_fapi_msg_hdr = NULL;
79 queue = nr5g_fapi_fapi2mac_queue(phy_id, is_urllc);
80 if (pthread_mutex_lock((pthread_mutex_t *) & queue->lock)) {
81 NR5G_FAPI_LOG(ERROR_LOG, ("unable to lock fapi2mac aggregate list"
85 if (queue->p_send_list_head && queue->p_send_list_tail) {
86 p_fapi_msg_hdr = (p_fapi_msg_header_t) (queue->p_send_list_head + 1);
87 p_fapi_msg_hdr->num_msg += 1;
88 queue->p_send_list_tail->p_next = p_list_elem;
89 queue->p_send_list_tail = p_list_elem;
91 queue->p_send_list_head = queue->p_send_list_tail = p_list_elem;
93 if (pthread_mutex_unlock((pthread_mutex_t *) & queue->lock)) {
94 NR5G_FAPI_LOG(ERROR_LOG, ("unable to unlock fapi2mac aggregate list"
100 //------------------------------------------------------------------------------
101 /** @ingroup group_lte_source_phy_fapi
103 * @param A pointer to phy Instance
105 * @return FAPI status
107 * @description This function send API list to L1
110 //------------------------------------------------------------------------------
111 void nr5g_fapi_fapi2mac_send_api_list(
115 p_fapi_msg_header_t p_fapi_msg_hdr = NULL;
116 p_fapi_api_queue_elem_t p_commit_list_head = NULL;
117 p_fapi_api_queue_elem_t p_commit_list_tail = NULL;
118 p_nr5g_fapi_fapi2mac_queue_t queue = NULL;
120 for (phy_id = 0; phy_id < FAPI_MAX_PHY_INSTANCES; phy_id++) {
121 queue = nr5g_fapi_fapi2mac_queue(phy_id, is_urllc);
122 if (pthread_mutex_lock((pthread_mutex_t *) & queue->lock)) {
123 NR5G_FAPI_LOG(ERROR_LOG, ("unable to lock fapi2mac aggregate list"
127 if (queue->p_send_list_head && queue->p_send_list_tail) {
129 (p_fapi_msg_header_t) (queue->p_send_list_head + 1);
130 if (p_fapi_msg_hdr->num_msg) {
131 if (p_commit_list_head && p_commit_list_tail) {
132 p_commit_list_tail->p_next = queue->p_send_list_head;
133 p_commit_list_tail = queue->p_send_list_tail;
135 p_commit_list_head = queue->p_send_list_head;
136 p_commit_list_tail = queue->p_send_list_tail;
139 nr5g_fapi_fapi2mac_wls_free_buffer((void *)
140 queue->p_send_list_head);
142 queue->p_send_list_head = queue->p_send_list_tail = NULL;
144 if (pthread_mutex_unlock((pthread_mutex_t *) & queue->lock)) {
145 NR5G_FAPI_LOG(ERROR_LOG, ("unable to unlock fapi2mac aggregate list"
151 if (p_commit_list_head)
152 nr5g_fapi_fapi2mac_wls_send(p_commit_list_head, is_urllc);
155 //------------------------------------------------------------------------------
156 /** @ingroup group_lte_source_phy_fapi
158 * @param[in] phyInstance PhyInstance Id
159 * @param[in] NumMessageInBlock Number of Messages in Block
160 * @param[in] AlignOffset Align Offset
161 * @param[in] MsgType Message Type
162 * @param[in] FrameNum Frame Number
163 * @param[in] subFrameNum subframe Number
165 * @return Pointer to the List Element structure
167 * @description This function allocates a buffer from shared memory WLS
168 * interface and creates a List Element structures. It then fills
169 * all the fields with data being passed in.
172 //------------------------------------------------------------------------------
173 p_fapi_api_queue_elem_t nr5g_fapi_fapi2mac_create_api_list_elem(
175 uint16_t num_message_in_block,
176 uint32_t align_offset)
178 p_fapi_api_queue_elem_t p_list_elem = NULL;
180 p_list_elem = (p_fapi_api_queue_elem_t)
181 nr5g_fapi_fapi2mac_wls_alloc_buffer();
182 //Fill header for link list of API messages
184 p_list_elem->msg_type = (uint8_t) msg_type;
185 p_list_elem->num_message_in_block = num_message_in_block;
186 p_list_elem->align_offset = (uint16_t) align_offset;
187 p_list_elem->msg_len = num_message_in_block * align_offset;
188 p_list_elem->p_next = NULL;
189 p_list_elem->p_tx_data_elm_list = NULL;
190 p_list_elem->time_stamp = 0;
196 //------------------------------------------------------------------------------
197 /** @ingroup group_lte_source_phy_fapi
201 * @description This function initializes the pthead_mutext_lock.
203 void nr5g_fapi_fapi2mac_init_api_list(
207 p_nr5g_fapi_fapi2mac_queue_t queue = NULL;
209 for (phy_id = 0; phy_id < FAPI_MAX_PHY_INSTANCES; phy_id++) {
210 queue = nr5g_fapi_fapi2mac_queue(phy_id, false);
211 pthread_mutex_init((pthread_mutex_t *) & queue->lock, NULL);
212 queue = nr5g_fapi_fapi2mac_queue(phy_id, true);
213 pthread_mutex_init((pthread_mutex_t *) & queue->lock, NULL);