/linux-master/net/sched/ |
H A D | sch_mq.c | 72 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 D | sch_generic.c | 75 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 D | sch_htb.c | 1126 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 D | sch_mqprio.c | 352 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 D | sch_plug.c | 184 netif_schedule_queue(sch->dev_queue); 192 netif_schedule_queue(sch->dev_queue);
|
H A D | sch_api.c | 1111 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 D | sch_cbs.c | 412 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 D | sch_prio.c | 198 queues[i] = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, 294 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
|
H A D | sch_fifo.c | 259 q = qdisc_create_dflt(sch->dev_queue, ops, TC_H_MAKE(sch->handle, 1),
|
H A D | sch_drr.c | 110 cl->qdisc = qdisc_create_dflt(sch->dev_queue, 211 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
|
H A D | sch_taprio.c | 2092 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 D | sch_etf.c | 379 q->queue = sch->dev_queue - netdev_get_tx_queue(dev, 0);
|
H A D | sch_multiq.c | 214 child = qdisc_create_dflt(sch->dev_queue,
|
H A D | sch_ets.c | 254 new = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops, 637 queues[i] = qdisc_create_dflt(sch->dev_queue, &pfifo_qdisc_ops,
|
H A D | sch_hfsc.c | 1061 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 D | sch_qfq.c | 481 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 D | netdev_queues.h | 145 netdev_txq_completed_mb(struct netdev_queue *dev_queue, argument 149 netdev_tx_completed_queue(dev_queue, pkts, bytes);
|
H A D | sch_generic.h | 84 * 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 D | pkt_sched.h | 144 return dev_net(q->dev_queue->dev);
|
/linux-master/include/linux/ |
H A D | netdevice.h | 3301 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 D | hns_enet.c | 333 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 D | hns_ethtool.c | 376 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 D | qos.c | 367 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 D | xenbus.c | 31 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 D | hns3_enet.c | 813 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...] |