Searched refs:dev_queue (Results 1 - 25 of 31) sorted by relevance

12

/linux-master/net/sched/
H A Dsch_mq.c72 struct netdev_queue *dev_queue; local
89 dev_queue = netdev_get_tx_queue(dev, ntx);
90 qdisc = qdisc_create_dflt(dev_queue, get_default_qdisc_ops(dev, ntx),
115 old = dev_graft_qdisc(qdisc->dev_queue, qdisc);
178 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); local
185 *old = dev_graft_qdisc(dev_queue, new);
203 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); local
205 return rtnl_dereference(dev_queue->qdisc_sleeping);
220 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); local
224 tcm->tcm_info = rtnl_dereference(dev_queue
231 struct netdev_queue *dev_queue = mq_queue_get(sch, cl); local
[all...]
H A Dsch_generic.c75 const struct netdev_queue *txq = q->dev_queue;
232 const struct netdev_queue *txq = q->dev_queue;
662 .dev_queue = &noop_netdev_queue,
925 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue, argument
934 if (!dev_queue) {
940 dev = dev_queue->dev;
941 sch = kzalloc_node(size, GFP_KERNEL, netdev_queue_numa_node_read(dev_queue));
976 sch->dev_queue = dev_queue;
988 struct Qdisc *qdisc_create_dflt(struct netdev_queue *dev_queue, argument
1117 dev_graft_qdisc(struct netdev_queue *dev_queue, struct Qdisc *qdisc) argument
1138 shutdown_scheduler_queue(struct net_device *dev, struct netdev_queue *dev_queue, void *_qdisc_default) argument
1153 attach_one_default_qdisc(struct net_device *dev, struct netdev_queue *dev_queue, void *_unused) argument
1215 transition_one_qdisc(struct net_device *dev, struct netdev_queue *dev_queue, void *_need_watchdog) argument
1268 dev_deactivate_queue(struct net_device *dev, struct netdev_queue *dev_queue, void *_qdisc_default) argument
1282 dev_reset_queue(struct net_device *dev, struct netdev_queue *dev_queue, void *_unused) argument
1314 struct netdev_queue *dev_queue; local
1393 qdisc_change_tx_queue_len(struct net_device *dev, struct netdev_queue *dev_queue) argument
1459 dev_init_scheduler_queue(struct net_device *dev, struct netdev_queue *dev_queue, void *_qdisc) argument
[all...]
H A Dsch_htb.c1126 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, ntx); local
1129 qdisc = qdisc_create_dflt(dev_queue, &pfifo_qdisc_ops,
1169 old = dev_graft_qdisc(qdisc->dev_queue, qdisc);
1174 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, ntx); local
1175 struct Qdisc *old = dev_graft_qdisc(dev_queue, NULL);
1191 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, ntx); local
1192 struct Qdisc *old = dev_graft_qdisc(dev_queue, sch);
1377 return sch->dev_queue;
1390 htb_graft_helper(struct netdev_queue *dev_queue, struct Qdisc *new_q) argument
1392 struct net_device *dev = dev_queue
1452 struct netdev_queue *dev_queue = sch->dev_queue; local
1534 htb_parent_to_leaf_offload(struct Qdisc *sch, struct netdev_queue *dev_queue, struct Qdisc *new_q) argument
1552 struct netdev_queue *dev_queue; local
1728 struct netdev_queue *dev_queue = sch->dev_queue; local
1780 struct netdev_queue *dev_queue; local
[all...]
H A Dsch_mqprio.c352 struct netdev_queue *dev_queue; local
399 dev_queue = netdev_get_tx_queue(dev, i);
400 qdisc = qdisc_create_dflt(dev_queue,
444 old = dev_graft_qdisc(qdisc->dev_queue, qdisc);
469 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); local
471 if (!dev_queue)
477 *old = dev_graft_qdisc(dev_queue, new);
616 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); local
618 if (!dev_queue)
621 return rtnl_dereference(dev_queue
647 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); local
708 struct netdev_queue *dev_queue = mqprio_queue_get(sch, cl); variable in typeref:struct:netdev_queue
[all...]
H A Dsch_plug.c184 netif_schedule_queue(sch->dev_queue);
192 netif_schedule_queue(sch->dev_queue);
H A Dsch_api.c1111 struct netdev_queue *dev_queue; local
1118 dev_queue = dev_ingress_queue(dev);
1119 if (!dev_queue) {
1124 q = rtnl_dereference(dev_queue->qdisc_sleeping);
1146 dev_queue = netdev_get_tx_queue(dev, i);
1147 old = dev_graft_qdisc(dev_queue, new);
1154 old = dev_graft_qdisc(dev_queue, NULL);
1163 dev_graft_qdisc(dev_queue, new);
1253 struct netdev_queue *dev_queue,
1299 sch = qdisc_alloc(dev_queue, op
1252 qdisc_create(struct net_device *dev, struct netdev_queue *dev_queue, u32 parent, u32 handle, struct nlattr **tca, int *errp, struct netlink_ext_ack *extack) argument
1767 struct netdev_queue *dev_queue; local
1873 struct netdev_queue *dev_queue; local
2341 struct netdev_queue *dev_queue; local
[all...]
H A Dsch_cbs.c412 q->qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
423 q->queue = sch->dev_queue - netdev_get_tx_queue(dev, 0);
498 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
H A Dsch_prio.c198 queues[i] = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
294 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
H A Dsch_fifo.c259 q = qdisc_create_dflt(sch->dev_queue, ops, TC_H_MAKE(sch->handle, 1),
H A Dsch_drr.c110 cl->qdisc = qdisc_create_dflt(sch->dev_queue,
211 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
H A Dsch_taprio.c2092 struct netdev_queue *dev_queue; local
2095 dev_queue = netdev_get_tx_queue(dev, i);
2096 qdisc = qdisc_create_dflt(dev_queue,
2126 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, ntx); local
2144 old = dev_graft_qdisc(dev_queue, dev_queue_qdisc);
2172 struct netdev_queue *dev_queue = taprio_queue_get(sch, cl); local
2174 if (!dev_queue)
2189 WARN_ON_ONCE(dev_graft_qdisc(dev_queue, new) != *old);
H A Dsch_etf.c379 q->queue = sch->dev_queue - netdev_get_tx_queue(dev, 0);
H A Dsch_multiq.c214 child = qdisc_create_dflt(sch->dev_queue,
H A Dsch_ets.c254 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
637 queues[i] = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
H A Dsch_hfsc.c1061 cl->qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
1193 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
1419 q->root.qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
H A Dsch_qfq.c481 cl->qdisc = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
603 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
/linux-master/include/net/
H A Dnetdev_queues.h145 netdev_txq_completed_mb(struct netdev_queue *dev_queue, argument
149 netdev_tx_completed_queue(dev_queue, pkts, bytes);
H A Dsch_generic.h84 * q->dev_queue : It can test
105 struct netdev_queue *dev_queue; member in struct:Qdisc
545 struct Qdisc *q = rcu_dereference_rtnl(qdisc->dev_queue->qdisc);
552 return rcu_dereference_bh(qdisc->dev_queue->qdisc);
557 return rcu_dereference_rtnl(qdisc->dev_queue->qdisc_sleeping);
570 return qdisc->dev_queue->dev;
688 struct Qdisc *dev_graft_qdisc(struct netdev_queue *dev_queue,
722 struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue,
726 struct Qdisc *qdisc_create_dflt(struct netdev_queue *dev_queue,
H A Dpkt_sched.h144 return dev_net(q->dev_queue->dev);
/linux-master/include/linux/
H A Dnetdevice.h3301 static __always_inline void netif_tx_start_queue(struct netdev_queue *dev_queue) argument
3303 clear_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state);
3327 void netif_tx_wake_queue(struct netdev_queue *dev_queue);
3351 static __always_inline void netif_tx_stop_queue(struct netdev_queue *dev_queue) argument
3354 set_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state);
3371 static inline bool netif_tx_queue_stopped(const struct netdev_queue *dev_queue) argument
3373 return test_bit(__QUEUE_STATE_DRV_XOFF, &dev_queue->state);
3387 static inline bool netif_xmit_stopped(const struct netdev_queue *dev_queue) argument
3389 return dev_queue->state & QUEUE_STATE_ANY_XOFF;
3393 netif_xmit_frozen_or_stopped(const struct netdev_queue *dev_queue) argument
3399 netif_xmit_frozen_or_drv_stopped(const struct netdev_queue *dev_queue) argument
3414 netdev_queue_set_dql_min_limit(struct netdev_queue *dev_queue, unsigned int min_limit) argument
3439 netdev_txq_bql_enqueue_prefetchw(struct netdev_queue *dev_queue) argument
3453 netdev_txq_bql_complete_prefetchw(struct netdev_queue *dev_queue) argument
3470 netdev_tx_sent_queue(struct netdev_queue *dev_queue, unsigned int bytes) argument
3500 __netdev_tx_sent_queue(struct netdev_queue *dev_queue, unsigned int bytes, bool xmit_more) argument
3546 netdev_tx_completed_queue(struct netdev_queue *dev_queue, unsigned int pkts, unsigned int bytes) argument
3601 netdev_reset_queue(struct net_device *dev_queue) argument
[all...]
/linux-master/drivers/net/ethernet/hisilicon/hns/
H A Dhns_enet.c333 struct netdev_queue *dev_queue; local
386 dev_queue = netdev_get_tx_queue(ndev, skb->queue_mapping);
387 netdev_tx_sent_queue(dev_queue, skb->len);
976 struct netdev_queue *dev_queue; local
1005 dev_queue = netdev_get_tx_queue(ndev, ring_data->queue_index);
1006 netdev_tx_completed_queue(dev_queue, pkts, bytes);
1017 if (netif_tx_queue_stopped(dev_queue) &&
1019 netif_tx_wake_queue(dev_queue);
1060 struct netdev_queue *dev_queue; local
1070 dev_queue
[all...]
H A Dhns_ethtool.c376 struct netdev_queue *dev_queue; local
407 dev_queue = netdev_get_tx_queue(ndev, ring_data->queue_index);
408 netdev_tx_reset_queue(dev_queue);
/linux-master/drivers/net/ethernet/mellanox/mlx5/core/en/
H A Dqos.c367 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, qid); local
368 struct Qdisc *qdisc = dev_queue->qdisc_sleeping;
/linux-master/drivers/net/xen-netback/
H A Dxenbus.c31 struct netdev_queue *dev_queue; local
92 dev_queue = netdev_get_tx_queue(queue->vif->dev, queue->id);
97 netif_tx_queue_stopped(dev_queue) ? "stopped" : "running");
/linux-master/drivers/net/ethernet/hisilicon/hns3/
H A Dhns3_enet.c813 struct netdev_queue *dev_queue; local
817 dev_queue = netdev_get_tx_queue(ndev,
819 netdev_tx_reset_queue(dev_queue);
2303 struct netdev_queue *dev_queue; local
2347 dev_queue = netdev_get_tx_queue(netdev, ring->queue_index);
2348 doorbell = __netdev_tx_sent_queue(dev_queue, desc_cb->send_bytes,
3634 struct netdev_queue *dev_queue; local
3651 dev_queue = netdev_get_tx_queue(netdev, ring->tqp->tqp_index);
3652 netdev_tx_completed_queue(dev_queue, pkts, bytes);
3660 if (netif_tx_queue_stopped(dev_queue)
[all...]

Completed in 503 milliseconds

12