Lines Matching refs:flow

21 	struct rte_flow *flow;  in bond_flow_alloc()  local
37 flow = rte_zmalloc_socket(NULL, offsetof(struct rte_flow, rule) + ret, in bond_flow_alloc()
39 if (unlikely(flow == NULL)) { in bond_flow_alloc()
43 ret = rte_flow_conv(RTE_FLOW_CONV_OP_RULE, &flow->rule, ret, &rule, in bond_flow_alloc()
49 rte_free(flow); in bond_flow_alloc()
52 return flow; in bond_flow_alloc()
56 bond_flow_release(struct rte_flow **flow) in bond_flow_release() argument
58 rte_free(*flow); in bond_flow_release()
59 *flow = NULL; in bond_flow_release()
91 struct rte_flow *flow; in bond_flow_create() local
94 flow = bond_flow_alloc(dev->data->numa_node, attr, patterns, actions); in bond_flow_create()
95 if (unlikely(flow == NULL)) { in bond_flow_create()
101 flow->flows[i] = rte_flow_create(internals->members[i].port_id, in bond_flow_create()
103 if (unlikely(flow->flows[i] == NULL)) { in bond_flow_create()
109 TAILQ_INSERT_TAIL(&internals->flow_list, flow, next); in bond_flow_create()
110 return flow; in bond_flow_create()
114 if (flow->flows[i] != NULL) in bond_flow_create()
116 flow->flows[i], err); in bond_flow_create()
118 bond_flow_release(&flow); in bond_flow_create()
123 bond_flow_destroy(struct rte_eth_dev *dev, struct rte_flow *flow, in bond_flow_destroy() argument
133 if (unlikely(flow->flows[i] == NULL)) in bond_flow_destroy()
136 flow->flows[i], err); in bond_flow_destroy()
143 TAILQ_REMOVE(&internals->flow_list, flow, next); in bond_flow_destroy()
144 bond_flow_release(&flow); in bond_flow_destroy()
152 struct rte_flow *flow; in bond_flow_flush() local
160 RTE_TAILQ_FOREACH_SAFE(flow, &internals->flow_list, next, tmp) { in bond_flow_flush()
161 lret = bond_flow_destroy(dev, flow, err); in bond_flow_flush()
171 bond_flow_query_count(struct rte_eth_dev *dev, struct rte_flow *flow, in bond_flow_query_count() argument
188 flow->flows[i], action, in bond_flow_query_count()
208 bond_flow_query(struct rte_eth_dev *dev, struct rte_flow *flow, in bond_flow_query() argument
214 return bond_flow_query_count(dev, flow, action, arg, err); in bond_flow_query()