Lines Matching refs:fq_flow
68 struct fq_flow { struct
80 struct fq_flow *next; /* next pointer in RR lists, or &detached */ argument
87 struct fq_flow *first; argument
88 struct fq_flow *last;
100 struct fq_flow internal; /* for non classified or high prio packets */
128 static struct fq_flow detached, throttled;
130 static void fq_flow_set_detached(struct fq_flow *f) in fq_flow_set_detached()
136 static bool fq_flow_is_detached(const struct fq_flow *f) in fq_flow_is_detached()
141 static bool fq_flow_is_throttled(const struct fq_flow *f) in fq_flow_is_throttled()
146 static void fq_flow_add_tail(struct fq_flow_head *head, struct fq_flow *flow) in fq_flow_add_tail()
156 static void fq_flow_unset_throttled(struct fq_sched_data *q, struct fq_flow *f) in fq_flow_unset_throttled()
163 static void fq_flow_set_throttled(struct fq_sched_data *q, struct fq_flow *f) in fq_flow_set_throttled()
168 struct fq_flow *aux; in fq_flow_set_throttled()
171 aux = rb_entry(parent, struct fq_flow, rate_node); in fq_flow_set_throttled()
195 static bool fq_gc_candidate(const struct fq_flow *f) in fq_gc_candidate()
205 struct fq_flow *f, *tofree[FQ_GC_MAX]; in fq_gc()
214 f = rb_entry(parent, struct fq_flow, fq_node); in fq_gc()
234 struct fq_flow *f = tofree[--fcnt]; in fq_gc()
241 static struct fq_flow *fq_classify(struct sk_buff *skb, struct fq_sched_data *q) in fq_classify()
246 struct fq_flow *f; in fq_classify()
293 f = rb_entry(parent, struct fq_flow, fq_node); in fq_classify()
337 static struct sk_buff *fq_peek(struct fq_flow *flow) in fq_peek()
353 static void fq_erase_head(struct Qdisc *sch, struct fq_flow *flow, in fq_erase_head()
365 static struct sk_buff *fq_dequeue_head(struct Qdisc *sch, struct fq_flow *flow) in fq_dequeue_head()
379 static void flow_queue_add(struct fq_flow *flow, struct sk_buff *skb) in flow_queue_add()
417 struct fq_flow *f; in fq_enqueue()
473 struct fq_flow *f = rb_entry(p, struct fq_flow, rate_node); in fq_check_throttled()
488 struct fq_flow *f; in fq_dequeue()
603 static void fq_flow_purge(struct fq_flow *flow) in fq_flow_purge()
624 struct fq_flow *f; in fq_reset()
638 f = rb_entry(p, struct fq_flow, fq_node); in fq_reset()
660 struct fq_flow *of, *nf; in fq_rehash()
668 of = rb_entry(op, struct fq_flow, fq_node); in fq_rehash()
681 nf = rb_entry(parent, struct fq_flow, fq_node); in fq_rehash()
982 sizeof(struct fq_flow), in fq_module_init()