| /hal_espressif-3.6.0/components/esp_ringbuf/test/ |
| D | test_ringbuf.c | 36 static void send_item_and_check(RingbufHandle_t handle, const uint8_t *item, size_t item_size, Tic… in send_item_and_check() argument
40 ret = xRingbufferSendFromISR(handle, (void *)item, item_size, NULL); in send_item_and_check()
42 ret = xRingbufferSend(handle, (void *)item, item_size, ticks_to_wait); in send_item_and_check()
47 …_and_check_failure(RingbufHandle_t handle, const uint8_t *item, size_t item_size, TickType_t tick… in send_item_and_check_failure() argument
51 ret = xRingbufferSendFromISR(handle, (void *)item, item_size, NULL); in send_item_and_check_failure()
53 ret = xRingbufferSend(handle, (void *)item, item_size, ticks_to_wait); in send_item_and_check_failure()
61 size_t item_size; in receive_check_and_return_item_no_split() local
64 item = (uint8_t *)xRingbufferReceiveFromISR(handle, &item_size); in receive_check_and_return_item_no_split()
66 item = (uint8_t *)xRingbufferReceive(handle, &item_size, ticks_to_wait); in receive_check_and_return_item_no_split()
69 TEST_ASSERT_MESSAGE(item_size == expected_size, "Item size is incorrect"); in receive_check_and_return_item_no_split()
[all …]
|
| /hal_espressif-3.6.0/examples/bluetooth/bluedroid/classic_bt/hfp_ag/main/ |
| D | bt_app_hf.c | 154 size_t item_size = 0; in bt_app_hf_outgoing_cb() local
159 vRingbufferGetInfo(s_m_rb, NULL, NULL, NULL, NULL, &item_size); in bt_app_hf_outgoing_cb()
160 if (item_size >= sz) { in bt_app_hf_outgoing_cb()
161 data = xRingbufferReceiveUpTo(s_m_rb, &item_size, 0, sz); in bt_app_hf_outgoing_cb()
162 memcpy(p_buf, data, item_size); in bt_app_hf_outgoing_cb()
216 uint32_t item_size = 0; in bt_app_send_data_task() local
241 vRingbufferGetInfo(s_m_rb, NULL, NULL, NULL, NULL, &item_size); in bt_app_send_data_task()
244 if(item_size >= WBS_PCM_INPUT_DATA_SIZE) { in bt_app_send_data_task()
248 if(item_size >= PCM_INPUT_DATA_SIZE) { in bt_app_send_data_task()
|
| /hal_espressif-3.6.0/examples/bluetooth/bluedroid/classic_bt/hfp_hf/main/ |
| D | bt_app_hf.c | 200 size_t item_size = 0; in bt_app_hf_client_outgoing_cb() local
201 uint8_t *data = xRingbufferReceiveUpTo(m_rb, &item_size, 0, sz); in bt_app_hf_client_outgoing_cb()
202 if (item_size == sz) { in bt_app_hf_client_outgoing_cb()
203 memcpy(p_buf, data, item_size); in bt_app_hf_client_outgoing_cb()
206 } else if (0 < item_size) { in bt_app_hf_client_outgoing_cb()
|
| /hal_espressif-3.6.0/examples/bluetooth/bluedroid/coex/a2dp_gatts_coex/main/ |
| D | bt_app_core.c | 122 size_t item_size = 0; in bt_i2s_task_handler() local
126 … data = (uint8_t *)xRingbufferReceive(s_ringbuf_i2s, &item_size, (portTickType)portMAX_DELAY); in bt_i2s_task_handler()
127 if (item_size != 0){ in bt_i2s_task_handler()
128 i2s_write(0, data, item_size, &bytes_written, portMAX_DELAY); in bt_i2s_task_handler()
|
| /hal_espressif-3.6.0/examples/bluetooth/bluedroid/classic_bt/a2dp_sink/main/ |
| D | bt_app_core.c | 96 size_t item_size = 0; in bt_i2s_task_handler() local
101 … data = (uint8_t *)xRingbufferReceive(s_ringbuf_i2s, &item_size, (portTickType)portMAX_DELAY); in bt_i2s_task_handler()
102 if (item_size != 0){ in bt_i2s_task_handler()
103 i2s_write(0, data, item_size, &bytes_written, portMAX_DELAY); in bt_i2s_task_handler()
|
| /hal_espressif-3.6.0/components/mdns/host_test/components/freertos_linux/ |
| D | freertos_linux.c | 34 size_t item_size; member
41 h->item_size = uxItemSize; in xQueueCreate()
49 return send_q(h->q, (uint8_t*)pvItemToQueue, h->item_size) ? pdTRUE : pdFAIL; in xQueueSend()
55 return recv_q(h->q, (uint8_t*)pvBuffer, h->item_size, xTicksToWait) ? pdTRUE : pdFAIL; in xQueueReceive()
|
| /hal_espressif-3.6.0/components/esp_wifi/esp32/ |
| D | esp_adapter.c | 116 wifi_static_queue_t* wifi_create_queue( int queue_len, int item_size) in wifi_create_queue() argument
127 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
132 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
151 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
171 static void * wifi_create_queue_wrapper(int queue_len, int item_size) in wifi_create_queue_wrapper() argument
173 return wifi_create_queue(queue_len, item_size); in wifi_create_queue_wrapper()
341 static void * queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
343 return (void *)xQueueCreate(queue_len, item_size); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/components/esp_wifi/esp32s2/ |
| D | esp_adapter.c | 98 wifi_static_queue_t* wifi_create_queue( int queue_len, int item_size) in wifi_create_queue() argument
109 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
114 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
133 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
153 static void * wifi_create_queue_wrapper(int queue_len, int item_size) in wifi_create_queue_wrapper() argument
155 return wifi_create_queue(queue_len, item_size); in wifi_create_queue_wrapper()
323 static void * queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
325 return (void *)xQueueCreate(queue_len, item_size); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/components/esp_wifi/esp32s3/ |
| D | esp_adapter.c | 106 wifi_static_queue_t* wifi_create_queue( int queue_len, int item_size) in wifi_create_queue() argument
117 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
122 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
141 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
161 static void * wifi_create_queue_wrapper(int queue_len, int item_size) in wifi_create_queue_wrapper() argument
163 return wifi_create_queue(queue_len, item_size); in wifi_create_queue_wrapper()
331 static void * queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
333 return (void *)xQueueCreate(queue_len, item_size); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/components/bt/controller/esp32/ |
| D | bt.c | 143 void *(* _queue_create)(uint32_t queue_len, uint32_t item_size);
185 void *(* _customer_queue_create)(uint32_t queue_len, uint32_t item_size);
291 static void *queue_create_hlevel_wrapper(uint32_t queue_len, uint32_t item_size);
298 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size);
336 static void *customer_queue_create_hlevel_wrapper(uint32_t queue_len, uint32_t item_size);
825 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
837 queue_storage = heap_caps_malloc((queue_len*item_size), MALLOC_CAP_INTERNAL|MALLOC_CAP_8BIT); in queue_create_wrapper()
842 handle = xQueueCreateStatic(queue_len, item_size, queue_storage, queue_buffer); in queue_create_wrapper()
872 return (void *)xQueueCreate(queue_len, item_size); in queue_create_wrapper()
898 static void *queue_create_hlevel_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_hlevel_wrapper() argument
[all …]
|
| /hal_espressif-3.6.0/zephyr/esp32/src/wifi/ |
| D | esp_wifi_adapter.c | 92 wifi_static_queue_t *wifi_create_queue(int queue_len, int item_size) in wifi_create_queue() argument
102 wifi_msgq_buffer = wifi_malloc(queue_len * item_size); in wifi_create_queue()
115 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
128 static void *wifi_create_queue_wrapper(int queue_len, int item_size) in wifi_create_queue_wrapper() argument
130 return wifi_create_queue(queue_len, item_size); in wifi_create_queue_wrapper()
283 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
292 k_msgq_init((struct k_msgq *)queue, wifi_msgq_buffer, item_size, queue_len); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/zephyr/esp32s2/src/wifi/ |
| D | esp_wifi_adapter.c | 90 wifi_static_queue_t *wifi_create_queue(int queue_len, int item_size) in wifi_create_queue() argument
100 wifi_msgq_buffer = wifi_malloc(queue_len * item_size); in wifi_create_queue()
113 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
126 static void *wifi_create_queue_wrapper(int queue_len, int item_size) in wifi_create_queue_wrapper() argument
128 return wifi_create_queue(queue_len, item_size); in wifi_create_queue_wrapper()
281 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
290 k_msgq_init((struct k_msgq *)queue, wifi_msgq_buffer, item_size, queue_len); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/zephyr/esp32s3/src/wifi/ |
| D | esp_wifi_adapter.c | 91 wifi_static_queue_t *wifi_create_queue(int queue_len, int item_size) in wifi_create_queue() argument
101 wifi_msgq_buffer = wifi_malloc(queue_len * item_size); in wifi_create_queue()
114 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
127 static void *wifi_create_queue_wrapper(int queue_len, int item_size) in wifi_create_queue_wrapper() argument
129 return wifi_create_queue(queue_len, item_size); in wifi_create_queue_wrapper()
307 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
316 k_msgq_init((struct k_msgq *)queue, wifi_msgq_buffer, item_size, queue_len); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/zephyr/esp32c3/src/wifi/ |
| D | esp_wifi_adapter.c | 107 wifi_static_queue_t *wifi_create_queue(int queue_len, int item_size) in wifi_create_queue() argument
117 wifi_msgq_buffer = wifi_malloc(queue_len * item_size); in wifi_create_queue()
130 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
143 static void *wifi_create_queue_wrapper(int queue_len, int item_size) in wifi_create_queue_wrapper() argument
145 return wifi_create_queue(queue_len, item_size); in wifi_create_queue_wrapper()
298 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
307 k_msgq_init((struct k_msgq *)queue, wifi_msgq_buffer, item_size, queue_len); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/components/esp_wifi/esp32c3/ |
| D | esp_adapter.c | 74 wifi_static_queue_t* wifi_create_queue( int queue_len, int item_size) in wifi_create_queue() argument
83 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
95 static void * wifi_create_queue_wrapper(int queue_len, int item_size) in wifi_create_queue_wrapper() argument
97 return wifi_create_queue(queue_len, item_size); in wifi_create_queue_wrapper()
277 static void * queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
279 return (void *)xQueueCreate(queue_len, item_size); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/zephyr/esp32/src/bt/ |
| D | esp_bt_adapter.c | 106 void *(*_queue_create)(uint32_t queue_len, uint32_t item_size);
149 void *(* _customer_queue_create)(uint32_t queue_len, uint32_t item_size);
221 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size);
538 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
547 queue->pool = (uint8_t *)k_malloc(queue_len * item_size * sizeof(uint8_t)); in queue_create_wrapper()
555 k_msgq_init(&queue->queue, queue->pool, item_size, queue_len); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/components/esp_wifi/include/esp_private/ |
| D | wifi_os_adapter.h | 49 void *(* _queue_create)(uint32_t queue_len, uint32_t item_size);
126 void * (* _wifi_create_queue)(int queue_len, int item_size);
|
| /hal_espressif-3.6.0/zephyr/esp32c3/src/bt/ |
| D | esp_bt_adapter.c | 134 void *(* _queue_create)(uint32_t queue_len, uint32_t item_size);
237 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size);
571 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
580 queue->pool = (uint8_t *)k_malloc(queue_len * item_size * sizeof(uint8_t)); in queue_create_wrapper()
588 k_msgq_init(&queue->queue, queue->pool, item_size, queue_len); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/zephyr/esp32s3/src/bt/ |
| D | esp_bt_adapter.c | 133 void *(* _queue_create)(uint32_t queue_len, uint32_t item_size);
236 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size);
562 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
571 queue->pool = (uint8_t *)k_malloc(queue_len * item_size * sizeof(uint8_t)); in queue_create_wrapper()
579 k_msgq_init(&queue->queue, queue->pool, item_size, queue_len); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/docs/en/api-reference/system/ |
| D | freertos_additions.rst | 111 size_t item_size;
112 char *item = (char *)xRingbufferReceive(buf_handle, &item_size, pdMS_TO_TICKS(1000));
117 for (int i = 0; i < item_size; i++) {
167 size_t item_size;
168 …char *item = (char *)xRingbufferReceiveUpTo(buf_handle, &item_size, pdMS_TO_TICKS(1000), sizeof(tx…
173 for (int i = 0; i < item_size; i++) {
314 size_t item_size;
315 char *item = (char *)xRingbufferReceive(buf_handle, &item_size, 0);
|
| /hal_espressif-3.6.0/components/bt/controller/esp32c3/ |
| D | bt.c | 157 void *(* _queue_create)(uint32_t queue_len, uint32_t item_size);
287 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size);
550 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
552 return (void *)xQueueCreate(queue_len, item_size); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/components/bt/controller/esp32s3/ |
| D | bt.c | 156 void *(* _queue_create)(uint32_t queue_len, uint32_t item_size);
285 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size);
533 static void *queue_create_wrapper(uint32_t queue_len, uint32_t item_size) in queue_create_wrapper() argument
535 return (void *)xQueueCreate(queue_len, item_size); in queue_create_wrapper()
|
| /hal_espressif-3.6.0/components/bt/host/bluedroid/btc/profile/std/spp/ |
| D | btc_spp.c | 1460 ssize_t item_size = 0; in spp_vfs_read() local
1493 item_size = -1; in spp_vfs_read()
1501 item_size += p_buf->len; in spp_vfs_read()
1507 item_size += size; in spp_vfs_read()
1521 return item_size; in spp_vfs_read()
|
