Searched refs:rx_queue (Results 1 – 3 of 3) sorted by relevance
| /hal_espressif-latest/components/esp_netif/vfs_l2tap/ |
| D | esp_vfs_l2tap.c | 45 QueueHandle_t rx_queue; member
89 l2tap_socket->rx_queue = xQueueCreate(RX_QUEUE_MAX_SIZE, sizeof(frame_queue_entry_t)); in init_rx_queue()
90 ESP_RETURN_ON_FALSE(l2tap_socket->rx_queue, ESP_ERR_NO_MEM, TAG, "create work queue failed"); in init_rx_queue()
101 if (xQueueSend(l2tap_socket->rx_queue, &frame_info, 0) != pdTRUE) { in push_rx_queue()
115 if (xQueueReceive(l2tap_socket->rx_queue, &frame_info, timeout) == pdTRUE) { in pop_rx_queue()
139 return (uxQueueMessagesWaiting(l2tap_socket->rx_queue) == 0); in rx_queue_empty()
145 while (xQueueReceive(l2tap_socket->rx_queue, &frame_info, 0) == pdTRUE) { in flush_rx_queue()
154 vQueueDelete(l2tap_socket->rx_queue); in delete_rx_queue()
155 l2tap_socket->rx_queue = NULL; in delete_rx_queue()
|
| /hal_espressif-latest/components/bt/host/bluedroid/stack/gap/ |
| D | gap_conn.c | 310 if (fixed_queue_is_empty(p_ccb->rx_queue)) { in GAP_ConnReadData()
317 BT_HDR *p_buf = fixed_queue_try_peek_first(p_ccb->rx_queue); in GAP_ConnReadData()
335 osi_free(fixed_queue_dequeue(p_ccb->rx_queue, 0)); in GAP_ConnReadData()
407 p_buf = (BT_HDR *)fixed_queue_dequeue(p_ccb->rx_queue, 0); in GAP_ConnBTRead()
992 fixed_queue_enqueue(p_ccb->rx_queue, p_msg, FIXED_QUEUE_MAX_TIMEOUT); in gap_data_ind()
1124 p_ccb->rx_queue = fixed_queue_new(QUEUE_SIZE_MAX); in gap_allocate_ccb()
1156 while (!fixed_queue_is_empty(p_ccb->rx_queue)) { in gap_release_ccb()
1157 osi_free(fixed_queue_dequeue(p_ccb->rx_queue, 0)); in gap_release_ccb()
1159 fixed_queue_free(p_ccb->rx_queue, NULL); in gap_release_ccb()
1160 p_ccb->rx_queue = NULL; in gap_release_ccb()
|
| /hal_espressif-latest/components/bt/host/bluedroid/stack/gap/include/ |
| D | gap_int.h | 75 fixed_queue_t *rx_queue; /* Queue of buffers waiting to be read */ member
|
