1 /*
2  * SPDX-FileCopyrightText: 2015-2024 Espressif Systems (Shanghai) CO LTD
3  *
4  * SPDX-License-Identifier: Apache-2.0
5  */
6 
7 #include <stddef.h>
8 #include <stdlib.h>
9 #include <stdio.h>
10 #include <string.h>
11 #include <assert.h>
12 #include <pthread.h>
13 
14 #include "freertos/FreeRTOS.h"
15 #include "freertos/task.h"
16 #include "freertos/queue.h"
17 #include "freertos/semphr.h"
18 #include "freertos/portmacro.h"
19 #include "esp_heap_caps.h"
20 #include "esp_timer.h"
21 #include "soc/rtc.h"
22 #include "esp_private/esp_clk.h"
23 #include "private/esp_coexist_adapter.h"
24 #include "esp32s2/rom/ets_sys.h"
25 #include "private/esp_coexist_debug.h"
26 
27 #define TAG "esp_coex_adapter"
28 
29 #define OSI_FUNCS_TIME_BLOCKING  0xffffffff
30 
31 typedef struct {
32     QueueHandle_t handle; /**< FreeRTOS queue handler */
33     void *storage;        /**< storage for FreeRTOS queue */
34 } modem_static_queue_t;
35 
esp_coex_common_env_is_chip_wrapper(void)36 bool IRAM_ATTR esp_coex_common_env_is_chip_wrapper(void)
37 {
38 #ifdef CONFIG_IDF_ENV_FPGA
39     return false;
40 #else
41     return true;
42 #endif
43 }
44 
esp_coex_common_spin_lock_create_wrapper(void)45 void * esp_coex_common_spin_lock_create_wrapper(void)
46 {
47     portMUX_TYPE tmp = portMUX_INITIALIZER_UNLOCKED;
48     void *mux = heap_caps_malloc(sizeof(portMUX_TYPE), MALLOC_CAP_8BIT|MALLOC_CAP_INTERNAL);
49 
50     if (mux) {
51         memcpy(mux,&tmp,sizeof(portMUX_TYPE));
52         return mux;
53     }
54     return NULL;
55 }
56 
esp_coex_common_int_disable_wrapper(void * wifi_int_mux)57 uint32_t IRAM_ATTR esp_coex_common_int_disable_wrapper(void *wifi_int_mux)
58 {
59     if (xPortInIsrContext()) {
60         portENTER_CRITICAL_ISR(wifi_int_mux);
61     } else {
62         portENTER_CRITICAL(wifi_int_mux);
63     }
64 
65     return 0;
66 }
67 
esp_coex_common_int_restore_wrapper(void * wifi_int_mux,uint32_t tmp)68 void IRAM_ATTR esp_coex_common_int_restore_wrapper(void *wifi_int_mux, uint32_t tmp)
69 {
70     if (xPortInIsrContext()) {
71         portEXIT_CRITICAL_ISR(wifi_int_mux);
72     } else {
73         portEXIT_CRITICAL(wifi_int_mux);
74     }
75 }
76 
esp_coex_common_task_yield_from_isr_wrapper(void)77 void IRAM_ATTR esp_coex_common_task_yield_from_isr_wrapper(void)
78 {
79     portYIELD_FROM_ISR();
80 }
81 
esp_coex_common_semphr_create_wrapper(uint32_t max,uint32_t init)82 void * esp_coex_common_semphr_create_wrapper(uint32_t max, uint32_t init)
83 {
84     return (void *)xSemaphoreCreateCounting(max, init);
85 }
86 
esp_coex_common_semphr_delete_wrapper(void * semphr)87 void esp_coex_common_semphr_delete_wrapper(void *semphr)
88 {
89     vSemaphoreDelete(semphr);
90 }
91 
esp_coex_common_semphr_take_wrapper(void * semphr,uint32_t block_time_tick)92 int32_t esp_coex_common_semphr_take_wrapper(void *semphr, uint32_t block_time_tick)
93 {
94     if (block_time_tick == OSI_FUNCS_TIME_BLOCKING) {
95         return (int32_t)xSemaphoreTake(semphr, portMAX_DELAY);
96     } else {
97         return (int32_t)xSemaphoreTake(semphr, block_time_tick);
98     }
99 }
100 
esp_coex_common_semphr_give_wrapper(void * semphr)101 int32_t esp_coex_common_semphr_give_wrapper(void *semphr)
102 {
103     return (int32_t)xSemaphoreGive(semphr);
104 }
105 
esp_coex_common_timer_disarm_wrapper(void * timer)106 void IRAM_ATTR esp_coex_common_timer_disarm_wrapper(void *timer)
107 {
108     ets_timer_disarm(timer);
109 }
110 
esp_coex_common_timer_done_wrapper(void * ptimer)111 void esp_coex_common_timer_done_wrapper(void *ptimer)
112 {
113     ets_timer_done(ptimer);
114 }
115 
esp_coex_common_timer_setfn_wrapper(void * ptimer,void * pfunction,void * parg)116 void esp_coex_common_timer_setfn_wrapper(void *ptimer, void *pfunction, void *parg)
117 {
118     ets_timer_setfn(ptimer, pfunction, parg);
119 }
120 
esp_coex_common_timer_arm_us_wrapper(void * ptimer,uint32_t us,bool repeat)121 void IRAM_ATTR esp_coex_common_timer_arm_us_wrapper(void *ptimer, uint32_t us, bool repeat)
122 {
123     ets_timer_arm_us(ptimer, us, repeat);
124 }
125 
esp_coex_common_malloc_internal_wrapper(size_t size)126 void * IRAM_ATTR esp_coex_common_malloc_internal_wrapper(size_t size)
127 {
128     return heap_caps_malloc(size, MALLOC_CAP_8BIT|MALLOC_CAP_DMA|MALLOC_CAP_INTERNAL);
129 }
130 
esp_coex_common_clk_slowclk_cal_get_wrapper(void)131 uint32_t esp_coex_common_clk_slowclk_cal_get_wrapper(void)
132 {
133     /* The bit width of WiFi light sleep clock calibration is 12 while the one of
134      * system is 19. It should shift 19 - 12 = 7.
135     */
136     return (esp_clk_slowclk_cal_get() >> (RTC_CLK_CAL_FRACT - SOC_WIFI_LIGHT_SLEEP_CLK_WIDTH));
137 }
138 
139 /* static wrapper */
140 
esp_coex_is_in_isr_wrapper(void)141 static int IRAM_ATTR esp_coex_is_in_isr_wrapper(void)
142 {
143     return !xPortCanYield();
144 }
145 
esp_coex_internal_semphr_create_wrapper(uint32_t max,uint32_t init)146 static void *esp_coex_internal_semphr_create_wrapper(uint32_t max, uint32_t init)
147 {
148     modem_static_queue_t *semphr = heap_caps_calloc(1, sizeof(modem_static_queue_t), MALLOC_CAP_8BIT|MALLOC_CAP_INTERNAL);
149     if (!semphr) {
150         return NULL;
151     }
152 
153 #ifdef CONFIG_SPIRAM_USE_MALLOC
154     semphr->storage = heap_caps_calloc(1, sizeof(StaticSemaphore_t), MALLOC_CAP_8BIT|MALLOC_CAP_INTERNAL);
155     if (!semphr->storage) {
156         goto _error;
157     }
158 
159     semphr->handle = xSemaphoreCreateCountingStatic(max, init, semphr->storage);
160     if (!semphr->handle) {
161         goto _error;
162     }
163     return (void *)semphr;
164 
165 _error:
166     if (semphr) {
167         if (semphr->storage) {
168             free(semphr->storage);
169         }
170 
171         free(semphr);
172     }
173     return NULL;
174 #else
175     semphr->handle = xSemaphoreCreateCounting(max, init);
176     return (void *)semphr;
177 #endif
178 }
179 
esp_coex_internal_semphr_delete_wrapper(void * semphr)180 static void esp_coex_internal_semphr_delete_wrapper(void *semphr)
181 {
182     modem_static_queue_t *semphr_item = (modem_static_queue_t *)semphr;
183     if (semphr_item) {
184         if (semphr_item->handle) {
185             vSemaphoreDelete(semphr_item->handle);
186         }
187 #ifdef CONFIG_SPIRAM_USE_MALLOC
188         if (semphr_item->storage) {
189             free(semphr_item->storage);
190         }
191 #endif
192         free(semphr_item);
193     }
194 }
195 
esp_coex_internal_semphr_take_from_isr_wrapper(void * semphr,void * hptw)196 static int32_t IRAM_ATTR esp_coex_internal_semphr_take_from_isr_wrapper(void *semphr, void *hptw)
197 {
198     return (int32_t)xSemaphoreTakeFromISR(((modem_static_queue_t *)semphr)->handle, hptw);
199 }
200 
esp_coex_internal_semphr_give_from_isr_wrapper(void * semphr,void * hptw)201 static int32_t IRAM_ATTR esp_coex_internal_semphr_give_from_isr_wrapper(void *semphr, void *hptw)
202 {
203     return (int32_t)xSemaphoreGiveFromISR(((modem_static_queue_t *)semphr)->handle, hptw);
204 }
205 
esp_coex_internal_semphr_take_wrapper(void * semphr,uint32_t block_time_tick)206 static int32_t esp_coex_internal_semphr_take_wrapper(void *semphr, uint32_t block_time_tick)
207 {
208     if (block_time_tick == OSI_FUNCS_TIME_BLOCKING) {
209         return (int32_t)xSemaphoreTake(((modem_static_queue_t *)semphr)->handle, portMAX_DELAY);
210     } else {
211         return (int32_t)xSemaphoreTake(((modem_static_queue_t *)semphr)->handle, block_time_tick);
212     }
213 }
214 
esp_coex_internal_semphr_give_wrapper(void * semphr)215 static int32_t esp_coex_internal_semphr_give_wrapper(void *semphr)
216 {
217     return (int32_t)xSemaphoreGive(((modem_static_queue_t *)semphr)->handle);
218 }
219 
esp_coexist_debug_matrix_init_wrapper(int evt,int sig,bool rev)220 static int esp_coexist_debug_matrix_init_wrapper(int evt, int sig, bool rev)
221 {
222 #if CONFIG_ESP_COEX_GPIO_DEBUG
223     return esp_coexist_debug_matrix_init(evt, sig, rev);
224 #else
225     return ESP_ERR_NOT_SUPPORTED;
226 #endif
227 }
228 
229 coex_adapter_funcs_t g_coex_adapter_funcs = {
230     ._version = COEX_ADAPTER_VERSION,
231     ._task_yield_from_isr = esp_coex_common_task_yield_from_isr_wrapper,
232     ._semphr_create = esp_coex_internal_semphr_create_wrapper,
233     ._semphr_delete = esp_coex_internal_semphr_delete_wrapper,
234     ._semphr_take_from_isr = esp_coex_internal_semphr_take_from_isr_wrapper,
235     ._semphr_give_from_isr = esp_coex_internal_semphr_give_from_isr_wrapper,
236     ._semphr_take = esp_coex_internal_semphr_take_wrapper,
237     ._semphr_give = esp_coex_internal_semphr_give_wrapper,
238     ._is_in_isr = esp_coex_is_in_isr_wrapper,
239     ._malloc_internal =  esp_coex_common_malloc_internal_wrapper,
240     ._free = free,
241     ._esp_timer_get_time = esp_timer_get_time,
242     ._timer_disarm = esp_coex_common_timer_disarm_wrapper,
243     ._timer_done = esp_coex_common_timer_done_wrapper,
244     ._timer_setfn = esp_coex_common_timer_setfn_wrapper,
245     ._timer_arm_us = esp_coex_common_timer_arm_us_wrapper,
246     ._debug_matrix_init = esp_coexist_debug_matrix_init_wrapper,
247     ._magic = COEX_ADAPTER_MAGIC,
248 };
249