| /freebsd/sys/contrib/dev/athk/ath12k/wifi7/ |
| H A D | dp.c | 21 int budget) in ath12k_wifi7_dp_service_srng() argument
37 work_done = ath12k_wifi7_dp_rx_process_err(dp, napi, budget); in ath12k_wifi7_dp_service_srng()
38 budget -= work_done; in ath12k_wifi7_dp_service_srng()
40 if (budget <= 0) in ath12k_wifi7_dp_service_srng()
45 work_done = ath12k_wifi7_dp_rx_process_wbm_err(dp, napi, budget); in ath12k_wifi7_dp_service_srng()
46 budget -= work_done; in ath12k_wifi7_dp_service_srng()
49 if (budget <= 0) in ath12k_wifi7_dp_service_srng()
55 work_done = ath12k_wifi7_dp_rx_process(dp, i, napi, budget); in ath12k_wifi7_dp_service_srng()
56 budget -= work_done; in ath12k_wifi7_dp_service_srng()
58 if (budget <= 0) in ath12k_wifi7_dp_service_srng()
[all …]
|
| H A D | dp_rx.h | 16 struct napi_struct *napi, int budget);
18 int budget);
21 int budget);
|
| H A D | dp_mon.h | 15 struct napi_struct *napi, int budget,
|
| /freebsd/contrib/libdivsufsort/lib/ |
| H A D | trsort.c | 202 trbudget_init(trbudget_t *budget, saidx_t chance, saidx_t incval) { in trbudget_init() argument
203 budget->chance = chance; in trbudget_init()
204 budget->remain = budget->incval = incval; in trbudget_init()
209 trbudget_check(trbudget_t *budget, saidx_t size) { in trbudget_check() argument
210 if(size <= budget->remain) { budget->remain -= size; return 1; } in trbudget_check()
211 if(budget->chance == 0) { budget->count += size; return 0; } in trbudget_check()
212 budget->remain += budget->incval - size; in trbudget_check()
213 budget->chance -= 1; in trbudget_check()
329 trbudget_t *budget) { in tr_introsort() argument
402 if(trbudget_check(budget, a - first)) { in tr_introsort()
[all …]
|
| /freebsd/sys/contrib/dev/athk/ath11k/ |
| H A D | dp_rx.h | 68 int ath11k_dp_process_rxdma_err(struct ath11k_base *ab, int mac_id, int budget);
70 struct napi_struct *napi, int budget);
72 int budget);
75 int budget);
89 struct napi_struct *napi, int budget);
91 struct napi_struct *napi, int budget);
|
| H A D | dp.c | 789 int budget) in ath11k_dp_service_srng() argument
805 work_done = ath11k_dp_process_rx_err(ab, napi, budget); in ath11k_dp_service_srng()
806 budget -= work_done; in ath11k_dp_service_srng()
808 if (budget <= 0) in ath11k_dp_service_srng()
815 budget); in ath11k_dp_service_srng()
816 budget -= work_done; in ath11k_dp_service_srng()
819 if (budget <= 0) in ath11k_dp_service_srng()
826 budget); in ath11k_dp_service_srng()
827 budget -= work_done; in ath11k_dp_service_srng()
829 if (budget <= 0) in ath11k_dp_service_srng()
[all …]
|
| /freebsd/sys/ofed/drivers/infiniband/core/ |
| H A D | ib_cq.c | 52 static int __ib_process_cq(struct ib_cq *cq, int budget, struct ib_wc *wcs, in __ib_process_cq() argument
63 budget - completed), wcs)) > 0) { in __ib_process_cq()
75 if (n != batch || (budget != -1 && completed >= budget)) in __ib_process_cq()
96 int ib_process_cq_direct(struct ib_cq *cq, int budget) in ib_process_cq_direct() argument
100 return __ib_process_cq(cq, budget, wcs, IB_POLL_BATCH_DIRECT); in ib_process_cq_direct()
|
| /freebsd/sys/net/ |
| H A D | mp_ring.c | 93 drain_ring_locked(struct ifmp_ring *r, union ring_state os, uint16_t prev, int budget) in drain_ring_locked() argument
133 if (cidx != pidx && pending < 64 && total < budget) in drain_ring_locked()
138 ns.flags = state_to_flags(ns, total >= budget); in drain_ring_locked()
167 drain_ring_lockless(struct ifmp_ring *r, union ring_state os, uint16_t prev, int budget) in drain_ring_lockless() argument
212 if (cidx != pidx && pending < 64 && total < budget) in drain_ring_lockless()
219 ns.flags = state_to_flags(ns, total >= budget); in drain_ring_lockless()
318 ifmp_ring_enqueue(struct ifmp_ring *r, void **items, int n, int budget, int abdicate) in ifmp_ring_enqueue() argument
385 drain_ring_locked(r, ns, os.flags, budget); in ifmp_ring_enqueue()
393 ifmp_ring_enqueue(struct ifmp_ring *r, void **items, int n, int budget, int abdicate) in ifmp_ring_enqueue() argument
467 drain_ring_lockless(r, ns, os.flags, budget); in ifmp_ring_enqueue()
[all …]
|
| /freebsd/contrib/bzip2/ |
| H A D | blocksort.c | 352 Int32* budget ) in mainGtU() argument
464 (*budget)--; in mainGtU()
492 Int32* budget ) in mainSimpleSort() argument
515 ptr[j-h]+d, v+d, block, quadrant, nblock, budget in mainSimpleSort()
529 ptr[j-h]+d, v+d, block, quadrant, nblock, budget in mainSimpleSort()
543 ptr[j-h]+d, v+d, block, quadrant, nblock, budget in mainSimpleSort()
552 if (*budget < 0) return; in mainSimpleSort()
628 Int32* budget ) in mainQSort3() argument
651 mainSimpleSort ( ptr, block, quadrant, nblock, lo, hi, d, budget ); in mainQSort3()
652 if (*budget < 0) return; in mainQSort3()
[all …]
|
| /freebsd/sys/dev/cxgbe/ |
| H A D | t4_mp_ring.c | 51 * over its budget it sets flags to TOO_BUSY. A producer that observes a
76 TOO_BUSY, /* consumer is running and is beyond its budget */
115 drain_ring(struct mp_ring *r, int budget) in drain_ring() argument
176 MPASS(total >= budget); in drain_ring()
184 if (total >= budget) { in drain_ring()
227 drain_txpkts(struct mp_ring *r, union ring_state os, int budget) in drain_txpkts() argument
254 drain_ring(r, budget); in drain_txpkts()
343 mp_ring_enqueue(struct mp_ring *r, void **items, int n, int budget)
416 drain_ring(r, budget); in mp_ring_enqueue()
468 drain_ring(r, budget); in mp_ring_enqueue()
344 mp_ring_enqueue(struct mp_ring * r,void ** items,int n,int budget) mp_ring_enqueue() argument
476 mp_ring_check_drainage(struct mp_ring * r,int budget) mp_ring_check_drainage() argument
[all...] |
| /freebsd/sys/compat/linuxkpi/common/src/ |
| H A D | linux_netdev.c | 141 rc = napi->poll(napi, napi->budget); in lkpi___napi_schedule_dd()
146 if (rc >= napi->budget) in lkpi___napi_schedule_dd()
305 NAPI_TRACE_TASK(napi, pending, napi->budget); in lkpi_napi_task()
306 count = napi->poll(napi, napi->budget); in lkpi_napi_task()
315 if (count >= napi->budget) { in lkpi_napi_task()
335 napi->budget = NAPI_POLL_WEIGHT; in linuxkpi_netif_napi_add()
|
| /freebsd/sys/dev/bnxt/bnxt_re/ |
| H A D | qplib_fp.c | 337 int budget = nq->budget; in bnxt_qplib_service_nq() local
351 while (budget--) { in bnxt_qplib_service_nq()
434 nq->stats.num_dbqne_processed, budget, hw_polled); in bnxt_qplib_service_nq()
611 nq->budget = 8; in bnxt_qplib_alloc_nq_mem()
2640 struct bnxt_qplib_cqe **pcqe, int *budget) in __flush_sq() argument
2649 while (*budget) { in __flush_sq()
2673 (*budget)--; in __flush_sq()
2682 if (!*budget && sq->swq_last != start) in __flush_sq()
2691 struct bnxt_qplib_cqe **pcqe, int *budget) in __flush_rq() argument
2713 while (*budget) { in __flush_rq()
[all …]
|
| /freebsd/sys/dev/liquidio/base/ |
| H A D | lio_request_manager.c | 395 struct lio_instr_queue *iq, uint32_t budget) in lio_process_iq_request_list() argument
463 if ((budget) && (inst_count >= budget)) in lio_process_iq_request_list()
475 uint32_t budget) in lio_flush_iq() argument
493 if (budget) in lio_flush_iq()
496 budget - in lio_flush_iq()
509 } while (tot_inst_processed < budget); in lio_flush_iq()
511 if (budget && (tot_inst_processed >= budget)) in lio_flush_iq()
|
| H A D | lio_iq.h | 321 uint32_t budget);
340 uint32_t budget);
|
| /freebsd/sys/dev/ice/ |
| H A D | ice_iflib_recovery_txrx.c | 51 static int ice_recovery_rxd_available(void *arg, uint16_t rxqid, qidx_t pidx, qidx_t budget);
128 * @budget: maximum Rx budget
137 qidx_t __unused pidx, qidx_t __unused budget) in ice_recovery_rxd_available() argument
|
| /freebsd/sys/contrib/zstd/lib/dictBuilder/ |
| H A D | divsufsort.c | 1050 trbudget_init(trbudget_t *budget, int chance, int incval) { in trbudget_init() argument
1051 budget->chance = chance; in trbudget_init()
1052 budget->remain = budget->incval = incval; in trbudget_init()
1057 trbudget_check(trbudget_t *budget, int size) { in trbudget_check() argument
1058 if(size <= budget->remain) { budget->remain -= size; return 1; } in trbudget_check()
1059 if(budget->chance == 0) { budget->count += size; return 0; } in trbudget_check()
1060 budget->remain += budget->incval - size; in trbudget_check()
1061 budget->chance -= 1; in trbudget_check()
1177 trbudget_t *budget) { in tr_introsort() argument
1250 if(trbudget_check(budget, a - first)) { in tr_introsort()
[all …]
|
| /freebsd/sys/dev/mlx5/mlx5_fpga/ |
| H A D | mlx5fpga_xfer.c | 44 unsigned int budget; member
142 if (xfer_state->inflight_count >= xfer_state->budget) in exec_more()
229 xfer_state->budget = 7; in mlx5_fpga_xfer_exec()
|
| /freebsd/sys/contrib/dev/iwlwifi/mld/ |
| H A D | thermal.c | 285 u32 budget; in iwl_mld_config_ctdp() local
293 budget = ((mld->power_budget_mw - IWL_MLD_MIN_CTDP_BUDGET_MW) * in iwl_mld_config_ctdp()
297 cmd.budget = cpu_to_le32(budget); in iwl_mld_config_ctdp()
|
| /freebsd/sys/contrib/device-tree/Bindings/soc/fsl/cpm_qe/qe/ |
| H A D | usb.txt | 17 - hub-power-budget : USB power budget for the root hub, in mA.
|
| /freebsd/sys/dev/netmap/ |
| H A D | if_ptnet.c | 190 unsigned int budget,
218 static int ptnet_rx_eof(struct ptnet_queue *pq, unsigned int budget,
1368 ptnet_drain_transmit_queue(struct ptnet_queue *pq, unsigned int budget, in ptnet_drain_transmit_queue() argument
1414 while (count < budget) { in ptnet_drain_transmit_queue()
1553 if (count >= budget && may_resched) { in ptnet_drain_transmit_queue()
1669 ptnet_rx_eof(struct ptnet_queue *pq, unsigned int budget, bool may_resched) in ptnet_rx_eof() argument
1693 while (count < budget) { in ptnet_rx_eof()
1889 if (count >= budget && may_resched) { in ptnet_rx_eof()
1924 ptnet_poll(if_t ifp, enum poll_cmd cmd, int budget) in ptnet_poll() argument
1933 queue_budget = MAX(budget / sc->num_rings, 1); in ptnet_poll()
[all …]
|
| /freebsd/sys/contrib/zstd/lib/compress/ |
| H A D | zstd_compress_superblock.c | 446 size_t n, budget = 0, inSize=0; in sizeBlockSequences() local
450 budget += headerSize; in sizeBlockSequences()
453 budget += sp[0].litLength * avgLitCost + avgSeqCost; in sizeBlockSequences()
454 if (budget > targetBudget) return 1; in sizeBlockSequences()
460 budget += currentCost; in sizeBlockSequences()
463 if ( (budget > targetBudget) in sizeBlockSequences()
465 && (budget < inSize * BYTESCALE) ) in sizeBlockSequences()
|
| /freebsd/sys/contrib/openzfs/module/zstd/lib/compress/ |
| H A D | zstd_compress_superblock.c | 447 size_t n, budget = 0, inSize=0; in sizeBlockSequences() local
451 budget += headerSize; in sizeBlockSequences()
454 budget += sp[0].litLength * avgLitCost + avgSeqCost; in sizeBlockSequences()
455 if (budget > targetBudget) return 1; in sizeBlockSequences()
461 budget += currentCost; in sizeBlockSequences()
464 if ( (budget > targetBudget) in sizeBlockSequences()
466 && (budget < inSize * BYTESCALE) ) in sizeBlockSequences()
|
| /freebsd/sys/contrib/dev/mediatek/mt76/mt7615/ |
| H A D | dma.c | 66 static int mt7615_poll_tx(struct napi_struct *napi, int budget) in mt7615_poll_tx() argument
87 static int mt7615_poll_rx(struct napi_struct *napi, int budget) in mt7615_poll_rx() argument
99 done = mt76_dma_rx_poll(napi, budget); in mt7615_poll_rx()
|
| /freebsd/sys/dev/ena/ |
| H A D | ena_datapath.c | 251 int budget = ENA_TX_BUDGET; in ena_tx_cleanup() local
303 } while (likely(--budget)); in ena_tx_cleanup()
306 tx_ring->qid, ENA_TX_BUDGET - budget); in ena_tx_cleanup()
338 return (budget == 0); in ena_tx_cleanup()
574 int budget = (ENA_RX_DESC_BUDGET == -1) ? INT_MAX : ENA_RX_DESC_BUDGET; in ena_rx_cleanup() local
683 budget -= ena_rx_ctx.descs; in ena_rx_cleanup()
684 } while (budget > 0); in ena_rx_cleanup()
706 return (budget <= 0); in ena_rx_cleanup()
|
| /freebsd/sys/contrib/dev/iwlwifi/pcie/gen1_2/ |
| H A D | rx.c | 998 static int iwl_pcie_rx_handle(struct iwl_trans *trans, int queue, int budget);
1005 static int iwl_pcie_napi_poll(struct napi_struct *napi, int budget) in iwl_pcie_napi_poll() argument
1015 ret = iwl_pcie_rx_handle(trans, rxq->id, budget); in iwl_pcie_napi_poll()
1018 rxq->id, ret, budget); in iwl_pcie_napi_poll()
1020 if (ret < budget) { in iwl_pcie_napi_poll()
1032 static int iwl_pcie_napi_poll_msix(struct napi_struct *napi, int budget) in iwl_pcie_napi_poll_msix() argument
1042 ret = iwl_pcie_rx_handle(trans, rxq->id, budget); in iwl_pcie_napi_poll_msix()
1044 budget); in iwl_pcie_napi_poll_msix()
1046 if (ret < budget) { in iwl_pcie_napi_poll_msix()
1498 static int iwl_pcie_rx_handle(struct iwl_trans *trans, int queue, int budget) in iwl_pcie_rx_handle() argument
[all …]
|