Home
last modified time | relevance | path

Searched refs:dev_queue (Results 1 – 25 of 32) sorted by relevance

12

/linux/net/sched/
H A Dsch_mq.c74 struct netdev_queue *dev_queue; in mq_init_common() local
90 dev_queue = netdev_get_tx_queue(dev, ntx); in mq_init_common()
91 qdisc = qdisc_create_dflt(dev_queue, in mq_init_common()
129 old = dev_graft_qdisc(qdisc->dev_queue, qdisc); in mq_attach()
212 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_graft()
219 *old = dev_graft_qdisc(dev_queue, new); in mq_graft()
237 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_find()
239 return rtnl_dereference(dev_queue->qdisc_sleeping);
256 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); in mq_dump_class_stats()
260 tcm->tcm_info = rtnl_dereference(dev_queue in mq_dump_class_stats()
199 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); mq_graft() local
224 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); mq_leaf() local
243 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); mq_dump_class() local
255 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); mq_dump_class_stats() local
[all...]
H A Dsch_generic.c101 const struct netdev_queue *txq = q->dev_queue; in __skb_dequeue_bad_txq()
261 const struct netdev_queue *txq = q->dev_queue; in dequeue_skb()
718 .dev_queue = &noop_netdev_queue,
982 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue, in qdisc_alloc() argument
991 if (!dev_queue) { in qdisc_alloc()
997 dev = dev_queue->dev; in qdisc_alloc()
998 sch = kzalloc_node(size, GFP_KERNEL, netdev_queue_numa_node_read(dev_queue)); in qdisc_alloc()
1029 sch->dev_queue = dev_queue; in qdisc_alloc()
1041 struct Qdisc *qdisc_create_dflt(struct netdev_queue *dev_queue, in qdisc_create_dflt() argument
1053 sch = qdisc_alloc(dev_queue, ops, extack); in qdisc_create_dflt()
[all …]
H A Dsch_htb.c1123 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, ntx); in htb_init() local
1126 qdisc = qdisc_create_dflt(dev_queue, &pfifo_qdisc_ops, in htb_init()
1166 old = dev_graft_qdisc(qdisc->dev_queue, qdisc); in htb_attach_offload()
1171 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, ntx); in htb_attach_offload() local
1172 struct Qdisc *old = dev_graft_qdisc(dev_queue, NULL); in htb_attach_offload()
1188 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, ntx); in htb_attach_software() local
1189 struct Qdisc *old = dev_graft_qdisc(dev_queue, sch); in htb_attach_software()
1375 return sch->dev_queue; in htb_select_queue()
1388 htb_graft_helper(struct netdev_queue *dev_queue, struct Qdisc *new_q) in htb_graft_helper() argument
1390 struct net_device *dev = dev_queue->dev; in htb_graft_helper()
[all …]
H A Dsch_mqprio.c350 struct netdev_queue *dev_queue; in mqprio_init() local
396 dev_queue = netdev_get_tx_queue(dev, i); in mqprio_init()
397 qdisc = qdisc_create_dflt(dev_queue, in mqprio_init()
441 old = dev_graft_qdisc(qdisc->dev_queue, qdisc); in mqprio_attach()
466 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); in mqprio_graft() local
468 if (!dev_queue) in mqprio_graft()
474 *old = dev_graft_qdisc(dev_queue, new); in mqprio_graft()
626 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); in mqprio_leaf() local
628 if (!dev_queue) in mqprio_leaf()
631 return rtnl_dereference(dev_queue->qdisc_sleeping); in mqprio_leaf()
[all …]
H A Dsch_api.c1115 struct netdev_queue *dev_queue; in qdisc_graft() local
1125 dev_queue = dev_ingress_queue(dev); in qdisc_graft()
1126 if (!dev_queue) { in qdisc_graft()
1131 q = rtnl_dereference(dev_queue->qdisc_sleeping); in qdisc_graft()
1153 dev_queue = netdev_get_tx_queue(dev, i); in qdisc_graft()
1154 old = dev_graft_qdisc(dev_queue, new); in qdisc_graft()
1161 old = dev_graft_qdisc(dev_queue, NULL); in qdisc_graft()
1170 dev_graft_qdisc(dev_queue, new); in qdisc_graft()
1272 struct netdev_queue *dev_queue, in qdisc_create() argument
1290 sch = qdisc_alloc(dev_queue, ops, extack); in qdisc_create()
[all …]
H A Dsch_plug.c184 netif_schedule_queue(sch->dev_queue); in plug_change()
192 netif_schedule_queue(sch->dev_queue); in plug_change()
H A Dsch_cbs.c426 q->qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in cbs_init()
437 q->queue = sch->dev_queue - netdev_get_tx_queue(dev, 0); in cbs_init()
512 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in cbs_graft()
H A Dsch_prio.c198 queues[i] = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in prio_tune()
294 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in prio_graft()
H A Dsch_drr.c114 cl->qdisc = qdisc_create_dflt(sch->dev_queue, in drr_change_class()
215 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in drr_graft_class()
H A Dsch_taprio.c2110 struct netdev_queue *dev_queue; in taprio_init() local
2113 dev_queue = netdev_get_tx_queue(dev, i); in taprio_init()
2114 qdisc = qdisc_create_dflt(dev_queue, in taprio_init()
2144 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, ntx); in taprio_attach() local
2162 old = dev_graft_qdisc(dev_queue, dev_queue_qdisc); in taprio_attach()
2190 struct netdev_queue *dev_queue = taprio_queue_get(sch, cl); in taprio_graft() local
2192 if (!dev_queue) in taprio_graft()
2210 WARN_ON_ONCE(dev_graft_qdisc(dev_queue, new) != *old); in taprio_graft()
H A Dsch_fifo.c263 q = qdisc_create_dflt(sch->dev_queue, ops, TC_H_MAKE(sch->handle, 1), in fifo_create_dflt()
H A Dsch_ets.c263 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in ets_class_graft()
644 queues[i] = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in ets_qdisc_change()
H A Dsch_multiq.c214 child = qdisc_create_dflt(sch->dev_queue, in multiq_tune()
H A Dsch_etf.c379 q->queue = sch->dev_queue - netdev_get_tx_queue(dev, 0); in etf_init()
H A Dsch_hfsc.c1060 cl->qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in hfsc_change_class()
1193 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in hfsc_graft_class()
1420 q->root.qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in hfsc_init_qdisc()
H A Dsch_qfq.c488 cl->qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in qfq_change_class()
610 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, in qfq_graft_class()
/linux/include/linux/
H A Dnetdevice.h3728 static __always_inline void netif_tx_start_queue(struct netdev_queue *dev_queue) in netif_tx_start_queue() argument
3730 clear_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_start_queue()
3754 void netif_tx_wake_queue(struct netdev_queue *dev_queue);
3778 static __always_inline void netif_tx_stop_queue(struct netdev_queue *dev_queue) in netif_tx_stop_queue() argument
3781 WRITE_ONCE(dev_queue->trans_start, jiffies); in netif_tx_stop_queue()
3787 set_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_stop_queue()
3804 static inline bool netif_tx_queue_stopped(const struct netdev_queue *dev_queue) in netif_tx_queue_stopped() argument
3806 return test_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state); in netif_tx_queue_stopped()
3820 static inline bool netif_xmit_stopped(const struct netdev_queue *dev_queue) in netif_xmit_stopped() argument
3822 return dev_queue->state & QUEUE_STATE_ANY_XOFF; in netif_xmit_stopped()
[all …]
/linux/include/net/
H A Dsch_generic.h104 struct netdev_queue *dev_queue; member
588 struct Qdisc *q = rcu_dereference_rtnl(qdisc->dev_queue->qdisc); in qdisc_root()
595 return rcu_dereference_bh(qdisc->dev_queue->qdisc); in qdisc_root_bh()
600 return rcu_dereference_rtnl(qdisc->dev_queue->qdisc_sleeping); in qdisc_root_sleeping()
613 return qdisc->dev_queue->dev; in qdisc_dev()
731 struct Qdisc *dev_graft_qdisc(struct netdev_queue *dev_queue,
740 struct netdev_queue *dev_queue, in dev_reset_queue() argument
746 qdisc = rtnl_dereference(dev_queue->qdisc_sleeping); in dev_reset_queue()
793 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue,
797 struct Qdisc *qdisc_create_dflt(struct netdev_queue *dev_queue,
/linux/drivers/net/ethernet/hisilicon/hns/
H A Dhns_enet.c333 struct netdev_queue *dev_queue; in hns_nic_net_xmit_hw() local
386 dev_queue = netdev_get_tx_queue(ndev, skb->queue_mapping); in hns_nic_net_xmit_hw()
387 netdev_tx_sent_queue(dev_queue, skb->len); in hns_nic_net_xmit_hw()
976 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
1070 dev_queue = netdev_get_tx_queue(ndev, ring_data->queue_index); in hns_nic_tx_clr_all_bufs()
[all …]
/linux/drivers/net/ethernet/mellanox/mlx5/core/en/
H A Dqos.c376 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, qid); in mlx5e_reset_qdisc() local
377 struct Qdisc *qdisc = rtnl_dereference(dev_queue->qdisc_sleeping); in mlx5e_reset_qdisc()
/linux/drivers/net/xen-netback/
H A Dxenbus.c31 struct netdev_queue *dev_queue; in xenvif_read_io_ring() local
92 dev_queue = netdev_get_tx_queue(queue->vif->dev, queue->id); in xenvif_read_io_ring()
97 netif_tx_queue_stopped(dev_queue) ? "stopped" : "running"); in xenvif_read_io_ring()
/linux/drivers/net/ethernet/hisilicon/hns3/
H A Dhns3_enet.c844 struct netdev_queue *dev_queue; in hns3_reset_tx_queue() local
848 dev_queue = netdev_get_tx_queue(ndev, in hns3_reset_tx_queue()
850 netdev_tx_reset_queue(dev_queue); in hns3_reset_tx_queue()
2332 struct netdev_queue *dev_queue; in hns3_nic_net_xmit() local
2376 dev_queue = netdev_get_tx_queue(netdev, ring->queue_index); in hns3_nic_net_xmit()
2377 doorbell = __netdev_tx_sent_queue(dev_queue, desc_cb->send_bytes, in hns3_nic_net_xmit()
3691 struct netdev_queue *dev_queue; in hns3_clean_tx_ring() local
3708 dev_queue = netdev_get_tx_queue(netdev, ring->tqp->tqp_index); in hns3_clean_tx_ring()
3709 netdev_tx_completed_queue(dev_queue, pkts, bytes); in hns3_clean_tx_ring()
3717 if (netif_tx_queue_stopped(dev_queue) && in hns3_clean_tx_ring()
[all …]
/linux/tools/perf/Documentation/
H A Dperf-trace.txt341 next block:*_unplug and the next three net:*dev_queue events, this last one
344 # perf trace -e sched:*switch/nr=2/,block:*_plug/nr=4/,block:*_unplug/nr=1/,net:*dev_queue/nr=3,max-stack=16/
/linux/drivers/net/ethernet/myricom/myri10ge/
H A Dmyri10ge.c1391 struct netdev_queue *dev_queue; in myri10ge_tx_done() local
1426 dev_queue = netdev_get_tx_queue(ss->dev, ss - ss->mgp->ss); in myri10ge_tx_done()
1437 __netif_tx_trylock(dev_queue)) { in myri10ge_tx_done()
1443 __netif_tx_unlock(dev_queue); in myri10ge_tx_done()
1447 if (netif_tx_queue_stopped(dev_queue) && in myri10ge_tx_done()
1451 netif_tx_wake_queue(dev_queue); in myri10ge_tx_done()
/linux/drivers/net/ethernet/marvell/octeontx2/nic/
H A Dqos.c1509 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, qid); in otx2_reset_qdisc() local
1510 struct Qdisc *qdisc = rtnl_dereference(dev_queue->qdisc_sleeping); in otx2_reset_qdisc()

12