Home
last modified time | relevance | path

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

/aosp12/system/bt/osi/test/
H A 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()
/aosp12/system/bt/btif/src/
H A Dbtif_a2dp_sink.cc564 fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue)); in btif_a2dp_sink_avk_handle_timer()
656 return fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_enqueue_buf()
658 if (fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue) == in btif_a2dp_sink_enqueue_buf()
660 uint8_t ret = fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_enqueue_buf()
673 if (fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue) == in btif_a2dp_sink_enqueue_buf()
679 return fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue); in btif_a2dp_sink_enqueue_buf()
H A Dbtif_a2dp_source.cc887 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_audio_handle_timer()
945 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_enqueue_callback()
955 if (fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue) + frames_n > in btif_a2dp_source_enqueue_callback()
958 (uint32_t)fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue), in btif_a2dp_source_enqueue_callback()
965 size_t drop_n = fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_enqueue_callback()
970 while (fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue)) { in btif_a2dp_source_enqueue_callback()
1025 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue); in btif_a2dp_source_audio_tx_flush_event()
1065 fixed_queue_length(btif_a2dp_source_cb.tx_audio_queue)); in log_tstamps_us()
/aosp12/system/bt/stack/rfcomm/
H A Dport_utils.cc393 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user()
489 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer()
501 (fixed_queue_length(p_port->rx.queue) < PORT_RX_BUF_LOW_WM)) { in port_flow_control_peer()
519 (fixed_queue_length(p_port->rx.queue) > PORT_RX_BUF_HIGH_WM)) && in port_flow_control_peer()
H A Dport_api.cc806 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_CRITICAL_WM)) { in port_write()
934 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) { in PORT_WriteDataCO()
939 p_port->tx.queue_size, fixed_queue_length(p_port->tx.queue), in PORT_WriteDataCO()
1061 (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) in PORT_WriteData()
H A Dport_rfc.cc793 (fixed_queue_length(p_port->rx.queue) + 1 > p_port->rx_buf_critical)) { in PORT_DataInd()
/aosp12/system/bt/osi/test/fuzzers/fixed_queue/
H A Dfuzz_fixed_queue.cc96 fixed_queue_length(fixed_queue); in callArbitraryFunction()
129 if (fixed_queue && fixed_queue_length(fixed_queue) > 0) { in callArbitraryFunction()
/aosp12/system/bt/stack/l2cap/
H A Dl2c_fcr.cc271 (fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q) >= in l2c_fcr_is_flow_controlled()
530 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q), p_ccb->fcrb.num_tries); in l2c_fcr_proc_pdu()
783 p_ccb->fcrb.wait_ack, fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in l2c_fcr_proc_tout()
853 if (num_bufs_acked > fixed_queue_length(p_fcrb->waiting_for_ack_q)) { in process_reqseq()
859 fixed_queue_length(p_fcrb->waiting_for_ack_q)); in process_reqseq()
1042 (fixed_queue_length(p_fcrb->srej_rcv_hold_q) < in process_i_frame()
1056 fixed_queue_length(p_fcrb->srej_rcv_hold_q), in process_i_frame()
1088 fixed_queue_length(p_fcrb->srej_rcv_hold_q)); in process_i_frame()
1280 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames()
1319 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames()
[all …]
H A Dl2c_api.cc1326 fixed_queue_length( in L2CA_SendFixedChnlData()
1565 lcid, num_to_flush, fixed_queue_length(p_ccb->xmit_hold_q), in L2CA_FlushChannel()
1621 num_left += fixed_queue_length(p_ccb->xmit_hold_q); in L2CA_FlushChannel()
H A Dl2c_main.cc1036 p_ccb->local_cid, fixed_queue_length(p_ccb->xmit_hold_q), in l2c_data_write()
H A Dl2c_utils.cc3224 status, p_ccb->local_cid, fixed_queue_length(p_ccb->xmit_hold_q), in send_congestion_status_to_all_clients()
3252 size_t q_count = fixed_queue_length(p_ccb->xmit_hold_q); in l2cu_check_channel_congestion()
H A Dl2c_link.cc1411 p_ccb->local_cid, fixed_queue_length(p_ccb->xmit_hold_q)); in l2cu_get_next_channel_in_rr()
/aosp12/system/bt/osi/include/
H A Dfixed_queue.h57 size_t fixed_queue_length(fixed_queue_t* queue);
/aosp12/system/bt/stack/bnep/
H A Dbnep_api.cc395 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) { in BNEP_WriteBuf()
495 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) in BNEP_Write()
H A Dbnep_utils.cc406 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) { in bnepu_check_send_packet()
/aosp12/system/bt/osi/src/
H A Dfixed_queue.cc103 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length() function
/aosp12/system/bt/bta/pan/
H A Dbta_pan_act.cc576 while (fixed_queue_length(p_scb->data_queue) > bta_pan_cb.q_level) { in bta_pan_tx_path()
/aosp12/system/bt/stack/avct/
H A Davct_lcb_act.cc555 fixed_queue_length(p_lcb->tx_q)); in avct_lcb_send_msg()
/aosp12/system/bt/stack/gatt/
H A Dgatt_sr.cc250 VLOG(1) << "Multi read count=" << fixed_queue_length(p_cmd->multi_rsp_q) in process_read_multi_rsp()
254 if (fixed_queue_length(p_cmd->multi_rsp_q) == in process_read_multi_rsp()
/aosp12/system/bt/test/stub/
H A Dosi.cc332 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length() function