Home
last modified time | relevance | path

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

/system/bt/osi/test/
Dfixed_queue_test.cpp105 EXPECT_EQ((size_t)0, fixed_queue_length(NULL)); in TEST_F()
110 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
114 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
118 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()
159 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
163 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
165 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
234 EXPECT_EQ((size_t)3, fixed_queue_length(queue)); in TEST_F()
237 EXPECT_EQ((size_t)2, fixed_queue_length(queue)); in TEST_F()
/system/bt/stack/rfcomm/
Dport_utils.c428 || (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user()
544 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) in port_flow_control_peer()
560 && (fixed_queue_length(p_port->rx.queue) < PORT_RX_BUF_LOW_WM)) in port_flow_control_peer()
581 || (fixed_queue_length(p_port->rx.queue) > PORT_RX_BUF_HIGH_WM)) in port_flow_control_peer()
Dport_api.c1162 count = fixed_queue_length(p_port->rx.queue); in PORT_Purge()
1397 || (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_CRITICAL_WM)) in port_write()
1588 || (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) in PORT_WriteDataCO()
1593 p_port->tx.queue_size, fixed_queue_length(p_port->tx.queue), available); in PORT_WriteDataCO()
1720 || (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) in PORT_WriteData()
Dport_rfc.c869 || (fixed_queue_length(p_port->rx.queue) + 1 > p_port->rx_buf_critical)) in PORT_DataInd()
/system/bt/osi/include/
Dfixed_queue.h49 size_t fixed_queue_length(fixed_queue_t *queue);
/system/bt/stack/l2cap/
Dl2c_fcr.c368 || (fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q) >= p_ccb->peer_cfg.fcr.tx_win_sz) ) in l2c_fcr_is_flow_controlled()
662 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q), in l2c_fcr_proc_pdu()
910 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in l2c_fcr_proc_tout()
997 if (num_bufs_acked > fixed_queue_length(p_fcrb->waiting_for_ack_q)) in process_reqseq()
1002 fixed_queue_length(p_fcrb->waiting_for_ack_q)); in process_reqseq()
1207 …if ( (tx_seq == next_srej) && (fixed_queue_length(p_fcrb->srej_rcv_hold_q) < p_ccb->our_cfg.fcr.tx… in process_i_frame()
1238 …p_ccb->local_cid, next_srej, fixed_queue_length(p_fcrb->srej_rcv_hold_q), p_ccb->our_cfg.fcr.tx_wi… in process_i_frame()
1269 … p_ccb->local_cid, tx_seq, fixed_queue_length(p_fcrb->srej_rcv_hold_q)); in process_i_frame()
1561 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames()
1599 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames()
[all …]
Dl2c_ucd.c455 (fixed_queue_length(p_ccb->xmit_hold_q) + in L2CA_UcdDataWrite()
456 fixed_queue_length(p_lcb->ucd_out_sec_pending_q)), in L2CA_UcdDataWrite()
Dl2c_utils.c3403 fixed_queue_length(p_ccb->xmit_hold_q)); in l2cu_get_next_channel_in_rr()
3723 size_t q_count = fixed_queue_length(p_ccb->xmit_hold_q); in l2cu_check_channel_congestion()
3728 q_count += fixed_queue_length(p_ccb->p_lcb->ucd_out_sec_pending_q); in l2cu_check_channel_congestion()
3758 fixed_queue_length(p_ccb->p_lcb->ucd_out_sec_pending_q), in l2cu_check_channel_congestion()
3759 fixed_queue_length(p_ccb->xmit_hold_q), in l2cu_check_channel_congestion()
3801 fixed_queue_length(p_ccb->p_lcb->ucd_out_sec_pending_q), in l2cu_check_channel_congestion()
3802 fixed_queue_length(p_ccb->xmit_hold_q), in l2cu_check_channel_congestion()
Dl2c_api.c1871 … fixed_queue_length(p_lcb->p_fixed_ccbs[fixed_cid - L2CAP_FIRST_FIXED_CHNL]->xmit_hold_q), in L2CA_SendFixedChnlData()
2227 fixed_queue_length(p_ccb->xmit_hold_q), in L2CA_FlushChannel()
2296 num_left += fixed_queue_length(p_ccb->xmit_hold_q); in L2CA_FlushChannel()
Dl2c_main.c939 fixed_queue_length(p_ccb->xmit_hold_q), in l2c_data_write()
/system/bt/stack/bnep/
Dbnep_api.c430 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) in BNEP_WriteBuf()
535 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) in BNEP_Write()
728 p_status->xmit_q_depth = fixed_queue_length(p_bcb->xmit_q); in BNEP_GetStatus()
Dbnep_utils.c437 if (fixed_queue_length(p_bcb->xmit_q) >= BNEP_MAX_XMITQ_DEPTH) in bnepu_check_send_packet()
/system/bt/btif/src/
Dbtif_media_task.c466 fixed_queue_length(btif_media_cb.TxAaQ)); in log_tstamps_us()
1346 fixed_queue_length(btif_media_cb.RxSbcQ)); in btif_media_task_avk_handle_timer()
1803 fixed_queue_length(btif_media_cb.TxAaQ); in btif_media_task_aa_tx_flush()
2741 return fixed_queue_length(btif_media_cb.RxSbcQ); in btif_media_sink_enque_buf()
2742 if (fixed_queue_length(btif_media_cb.RxSbcQ) == MAX_OUTPUT_A2DP_FRAME_QUEUE_SZ) in btif_media_sink_enque_buf()
2744 UINT8 ret = fixed_queue_length(btif_media_cb.RxSbcQ); in btif_media_sink_enque_buf()
2763 if (fixed_queue_length(btif_media_cb.RxSbcQ) == MAX_A2DP_DELAYED_START_FRAME_COUNT) { in btif_media_sink_enque_buf()
2768 return fixed_queue_length(btif_media_cb.RxSbcQ); in btif_media_sink_enque_buf()
3049 fixed_queue_length(btif_media_cb.TxAaQ); in btif_media_aa_prep_sbc_2_send()
3094 if (fixed_queue_length(btif_media_cb.TxAaQ) > (MAX_OUTPUT_A2DP_FRAME_QUEUE_SZ - nb_frame)) in btif_media_aa_prep_2_send()
[all …]
/system/bt/stack/gatt/
Dgatt_auth.c196 for (size_t count = fixed_queue_length(p_tcb->pending_enc_clcb); in gatt_enc_cmpl_cback()
249 size_t count = fixed_queue_length(p_tcb->pending_enc_clcb); in gatt_notify_enc_cmpl()
Dgatt_sr.c139 fixed_queue_length(p_cmd->multi_rsp_q), in process_read_multi_rsp()
142 if (fixed_queue_length(p_cmd->multi_rsp_q) == p_cmd->multi_req.num_handles) in process_read_multi_rsp()
Dgatt_utils.c1421 fixed_queue_length(p_sreg->p_db->svc_buffer)); in gatt_sr_alloc_rcb()
/system/bt/bta/pan/
Dbta_pan_act.c668 while (fixed_queue_length(p_scb->data_queue) > bta_pan_cb.q_level) in bta_pan_tx_path()
695 while (fixed_queue_length(p_scb->data_queue) > bta_pan_cb.q_level) in bta_pan_tx_path()
/system/bt/osi/src/
Dfixed_queue.c97 size_t fixed_queue_length(fixed_queue_t *queue) { in fixed_queue_length() function
/system/bt/stack/avct/
Davct_lcb_act.c627 fixed_queue_length(p_lcb->tx_q)); in avct_lcb_send_msg()
/system/bt/stack/btm/
Dbtm_sco.c256 fixed_queue_length(p_ccb->xmit_data_q) + 1);
/system/bt/stack/avdt/
Davdt_scb_act.c1436 fixed_queue_length(p_scb->frag_q), p_scb->frag_off); in avdt_scb_snd_stream_close()