Lines Matching refs:flow
2287 static inline int f_seen(const struct pktgen_dev *pkt_dev, int flow) in f_seen() argument
2289 return !!(pkt_dev->flows[flow].flags & F_INIT); in f_seen()
2294 int flow = pkt_dev->curfl; in f_pick() local
2297 if (pkt_dev->flows[flow].count >= pkt_dev->lflow) { in f_pick()
2299 pkt_dev->flows[flow].count = 0; in f_pick()
2300 pkt_dev->flows[flow].flags = 0; in f_pick()
2306 flow = prandom_u32() % pkt_dev->cflows; in f_pick()
2307 pkt_dev->curfl = flow; in f_pick()
2309 if (pkt_dev->flows[flow].count > pkt_dev->lflow) { in f_pick()
2310 pkt_dev->flows[flow].count = 0; in f_pick()
2311 pkt_dev->flows[flow].flags = 0; in f_pick()
2324 static void get_ipsec_sa(struct pktgen_dev *pkt_dev, int flow) in get_ipsec_sa() argument
2326 struct xfrm_state *x = pkt_dev->flows[flow].x; in get_ipsec_sa()
2345 pkt_dev->flows[flow].x = x; in get_ipsec_sa()
2383 int flow = 0; in mod_cur_headers() local
2386 flow = f_pick(pkt_dev); in mod_cur_headers()
2502 if (pkt_dev->cflows && f_seen(pkt_dev, flow)) { in mod_cur_headers()
2503 pkt_dev->cur_daddr = pkt_dev->flows[flow].cur_daddr; in mod_cur_headers()
2532 pkt_dev->flows[flow].flags |= F_INIT; in mod_cur_headers()
2533 pkt_dev->flows[flow].cur_daddr = in mod_cur_headers()
2537 get_ipsec_sa(pkt_dev, flow); in mod_cur_headers()
2574 pkt_dev->flows[flow].count++; in mod_cur_headers()