Lines Matching defs:rflow
4993 * @rflow: Specific flow to check activity.
4994 * @flow_table: per-queue flowtable that @rflow belongs to.
4995 * @cpu: CPU saved in @rflow.
5002 static bool rps_flow_is_active(struct rps_dev_flow *rflow,
5013 flow_last_active = READ_ONCE(rflow->last_qtail);
5022 struct rps_dev_flow *rflow, u16 next_cpu, u32 hash)
5067 old_rflow = rflow;
5068 rflow = tmp_rflow;
5069 WRITE_ONCE(rflow->filter, rc);
5070 WRITE_ONCE(rflow->hash, hash);
5077 rps_input_queue_tail_save(&rflow->last_qtail, head);
5080 WRITE_ONCE(rflow->cpu, next_cpu);
5081 return rflow;
5127 struct rps_dev_flow *rflow;
5143 rflow = &flow_table->flows[rfs_slot(hash, flow_table)];
5144 tcpu = rflow->cpu;
5160 rflow->last_qtail)) >= 0)) {
5162 rflow = set_rps_cpu(dev, skb, rflow, next_cpu, hash);
5166 *rflowp = rflow;
5204 struct rps_dev_flow *rflow;
5212 rflow = &flow_table->flows[flow_id];
5213 cpu = READ_ONCE(rflow->cpu);
5214 if (READ_ONCE(rflow->filter) == filter_id &&
5215 rps_flow_is_active(rflow, flow_table, cpu))
5674 struct rps_dev_flow voidflow, *rflow = &voidflow;
5679 cpu = get_rps_cpu(skb->dev, skb, &rflow);
5683 ret = enqueue_to_backlog(skb, cpu, &rflow->last_qtail);
6370 struct rps_dev_flow voidflow, *rflow = &voidflow;
6371 int cpu = get_rps_cpu(skb->dev, skb, &rflow);
6374 ret = enqueue_to_backlog(skb, cpu, &rflow->last_qtail);
6403 struct rps_dev_flow voidflow, *rflow = &voidflow;
6404 int cpu = get_rps_cpu(skb->dev, skb, &rflow);
6409 enqueue_to_backlog(skb, cpu, &rflow->last_qtail);