Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 113) sorted by relevance

12345

/hal_espressif-2.7.6/components/bt/common/osi/
Dfixed_queue.c71 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) in fixed_queue_free() argument
75 if (queue == NULL) { in fixed_queue_free()
79 fixed_queue_unregister_dequeue(queue); in fixed_queue_free()
82 … for (node = list_begin(queue->list); node != list_end(queue->list); node = list_next(node)) { in fixed_queue_free()
87 list_free(queue->list); in fixed_queue_free()
88 osi_sem_free(&queue->enqueue_sem); in fixed_queue_free()
89 osi_sem_free(&queue->dequeue_sem); in fixed_queue_free()
90 osi_mutex_free(&queue->lock); in fixed_queue_free()
91 osi_free(queue); in fixed_queue_free()
94 bool fixed_queue_is_empty(fixed_queue_t *queue) in fixed_queue_is_empty() argument
[all …]
/hal_espressif-2.7.6/components/bt/common/osi/include/osi/
Dfixed_queue.h38 typedef void (*fixed_queue_cb)(fixed_queue_t *queue);
48 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb);
52 bool fixed_queue_is_empty(fixed_queue_t *queue);
56 size_t fixed_queue_length(fixed_queue_t *queue);
60 size_t fixed_queue_capacity(fixed_queue_t *queue);
64 bool fixed_queue_enqueue(fixed_queue_t *queue, void *data, uint32_t timeout);
69 void *fixed_queue_dequeue(fixed_queue_t *queue, uint32_t timeout);
74 void *fixed_queue_try_peek_first(fixed_queue_t *queue);
79 void *fixed_queue_try_peek_last(fixed_queue_t *queue);
86 void *fixed_queue_try_remove_from_queue(fixed_queue_t *queue, void *data);
[all …]
/hal_espressif-2.7.6/components/freertos/
Dlinker.lf82 queue: prvIsQueueFull (default)
83 queue: prvInitialiseNewQueue (default)
84 queue: prvInitialiseMutex (default)
85 queue: uxQueueSpacesAvailable (default)
86 queue: xQueueGenericReset (default)
87 queue: xQueueGenericCreate (default)
88 queue: xQueueGetMutexHolder (default)
89 queue: xQueueCreateCountingSemaphore (default)
90 queue: xQueueGenericSend (default)
91 queue: xQueueCreateMutex (default)
[all …]
/hal_espressif-2.7.6/components/freertos/test/
Dtest_preemption.c29 QueueHandle_t queue = (QueueHandle_t) param; in task_send_to_queue() local
36 xQueueSendToBack(queue, &ccount, 0); in task_send_to_queue()
51 QueueHandle_t queue = xQueueCreate(1, sizeof(uint32_t)); variable
56 …xTaskCreatePinnedToCore(task_send_to_queue, "YIELD", 2048, (void *)queue, UNITY_FREERTOS_PRIORITY …
62 TEST_ASSERT( xQueueReceive(queue, &yield_ccount, 100 / portTICK_PERIOD_MS) );
71 vQueueDelete(queue);
85 QueueHandle_t queue = xQueueCreate(1, sizeof(uint32_t)); variable
90 …xTaskCreatePinnedToCore(task_send_to_queue, "YIELD", 2048, (void *)queue, UNITY_FREERTOS_PRIORITY …
99 TEST_ASSERT( xQueueReceive(queue, &yield_ccount, 100 / portTICK_PERIOD_MS) );
107 vQueueDelete(queue);
/hal_espressif-2.7.6/components/esp_wifi/esp32s2/
Desp_adapter.c105 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
107 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
108 if (!queue) { in wifi_create_queue()
114 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
115 if (!queue->storage) { in wifi_create_queue()
119 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
121 if (!queue->handle) { in wifi_create_queue()
125 return queue; in wifi_create_queue()
128 if (queue) { in wifi_create_queue()
129 if (queue->storage) { in wifi_create_queue()
[all …]
/hal_espressif-2.7.6/components/esp_wifi/esp32s3/
Desp_adapter.c107 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
109 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
110 if (!queue) { in wifi_create_queue()
116 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
117 if (!queue->storage) { in wifi_create_queue()
121 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
123 if (!queue->handle) { in wifi_create_queue()
127 return queue; in wifi_create_queue()
130 if (queue) { in wifi_create_queue()
131 if (queue->storage) { in wifi_create_queue()
[all …]
/hal_espressif-2.7.6/components/esp_wifi/esp32/
Desp_adapter.c117 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
119 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
120 if (!queue) { in wifi_create_queue()
126 …queue->storage = heap_caps_calloc(1, sizeof(StaticQueue_t) + (queue_len*item_size), MALLOC_CAP_INT… in wifi_create_queue()
127 if (!queue->storage) { in wifi_create_queue()
131 …queue->handle = xQueueCreateStatic( queue_len, item_size, ((uint8_t*)(queue->storage)) + sizeof(St… in wifi_create_queue()
133 if (!queue->handle) { in wifi_create_queue()
137 return queue; in wifi_create_queue()
140 if (queue) { in wifi_create_queue()
141 if (queue->storage) { in wifi_create_queue()
[all …]
/hal_espressif-2.7.6/zephyr/esp32/src/wifi/
Desp_wifi_adapter.c98 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
100 queue = (wifi_static_queue_t *)k_malloc(sizeof(wifi_static_queue_t)); in wifi_create_queue()
101 if (!queue) { in wifi_create_queue()
111 queue->handle = k_malloc(sizeof(struct k_msgq)); in wifi_create_queue()
112 if (queue->handle == NULL) { in wifi_create_queue()
118 k_msgq_init((struct k_msgq *)queue->handle, wifi_msgq_buffer, item_size, queue_len); in wifi_create_queue()
120 return queue; in wifi_create_queue()
123 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
125 if (queue) { in wifi_delete_queue()
126 k_free(queue->handle); in wifi_delete_queue()
[all …]
/hal_espressif-2.7.6/components/mdns/private_include/
Dmdns_private.h121 #define queueToEnd(type, queue, item) \ argument
122 if (!queue) { \
123 queue = item; \
125 type * _q = queue; \
130 #define queueDetach(type, queue, item) \ argument
131 if (queue) { \
132 if (queue == item) { \
133 queue = queue->next; \
135 type * _q = queue; \
146 #define queueFree(type, queue) while (queue) { type * _q = queue; queue = queue->next; free(_q); } argument
/hal_espressif-2.7.6/zephyr/esp32c3/src/bt/
Desp_bt_adapter.c108 struct k_msgq queue; member
134 void (* _queue_delete)(void *queue);
135 int (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
136 int (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
137 int (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
138 int (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
239 static void queue_delete_wrapper(void *queue);
240 static int queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
241 static int IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
242 static int queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
[all …]
/hal_espressif-2.7.6/components/esp_wifi/esp32c3/
Desp_adapter.c84 wifi_static_queue_t *queue = NULL; in wifi_create_queue() local
86 …queue = (wifi_static_queue_t*)heap_caps_malloc(sizeof(wifi_static_queue_t), MALLOC_CAP_INTERNAL|MA… in wifi_create_queue()
87 if (!queue) { in wifi_create_queue()
91 queue->handle = xQueueCreate( queue_len, item_size); in wifi_create_queue()
92 return queue; in wifi_create_queue()
95 void wifi_delete_queue(wifi_static_queue_t *queue) in wifi_delete_queue() argument
97 if (queue) { in wifi_delete_queue()
98 vQueueDelete(queue->handle); in wifi_delete_queue()
99 free(queue); in wifi_delete_queue()
108 static void wifi_delete_queue_wrapper(void *queue) in wifi_delete_queue_wrapper() argument
[all …]
/hal_espressif-2.7.6/examples/system/sysview_tracing_heap_log/main/
Dsysview_heap_log.c23 QueueHandle_t queue = (QueueHandle_t)p; in free_task() local
26 if (xQueueReceive(queue, ( void * )&p, portMAX_DELAY) != pdPASS) { in free_task()
46 QueueHandle_t queue = xQueueCreate(10, sizeof(void *)); in alloc_task() local
47 if(queue == 0) { in alloc_task()
52 xTaskCreatePinnedToCore(free_task, task_name, 2500, queue, 5, NULL, portNUM_PROCESSORS-1); in alloc_task()
61 if (xQueueSend(queue, ( void * )&p, portMAX_DELAY) != pdPASS) { in alloc_task()
/hal_espressif-2.7.6/components/bt/controller/esp32s3/
Dbt.c135 void (* _queue_delete)(void *queue);
136 int32_t (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
137 int32_t (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
138 int32_t (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
139 int32_t (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
224 static bool btdm_queue_generic_register(const btdm_queue_item_t *queue);
225 static bool btdm_queue_generic_deregister(btdm_queue_item_t *queue);
241 static void queue_delete_wrapper(void *queue);
242 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
243 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
[all …]
/hal_espressif-2.7.6/zephyr/esp32/src/bt/
Desp_bt_adapter.c83 struct k_msgq queue; member
107 void (*_queue_delete)(void *queue);
108 int32_t (*_queue_send)(void *queue, void *item, uint32_t block_time_ms);
109 int32_t (*_queue_send_from_isr)(void *queue, void *item, void *hptw);
110 int32_t (*_queue_recv)(void *queue, void *item, uint32_t block_time_ms);
111 int32_t (*_queue_recv_from_isr)(void *queue, void *item, void *hptw);
218 static void queue_delete_wrapper(void *queue);
219 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
220 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
221 static int32_t queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
[all …]
/hal_espressif-2.7.6/components/bt/host/bluedroid/stack/rfcomm/
Dport_utils.c131 p_port->tx.queue = fixed_queue_new(QUEUE_SIZE_MAX); in port_set_defaults()
132 p_port->rx.queue = fixed_queue_new(QUEUE_SIZE_MAX); in port_set_defaults()
213 if (p_port->rx.queue != NULL) { in port_release_port()
214 while ((p_buf = (BT_HDR *)fixed_queue_dequeue(p_port->rx.queue, 0)) != NULL) { in port_release_port()
220 if (p_port->tx.queue != NULL) { in port_release_port()
221 while ((p_buf = (BT_HDR *)fixed_queue_dequeue(p_port->tx.queue, 0)) != NULL) { in port_release_port()
240 fixed_queue_free(p_port->tx.queue, NULL); in port_release_port()
241 p_port->tx.queue = NULL; in port_release_port()
242 fixed_queue_free(p_port->rx.queue, NULL); in port_release_port()
243 p_port->rx.queue = NULL; in port_release_port()
[all …]
/hal_espressif-2.7.6/components/bt/controller/esp32/
Dbt.c149 void (* _queue_delete)(void *queue);
150 int32_t (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
151 int32_t (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
152 int32_t (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
153 int32_t (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
269 static bool btdm_queue_generic_register(const btdm_queue_item_t *queue);
270 static bool btdm_queue_generic_deregister(btdm_queue_item_t *queue);
286 static void queue_delete_wrapper(void *queue);
287 static int32_t queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
288 static int32_t IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
[all …]
/hal_espressif-2.7.6/components/esp_wifi/include/esp_private/
Dwifi_os_adapter.h58 void (* _queue_delete)(void *queue);
59 int32_t (* _queue_send)(void *queue, void *item, uint32_t block_time_tick);
60 int32_t (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
61 int32_t (* _queue_send_to_back)(void *queue, void *item, uint32_t block_time_tick);
62 int32_t (* _queue_send_to_front)(void *queue, void *item, uint32_t block_time_tick);
63 int32_t (* _queue_recv)(void *queue, void *item, uint32_t block_time_tick);
64 uint32_t (* _queue_msg_waiting)(void *queue);
135 void (* _wifi_delete_queue)(void * queue);
/hal_espressif-2.7.6/components/hal/
Dsdio_slave_hal.c557 sdio_slave_hal_recv_stailq_t *const queue = &(hal->recv_link_list); in recv_get_first_empty_buf() local
558 lldesc_t *desc = STAILQ_FIRST(queue); in recv_get_first_empty_buf()
598 sdio_slave_hal_recv_stailq_t *const queue = &hal->recv_link_list; in sdio_slave_hal_recv_unload_desc() local
599 lldesc_t *desc = STAILQ_FIRST(queue); in sdio_slave_hal_recv_unload_desc()
601 STAILQ_REMOVE_HEAD(queue, qe); in sdio_slave_hal_recv_unload_desc()
639 sdio_slave_hal_recv_stailq_t *const queue = &hal->recv_link_list; in sdio_slave_hal_recv_flush_one_buffer() local
640 lldesc_t *desc = STAILQ_FIRST(queue); in sdio_slave_hal_recv_flush_one_buffer()
642 STAILQ_REMOVE_HEAD(queue, qe); in sdio_slave_hal_recv_flush_one_buffer()
644 STAILQ_INSERT_TAIL(queue, desc, qe); in sdio_slave_hal_recv_flush_one_buffer()
651 sdio_slave_hal_recv_stailq_t *const queue = &(hal->recv_link_list); in sdio_slave_hal_load_buf() local
[all …]
/hal_espressif-2.7.6/components/bt/controller/esp32c3/
Dbt.c165 void (* _queue_delete)(void *queue);
166 int (* _queue_send)(void *queue, void *item, uint32_t block_time_ms);
167 int (* _queue_send_from_isr)(void *queue, void *item, void *hptw);
168 int (* _queue_recv)(void *queue, void *item, uint32_t block_time_ms);
169 int (* _queue_recv_from_isr)(void *queue, void *item, void *hptw);
295 static void queue_delete_wrapper(void *queue);
296 static int queue_send_wrapper(void *queue, void *item, uint32_t block_time_ms);
297 static int IRAM_ATTR queue_send_from_isr_wrapper(void *queue, void *item, void *hptw);
298 static int queue_recv_wrapper(void *queue, void *item, uint32_t block_time_ms);
299 static int IRAM_ATTR queue_recv_from_isr_wrapper(void *queue, void *item, void *hptw);
[all …]
/hal_espressif-2.7.6/components/esp32/include/rom/
Dqueue.h1 #warning rom/queue.h is deprecated, please use sys/queue.h instead
/hal_espressif-2.7.6/components/bt/host/bluedroid/btc/profile/std/spp/
Dbtc_spp.c53 fixed_queue_t *queue; /* Queue of buffers waiting to be sent */ member
109 if ((slot_data->queue = fixed_queue_new(queue_size)) == NULL) { in init_slot_data()
118 fixed_queue_free(slot_data->queue, spp_osi_free); in free_slot_data()
119 slot_data->queue = NULL; in free_slot_data()
817 … if ((p_buf = fixed_queue_try_peek_first(slot->tx.queue)) != NULL && p_buf->layer_specific == 0) { in btc_spp_write()
823 if (fixed_queue_enqueue(slot->tx.queue, arg->write.p_data, 0)) { in btc_spp_write()
1015 osi_free(fixed_queue_dequeue(slot->tx.queue, FIXED_QUEUE_MAX_TIMEOUT)); in btc_spp_cb_handler()
1021 if ((p_buf = fixed_queue_try_peek_first(slot->tx.queue)) == NULL) { in btc_spp_cb_handler()
1029 osi_free(fixed_queue_dequeue(slot->tx.queue, FIXED_QUEUE_MAX_TIMEOUT)); in btc_spp_cb_handler()
1030 if (fixed_queue_length(slot->tx.queue) <= SLOT_TX_QUEUE_LOW_WM) { in btc_spp_cb_handler()
[all …]
/hal_espressif-2.7.6/components/bt/esp_ble_mesh/mesh_models/client/
Dclient_common.c93 if ((node = bt_mesh_client_pick_node(&data->queue, ctx->addr)) == NULL) { in bt_mesh_is_client_recv_publish_msg()
309 if (bt_mesh_client_check_node_in_list(&internal->queue, param->ctx.addr)) { in bt_mesh_client_send_msg()
340 sys_slist_append(&internal->queue, &node->client_node); in bt_mesh_client_send_msg()
407 sys_slist_init(&data->queue); in bt_mesh_client_init()
475 sys_slist_find_and_remove(&internal->queue, &node->client_node); in bt_mesh_client_free_node()
496 while (!sys_slist_is_empty(&internal->queue)) { in bt_mesh_client_clear_list()
497 node = (void *)sys_slist_get_not_empty(&internal->queue); in bt_mesh_client_clear_list()
/hal_espressif-2.7.6/components/freemodbus/
DKconfig67 int "Modbus serial task queue length"
71 Modbus serial driver queue length. It is used by event queue task.
143 int "Modbus controller notification queue size"
147 Modbus controller notification queue size.
148 The notification queue is used to get information about accessed parameters.
159 int "Modbus stack event queue timeout (ms)"
163 Modbus stack event queue timeout in milliseconds. This may help to optimize
/hal_espressif-2.7.6/tools/test_apps/protocols/mqtt/publish_connect_test/
Dapp_test.py49 … def __init__(self, dut, transport, qos, repeat, published, queue, publish_cfg, log_details=False): argument
59 self.publish_cfg['queue'] = queue
95 queue = self.publish_cfg['queue']
102 … .format(transport, qos, MqttPublisher.published, queue, MqttPublisher.expected_data))
128 … x in (transport, self.sample_string, self.repeat, MqttPublisher.published, qos, queue)), eol='\n')
356 def start_publish_case(transport, qos, repeat, published, queue): argument
358 .format(transport, qos, published, repeat * DEFAULT_MSG_SIZE, queue))
359 with MqttPublisher(dut1, transport, qos, repeat, published, queue, publish_cfg):
/hal_espressif-2.7.6/examples/wifi/simple_sniffer/main/
DKconfig.projbuild42 int "Length of sniffer work queue"
46 The task gets some basic info of sniffer packet via queue.
47 Here you should specify the length of queue.

12345