628 static int noop_enqueue(struct sk_buff *skb, struct Qdisc *qdisc,  in noop_enqueue()  argument
635 static struct sk_buff *noop_dequeue(struct Qdisc *qdisc)  in noop_dequeue()  argument
650 	RCU_POINTER_INITIALIZER(qdisc, &noop_qdisc),
677 static int noqueue_init(struct Qdisc *qdisc, struct nlattr *opt,  in noqueue_init()  argument
683 	qdisc->enqueue = NULL;  in noqueue_init()
721 static int pfifo_fast_enqueue(struct sk_buff *skb, struct Qdisc *qdisc,  in pfifo_fast_enqueue()  argument
725 	struct pfifo_fast_priv *priv = qdisc_priv(qdisc);  in pfifo_fast_enqueue()
733 		if (qdisc_is_percpu_stats(qdisc))  in pfifo_fast_enqueue()
734 			return qdisc_drop_cpu(skb, qdisc, to_free);  in pfifo_fast_enqueue()
736 			return qdisc_drop(skb, qdisc, to_free);  in pfifo_fast_enqueue()
739 	qdisc_update_stats_at_enqueue(qdisc, pkt_len);  in pfifo_fast_enqueue()
743 static struct sk_buff *pfifo_fast_dequeue(struct Qdisc *qdisc)  in pfifo_fast_dequeue()  argument
745 	struct pfifo_fast_priv *priv = qdisc_priv(qdisc);  in pfifo_fast_dequeue()
760 		qdisc_update_stats_at_dequeue(qdisc, skb);  in pfifo_fast_dequeue()
762 		   READ_ONCE(qdisc->state) & QDISC_STATE_NON_EMPTY) {  in pfifo_fast_dequeue()
768 		clear_bit(__QDISC_STATE_MISSED, &qdisc->state);  in pfifo_fast_dequeue()
769 		clear_bit(__QDISC_STATE_DRAINING, &qdisc->state);  in pfifo_fast_dequeue()
784 static struct sk_buff *pfifo_fast_peek(struct Qdisc *qdisc)  in pfifo_fast_peek()  argument
786 	struct pfifo_fast_priv *priv = qdisc_priv(qdisc);  in pfifo_fast_peek()
799 static void pfifo_fast_reset(struct Qdisc *qdisc)  in pfifo_fast_reset()  argument
802 	struct pfifo_fast_priv *priv = qdisc_priv(qdisc);  in pfifo_fast_reset()
818 	if (qdisc_is_percpu_stats(qdisc)) {  in pfifo_fast_reset()
822 			q = per_cpu_ptr(qdisc->cpu_qstats, i);  in pfifo_fast_reset()
829 static int pfifo_fast_dump(struct Qdisc *qdisc, struct sk_buff *skb)  in pfifo_fast_dump()  argument
842 static int pfifo_fast_init(struct Qdisc *qdisc, struct nlattr *opt,  in pfifo_fast_init()  argument
845 	unsigned int qlen = qdisc_dev(qdisc)->tx_queue_len;  in pfifo_fast_init()
846 	struct pfifo_fast_priv *priv = qdisc_priv(qdisc);  in pfifo_fast_init()
863 	qdisc->flags |= TCQ_F_CAN_BYPASS;  in pfifo_fast_init()
1018 void qdisc_reset(struct Qdisc *qdisc)  in qdisc_reset()  argument
1020 	const struct Qdisc_ops *ops = qdisc->ops;  in qdisc_reset()
1022 	trace_qdisc_reset(qdisc);  in qdisc_reset()
1025 		ops->reset(qdisc);  in qdisc_reset()
1027 	__skb_queue_purge(&qdisc->gso_skb);  in qdisc_reset()
1028 	__skb_queue_purge(&qdisc->skb_bad_txq);  in qdisc_reset()
1030 	qdisc->q.qlen = 0;  in qdisc_reset()
1031 	qdisc->qstats.backlog = 0;  in qdisc_reset()
1035 void qdisc_free(struct Qdisc *qdisc)  in qdisc_free()  argument
1037 	if (qdisc_is_percpu_stats(qdisc)) {  in qdisc_free()
1038 		free_percpu(qdisc->cpu_bstats);  in qdisc_free()
1039 		free_percpu(qdisc->cpu_qstats);  in qdisc_free()
1042 	kfree(qdisc);  in qdisc_free()
1052 static void __qdisc_destroy(struct Qdisc *qdisc)  in __qdisc_destroy()  argument
1054 	const struct Qdisc_ops  *ops = qdisc->ops;  in __qdisc_destroy()
1057 	qdisc_hash_del(qdisc);  in __qdisc_destroy()
1059 	qdisc_put_stab(rtnl_dereference(qdisc->stab));  in __qdisc_destroy()
1061 	gen_kill_estimator(&qdisc->rate_est);  in __qdisc_destroy()
1063 	qdisc_reset(qdisc);  in __qdisc_destroy()
1066 		ops->destroy(qdisc);  in __qdisc_destroy()
1068 	lockdep_unregister_key(&qdisc->root_lock_key);  in __qdisc_destroy()
1070 	netdev_put(qdisc_dev(qdisc), &qdisc->dev_tracker);  in __qdisc_destroy()
1072 	trace_qdisc_destroy(qdisc);  in __qdisc_destroy()
1074 	call_rcu(&qdisc->rcu, qdisc_free_cb);  in __qdisc_destroy()
1077 void qdisc_destroy(struct Qdisc *qdisc)  in qdisc_destroy()  argument
1079 	if (qdisc->flags & TCQ_F_BUILTIN)  in qdisc_destroy()
1082 	__qdisc_destroy(qdisc);  in qdisc_destroy()
1085 void qdisc_put(struct Qdisc *qdisc)  in qdisc_put()  argument
1087 	if (!qdisc)  in qdisc_put()
1090 	if (qdisc->flags & TCQ_F_BUILTIN ||  in qdisc_put()
1091 	    !refcount_dec_and_test(&qdisc->refcnt))  in qdisc_put()
1094 	__qdisc_destroy(qdisc);  in qdisc_put()
1103 void qdisc_put_unlocked(struct Qdisc *qdisc)  in qdisc_put_unlocked()  argument
1105 	if (qdisc->flags & TCQ_F_BUILTIN ||  in qdisc_put_unlocked()
1106 	    !refcount_dec_and_rtnl_lock(&qdisc->refcnt))  in qdisc_put_unlocked()
1109 	__qdisc_destroy(qdisc);  in qdisc_put_unlocked()
1116 			      struct Qdisc *qdisc)  in dev_graft_qdisc()  argument
1125 	if (qdisc == NULL)  in dev_graft_qdisc()
1126 		qdisc = &noop_qdisc;  in dev_graft_qdisc()
1127 	rcu_assign_pointer(dev_queue->qdisc_sleeping, qdisc);  in dev_graft_qdisc()
1128 	rcu_assign_pointer(dev_queue->qdisc, &noop_qdisc);  in dev_graft_qdisc()
1140 	struct Qdisc *qdisc = rtnl_dereference(dev_queue->qdisc_sleeping);  in shutdown_scheduler_queue()  local
1143 	if (qdisc) {  in shutdown_scheduler_queue()
1144 		rcu_assign_pointer(dev_queue->qdisc, qdisc_default);  in shutdown_scheduler_queue()
1147 		qdisc_put(qdisc);  in shutdown_scheduler_queue()
1155 	struct Qdisc *qdisc;  in attach_one_default_qdisc()  local
1163 	qdisc = qdisc_create_dflt(dev_queue, ops, TC_H_ROOT, NULL);  in attach_one_default_qdisc()
1164 	if (!qdisc)  in attach_one_default_qdisc()
1168 		qdisc->flags |= TCQ_F_ONETXQUEUE | TCQ_F_NOPARENT;  in attach_one_default_qdisc()
1169 	rcu_assign_pointer(dev_queue->qdisc_sleeping, qdisc);  in attach_one_default_qdisc()
1175 	struct Qdisc *qdisc;  in attach_default_qdiscs()  local
1182 		qdisc = rtnl_dereference(txq->qdisc_sleeping);  in attach_default_qdiscs()
1183 		rcu_assign_pointer(dev->qdisc, qdisc);  in attach_default_qdiscs()
1184 		qdisc_refcount_inc(qdisc);  in attach_default_qdiscs()
1186 		qdisc = qdisc_create_dflt(txq, &mq_qdisc_ops, TC_H_ROOT, NULL);  in attach_default_qdiscs()
1187 		if (qdisc) {  in attach_default_qdiscs()
1188 			rcu_assign_pointer(dev->qdisc, qdisc);  in attach_default_qdiscs()
1189 			qdisc->ops->attach(qdisc);  in attach_default_qdiscs()
1192 	qdisc = rtnl_dereference(dev->qdisc);  in attach_default_qdiscs()
1195 	if (qdisc == &noop_qdisc) {  in attach_default_qdiscs()
1201 		qdisc = rtnl_dereference(txq->qdisc_sleeping);  in attach_default_qdiscs()
1202 		rcu_assign_pointer(dev->qdisc, qdisc);  in attach_default_qdiscs()
1203 		qdisc_refcount_inc(qdisc);  in attach_default_qdiscs()
1208 	if (qdisc != &noop_qdisc)  in attach_default_qdiscs()
1209 		qdisc_hash_add(qdisc, false);  in attach_default_qdiscs()
1223 	rcu_assign_pointer(dev_queue->qdisc, new_qdisc);  in transition_one_qdisc()
1239 	if (rtnl_dereference(dev->qdisc) == &noop_qdisc)  in dev_activate()
1258 static void qdisc_deactivate(struct Qdisc *qdisc)  in qdisc_deactivate()  argument
1260 	if (qdisc->flags & TCQ_F_BUILTIN)  in qdisc_deactivate()
1263 	set_bit(__QDISC_STATE_DEACTIVATED, &qdisc->state);  in qdisc_deactivate()
1271 	struct Qdisc *qdisc;  in dev_deactivate_queue()  local
1273 	qdisc = rtnl_dereference(dev_queue->qdisc);  in dev_deactivate_queue()
1274 	if (qdisc) {  in dev_deactivate_queue()
1275 		qdisc_deactivate(qdisc);  in dev_deactivate_queue()
1276 		rcu_assign_pointer(dev_queue->qdisc, qdisc_default);  in dev_deactivate_queue()
1284 	struct Qdisc *qdisc;  in dev_reset_queue()  local
1287 	qdisc = rtnl_dereference(dev_queue->qdisc_sleeping);  in dev_reset_queue()
1288 	if (!qdisc)  in dev_reset_queue()
1291 	nolock = qdisc->flags & TCQ_F_NOLOCK;  in dev_reset_queue()
1294 		spin_lock_bh(&qdisc->seqlock);  in dev_reset_queue()
1295 	spin_lock_bh(qdisc_lock(qdisc));  in dev_reset_queue()
1297 	qdisc_reset(qdisc);  in dev_reset_queue()
1299 	spin_unlock_bh(qdisc_lock(qdisc));  in dev_reset_queue()
1301 		clear_bit(__QDISC_STATE_MISSED, &qdisc->state);  in dev_reset_queue()
1302 		clear_bit(__QDISC_STATE_DRAINING, &qdisc->state);  in dev_reset_queue()
1303 		spin_unlock_bh(&qdisc->seqlock);  in dev_reset_queue()
1394 	struct Qdisc *qdisc = rtnl_dereference(dev_queue->qdisc_sleeping);  in qdisc_change_tx_queue_len()  local
1395 	const struct Qdisc_ops *ops = qdisc->ops;  in qdisc_change_tx_queue_len()
1398 		return ops->change_tx_queue_len(qdisc, dev->tx_queue_len);  in qdisc_change_tx_queue_len()
1405 	struct Qdisc *qdisc = rtnl_dereference(dev->qdisc);  in dev_qdisc_change_real_num_tx()  local
1407 	if (qdisc->ops->change_real_num_tx)  in dev_qdisc_change_real_num_tx()
1408 		qdisc->ops->change_real_num_tx(qdisc, new_real_tx);  in dev_qdisc_change_real_num_tx()
1415 	struct Qdisc *qdisc;  in mq_change_real_num_tx()  local
1419 		qdisc = rtnl_dereference(netdev_get_tx_queue(dev, i)->qdisc_sleeping);  in mq_change_real_num_tx()
1423 		if (qdisc != &noop_qdisc && !qdisc->handle)  in mq_change_real_num_tx()
1424 			qdisc_hash_del(qdisc);  in mq_change_real_num_tx()
1427 		qdisc = rtnl_dereference(netdev_get_tx_queue(dev, i)->qdisc_sleeping);  in mq_change_real_num_tx()
1428 		if (qdisc != &noop_qdisc && !qdisc->handle)  in mq_change_real_num_tx()
1429 			qdisc_hash_add(qdisc, false);  in mq_change_real_num_tx()
1461 	struct Qdisc *qdisc = _qdisc;  in dev_init_scheduler_queue()  local
1463 	rcu_assign_pointer(dev_queue->qdisc, qdisc);  in dev_init_scheduler_queue()
1464 	rcu_assign_pointer(dev_queue->qdisc_sleeping, qdisc);  in dev_init_scheduler_queue()
1469 	rcu_assign_pointer(dev->qdisc, &noop_qdisc);  in dev_init_scheduler()
1482 	qdisc_put(rtnl_dereference(dev->qdisc));  in dev_shutdown()
1483 	rcu_assign_pointer(dev->qdisc, &noop_qdisc);  in dev_shutdown()
1597 void mini_qdisc_pair_init(struct mini_Qdisc_pair *miniqp, struct Qdisc *qdisc,  in mini_qdisc_pair_init()  argument
1600 	miniqp->miniq1.cpu_bstats = qdisc->cpu_bstats;  in mini_qdisc_pair_init()
1601 	miniqp->miniq1.cpu_qstats = qdisc->cpu_qstats;  in mini_qdisc_pair_init()
1602 	miniqp->miniq2.cpu_bstats = qdisc->cpu_bstats;  in mini_qdisc_pair_init()
1603 	miniqp->miniq2.cpu_qstats = qdisc->cpu_qstats;  in mini_qdisc_pair_init()