Searched refs:data_queue (Results 1 – 5 of 5) sorted by relevance
117 p_scb->data_queue = fixed_queue_new(SIZE_MAX); in bta_pan_conn_state_cback()200 fixed_queue_enqueue(p_scb->data_queue, p_new_buf); in bta_pan_data_buf_ind_cback()388 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_scb->data_queue)) != in bta_pan_disable()524 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_scb->data_queue)) != NULL) in bta_pan_conn_close()573 while (fixed_queue_length(p_scb->data_queue) > bta_pan_cb.q_level) { in bta_pan_tx_path()574 BT_HDR* p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_scb->data_queue); in bta_pan_tx_path()
133 data_queue; /* Queue of buffers waiting to be passed to application */ member
185 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_scb->data_queue); in bta_pan_ci_readbuf()
256 fixed_queue_free(p_scb->data_queue, NULL); in bta_pan_scb_dealloc()
65 self.data_queue = asyncio.Queue()93 self.dlc.sink = self.data_queue.put_nowait120 received_data = await self.data_queue.get()