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()
133 q->limit = qdisc_dev(sch)->tx_queue_len in plug_init()
141 q->limit = ctl->limit; in plug_init()
160 struct plug_sched_data *q = qdisc_priv(sch); in plug_change() local
173 q->pkts_last_epoch = q->pkts_current_epoch; in plug_change()
174 q->pkts_current_epoch = 0; in plug_change()
175 if (q->unplug_indefinite) in plug_change()
177 q->unplug_indefinite = false; in plug_change()
183 q->pkts_to_release += q->pkts_last_epoch; in plug_change()
184 q->pkts_last_epoch = 0; in plug_change()
189 q->unplug_indefinite = true; in plug_change()
190 q->pkts_to_release = 0; in plug_change()
191 q->pkts_last_epoch = 0; in plug_change()
192 q->pkts_current_epoch = 0; in plug_change()
198 q->limit = msg->limit; in plug_change()