Lines Matching refs:qdisc
126 static inline void qdisc_refcount_inc(struct Qdisc *qdisc) in qdisc_refcount_inc() argument
128 if (qdisc->flags & TCQ_F_BUILTIN) in qdisc_refcount_inc()
130 refcount_inc(&qdisc->refcnt); in qdisc_refcount_inc()
137 static inline struct Qdisc *qdisc_refcount_inc_nz(struct Qdisc *qdisc) in qdisc_refcount_inc_nz() argument
139 if (qdisc->flags & TCQ_F_BUILTIN) in qdisc_refcount_inc_nz()
140 return qdisc; in qdisc_refcount_inc_nz()
141 if (refcount_inc_not_zero(&qdisc->refcnt)) in qdisc_refcount_inc_nz()
142 return qdisc; in qdisc_refcount_inc_nz()
146 static inline bool qdisc_is_running(struct Qdisc *qdisc) in qdisc_is_running() argument
148 if (qdisc->flags & TCQ_F_NOLOCK) in qdisc_is_running()
149 return spin_is_locked(&qdisc->seqlock); in qdisc_is_running()
150 return (raw_read_seqcount(&qdisc->running) & 1) ? true : false; in qdisc_is_running()
153 static inline bool nolock_qdisc_is_empty(const struct Qdisc *qdisc) in nolock_qdisc_is_empty() argument
155 return !(READ_ONCE(qdisc->state) & QDISC_STATE_NON_EMPTY); in nolock_qdisc_is_empty()
163 static inline bool qdisc_is_empty(const struct Qdisc *qdisc) in qdisc_is_empty() argument
165 if (qdisc_is_percpu_stats(qdisc)) in qdisc_is_empty()
166 return nolock_qdisc_is_empty(qdisc); in qdisc_is_empty()
167 return !READ_ONCE(qdisc->q.qlen); in qdisc_is_empty()
170 static inline bool qdisc_run_begin(struct Qdisc *qdisc) in qdisc_run_begin() argument
172 if (qdisc->flags & TCQ_F_NOLOCK) { in qdisc_run_begin()
173 if (spin_trylock(&qdisc->seqlock)) in qdisc_run_begin()
187 if (test_bit(__QDISC_STATE_MISSED, &qdisc->state)) in qdisc_run_begin()
197 set_bit(__QDISC_STATE_MISSED, &qdisc->state); in qdisc_run_begin()
208 return spin_trylock(&qdisc->seqlock); in qdisc_run_begin()
209 } else if (qdisc_is_running(qdisc)) { in qdisc_run_begin()
215 raw_write_seqcount_begin(&qdisc->running); in qdisc_run_begin()
216 seqcount_acquire(&qdisc->running.dep_map, 0, 1, _RET_IP_); in qdisc_run_begin()
220 static inline void qdisc_run_end(struct Qdisc *qdisc) in qdisc_run_end() argument
222 if (qdisc->flags & TCQ_F_NOLOCK) { in qdisc_run_end()
223 spin_unlock(&qdisc->seqlock); in qdisc_run_end()
226 &qdisc->state))) in qdisc_run_end()
227 __netif_schedule(qdisc); in qdisc_run_end()
229 write_seqcount_end(&qdisc->running); in qdisc_run_end()
233 static inline bool qdisc_may_bulk(const struct Qdisc *qdisc) in qdisc_may_bulk() argument
235 return qdisc->flags & TCQ_F_ONETXQUEUE; in qdisc_may_bulk()
544 static inline spinlock_t *qdisc_lock(struct Qdisc *qdisc) in qdisc_lock() argument
546 return &qdisc->q.lock; in qdisc_lock()
549 static inline struct Qdisc *qdisc_root(const struct Qdisc *qdisc) in qdisc_root() argument
551 struct Qdisc *q = rcu_dereference_rtnl(qdisc->dev_queue->qdisc); in qdisc_root()
556 static inline struct Qdisc *qdisc_root_bh(const struct Qdisc *qdisc) in qdisc_root_bh() argument
558 return rcu_dereference_bh(qdisc->dev_queue->qdisc); in qdisc_root_bh()
561 static inline struct Qdisc *qdisc_root_sleeping(const struct Qdisc *qdisc) in qdisc_root_sleeping() argument
563 return qdisc->dev_queue->qdisc_sleeping; in qdisc_root_sleeping()
577 static inline spinlock_t *qdisc_root_lock(const struct Qdisc *qdisc) in qdisc_root_lock() argument
579 struct Qdisc *root = qdisc_root(qdisc); in qdisc_root_lock()
585 static inline spinlock_t *qdisc_root_sleeping_lock(const struct Qdisc *qdisc) in qdisc_root_sleeping_lock() argument
587 struct Qdisc *root = qdisc_root_sleeping(qdisc); in qdisc_root_sleeping_lock()
593 static inline seqcount_t *qdisc_root_sleeping_running(const struct Qdisc *qdisc) in qdisc_root_sleeping_running() argument
595 struct Qdisc *root = qdisc_root_sleeping(qdisc); in qdisc_root_sleeping_running()
601 static inline struct net_device *qdisc_dev(const struct Qdisc *qdisc) in qdisc_dev() argument
603 return qdisc->dev_queue->dev; in qdisc_dev()
693 struct Qdisc *qdisc);
694 void qdisc_reset(struct Qdisc *qdisc);
695 void qdisc_put(struct Qdisc *qdisc);
696 void qdisc_put_unlocked(struct Qdisc *qdisc);
697 void qdisc_tree_reduce_backlog(struct Qdisc *qdisc, int n, int len);
725 void qdisc_free(struct Qdisc *qdisc);
756 struct Qdisc *qdisc; in qdisc_reset_all_tx_gt() local
759 qdisc = rtnl_dereference(netdev_get_tx_queue(dev, i)->qdisc); in qdisc_reset_all_tx_gt()
760 if (qdisc) { in qdisc_reset_all_tx_gt()
761 spin_lock_bh(qdisc_lock(qdisc)); in qdisc_reset_all_tx_gt()
762 qdisc_reset(qdisc); in qdisc_reset_all_tx_gt()
763 spin_unlock_bh(qdisc_lock(qdisc)); in qdisc_reset_all_tx_gt()
776 const struct Qdisc *q = rcu_dereference(txq->qdisc); in qdisc_all_tx_empty()
794 if (rcu_access_pointer(txq->qdisc) != txq->qdisc_sleeping) in qdisc_tx_changing()
807 if (rcu_access_pointer(txq->qdisc) != &noop_qdisc) in qdisc_tx_is_noop()
1339 void mini_qdisc_pair_init(struct mini_Qdisc_pair *miniqp, struct Qdisc *qdisc,