Searched refs:fixed_queue_length (Results 1 – 16 of 16) sorted by relevance
/device/soc/esp/esp32/components/bt/host/bluedroid/stack/l2cap/ |
D | l2c_fcr.c | 380 … || (fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q) >= p_ccb->peer_cfg.fcr.tx_win_sz) ) { in l2c_fcr_is_flow_controlled() 663 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q), in l2c_fcr_proc_pdu() 818 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in l2c_fcr_proc_tout() 902 if (num_bufs_acked > fixed_queue_length(p_fcrb->waiting_for_ack_q)) { in process_reqseq() 906 fixed_queue_length(p_fcrb->waiting_for_ack_q)); in process_reqseq() 1098 …if ( (tx_seq == next_srej) && (fixed_queue_length(p_fcrb->srej_rcv_hold_q) < p_ccb->our_cfg.fcr.tx… in process_i_frame() 1124 …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() 1147 … p_ccb->local_cid, tx_seq, fixed_queue_length(p_fcrb->srej_rcv_hold_q)); in process_i_frame() 1417 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames() 1454 fixed_queue_length(p_ccb->fcrb.waiting_for_ack_q)); in retransmit_i_frames() [all …]
|
D | l2c_ucd.c | 424 (fixed_queue_length(p_ccb->xmit_hold_q) + in L2CA_UcdDataWrite() 425 fixed_queue_length(p_lcb->ucd_out_sec_pending_q)), in L2CA_UcdDataWrite()
|
D | l2c_api.c | 1839 … fixed_queue_length(p_lcb->p_fixed_ccbs[fixed_cid - L2CAP_FIRST_FIXED_CHNL]->xmit_hold_q), in L2CA_SendFixedChnlData() 2198 fixed_queue_length(p_ccb->xmit_hold_q), in L2CA_FlushChannel() 2264 num_left += fixed_queue_length(p_ccb->xmit_hold_q); in L2CA_FlushChannel() 2346 att_acl_pkt_num = fixed_queue_length(queue); in l2ble_update_att_acl_pkt_num()
|
D | l2c_utils.c | 3323 fixed_queue_length(p_ccb->xmit_hold_q)); in l2cu_get_next_channel_in_rr() 3615 size_t q_count = fixed_queue_length(p_ccb->xmit_hold_q); 3619 q_count += fixed_queue_length(p_ccb->p_lcb->ucd_out_sec_pending_q); 3643 fixed_queue_length(p_ccb->p_lcb->ucd_out_sec_pending_q), 3644 fixed_queue_length(p_ccb->xmit_hold_q), 3679 fixed_queue_length(p_ccb->p_lcb->ucd_out_sec_pending_q), 3680 fixed_queue_length(p_ccb->xmit_hold_q),
|
D | l2c_main.c | 1020 fixed_queue_length(p_ccb->xmit_hold_q), in l2c_data_write()
|
/device/soc/esp/esp32/components/bt/host/bluedroid/stack/rfcomm/ |
D | port_utils.c | 418 || (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM); in port_flow_control_user() 532 else if (fixed_queue_length(p_port->rx.queue) >= p_port->credit_rx_max) { in port_flow_control_peer() 545 && (fixed_queue_length(p_port->rx.queue) < PORT_RX_BUF_LOW_WM)) { in port_flow_control_peer() 564 || (fixed_queue_length(p_port->rx.queue) > PORT_RX_BUF_HIGH_WM)) in port_flow_control_peer()
|
D | port_api.c | 1170 count = fixed_queue_length(p_port->rx.queue); in PORT_Purge() 1395 || (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_CRITICAL_WM)){ in port_write() 1538 || (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) { in PORT_WriteDataCO() 1542 p_port->tx.queue_size, fixed_queue_length(p_port->tx.queue), available); in PORT_WriteDataCO() 1674 || (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM)) { in PORT_WriteData()
|
D | port_rfc.c | 851 || (fixed_queue_length(p_port->rx.queue) + 1 > p_port->rx_buf_critical)) { in PORT_DataInd()
|
/device/soc/esp/esp32/components/bt/host/bluedroid/btc/profile/std/spp/ |
D | btc_spp.c | 1028 if (fixed_queue_length(slot->tx.queue) <= SLOT_TX_QUEUE_LOW_WM) { in btc_spp_cb_handler() 1081 … if (slot->close_alarm == NULL && slot->rx.queue && fixed_queue_length(slot->rx.queue) > 0) { in btc_spp_cb_handler() 1166 fixed_queue_length(slot->rx.queue) > 0) { in btc_spp_cb_handler() 1242 size_t rx_len = fixed_queue_length(slot->rx.queue); in bta_co_rfc_data_incoming() 1248 } else if (fixed_queue_length(slot->rx.queue) > 2) { in bta_co_rfc_data_incoming() 1249 …RACE_DEBUG("%s data post stop! %d %d", __func__, slot->rfc_handle, fixed_queue_length(slot->rx.que… in bta_co_rfc_data_incoming() 1254 if (fixed_queue_length(slot->rx.queue) > 2) { in bta_co_rfc_data_incoming() 1255 …RACE_DEBUG("%s data post stop! %d %d", __func__, slot->rfc_handle, fixed_queue_length(slot->rx.que… in bta_co_rfc_data_incoming() 1328 tx_len = fixed_queue_length(slot->tx.queue); in spp_vfs_write() 1331 … BTC_TRACE_DEBUG("%s tx_len:%d, fd:%d\n", __func__, fixed_queue_length(slot->tx.queue), fd); in spp_vfs_write() [all …]
|
/device/soc/esp/esp32/components/bt/common/osi/include/osi/ |
D | fixed_queue.h | 56 size_t fixed_queue_length(fixed_queue_t *queue);
|
/device/soc/esp/esp32/components/bt/host/bluedroid/stack/gatt/ |
D | gatt_auth.c | 195 for (size_t count = fixed_queue_length(p_tcb->pending_enc_clcb); in gatt_enc_cmpl_cback() 238 size_t count = fixed_queue_length(p_tcb->pending_enc_clcb); in gatt_notify_enc_cmpl()
|
D | gatt_sr.c | 186 fixed_queue_length(p_cmd->multi_rsp_q), in process_read_multi_rsp() 189 if (fixed_queue_length(p_cmd->multi_rsp_q) == p_cmd->multi_req.num_handles) { in process_read_multi_rsp() 386 queue_num = fixed_queue_length(prepare_record->queue); in gatt_process_exec_write_req()
|
D | gatt_utils.c | 1458 … GATT_TRACE_DEBUG ("total buffer in db [%d]", fixed_queue_length(p_sreg->p_db->svc_buffer)); in gatt_sr_alloc_rcb()
|
/device/soc/esp/esp32/components/bt/common/osi/ |
D | fixed_queue.c | 109 size_t fixed_queue_length(fixed_queue_t *queue) in fixed_queue_length() function
|
D | thread.c | 277 return fixed_queue_length(thread->work_queues[wq_idx]); in osi_thread_queue_wait_size()
|
/device/soc/esp/esp32/components/bt/host/bluedroid/stack/btm/ |
D | btm_sco.c | 300 fixed_queue_length(p_ccb->xmit_data_q) + 1); in btm_sco_check_send_pkts() 443 if (fixed_queue_length(p_ccb->xmit_data_q) < BTM_SCO_XMIT_QUEUE_THRS) { in BTM_WriteScoData() 444 if (fixed_queue_length(p_ccb->xmit_data_q) >= BTM_SCO_XMIT_QUEUE_HIGH_WM) { in BTM_WriteScoData()
|