Lines Matching defs:flow
84 * Included flow support. 030802 ANK.
254 /* flow flag bits */
255 #define F_INIT (1<<0) /* flow has been initialized */
403 unsigned int curfl; /* current sequenced flow (state)*/
2200 static inline int f_seen(const struct pktgen_dev *pkt_dev, int flow)
2202 return !!(pkt_dev->flows[flow].flags & F_INIT);
2207 int flow = pkt_dev->curfl;
2210 if (pkt_dev->flows[flow].count >= pkt_dev->lflow) {
2212 pkt_dev->flows[flow].count = 0;
2213 pkt_dev->flows[flow].flags = 0;
2219 flow = prandom_u32() % pkt_dev->cflows;
2220 pkt_dev->curfl = flow;
2222 if (pkt_dev->flows[flow].count > pkt_dev->lflow) {
2223 pkt_dev->flows[flow].count = 0;
2224 pkt_dev->flows[flow].flags = 0;
2237 static void get_ipsec_sa(struct pktgen_dev *pkt_dev, int flow)
2239 struct xfrm_state *x = pkt_dev->flows[flow].x;
2258 pkt_dev->flows[flow].x = x;
2296 int flow = 0;
2299 flow = f_pick(pkt_dev);
2415 if (pkt_dev->cflows && f_seen(pkt_dev, flow)) {
2416 pkt_dev->cur_daddr = pkt_dev->flows[flow].cur_daddr;
2445 pkt_dev->flows[flow].flags |= F_INIT;
2446 pkt_dev->flows[flow].cur_daddr =
2450 get_ipsec_sa(pkt_dev, flow);
2487 pkt_dev->flows[flow].count++;
2936 *(__be32 *) iph = htonl(0x60000000); /* Version + flow */
2939 /* Version + traffic class + flow (0) */