Home
last modified time | relevance | path

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

/system/bt/osi/test/
Dfixed_queue_test.cc150 EXPECT_EQ((size_t)0, fixed_queue_length(NULL)); in TEST_F()
155 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
159 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
163 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
202 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
204 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
208 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
210 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
279 EXPECT_EQ((size_t)3, fixed_queue_length(queue)); in TEST_F()
282 EXPECT_EQ((size_t)2, fixed_queue_length(queue)); in TEST_F()
/system/bt/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()
/system/bt/btif/src/
Dbtif_a2dp_sink.cc559 fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue)); in btif_a2dp_sink_avk_handle_timer()
651 return fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_enqueue_buf()
653 if (fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue) == in btif_a2dp_sink_enqueue_buf()
655 uint8_t ret = fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_enqueue_buf()
668 if (fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue) == in btif_a2dp_sink_enqueue_buf()
674 return fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_enqueue_buf()
Dbtif_a2dp_source.cc882 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_audio_handle_timer()
940 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_enqueue_callback()
950 if (fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue) + frames_n > in btif_a2dp_source_enqueue_callback()
953 (uint32_t)fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue), in btif_a2dp_source_enqueue_callback()
960 size_t drop_n = fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_enqueue_callback()
965 while (fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue)) { in btif_a2dp_source_enqueue_callback()
1026 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_audio_tx_flush_event()
1066 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue)); in log_tstamps_us()
/system/bt/osi/include/
Dfixed_queue.h57 size_t fixed_queue_length(fixed_queue_t* queue);
/system/bt/stack/rfcomm/
Dport_utils.cc391 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user()
487 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer()
499 (fixed_queue_length(p_port->rx.queue) < PORT_RX_BUF_LOW_WM)) { in port_flow_control_peer()
517 (fixed_queue_length(p_port->rx.queue) > PORT_RX_BUF_HIGH_WM)) && in port_flow_control_peer()
Dport_api.cc788 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_CRITICAL_WM)) { in port_write()
916 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) { in PORT_WriteDataCO()
921 p_port->tx.queue_size, fixed_queue_length(p_port->tx.queue), in PORT_WriteDataCO()
1043 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) in PORT_WriteData()
Dport_rfc.cc794 (fixed_queue_length(p_port->rx.queue) + 1 > p_port->rx_buf_critical)) { in PORT_DataInd()
/system/bt/stack/l2cap/
Dl2c_fcr.cc380 (fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q) >= in l2c_fcr_is_flow_controlled()
667 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q), p_ccb->fcrb.num_tries); in l2c_fcr_proc_pdu()
923 p_ccb->fcrb.wait_ack, fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in l2c_fcr_proc_tout()
1000 if (num_bufs_acked > fixed_queue_length(p_fcrb->waiting_for_ack_q)) { in process_reqseq()
1006 fixed_queue_length(p_fcrb->waiting_for_ack_q)); in process_reqseq()
1202 (fixed_queue_length(p_fcrb->srej_rcv_hold_q) < in process_i_frame()
1234 fixed_queue_length(p_fcrb->srej_rcv_hold_q), in process_i_frame()
1266 fixed_queue_length(p_fcrb->srej_rcv_hold_q)); in process_i_frame()
1544 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames()
1583 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames()
[all …]
Dl2c_api.cc1598 fixed_cid, fixed_queue_length( in L2CA_SendFixedChnlData()
1837 lcid, num_to_flush, fixed_queue_length(p_ccb->xmit_hold_q), in L2CA_FlushChannel()
1899 num_left += fixed_queue_length(p_ccb->xmit_hold_q); in L2CA_FlushChannel()
Dl2c_main.cc999 p_ccb->local_cid, fixed_queue_length(p_ccb->xmit_hold_q), in l2c_data_write()
Dl2c_utils.cc3110 fixed_queue_length(p_ccb->xmit_hold_q)); in l2cu_get_next_channel_in_rr()
3400 status, p_ccb->local_cid, fixed_queue_length(p_ccb->xmit_hold_q), in send_congestion_status_to_all_clients()
3430 size_t q_count = fixed_queue_length(p_ccb->xmit_hold_q); in l2cu_check_channel_congestion()
/system/bt/stack/bnep/
Dbnep_api.cc398 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) { in BNEP_WriteBuf()
498 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) in BNEP_Write()
682 p_status->xmit_q_depth = fixed_queue_length(p_bcb->xmit_q); in BNEP_GetStatus()
Dbnep_utils.cc407 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) { in bnepu_check_send_packet()
/system/bt/osi/src/
Dfixed_queue.cc103 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length() function
/system/bt/stack/avct/
Davct_lcb_act.cc556 fixed_queue_length(p_lcb->tx_q)); in avct_lcb_send_msg()
/system/bt/bta/pan/
Dbta_pan_act.cc606 while (fixed_queue_length(p_scb->data_queue) > bta_pan_cb.q_level) { in bta_pan_tx_path()
/system/bt/stack/gatt/
Dgatt_sr.cc133 VLOG(1) << "Multi read count=" << fixed_queue_length(p_cmd->multi_rsp_q) in process_read_multi_rsp()
136 if (fixed_queue_length(p_cmd->multi_rsp_q) == in process_read_multi_rsp()