Lines Matching defs:flow
84 * Included flow support. 030802 ANK.
263 /* flow flag bits */
264 #define F_INIT (1<<0) /* flow has been initialized */
419 unsigned int curfl; /* current sequenced flow (state)*/
2308 static inline int f_seen(const struct pktgen_dev *pkt_dev, int flow)
2310 return !!(pkt_dev->flows[flow].flags & F_INIT);
2315 int flow = pkt_dev->curfl;
2318 if (pkt_dev->flows[flow].count >= pkt_dev->lflow) {
2320 pkt_dev->flows[flow].count = 0;
2321 pkt_dev->flows[flow].flags = 0;
2327 flow = get_random_u32_below(pkt_dev->cflows);
2328 pkt_dev->curfl = flow;
2330 if (pkt_dev->flows[flow].count > pkt_dev->lflow) {
2331 pkt_dev->flows[flow].count = 0;
2332 pkt_dev->flows[flow].flags = 0;
2345 static void get_ipsec_sa(struct pktgen_dev *pkt_dev, int flow)
2347 struct xfrm_state *x = pkt_dev->flows[flow].x;
2366 pkt_dev->flows[flow].x = x;
2402 int flow = 0;
2405 flow = f_pick(pkt_dev);
2519 if (pkt_dev->cflows && f_seen(pkt_dev, flow)) {
2520 pkt_dev->cur_daddr = pkt_dev->flows[flow].cur_daddr;
2548 pkt_dev->flows[flow].flags |= F_INIT;
2549 pkt_dev->flows[flow].cur_daddr =
2553 get_ipsec_sa(pkt_dev, flow);
2597 pkt_dev->flows[flow].count++;
3075 *(__be32 *) iph = htonl(0x60000000); /* Version + flow */
3078 /* Version + traffic class + flow (0) */