/net/sched/ |
H A D | sch_generic.c | 40 * qdisc_lock(qdisc) spinlock. 43 * - enqueue, dequeue are serialized via qdisc root lock 44 * - ingress filtering is also serialized via qdisc root lock 155 /* And release qdisc */ 196 * this qdisc at a time. qdisc_lock(q) serializes queue accesses for 382 static int noop_enqueue(struct sk_buff *skb, struct Qdisc *qdisc) argument 388 static struct sk_buff *noop_dequeue(struct Qdisc *qdisc) argument 403 .qdisc = &noop_qdisc, 430 .qdisc = &noqueue_qdisc, 480 static int pfifo_fast_enqueue(struct sk_buff *skb, struct Qdisc *qdisc) argument 495 pfifo_fast_dequeue(struct Qdisc *qdisc) argument 514 pfifo_fast_peek(struct Qdisc *qdisc) argument 528 pfifo_fast_reset(struct Qdisc *qdisc) argument 541 pfifo_fast_dump(struct Qdisc *qdisc, struct sk_buff *skb) argument 554 pfifo_fast_init(struct Qdisc *qdisc, struct nlattr *opt) argument 650 qdisc_reset(struct Qdisc *qdisc) argument 667 struct Qdisc *qdisc = container_of(head, struct Qdisc, rcu_head); local 675 qdisc_destroy(struct Qdisc *qdisc) argument 707 dev_graft_qdisc(struct netdev_queue *dev_queue, struct Qdisc *qdisc) argument 736 struct Qdisc *qdisc = &noqueue_qdisc; local 754 struct Qdisc *qdisc; local 821 struct Qdisc *qdisc; local 914 struct Qdisc *qdisc = _qdisc; local 934 struct Qdisc *qdisc = dev_queue->qdisc_sleeping; local [all...] |
H A D | sch_mq.c | 43 struct Qdisc *qdisc; local 60 qdisc = qdisc_create_dflt(dev_queue, default_qdisc_ops, 63 if (qdisc == NULL) 65 priv->qdiscs[ntx] = qdisc; 66 qdisc->flags |= TCQ_F_ONETXQUEUE; 81 struct Qdisc *qdisc, *old; local 85 qdisc = priv->qdiscs[ntx]; 86 old = dev_graft_qdisc(qdisc->dev_queue, qdisc); 91 qdisc_list_add(qdisc); 102 struct Qdisc *qdisc; local [all...] |
H A D | sch_mqprio.c | 97 struct Qdisc *qdisc; local 117 /* pre-allocate qdisc, attachment can't fail */ 127 qdisc = qdisc_create_dflt(dev_queue, default_qdisc_ops, 130 if (qdisc == NULL) { 134 priv->qdiscs[i] = qdisc; 135 qdisc->flags |= TCQ_F_ONETXQUEUE; 170 struct Qdisc *qdisc, *old; local 173 /* Attach underlying qdisc */ 175 qdisc = priv->qdiscs[ntx]; 176 old = dev_graft_qdisc(qdisc 226 struct Qdisc *qdisc; local 330 struct Qdisc *qdisc; variable in typeref:struct:Qdisc [all...] |
H A D | sch_drr.c | 30 struct Qdisc *qdisc; member in struct:drr_class 55 unsigned int len = cl->qdisc->q.qlen; 57 qdisc_reset(cl->qdisc); 58 qdisc_tree_decrease_qlen(cl->qdisc, len); 114 cl->qdisc = qdisc_create_dflt(sch->dev_queue, 116 if (cl->qdisc == NULL) 117 cl->qdisc = &noop_qdisc; 124 qdisc_destroy(cl->qdisc); 143 qdisc_destroy(cl->qdisc); 231 *old = cl->qdisc; [all...] |
H A D | sch_red.c | 46 struct Qdisc *qdisc; member in struct:red_sched_data 62 struct Qdisc *child = q->qdisc; 116 struct Qdisc *child = q->qdisc; 132 struct Qdisc *child = q->qdisc; 140 struct Qdisc *child = q->qdisc; 160 qdisc_reset(q->qdisc); 170 qdisc_destroy(q->qdisc); 213 qdisc_tree_decrease_qlen(q->qdisc, q->qdisc->q.qlen); 214 qdisc_destroy(q->qdisc); [all...] |
H A D | sch_multiq.c | 70 struct Qdisc *qdisc; local 73 qdisc = multiq_classify(skb, sch, &ret); 75 if (qdisc == NULL) { 84 ret = qdisc_enqueue(skb, qdisc); 97 struct Qdisc *qdisc; local 112 qdisc = q->queues[q->curband]; 113 skb = qdisc->dequeue(qdisc); 129 struct Qdisc *qdisc; local 144 qdisc 159 struct Qdisc *qdisc; local [all...] |
H A D | sch_tbf.c | 97 It is passed to the default bfifo qdisc - if the inner qdisc is 114 struct Qdisc *qdisc; /* Inner qdisc, default - bfifo queue */ member in struct:tbf_sched_data 175 ret = qdisc_enqueue(segs, q->qdisc); 201 ret = qdisc_enqueue(skb, q->qdisc); 217 if (q->qdisc->ops->drop && (len = q->qdisc->ops->drop(q->qdisc)) != 0) { 234 skb = q->qdisc [all...] |
H A D | sch_prio.c | 72 struct Qdisc *qdisc; local 75 qdisc = prio_classify(skb, sch, &ret); 77 if (qdisc == NULL) { 86 ret = qdisc_enqueue(skb, qdisc); 102 struct Qdisc *qdisc = q->queues[prio]; local 103 struct sk_buff *skb = qdisc->ops->peek(qdisc); 116 struct Qdisc *qdisc = q->queues[prio]; local 117 struct sk_buff *skb = qdisc_dequeue_peeked(qdisc); 133 struct Qdisc *qdisc; local [all...] |
H A D | sch_qfq.c | 141 struct Qdisc *qdisc; member in struct:qfq_class 223 unsigned int len = cl->qdisc->q.qlen; 225 qdisc_reset(cl->qdisc); 226 qdisc_tree_decrease_qlen(cl->qdisc, len); 330 if (cl->qdisc->q.qlen > 0) { /* adding an active class */ 380 if (cl->qdisc->q.qlen > 0) /* class is active */ 482 cl->qdisc = qdisc_create_dflt(sch->dev_queue, 484 if (cl->qdisc == NULL) 485 cl->qdisc = &noop_qdisc; 525 qdisc_destroy(cl->qdisc); [all...] |
H A D | sch_sfb.c | 57 struct Qdisc *qdisc; member in struct:sfb_sched_data 81 u32 childdrop; /* drops in child qdisc */ 283 struct Qdisc *child = q->qdisc; 431 struct Qdisc *child = q->qdisc; 434 skb = child->dequeue(q->qdisc); 448 struct Qdisc *child = q->qdisc; 459 qdisc_reset(q->qdisc); 472 qdisc_destroy(q->qdisc); 521 qdisc_tree_decrease_qlen(q->qdisc, q->qdisc [all...] |
H A D | sch_netem.c | 51 This qdisc does not do classification that can be handled in 72 /* internal t(ime)fifo qdisc uses t_root and sch->limit */ 75 /* optional qdisc for classful handling (NULL at netem init) */ 76 struct Qdisc *qdisc; member in struct:netem_sched_data 412 * Insert one skb into qdisc. 450 * qdisc tree, since parent queuer expects that only one 556 if (!len && q->qdisc && q->qdisc->ops->drop) 557 len = q->qdisc->ops->drop(q->qdisc); [all...] |
H A D | sch_hfsc.c | 126 struct Qdisc *qdisc; /* leaf qdisc */ member in struct:hfsc_class 128 struct rb_node el_node; /* qdisc's eligible tree member */ 770 if (cl->qdisc->q.qlen == 0 && cl->cl_flags & HFSC_FSC) 897 unsigned int len = cl->qdisc->q.qlen; 899 qdisc_reset(cl->qdisc); 900 qdisc_tree_decrease_qlen(cl->qdisc, len); 1035 if (cl->qdisc->q.qlen != 0) { 1037 update_ed(cl, qdisc_peek_len(cl->qdisc)); 1089 cl->qdisc [all...] |
H A D | sch_api.c | 55 Generally, queueing discipline ("qdisc") is a black box, 60 qdisc's are divided to two categories: 74 All real intelligent work is done inside qdisc modules. 109 returns qdisc to initial state: purge all buffers, clear all 114 initializes newly created qdisc. 118 destroys resources allocated by init and during lifetime of qdisc. 122 changes qdisc parameters. 203 /* Get default qdisc if not otherwise specified */ 226 /* Set new default qdisc to use */ 255 /* We know handle. Find qdisc amon 566 qdisc_warn_nonwc(const char *txt, struct Qdisc *qdisc) argument 589 qdisc_watchdog_init(struct qdisc_watchdog *wd, struct Qdisc *qdisc) argument [all...] |
H A D | sch_cbq.c | 106 struct Qdisc *qdisc; /* Ptr to CBQ discipline */ member in struct:cbq_class 303 struct cbq_sched_data *q = qdisc_priv(cl->qdisc); 327 struct cbq_sched_data *q = qdisc_priv(this->qdisc); 411 struct cbq_sched_data *q = qdisc_priv(cl->qdisc); 465 struct cbq_sched_data *q = qdisc_priv(cl->qdisc); 484 struct cbq_sched_data *q = qdisc_priv(cl->qdisc); 488 &qdisc_root_sleeping(cl->qdisc)->state)) 529 struct cbq_sched_data *q = qdisc_priv(cl->qdisc); 547 cl->qdisc->q.qlen--; 591 struct Qdisc *sch = q->watchdog.qdisc; [all...] |
H A D | sch_teql.c | 31 and new qdisc with the same name. To join a slave to the equalizer 32 you should just set this qdisc on a device f.e. 34 # tc qdisc add dev eth0 root teql0 35 # tc qdisc add dev eth1 root teql0 77 /* "teql*" qdisc routines */ 103 q = rcu_dereference_bh(dat_queue->qdisc); 121 /* teql is meant to be used as root qdisc */ 163 root_lock = qdisc_root_sleeping_lock(rtnl_dereference(txq->qdisc)); 165 qdisc_reset(rtnl_dereference(txq->qdisc)); 272 if (rcu_access_pointer(txq->qdisc) [all...] |
H A D | cls_api.c | 168 /* Find qdisc */ 170 q = dev->qdisc; 435 q = dev->qdisc;
|
H A D | sch_htb.c | 155 /* filters for qdisc itself */ 198 * filters in qdisc and in inner nodes (if higher filter points to the inner 829 * qdisc drops packets in enqueue routine or if someone used 931 &qdisc_root_sleeping(q->watchdog.qdisc)->state)) { 933 qdisc_throttled(q->watchdog.qdisc); 1012 struct Qdisc *sch = q->watchdog.qdisc; 1069 /* Its safe to not acquire qdisc lock. As we hold RTNL, 1070 * no change can happen on the qdisc parameters. 1100 /* Its safe to not acquire qdisc lock. As we hold RTNL, 1424 /* create leaf qdisc earl [all...] |
/net/caif/ |
H A D | caif_dev.c | 189 qlen = qdisc_qlen(rcu_dereference_bh(txq->qdisc));
|
/net/core/ |
H A D | dev.c | 2071 * greater then real_num_tx_queues stale skbs on the qdisc must be flushed. 2184 struct Qdisc *q = rcu_dereference(txq->qdisc); 2207 q = rcu_dereference(txq->qdisc); 2220 q = rcu_dereference(dev_queue->qdisc); 2787 * separate lock before trying to get qdisc main lock. 2803 * waiting to be sent out; and the qdisc is not running - 2916 /* If device/qdisc don't need skb->dst, release it right now while 2925 q = rcu_dereference_bh(txq->qdisc); 2946 Either shot noqueue qdisc, it is even simpler 8) 3502 q = rcu_dereference(rxq->qdisc); [all...] |
H A D | rtnetlink.c | 1012 (dev->qdisc && 1013 nla_put_string(skb, IFLA_QDISC, dev->qdisc->ops->id)) ||
|