/linux-master/drivers/net/ethernet/pensando/ionic/ |
H A D | ionic_txrx.c | 930 int ionic_tx_napi(struct napi_struct *napi, int budget) argument 937 work_done = ionic_tx_cq_service(cq, budget); 939 if (unlikely(!budget)) 940 return budget; 942 if (work_done < budget && napi_complete_done(napi, work_done)) { 969 int ionic_rx_napi(struct napi_struct *napi, int budget) argument 976 if (unlikely(!budget)) 977 return budget; 979 work_done = ionic_cq_service(cq, budget, 985 if (work_done < budget 1004 ionic_txrx_napi(struct napi_struct *napi, int budget) argument [all...] |
/linux-master/drivers/net/ethernet/intel/iavf/ |
H A D | iavf_txrx.c | 211 * Returns true if there's any budget left (e.g. the clean is finished) 220 unsigned int budget = IAVF_DEFAULT_IRQ_WORK; local 298 /* update budget accounting */ 299 budget--; 300 } while (likely(budget)); 319 if (budget && 346 return !!budget; 1128 * @budget: Total limit on number of packets to process 1137 static int iavf_clean_rx_irq(struct iavf_ring *rx_ring, int budget) argument 1144 while (likely(total_rx_packets < (unsigned int)budget)) { 1363 iavf_napi_poll(struct napi_struct *napi, int budget) argument [all...] |
/linux-master/drivers/net/ethernet/mellanox/mlx4/ |
H A D | en_rx.c | 414 * this cache when it is sized to be a multiple of the napi budget. 714 int mlx4_en_process_rx_cq(struct net_device *dev, struct mlx4_en_cq *cq, int budget) argument 728 if (unlikely(!priv->port_up || budget <= 0)) 962 if (unlikely(++polled == budget)) 998 int mlx4_en_poll_rx_cq(struct napi_struct *napi, int budget) argument 1007 if (!budget) 1014 budget) < budget; 1019 done = mlx4_en_process_rx_cq(dev, cq, budget); 1022 if (done == budget || !clean_complet [all...] |
/linux-master/drivers/net/ethernet/netronome/nfp/ |
H A D | nfp_net_dp.h | 142 int (*poll)(struct napi_struct *napi, int budget); 143 int (*xsk_poll)(struct napi_struct *napi, int budget);
|
/linux-master/drivers/net/ethernet/cavium/liquidio/ |
H A D | octeon_droq.c | 745 u32 budget) 756 if (pkt_count > budget) 757 pkt_count = budget; 787 struct octeon_droq *droq, u32 budget) 793 if (budget > droq->max_count) 794 budget = droq->max_count; 796 while (total_pkts_processed < budget) { 799 pkts_available = min((budget - total_pkts_processed), 743 octeon_droq_process_packets(struct octeon_device *oct, struct octeon_droq *droq, u32 budget) argument 786 octeon_droq_process_poll_pkts(struct octeon_device *oct, struct octeon_droq *droq, u32 budget) argument
|
/linux-master/drivers/net/ethernet/fungible/funeth/ |
H A D | funeth_rx.c | 477 * budget. Return the remaining budget. 479 static int fun_process_cqes(struct funeth_rxq *q, int budget) argument 488 while (budget && !cqe_phase_mismatch(q->next_cqe_info, q->phase)) { 493 budget--; 504 return budget; 510 int fun_rxq_napi_poll(struct napi_struct *napi, int budget) argument 514 int work_done = budget - fun_process_cqes(q, budget); 517 if (unlikely(work_done >= budget)) [all...] |
H A D | funeth_txrx.h | 139 u64 rx_budget; /* NAPI iterations that exhausted their budget */ 247 int fun_rxq_napi_poll(struct napi_struct *napi, int budget); 248 int fun_txq_napi_poll(struct napi_struct *napi, int budget);
|
/linux-master/drivers/net/ethernet/mscc/ |
H A D | ocelot_fdma.c | 389 static int ocelot_fdma_rx_get(struct ocelot *ocelot, int budget) argument 405 while (budget--) { 481 static void ocelot_fdma_tx_cleanup(struct ocelot *ocelot, int budget) argument 510 napi_consume_skb(skb, budget); 551 static int ocelot_fdma_napi_poll(struct napi_struct *napi, int budget) argument 558 ocelot_fdma_tx_cleanup(ocelot, budget); 562 work_done = ocelot_fdma_rx_get(ocelot, budget); 567 if (work_done < budget) {
|
/linux-master/drivers/net/ethernet/arc/ |
H A D | emac_main.c | 168 * @budget: How many BDs to process on 1 call. 174 static int arc_emac_rx(struct net_device *ndev, int budget) argument 179 for (work_done = 0; work_done < budget; work_done++) { 289 * @budget: How many BDs requested to process on 1 call. 298 int budget, unsigned int work_done) 306 if (priv->rx_missed_errors && budget) { 318 * @budget: How many BDs to process on 1 call. 322 static int arc_emac_poll(struct napi_struct *napi, int budget) argument 331 work_done = arc_emac_rx(ndev, budget); 332 if (work_done < budget) { 297 arc_emac_rx_stall_check(struct net_device *ndev, int budget, unsigned int work_done) argument [all...] |
/linux-master/drivers/net/ethernet/marvell/octeon_ep_vf/ |
H A D | octep_vf_main.h | 328 int octep_vf_iq_process_completions(struct octep_vf_iq *iq, u16 budget); 329 int octep_vf_oq_process_rx(struct octep_vf_oq *oq, int budget);
|
H A D | octep_vf_rx.c | 471 * @budget: max number of packets can be processed in one invocation. 474 * Keeps checking for new packets until budget is used or no new packets seen. 478 int octep_vf_oq_process_rx(struct octep_vf_oq *oq, int budget) argument 486 while (total_pkts_processed < budget) { 490 pkts_available = min(budget - total_pkts_processed,
|
/linux-master/drivers/net/ethernet/apm/xgene-v2/ |
H A D | main.c | 285 static int xge_rx_poll(struct net_device *ndev, unsigned int budget) argument 306 for (i = 0; i < budget; i++) { 510 static int xge_napi(struct napi_struct *napi, const int budget) argument 519 processed = xge_rx_poll(ndev, budget); 521 if (processed < budget) {
|
/linux-master/drivers/net/ethernet/ti/ |
H A D | cpsw_priv.h | 328 int budget; member in struct:cpsw_vector 455 int cpsw_tx_mq_poll(struct napi_struct *napi_tx, int budget); 456 int cpsw_tx_poll(struct napi_struct *napi_tx, int budget); 457 int cpsw_rx_mq_poll(struct napi_struct *napi_rx, int budget); 458 int cpsw_rx_poll(struct napi_struct *napi_rx, int budget);
|
/linux-master/block/ |
H A D | bfq-iosched.c | 27 * budget. This change from the time to the service domain enables BFQ 179 /* Default maximum budget values, in sectors and number of requests. */ 1059 * has enough budget to serve at least its first request (if the 1061 * budget for its first request, it has to go through two dispatch 1085 if (entity->budget != new_budget) { 1086 entity->budget = new_budget; 1087 bfq_log_bfqq(bfqd, bfqq, "updated next rq: new budget %lu", 1452 return entity->budget - entity->service; 1456 * If enough samples have been computed, return the current max budget 1458 * estimated disk peak rate; otherwise return the default max budget 3965 int budget, min_budget; local [all...] |
H A D | bfq-wf2q.c | 146 * Returns true if this budget changes may let next_in_service->parent 166 if (bfqg_entity->budget > next_in_service->budget) 168 bfqg_entity->budget = next_in_service->budget; 818 * If a queue does not consume its budget fast enough, then providing 820 * severely. For this reason, queues that consume their budget slowly 847 /* Increase budget to avoid inconsistencies */ 848 if (tot_serv_to_charge > entity->budget) 849 entity->budget [all...] |
/linux-master/drivers/net/ethernet/ti/icssg/ |
H A D | icssg_common.c | 125 int budget, bool *tdown) 169 napi_consume_skb(skb, budget); 203 static int emac_napi_tx_poll(struct napi_struct *napi_tx, int budget) argument 210 num_tx_packets = emac_tx_complete_packets(emac, tx_chn->id, budget, 213 if (num_tx_packets >= budget) 214 return budget; 871 int emac_napi_rx_poll(struct napi_struct *napi_rx, int budget) argument 883 cur_budget = budget - num_rx; 892 if (num_rx >= budget) 896 if (num_rx < budget 124 emac_tx_complete_packets(struct prueth_emac *emac, int chn, int budget, bool *tdown) argument [all...] |
/linux-master/drivers/net/ethernet/google/gve/ |
H A D | gve_tx.c | 947 int budget) 954 while (sent < budget) { 977 bool gve_xdp_poll(struct gve_notify_block *block, int budget) argument 987 to_do = min_t(u32, (nic_done - tx->done), budget); 992 int sent = gve_xsk_tx(priv, tx, budget); 997 repoll |= (sent == budget); 1006 bool gve_tx_poll(struct gve_notify_block *block, int budget) argument 1013 /* If budget is 0, do all the work */ 1014 if (budget == 0) 1015 budget 946 gve_xsk_tx(struct gve_priv *priv, struct gve_tx_ring *tx, int budget) argument [all...] |
/linux-master/drivers/net/ethernet/chelsio/cxgb4vf/ |
H A D | sge.c | 1744 * @budget: how many responses can be processed in this round 1747 * the supplied budget. Responses include received packets as well as 1754 static int process_responses(struct sge_rspq *rspq, int budget) argument 1759 int budget_left = budget; 1871 return budget - budget_left; 1877 * @budget: how many packets we can process in this round 1885 static int napi_rx_handler(struct napi_struct *napi, int budget) argument 1889 int work_done = process_responses(rspq, budget); 1892 if (likely(work_done < budget)) { 2126 unsigned int i, budget; local [all...] |
/linux-master/drivers/net/ethernet/marvell/octeontx2/nic/ |
H A D | otx2_txrx.c | 137 int budget, int *tx_pkts, int *tx_bytes) 172 napi_consume_skb(skb, budget); 393 struct otx2_cq_queue *cq, int budget) 399 if (cq->pend_cqe >= budget) 406 while (likely(processed_cqe < budget) && cq->pend_cqe) { 451 struct otx2_cq_queue *cq, int budget) 458 if (cq->pend_cqe >= budget) 468 while (likely(processed_cqe < budget) && cq->pend_cqe) { 482 cqe, budget, &tx_pkts, &tx_bytes); 533 int otx2_napi_handler(struct napi_struct *napi, int budget) argument 133 otx2_snd_pkt_handler(struct otx2_nic *pfvf, struct otx2_cq_queue *cq, struct otx2_snd_queue *sq, struct nix_cqe_tx_s *cqe, int budget, int *tx_pkts, int *tx_bytes) argument 391 otx2_rx_napi_handler(struct otx2_nic *pfvf, struct napi_struct *napi, struct otx2_cq_queue *cq, int budget) argument 450 otx2_tx_napi_handler(struct otx2_nic *pfvf, struct otx2_cq_queue *cq, int budget) argument [all...] |
/linux-master/drivers/net/ethernet/engleder/ |
H A D | tsnep_main.c | 816 int budget = 128; local 883 budget--; 884 } while (likely(budget)); 901 return budget != 0; 1428 int budget) 1453 while (likely(done < budget) && (rx->read != rx->write)) { 1534 int budget) 1554 while (likely(done < budget) && (rx->read != rx->write)) { 1645 return desc_available ? budget : done; 1800 static int tsnep_poll(struct napi_struct *napi, int budget) argument 1427 tsnep_rx_poll(struct tsnep_rx *rx, struct napi_struct *napi, int budget) argument 1533 tsnep_rx_poll_zc(struct tsnep_rx *rx, struct napi_struct *napi, int budget) argument [all...] |
/linux-master/drivers/net/wireless/mediatek/mt76/ |
H A D | dma.c | 830 mt76_dma_rx_process(struct mt76_dev *dev, struct mt76_queue *q, int budget) argument 845 while (done < budget) { 914 int mt76_dma_rx_poll(struct napi_struct *napi, int budget) argument 925 cur = mt76_dma_rx_process(dev, &dev->q_rx[qid], budget - done); 928 } while (cur && done < budget); 932 if (done < budget && napi_complete(napi)) 941 int (*poll)(struct napi_struct *napi, int budget)) 940 mt76_dma_init(struct mt76_dev *dev, int (*poll)(struct napi_struct *napi, int budget)) argument
|
/linux-master/drivers/net/ethernet/freescale/dpaa2/ |
H A D | dpaa2-xsk.c | 396 int budget = DPAA2_ETH_TX_ZC_PER_NAPI; local 410 batch = xsk_tx_peek_release_desc_batch(ch->xsk_pool, budget); 453 return total_enqueued == budget;
|
/linux-master/drivers/net/wan/ |
H A D | lapbether.c | 88 static int lapbeth_napi_poll(struct napi_struct *napi, int budget) argument 95 for (; processed < budget; ++processed) { 102 if (processed < budget)
|
/linux-master/drivers/net/ethernet/marvell/octeon_ep/ |
H A D | octep_rx.c | 471 * @budget: max number of packets can be processed in one invocation. 474 * Keeps checking for new packets until budget is used or no new packets seen. 478 int octep_oq_process_rx(struct octep_oq *oq, int budget) argument 486 while (total_pkts_processed < budget) { 490 pkts_available = min(budget - total_pkts_processed,
|
/linux-master/drivers/net/ethernet/netronome/nfp/nfdk/ |
H A D | dp.c | 469 * @budget: NAPI budget (only used as bool to determine if in NAPI context) 471 static void nfp_nfdk_tx_complete(struct nfp_net_tx_ring *tx_ring, int budget) argument 538 napi_consume_skb(skb, budget); 1017 * nfp_nfdk_rx() - receive up to @budget packets on @rx_ring 1019 * @budget: NAPI budget 1027 static int nfp_nfdk_rx(struct nfp_net_rx_ring *rx_ring, int budget) argument 1046 while (pkts_polled < budget) { 1252 pkts_polled = budget; 1265 nfp_nfdk_poll(struct napi_struct *napi, int budget) argument 1559 unsigned int budget = 512; local [all...] |