Lines Matching refs:q
91 struct plug_sched_data *q = qdisc_priv(sch); in plug_enqueue() local
93 if (likely(sch->qstats.backlog + skb->len <= q->limit)) { in plug_enqueue()
94 if (!q->unplug_indefinite) in plug_enqueue()
95 q->pkts_current_epoch++; in plug_enqueue()
104 struct plug_sched_data *q = qdisc_priv(sch); in plug_dequeue() local
109 if (!q->unplug_indefinite) { in plug_dequeue()
110 if (!q->pkts_to_release) { in plug_dequeue()
117 q->pkts_to_release--; in plug_dequeue()
125 struct plug_sched_data *q = qdisc_priv(sch); in plug_init() local
127 q->pkts_current_epoch = 0; in plug_init()
128 q->pkts_last_epoch = 0; in plug_init()
129 q->pkts_to_release = 0; in plug_init()
130 q->unplug_indefinite = false; in plug_init()
138 q->limit = pkt_limit * psched_mtu(qdisc_dev(sch)); in plug_init()
145 q->limit = ctl->limit; in plug_init()
164 struct plug_sched_data *q = qdisc_priv(sch); in plug_change() local
177 q->pkts_last_epoch = q->pkts_current_epoch; in plug_change()
178 q->pkts_current_epoch = 0; in plug_change()
179 if (q->unplug_indefinite) in plug_change()
181 q->unplug_indefinite = false; in plug_change()
187 q->pkts_to_release += q->pkts_last_epoch; in plug_change()
188 q->pkts_last_epoch = 0; in plug_change()
193 q->unplug_indefinite = true; in plug_change()
194 q->pkts_to_release = 0; in plug_change()
195 q->pkts_last_epoch = 0; in plug_change()
196 q->pkts_current_epoch = 0; in plug_change()
202 q->limit = msg->limit; in plug_change()