Lines Matching refs:pq

113 _dhd_wlfc_prec_enque(struct pktq *pq, int prec, void* p, bool qHead,  in _dhd_wlfc_prec_enque()  argument
123 ASSERT(prec >= 0 && prec < pq->num_prec); in _dhd_wlfc_prec_enque()
126 ASSERT(!pktq_full(pq)); in _dhd_wlfc_prec_enque()
127 ASSERT(!pktqprec_full(pq, prec)); in _dhd_wlfc_prec_enque()
129 q = &pq->q[prec]; in _dhd_wlfc_prec_enque()
185 pq->n_pkts_tot++; in _dhd_wlfc_prec_enque()
187 if (pq->hi_prec < prec) in _dhd_wlfc_prec_enque()
188 pq->hi_prec = (uint8)prec; in _dhd_wlfc_prec_enque()
428 struct pktq *pq; in _dhd_wlfc_deque_afq() local
450 pq = &entry->afq; in _dhd_wlfc_deque_afq()
452 ASSERT(prec < pq->num_prec); in _dhd_wlfc_deque_afq()
454 q = &pq->q[prec]; in _dhd_wlfc_deque_afq()
495 pq->n_pkts_tot--; in _dhd_wlfc_deque_afq()
755 _dhd_wlfc_prec_enq_with_drop(dhd_pub_t *dhdp, struct pktq *pq, void *pkt, int prec, bool qHead, in _dhd_wlfc_prec_enq_with_drop() argument
762 ASSERT(dhdp && pq && pkt); in _dhd_wlfc_prec_enq_with_drop()
763 ASSERT(prec >= 0 && prec < pq->num_prec); in _dhd_wlfc_prec_enq_with_drop()
770 if (!pktqprec_full(pq, prec) && !pktq_full(pq)) { in _dhd_wlfc_prec_enq_with_drop()
775 if (pktqprec_full(pq, prec)) { in _dhd_wlfc_prec_enq_with_drop()
777 } else if (pktq_full(pq)) { in _dhd_wlfc_prec_enq_with_drop()
778 p = pktq_peek_tail(pq, &eprec); in _dhd_wlfc_prec_enq_with_drop()
784 if (!pktqprec_empty(pq, prec)) { in _dhd_wlfc_prec_enq_with_drop()
795 ASSERT(!pktqprec_empty(pq, eprec)); in _dhd_wlfc_prec_enq_with_drop()
797 dhd_prec_drop_pkts(dhdp, pq, eprec, _dhd_wlfc_prec_drop); in _dhd_wlfc_prec_enq_with_drop()
802 _dhd_wlfc_prec_enque(pq, prec, pkt, qHead, current_seq, in _dhd_wlfc_prec_enq_with_drop()
927 _dhd_wlfc_flow_control_check(athost_wl_status_info_t* ctx, struct pktq* pq, uint8 if_id) in _dhd_wlfc_flow_control_check() argument
942 if ((pq->n_pkts_tot <= WLFC_FLOWCONTROL_LOWATER) && (ctx->hostif_flow_state[if_id] == ON)) { in _dhd_wlfc_flow_control_check()
956 if (pq->n_pkts_tot >= WLFC_FLOWCONTROL_HIWATER && ctx->hostif_flow_state[if_id] == OFF) { in _dhd_wlfc_flow_control_check()
1525 _dhd_wlfc_pktq_flush(athost_wl_status_info_t* ctx, struct pktq *pq, in _dhd_wlfc_pktq_flush() argument
1536 if (pq->n_pkts_tot == 0) { in _dhd_wlfc_pktq_flush()
1540 for (prec = 0; prec < pq->num_prec; prec++) { in _dhd_wlfc_pktq_flush()
1544 q = &pq->q[prec]; in _dhd_wlfc_pktq_flush()
1602 pq->n_pkts_tot--; in _dhd_wlfc_pktq_flush()
1622 ASSERT(pq->n_pkts_tot == 0); in _dhd_wlfc_pktq_flush()
1627 _dhd_wlfc_pktq_pdeq_with_fn(struct pktq *pq, int prec, f_processpkt_t fn, void *arg) in _dhd_wlfc_pktq_pdeq_with_fn() argument
1632 ASSERT(prec >= 0 && prec < pq->num_prec); in _dhd_wlfc_pktq_pdeq_with_fn()
1634 q = &pq->q[prec]; in _dhd_wlfc_pktq_pdeq_with_fn()
1663 pq->n_pkts_tot--; in _dhd_wlfc_pktq_pdeq_with_fn()
2121 struct pktq *pq; in dhd_wlfc_suppressed_acked_update() local
2144 pq = &entry->psq; in dhd_wlfc_suppressed_acked_update()
2146 ASSERT(((prec << 1) + 1) < pq->num_prec); in dhd_wlfc_suppressed_acked_update()
2148 q = &pq->q[((prec << 1) + 1)]; in dhd_wlfc_suppressed_acked_update()
2183 pq->n_pkts_tot--; in dhd_wlfc_suppressed_acked_update()