| /Linux-v4.19/net/sched/ |
| D | sch_generic.c | 54 const struct netdev_queue *txq = q->dev_queue; in __skb_dequeue_bad_txq()
222 const struct netdev_queue *txq = q->dev_queue; in dequeue_skb()
572 .dev_queue = &noop_netdev_queue,
803 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue, in qdisc_alloc() argument
813 if (!dev_queue) { in qdisc_alloc()
819 dev = dev_queue->dev; in qdisc_alloc()
821 netdev_queue_numa_node_read(dev_queue)); in qdisc_alloc()
830 netdev_queue_numa_node_read(dev_queue)); in qdisc_alloc()
871 sch->dev_queue = dev_queue; in qdisc_alloc()
882 struct Qdisc *qdisc_create_dflt(struct netdev_queue *dev_queue, in qdisc_create_dflt() argument
[all …]
|
| D | sch_mq.c | 77 struct netdev_queue *dev_queue; in mq_init() local
94 dev_queue = netdev_get_tx_queue(dev, ntx); in mq_init()
95 qdisc = qdisc_create_dflt(dev_queue, get_default_qdisc_ops(dev, ntx), in mq_init()
120 old = dev_graft_qdisc(qdisc->dev_queue, qdisc); in mq_attach()
198 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_graft() local
204 *old = dev_graft_qdisc(dev_queue, new); in mq_graft()
214 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_leaf() local
216 return dev_queue->qdisc_sleeping; in mq_leaf()
231 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_dump_class() local
235 tcm->tcm_info = dev_queue->qdisc_sleeping->handle; in mq_dump_class()
[all …]
|
| D | sch_mqprio.c | 140 struct netdev_queue *dev_queue; in mqprio_init() local
229 dev_queue = netdev_get_tx_queue(dev, i); in mqprio_init()
230 qdisc = qdisc_create_dflt(dev_queue, in mqprio_init()
301 old = dev_graft_qdisc(qdisc->dev_queue, qdisc); in mqprio_attach()
326 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); in mqprio_graft() local
328 if (!dev_queue) in mqprio_graft()
334 *old = dev_graft_qdisc(dev_queue, new); in mqprio_graft()
462 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); in mqprio_leaf() local
464 if (!dev_queue) in mqprio_leaf()
467 return dev_queue->qdisc_sleeping; in mqprio_leaf()
[all …]
|
| D | sch_api.c | 967 struct netdev_queue *dev_queue = dev_ingress_queue(dev); in qdisc_graft() local
970 dev_queue = netdev_get_tx_queue(dev, i); in qdisc_graft()
972 old = dev_graft_qdisc(dev_queue, new); in qdisc_graft()
1067 struct netdev_queue *dev_queue, in qdisc_create() argument
1113 sch = qdisc_alloc(dev_queue, ops, extack); in qdisc_create()
1562 struct netdev_queue *dev_queue; in tc_modify_qdisc() local
1565 dev_queue = p->ops->cl_ops->select_queue(p, tcm); in tc_modify_qdisc()
1567 dev_queue = p->dev_queue; in tc_modify_qdisc()
1569 dev_queue = netdev_get_tx_queue(dev, 0); in tc_modify_qdisc()
1571 q = qdisc_create(dev, dev_queue, p, in tc_modify_qdisc()
[all …]
|
| D | sch_plug.c | 191 netif_schedule_queue(sch->dev_queue); in plug_change()
199 netif_schedule_queue(sch->dev_queue); in plug_change()
|
| D | sch_cbs.c | 355 q->qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in cbs_init()
362 q->queue = sch->dev_queue - netdev_get_tx_queue(dev, 0); in cbs_init()
431 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in cbs_graft()
|
| D | sch_fifo.c | 175 q = qdisc_create_dflt(sch->dev_queue, ops, TC_H_MAKE(sch->handle, 1), in fifo_create_dflt()
|
| D | sch_dsmark.c | 73 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in dsmark_graft()
384 p->q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, sch->handle, in dsmark_init()
|
| D | sch_drr.c | 122 cl->qdisc = qdisc_create_dflt(sch->dev_queue, in drr_change_class()
222 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in drr_graft_class()
|
| D | sch_atm.c | 293 flow->q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, classid, in atm_tc_change()
549 p->link.q = qdisc_create_dflt(sch->dev_queue, in atm_tc_init()
|
| D | sch_multiq.c | 216 child = qdisc_create_dflt(sch->dev_queue, in multiq_tune()
|
| D | sch_hfsc.c | 1065 cl->qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in hfsc_change_class()
1187 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in hfsc_graft_class()
1418 q->root.qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in hfsc_init_qdisc()
|
| D | sch_htb.c | 1171 (new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in htb_graft()
1280 new_q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in htb_delete()
1418 new_q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in htb_change_class()
|
| D | sch_etf.c | 349 q->queue = sch->dev_queue - netdev_get_tx_queue(dev, 0); in etf_init()
|
| D | sch_prio.c | 203 queues[i] = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in prio_tune()
|
| D | sch_cbq.c | 1178 q->link.q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in cbq_init()
1383 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in cbq_graft()
1621 cl->q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, classid, in cbq_change_class()
|
| /Linux-v4.19/include/linux/ |
| D | netdevice.h | 3001 static __always_inline void netif_tx_start_queue(struct netdev_queue *dev_queue) in netif_tx_start_queue() argument
3003 clear_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_start_queue()
3027 void netif_tx_wake_queue(struct netdev_queue *dev_queue);
3051 static __always_inline void netif_tx_stop_queue(struct netdev_queue *dev_queue) in netif_tx_stop_queue() argument
3053 set_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_stop_queue()
3070 static inline bool netif_tx_queue_stopped(const struct netdev_queue *dev_queue) in netif_tx_queue_stopped() argument
3072 return test_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_queue_stopped()
3086 static inline bool netif_xmit_stopped(const struct netdev_queue *dev_queue) in netif_xmit_stopped() argument
3088 return dev_queue->state & QUEUE_STATE_ANY_XOFF; in netif_xmit_stopped()
3092 netif_xmit_frozen_or_stopped(const struct netdev_queue *dev_queue) in netif_xmit_frozen_or_stopped() argument
[all …]
|
| /Linux-v4.19/include/net/ |
| D | sch_generic.h | 86 struct netdev_queue *dev_queue; member
424 struct Qdisc *q = rcu_dereference_rtnl(qdisc->dev_queue->qdisc); in qdisc_root()
431 return qdisc->dev_queue->qdisc_sleeping; in qdisc_root_sleeping()
471 return qdisc->dev_queue->dev; in qdisc_dev()
554 struct Qdisc *dev_graft_qdisc(struct netdev_queue *dev_queue,
560 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue,
564 struct Qdisc *qdisc_create_dflt(struct netdev_queue *dev_queue,
|
| D | pkt_sched.h | 146 return dev_net(q->dev_queue->dev); in qdisc_net()
|
| D | pkt_cls.h | 70 return tcf_block_q(block)->dev_queue->dev; in tcf_block_dev()
|
| /Linux-v4.19/drivers/net/ethernet/hisilicon/hns/ |
| D | hns_enet.c | 318 struct netdev_queue *dev_queue; in hns_nic_net_xmit_hw() local
369 dev_queue = netdev_get_tx_queue(ndev, skb->queue_mapping); in hns_nic_net_xmit_hw()
370 netdev_tx_sent_queue(dev_queue, skb->len); in hns_nic_net_xmit_hw()
972 struct netdev_queue *dev_queue; in hns_nic_tx_poll_one() local
1005 dev_queue = netdev_get_tx_queue(ndev, ring_data->queue_index); in hns_nic_tx_poll_one()
1006 netdev_tx_completed_queue(dev_queue, pkts, bytes); in hns_nic_tx_poll_one()
1017 if (netif_tx_queue_stopped(dev_queue) && in hns_nic_tx_poll_one()
1019 netif_tx_wake_queue(dev_queue); in hns_nic_tx_poll_one()
1060 struct netdev_queue *dev_queue; in hns_nic_tx_clr_all_bufs() local
1074 dev_queue = netdev_get_tx_queue(ndev, ring_data->queue_index); in hns_nic_tx_clr_all_bufs()
[all …]
|
| D | hns_ethtool.c | 377 struct netdev_queue *dev_queue; in __lb_other_process() local
408 dev_queue = netdev_get_tx_queue(ndev, ring_data->queue_index); in __lb_other_process()
409 netdev_tx_reset_queue(dev_queue); in __lb_other_process()
|
| /Linux-v4.19/drivers/net/ethernet/hisilicon/hns3/ |
| D | hns3_enet.c | 1089 struct netdev_queue *dev_queue; in hns3_nic_net_xmit() local
1160 dev_queue = netdev_get_tx_queue(netdev, ring_data->queue_index); in hns3_nic_net_xmit()
1161 netdev_tx_sent_queue(dev_queue, skb->len); in hns3_nic_net_xmit()
1918 struct netdev_queue *dev_queue; in hns3_clean_tx_ring() local
1955 dev_queue = netdev_get_tx_queue(netdev, ring->tqp->tqp_index); in hns3_clean_tx_ring()
1956 netdev_tx_completed_queue(dev_queue, pkts, bytes); in hns3_clean_tx_ring()
1964 if (netif_tx_queue_stopped(dev_queue)) { in hns3_clean_tx_ring()
1965 netif_tx_wake_queue(dev_queue); in hns3_clean_tx_ring()
3365 struct netdev_queue *dev_queue; in hns3_clear_all_ring() local
3370 dev_queue = netdev_get_tx_queue(ndev, in hns3_clear_all_ring()
[all …]
|
| /Linux-v4.19/drivers/net/xen-netback/ |
| D | xenbus.c | 59 struct netdev_queue *dev_queue; in xenvif_read_io_ring() local
120 dev_queue = netdev_get_tx_queue(queue->vif->dev, queue->id); in xenvif_read_io_ring()
125 netif_tx_queue_stopped(dev_queue) ? "stopped" : "running"); in xenvif_read_io_ring()
|
| /Linux-v4.19/drivers/net/ethernet/myricom/myri10ge/ |
| D | myri10ge.c | 1392 struct netdev_queue *dev_queue; in myri10ge_tx_done() local
1427 dev_queue = netdev_get_tx_queue(ss->dev, ss - ss->mgp->ss); in myri10ge_tx_done()
1438 __netif_tx_trylock(dev_queue)) { in myri10ge_tx_done()
1445 __netif_tx_unlock(dev_queue); in myri10ge_tx_done()
1449 if (netif_tx_queue_stopped(dev_queue) && in myri10ge_tx_done()
1453 netif_tx_wake_queue(dev_queue); in myri10ge_tx_done()
|
