| /linux-4.1.27/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()
414 .dev_queue = &noop_netdev_queue,
441 .dev_queue = &noqueue_netdev_queue,
581 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue, in qdisc_alloc() argument
588 struct net_device *dev = dev_queue->dev; in qdisc_alloc()
591 netdev_queue_numa_node_read(dev_queue)); in qdisc_alloc()
600 netdev_queue_numa_node_read(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 | 831 struct netdev_queue *dev_queue = dev_ingress_queue(dev); in qdisc_graft() local
834 dev_queue = netdev_get_tx_queue(dev, i); in qdisc_graft()
836 old = dev_graft_qdisc(dev_queue, new); in qdisc_graft()
889 qdisc_create(struct net_device *dev, struct netdev_queue *dev_queue, in qdisc_create() argument
932 sch = qdisc_alloc(dev_queue, ops); in qdisc_create()
1301 struct netdev_queue *dev_queue; in tc_modify_qdisc() local
1304 dev_queue = p->ops->cl_ops->select_queue(p, tcm); in tc_modify_qdisc()
1306 dev_queue = p->dev_queue; in tc_modify_qdisc()
1308 dev_queue = netdev_get_tx_queue(dev, 0); in tc_modify_qdisc()
1310 q = qdisc_create(dev, dev_queue, p, in tc_modify_qdisc()
[all …]
|
| D | sch_plug.c | 190 netif_schedule_queue(sch->dev_queue); in plug_change()
198 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 | 64 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in dsmark_graft()
385 p->q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, sch->handle); in dsmark_init()
|
| D | sch_drr.c | 114 cl->qdisc = qdisc_create_dflt(sch->dev_queue, in drr_change_class()
223 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_prio.c | 204 child = qdisc_create_dflt(sch->dev_queue, in prio_tune()
|
| D | sch_multiq.c | 231 child = qdisc_create_dflt(sch->dev_queue, in multiq_tune()
|
| D | sch_htb.c | 1164 (new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in htb_graft()
1289 new_q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in htb_delete()
1428 new_q = qdisc_create_dflt(sch->dev_queue, in htb_change_class()
|
| D | sch_hfsc.c | 1089 cl->qdisc = qdisc_create_dflt(sch->dev_queue, in hfsc_change_class()
1212 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in hfsc_graft_class()
1454 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()
1867 cl->q = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, classid); in cbq_change_class()
|
| D | sch_qfq.c | 482 cl->qdisc = qdisc_create_dflt(sch->dev_queue, in qfq_change_class()
616 new = qdisc_create_dflt(sch->dev_queue, in qfq_graft_class()
|
| D | sch_fq.c | 622 netdev_queue_numa_node_read(sch->dev_queue)); in fq_resize()
|
| /linux-4.1.27/include/linux/ |
| D | netdevice.h | 2503 static inline void netif_tx_start_queue(struct netdev_queue *dev_queue) in netif_tx_start_queue() argument
2505 clear_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_start_queue()
2529 void netif_tx_wake_queue(struct netdev_queue *dev_queue);
2553 static inline void netif_tx_stop_queue(struct netdev_queue *dev_queue) in netif_tx_stop_queue() argument
2555 if (WARN_ON(!dev_queue)) { in netif_tx_stop_queue()
2559 set_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_stop_queue()
2584 static inline bool netif_tx_queue_stopped(const struct netdev_queue *dev_queue) in netif_tx_queue_stopped() argument
2586 return test_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_queue_stopped()
2600 static inline bool netif_xmit_stopped(const struct netdev_queue *dev_queue) in netif_xmit_stopped() argument
2602 return dev_queue->state & QUEUE_STATE_ANY_XOFF; in netif_xmit_stopped()
[all …]
|
| /linux-4.1.27/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()
394 struct Qdisc *dev_graft_qdisc(struct netdev_queue *dev_queue,
399 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue,
401 struct Qdisc *qdisc_create_dflt(struct netdev_queue *dev_queue,
|
| /linux-4.1.27/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.1.27/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.1.27/drivers/net/ |
| D | xen-netfront.c | 246 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, queue->id); in xennet_maybe_wake_tx() local
248 if (unlikely(netif_tx_queue_stopped(dev_queue)) && in xennet_maybe_wake_tx()
|
| /linux-4.1.27/net/core/ |
| D | dev.c | 2269 void netif_tx_wake_queue(struct netdev_queue *dev_queue) in netif_tx_wake_queue() argument
2271 if (test_and_clear_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state)) { in netif_tx_wake_queue()
2275 q = rcu_dereference(dev_queue->qdisc); in netif_tx_wake_queue()
|