Lines Matching refs:flow
90 * Included flow support. 030802 ANK.
236 /* flow flag bits */
237 #define F_INIT (1<<0) /* flow has been initialized */
385 unsigned int curfl; /* current sequenced flow (state)*/
2236 static inline int f_seen(const struct pktgen_dev *pkt_dev, int flow)
2238 return !!(pkt_dev->flows[flow].flags & F_INIT);
2243 int flow = pkt_dev->curfl;
2246 if (pkt_dev->flows[flow].count >= pkt_dev->lflow) {
2248 pkt_dev->flows[flow].count = 0;
2249 pkt_dev->flows[flow].flags = 0;
2255 flow = prandom_u32() % pkt_dev->cflows;
2256 pkt_dev->curfl = flow;
2258 if (pkt_dev->flows[flow].count > pkt_dev->lflow) {
2259 pkt_dev->flows[flow].count = 0;
2260 pkt_dev->flows[flow].flags = 0;
2273 static void get_ipsec_sa(struct pktgen_dev *pkt_dev, int flow)
2275 struct xfrm_state *x = pkt_dev->flows[flow].x;
2294 pkt_dev->flows[flow].x = x;
2332 int flow = 0;
2335 flow = f_pick(pkt_dev);
2451 if (pkt_dev->cflows && f_seen(pkt_dev, flow)) {
2452 pkt_dev->cur_daddr = pkt_dev->flows[flow].cur_daddr;
2481 pkt_dev->flows[flow].flags |= F_INIT;
2482 pkt_dev->flows[flow].cur_daddr =
2486 get_ipsec_sa(pkt_dev, flow);
2523 pkt_dev->flows[flow].count++;
2960 *(__be32 *) iph = htonl(0x60000000); /* Version + flow */
2963 /* Version + traffic class + flow (0) */