Home
last modified time | relevance | path

Searched refs:fixed_queue_try_dequeue (Results 1 – 25 of 28) sorted by relevance

12

/system/bt/osi/test/
Dfixed_queue_test.cc41 void* msg = fixed_queue_try_dequeue(queue); in fixed_queue_ready()
140 ASSERT_EQ(DUMMY_DATA_STRING, fixed_queue_try_dequeue(queue)); in TEST_F()
162 ASSERT_EQ(DUMMY_DATA_STRING, fixed_queue_try_dequeue(queue)); in TEST_F()
209 EXPECT_EQ(DUMMY_DATA_STRING, fixed_queue_try_dequeue(queue)); in TEST_F()
221 EXPECT_EQ(DUMMY_DATA_STRING, fixed_queue_try_dequeue(queue)); in TEST_F()
225 EXPECT_EQ(NULL, fixed_queue_try_dequeue(queue)); in TEST_F()
228 EXPECT_EQ(NULL, fixed_queue_try_dequeue(NULL)); in TEST_F()
/system/bt/osi/test/fuzzers/fixed_queue/
Dfuzz_fixed_queue.cc33 void* msg = fixed_queue_try_dequeue(queue); in fqCb()
135 fixed_queue_try_dequeue(fixed_queue); in callArbitraryFunction()
/system/bt/osi/include/
Dfixed_queue.h82 void* fixed_queue_try_dequeue(fixed_queue_t* queue);
/system/bt/osi/src/
Dthread.cc226 static_cast<work_item_t*>(fixed_queue_try_dequeue(thread->work_queue)); in run_thread()
231 static_cast<work_item_t*>(fixed_queue_try_dequeue(thread->work_queue)); in run_thread()
Dfixed_queue.cc89 void* data = fixed_queue_try_dequeue(queue); in fixed_queue_flush()
162 void* fixed_queue_try_dequeue(fixed_queue_t* queue) { in fixed_queue_try_dequeue() function
Dalarm.cc608 alarm_t* alarm = (alarm_t*)fixed_queue_try_dequeue(queue); in alarm_queue_ready()
/system/bt/stack/gap/
Dgap_conn.cc403 osi_free(fixed_queue_try_dequeue(p_ccb->rx_queue)); in GAP_ConnReadData()
470 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->rx_queue); in GAP_ConnBTRead()
490 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->tx_queue)) != NULL) { in gap_try_write_queued_data()
1133 osi_free(fixed_queue_try_dequeue(p_ccb->rx_queue)); in gap_release_ccb()
1138 osi_free(fixed_queue_try_dequeue(p_ccb->tx_queue)); in gap_release_ccb()
/system/bt/stack/avdt/
Davdt_ccb_act.cc63 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->rsp_q)) != NULL) in avdt_ccb_clear_ccb()
658 p_ccb->p_curr_cmd = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->cmd_q); in avdt_ccb_clear_cmds()
808 p_msg = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->cmd_q); in avdt_ccb_snd_cmd()
840 while ((p_msg = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->rsp_q)) != NULL) { in avdt_ccb_snd_msg()
/system/bt/bta/pan/
Dbta_pan_act.cc419 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_scb->data_queue)) != in bta_pan_disable()
557 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_scb->data_queue)) != NULL) in bta_pan_conn_close()
607 BT_HDR* p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_scb->data_queue); in bta_pan_tx_path()
Dbta_pan_ci.cc191 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_scb->data_queue); in bta_pan_ci_readbuf()
/system/bt/stack/rfcomm/
Dport_utils.cc209 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->rx.queue)) != in port_release_port()
215 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue)) != in port_release_port()
Drfc_utils.cc429 BT_HDR* p = (BT_HDR*)fixed_queue_try_dequeue(p_mcb->cmd_q); in rfc_check_send_cmd()
Drfc_mx_fsm.cc506 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_mcb->cmd_q)) != NULL) in rfc_mx_sm_state_disc_wait_ua()
Dport_rfc.cc910 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_port->tx.queue); in port_rfc_send_tx_data()
Dport_api.cc737 osi_free(fixed_queue_try_dequeue(p_port->rx.queue)); in PORT_ReadData()
/system/bt/btif/src/
Dbtif_a2dp_sink.cc554 p_msg = (BT_HDR*)fixed_queue_try_dequeue(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_avk_handle_timer()
656 osi_free(fixed_queue_try_dequeue(btif_a2dp_sink_cb.rx_audio_queue)); in btif_a2dp_sink_enqueue_buf()
Dbtif_a2dp_source.cc968 fixed_queue_try_dequeue(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_enqueue_callback()
1047 (BT_HDR*)fixed_queue_try_dequeue(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_audio_readbuf()
/system/bt/stack/l2cap/
Dl2c_fcr.cc756 while ((p_buf = (BT_HDR*)fixed_queue_try_dequeue(temp_q)) != NULL) { in l2c_fcr_proc_pdu()
1026 (BT_HDR*)fixed_queue_try_dequeue(p_fcrb->waiting_for_ack_q); in process_reqseq()
1603 osi_free(fixed_queue_try_dequeue(p_ccb->fcrb.retrans_q)); in retransmit_i_frames()
1657 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->fcrb.retrans_q); in l2c_fcr_get_next_xmit_sdu_seg()
1714 p_xmit = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->xmit_hold_q); in l2c_fcr_get_next_xmit_sdu_seg()
1841 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->xmit_hold_q); in l2c_lcc_get_next_xmit_sdu_seg()
Dl2c_utils.cc224 (tL2CAP_SEC_DATA*)fixed_queue_try_dequeue(p_lcb->le_sec_pending_q); in l2cu_release_lcb()
879 while ((p_buf2 = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->xmit_hold_q)) != in l2cu_send_peer_disc_req()
3265 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->xmit_hold_q); in l2cu_get_next_buffer_to_send()
3315 p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_ccb->xmit_hold_q); in l2cu_get_next_buffer_to_send()
/system/bt/stack/avct/
Davct_lcb_act.cc430 (p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_lcb->tx_q)) != NULL) { in avct_lcb_cong_ind()
/system/bt/stack/bnep/
Dbnep_main.cc406 BT_HDR* p_buf = (BT_HDR*)fixed_queue_try_dequeue(p_bcb->xmit_q); in bnep_congestion_ind()
Dbnep_utils.cc152 osi_free(fixed_queue_try_dequeue(p_bcb->xmit_q)); in bnepu_release_bcb()
/system/bt/stack/btm/
Dbtm_acl.cc2425 p_buf = (BT_HDR*)fixed_queue_try_dequeue(btm_cb.page_queue); in btm_acl_resubmit_page()
2457 while ((p = (BT_HDR*)fixed_queue_try_dequeue(btm_cb.page_queue)) != NULL) in btm_acl_reset_paging()
/system/bt/stack/gatt/
Dgatt_utils.cc98 osi_free(fixed_queue_try_dequeue(p_tcb->pending_ind_q)); in gatt_free_pending_ind()
/system/bt/stack/avrc/
Davrc_api.cc166 while ((p_next_cmd = (BT_HDR*)fixed_queue_try_dequeue( in avrc_send_next_vendor_cmd()

12