Home
last modified time | relevance | path

Searched refs:fixed_queue_length (Results 1 – 23 of 23) sorted by relevance

/packages/modules/Bluetooth/system/osi/test/
Dfixed_queue_test.cc148 EXPECT_EQ((size_t)0, fixed_queue_length(NULL)); in TEST_F()
153 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
157 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
161 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
200 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
202 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
206 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
208 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
277 EXPECT_EQ((size_t)3, fixed_queue_length(queue)); in TEST_F()
280 EXPECT_EQ((size_t)2, fixed_queue_length(queue)); in TEST_F()
/packages/modules/Bluetooth/system/test/mock/
Dmock_osi_fixed_queue.cc44 struct fixed_queue_length fixed_queue_length; variable
95 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length() function
97 return test::mock::osi_fixed_queue::fixed_queue_length(queue); in fixed_queue_length()
Dmock_osi_fixed_queue.h144 struct fixed_queue_length { struct
150 extern struct fixed_queue_length fixed_queue_length; argument
/packages/modules/Bluetooth/system/btif/src/
Dbtif_a2dp_sink.cc575 fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue)); in btif_a2dp_sink_avk_handle_timer()
671 return fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_enqueue_buf()
682 if (fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue) == in btif_a2dp_sink_enqueue_buf()
685 uint8_t ret = fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_enqueue_buf()
691 fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue) >= in btif_a2dp_sink_enqueue_buf()
700 return fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_enqueue_buf()
Dbtif_a2dp_source.cc914 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_audio_handle_timer()
970 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_enqueue_callback()
980 if (fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue) + frames_n > in btif_a2dp_source_enqueue_callback()
983 (uint32_t)fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue), in btif_a2dp_source_enqueue_callback()
990 size_t drop_n = fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_enqueue_callback()
995 while (fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue)) { in btif_a2dp_source_enqueue_callback()
1060 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_audio_tx_flush_event()
1099 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue)); in log_tstamps_us()
/packages/modules/Bluetooth/system/stack/rfcomm/
Dport_utils.cc389 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user()
485 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer()
497 (fixed_queue_length(p_port->rx.queue) < PORT_RX_BUF_LOW_WM)) { in port_flow_control_peer()
515 (fixed_queue_length(p_port->rx.queue) > PORT_RX_BUF_HIGH_WM)) && in port_flow_control_peer()
Dport_api.cc808 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_CRITICAL_WM)) { in port_write()
933 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) { in PORT_WriteDataCO()
938 p_port->tx.queue_size, fixed_queue_length(p_port->tx.queue), in PORT_WriteDataCO()
1063 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) in PORT_WriteData()
Dport_rfc.cc806 (fixed_queue_length(p_port->rx.queue) + 1 > p_port->rx_buf_critical)) { in PORT_DataInd()
/packages/modules/Bluetooth/system/stack/l2cap/
Dl2c_fcr.cc270 (fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q) >= in l2c_fcr_is_flow_controlled()
529 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q), p_ccb->fcrb.num_tries); in l2c_fcr_proc_pdu()
788 p_ccb->fcrb.wait_ack, fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in l2c_fcr_proc_tout()
859 if (num_bufs_acked > fixed_queue_length(p_fcrb->waiting_for_ack_q)) { in process_reqseq()
865 fixed_queue_length(p_fcrb->waiting_for_ack_q)); in process_reqseq()
1048 (fixed_queue_length(p_fcrb->srej_rcv_hold_q) < in process_i_frame()
1062 fixed_queue_length(p_fcrb->srej_rcv_hold_q), in process_i_frame()
1094 fixed_queue_length(p_fcrb->srej_rcv_hold_q)); in process_i_frame()
1285 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames()
1322 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames()
[all …]
Dl2c_api.cc1352 fixed_queue_length( in L2CA_SendFixedChnlData()
1573 lcid, num_to_flush, fixed_queue_length(p_ccb->xmit_hold_q), in L2CA_FlushChannel()
1630 num_left += fixed_queue_length(p_ccb->xmit_hold_q); in L2CA_FlushChannel()
Dl2c_main.cc943 p_ccb->local_cid, fixed_queue_length(p_ccb->xmit_hold_q), in l2c_data_write()
Dl2c_link.cc1201 fixed_queue_length(p_ccb->xmit_hold_q)); in l2cu_get_next_channel_in_rr()
Dl2c_utils.cc3503 status, p_ccb->local_cid, fixed_queue_length(p_ccb->xmit_hold_q), in send_congestion_status_to_all_clients()
3531 size_t q_count = fixed_queue_length(p_ccb->xmit_hold_q); in l2cu_check_channel_congestion()
/packages/modules/Bluetooth/system/osi/test/fuzzers/fixed_queue/
Dfuzz_fixed_queue.cc96 fixed_queue_length(fixed_queue); in callArbitraryFunction()
129 if (fixed_queue && fixed_queue_length(fixed_queue) > 0) { in callArbitraryFunction()
/packages/modules/Bluetooth/system/osi/include/
Dfixed_queue.h57 size_t fixed_queue_length(fixed_queue_t* queue);
/packages/modules/Bluetooth/system/test/fake/
Dfake_osi.cc297 test::mock::osi_fixed_queue::fixed_queue_length.body = [](fixed_queue_t* q) { in FakeOsi()
303 return test::mock::osi_fixed_queue::fixed_queue_length(q) == 0; in FakeOsi()
406 test::mock::osi_fixed_queue::fixed_queue_length = {}; in ~FakeOsi()
/packages/modules/Bluetooth/system/stack/bnep/
Dbnep_api.cc404 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) { in BNEP_WriteBuf()
503 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) in BNEP_Write()
Dbnep_utils.cc409 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) { in bnepu_check_send_packet()
/packages/modules/Bluetooth/system/osi/src/
Dfixed_queue.cc106 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length() function
/packages/modules/Bluetooth/system/bta/pan/
Dbta_pan_act.cc573 while (fixed_queue_length(p_scb->data_queue) > bta_pan_cb.q_level) { in bta_pan_tx_path()
/packages/modules/Bluetooth/system/test/stub/
Dosi.cc305 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length() function
/packages/modules/Bluetooth/system/stack/gatt/
Dgatt_sr.cc278 fixed_queue_length(p_cmd->multi_rsp_q), in process_read_multi_rsp()
281 if (fixed_queue_length(p_cmd->multi_rsp_q) == in process_read_multi_rsp()
/packages/modules/Bluetooth/system/stack/avct/
Davct_lcb_act.cc634 log::verbose("tx_q_count:{}", fixed_queue_length(p_lcb->tx_q)); in avct_lcb_send_msg()