| /linux-4.4.14/net/sched/ |
| D | sch_generic.c | 86 const struct netdev_queue *txq = q->dev_queue; in dequeue_skb()
112 struct netdev_queue *dev_queue, in handle_dev_cpu_collision() argument
117 if (unlikely(dev_queue->xmit_lock_owner == smp_processor_id())) { in handle_dev_cpu_collision()
126 dev_queue->dev->name); in handle_dev_cpu_collision()
417 .dev_queue = &noop_netdev_queue,
576 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue, in qdisc_alloc() argument
583 struct net_device *dev = dev_queue->dev; in qdisc_alloc()
586 netdev_queue_numa_node_read(dev_queue)); in qdisc_alloc()
595 netdev_queue_numa_node_read(dev_queue)); in qdisc_alloc()
611 sch->dev_queue = dev_queue; in qdisc_alloc()
[all …]
|
| D | sch_mq.c | 42 struct netdev_queue *dev_queue; in mq_init() local
59 dev_queue = netdev_get_tx_queue(dev, ntx); in mq_init()
60 qdisc = qdisc_create_dflt(dev_queue, default_qdisc_ops, in mq_init()
86 old = dev_graft_qdisc(qdisc->dev_queue, qdisc); in mq_attach()
138 struct netdev_queue *dev_queue = mq_queue_get(sch, ntx); in mq_select_queue() local
140 if (!dev_queue) { in mq_select_queue()
145 return dev_queue; in mq_select_queue()
151 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_graft() local
157 *old = dev_graft_qdisc(dev_queue, new); in mq_graft()
167 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_leaf() local
[all …]
|
| D | sch_mqprio.c | 96 struct netdev_queue *dev_queue; in mqprio_init() local
126 dev_queue = netdev_get_tx_queue(dev, i); in mqprio_init()
127 qdisc = qdisc_create_dflt(dev_queue, default_qdisc_ops, in mqprio_init()
176 old = dev_graft_qdisc(qdisc->dev_queue, qdisc); in mqprio_attach()
201 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); in mqprio_graft() local
203 if (!dev_queue) in mqprio_graft()
209 *old = dev_graft_qdisc(dev_queue, new); in mqprio_graft()
266 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); in mqprio_leaf() local
268 if (!dev_queue) in mqprio_leaf()
271 return dev_queue->qdisc_sleeping; in mqprio_leaf()
[all …]
|
| D | sch_api.c | 833 struct netdev_queue *dev_queue = dev_ingress_queue(dev); in qdisc_graft() local
836 dev_queue = netdev_get_tx_queue(dev, i); in qdisc_graft()
838 old = dev_graft_qdisc(dev_queue, new); in qdisc_graft()
891 qdisc_create(struct net_device *dev, struct netdev_queue *dev_queue, in qdisc_create() argument
934 sch = qdisc_alloc(dev_queue, ops); in qdisc_create()
1303 struct netdev_queue *dev_queue; in tc_modify_qdisc() local
1306 dev_queue = p->ops->cl_ops->select_queue(p, tcm); in tc_modify_qdisc()
1308 dev_queue = p->dev_queue; in tc_modify_qdisc()
1310 dev_queue = netdev_get_tx_queue(dev, 0); in tc_modify_qdisc()
1312 q = qdisc_create(dev, dev_queue, p, in tc_modify_qdisc()
[all …]
|
| D | sch_plug.c | 186 netif_schedule_queue(sch->dev_queue); in plug_change()
194 netif_schedule_queue(sch->dev_queue); in plug_change()
|
| D | sch_fifo.c | 169 q = qdisc_create_dflt(sch->dev_queue, ops, TC_H_MAKE(sch->handle, 1)); in fifo_create_dflt()
|
| D | sch_dsmark.c | 70 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in dsmark_graft()
383 p->q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, sch->handle); in dsmark_init()
|
| D | sch_drr.c | 115 cl->qdisc = qdisc_create_dflt(sch->dev_queue, in drr_change_class()
224 new = qdisc_create_dflt(sch->dev_queue, in drr_graft_class()
|
| D | sch_atm.c | 277 flow->q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, classid); in atm_tc_change()
544 p->link.q = qdisc_create_dflt(sch->dev_queue, in atm_tc_init()
|
| D | sch_multiq.c | 232 child = qdisc_create_dflt(sch->dev_queue, in multiq_tune()
|
| D | sch_prio.c | 204 child = qdisc_create_dflt(sch->dev_queue, in prio_tune()
|
| D | sch_htb.c | 1165 (new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in htb_graft()
1282 new_q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in htb_delete()
1423 new_q = qdisc_create_dflt(sch->dev_queue, in htb_change_class()
|
| D | sch_hfsc.c | 1090 cl->qdisc = qdisc_create_dflt(sch->dev_queue, in hfsc_change_class()
1213 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in hfsc_graft_class()
1451 q->root.qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in hfsc_init_qdisc()
|
| D | sch_cbq.c | 1370 q->link.q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in cbq_init()
1617 new = qdisc_create_dflt(sch->dev_queue, in cbq_graft()
1862 cl->q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, classid); in cbq_change_class()
|
| D | sch_qfq.c | 481 cl->qdisc = qdisc_create_dflt(sch->dev_queue, in qfq_change_class()
615 new = qdisc_create_dflt(sch->dev_queue, in qfq_graft_class()
|
| D | sch_fq.c | 625 netdev_queue_numa_node_read(sch->dev_queue)); in fq_resize()
|
| /linux-4.4.14/include/linux/ |
| D | netdevice.h | 2598 static inline void netif_tx_start_queue(struct netdev_queue *dev_queue) in netif_tx_start_queue() argument
2600 clear_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_start_queue()
2624 void netif_tx_wake_queue(struct netdev_queue *dev_queue);
2648 static inline void netif_tx_stop_queue(struct netdev_queue *dev_queue) in netif_tx_stop_queue() argument
2650 set_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_stop_queue()
2667 static inline bool netif_tx_queue_stopped(const struct netdev_queue *dev_queue) in netif_tx_queue_stopped() argument
2669 return test_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_queue_stopped()
2683 static inline bool netif_xmit_stopped(const struct netdev_queue *dev_queue) in netif_xmit_stopped() argument
2685 return dev_queue->state & QUEUE_STATE_ANY_XOFF; in netif_xmit_stopped()
2689 netif_xmit_frozen_or_stopped(const struct netdev_queue *dev_queue) in netif_xmit_frozen_or_stopped() argument
[all …]
|
| /linux-4.4.14/include/net/ |
| D | sch_generic.h | 82 struct netdev_queue *dev_queue; member
287 struct Qdisc *q = rcu_dereference_rtnl(qdisc->dev_queue->qdisc); in qdisc_root()
294 return qdisc->dev_queue->qdisc_sleeping; in qdisc_root_sleeping()
326 return qdisc->dev_queue->dev; in qdisc_dev()
395 struct Qdisc *dev_graft_qdisc(struct netdev_queue *dev_queue,
401 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue,
403 struct Qdisc *qdisc_create_dflt(struct netdev_queue *dev_queue,
|
| /linux-4.4.14/drivers/net/ethernet/hisilicon/hns/ |
| D | hns_enet.c | 110 struct netdev_queue *dev_queue; in hns_nic_net_xmit_hw() local
172 dev_queue = netdev_get_tx_queue(ndev, skb->queue_mapping); in hns_nic_net_xmit_hw()
173 netdev_tx_sent_queue(dev_queue, skb->len); in hns_nic_net_xmit_hw()
620 struct netdev_queue *dev_queue; in hns_nic_tx_poll_one() local
650 dev_queue = netdev_get_tx_queue(ndev, ring_data->queue_index); in hns_nic_tx_poll_one()
651 netdev_tx_completed_queue(dev_queue, pkts, bytes); in hns_nic_tx_poll_one()
659 if (netif_tx_queue_stopped(dev_queue) && in hns_nic_tx_poll_one()
661 netif_tx_wake_queue(dev_queue); in hns_nic_tx_poll_one()
688 struct netdev_queue *dev_queue; in hns_nic_tx_clr_all_bufs() local
702 dev_queue = netdev_get_tx_queue(ndev, ring_data->queue_index); in hns_nic_tx_clr_all_bufs()
[all …]
|
| D | hns_ethtool.c | 400 struct netdev_queue *dev_queue; in __lb_other_process() local
422 dev_queue = netdev_get_tx_queue(ndev, ring_data->queue_index); in __lb_other_process()
423 netdev_tx_reset_queue(dev_queue); in __lb_other_process()
|
| /linux-4.4.14/drivers/net/xen-netback/ |
| D | xenbus.c | 58 struct netdev_queue *dev_queue; in xenvif_read_io_ring() local
119 dev_queue = netdev_get_tx_queue(queue->vif->dev, queue->id); in xenvif_read_io_ring()
124 netif_tx_queue_stopped(dev_queue) ? "stopped" : "running"); in xenvif_read_io_ring()
|
| /linux-4.4.14/drivers/net/ethernet/myricom/myri10ge/ |
| D | myri10ge.c | 1522 struct netdev_queue *dev_queue; in myri10ge_tx_done() local
1557 dev_queue = netdev_get_tx_queue(ss->dev, ss - ss->mgp->ss); in myri10ge_tx_done()
1568 __netif_tx_trylock(dev_queue)) { in myri10ge_tx_done()
1575 __netif_tx_unlock(dev_queue); in myri10ge_tx_done()
1579 if (netif_tx_queue_stopped(dev_queue) && in myri10ge_tx_done()
1583 netif_tx_wake_queue(dev_queue); in myri10ge_tx_done()
|
| /linux-4.4.14/drivers/net/ |
| D | xen-netfront.c | 245 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, queue->id); in xennet_maybe_wake_tx() local
247 if (unlikely(netif_tx_queue_stopped(dev_queue)) && in xennet_maybe_wake_tx()
|
| /linux-4.4.14/net/core/ |
| D | dev.c | 2301 void netif_tx_wake_queue(struct netdev_queue *dev_queue) in netif_tx_wake_queue() argument
2303 if (test_and_clear_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state)) { in netif_tx_wake_queue()
2307 q = rcu_dereference(dev_queue->qdisc); in netif_tx_wake_queue()
|