Lines Matching refs:remote_flow
130 struct rte_flow *remote_flow; /* associated remote flow */ member
1361 struct rte_flow *remote_flow = NULL; in tap_flow_create() local
1419 remote_flow = rte_zmalloc(__func__, sizeof(struct rte_flow), 0); in tap_flow_create()
1420 if (!remote_flow) { in tap_flow_create()
1426 msg = &remote_flow->msg; in tap_flow_create()
1432 tap_flow_set_handle(remote_flow); in tap_flow_create()
1434 error, remote_flow, TCA_EGRESS_REDIR)) { in tap_flow_create()
1458 flow->remote_flow = remote_flow; in tap_flow_create()
1462 if (remote_flow) in tap_flow_create()
1463 rte_free(remote_flow); in tap_flow_create()
1486 struct rte_flow *remote_flow = flow->remote_flow; in tap_flow_destroy_pmd() local
1513 if (remote_flow) { in tap_flow_destroy_pmd()
1514 remote_flow->msg.nh.nlmsg_flags = NLM_F_REQUEST | NLM_F_ACK; in tap_flow_destroy_pmd()
1515 remote_flow->msg.nh.nlmsg_type = RTM_DELTFILTER; in tap_flow_destroy_pmd()
1517 ret = tap_nl_send(pmd->nlsk_fd, &remote_flow->msg.nh); in tap_flow_destroy_pmd()
1538 if (remote_flow) in tap_flow_destroy_pmd()
1539 rte_free(remote_flow); in tap_flow_destroy_pmd()
1589 struct rte_flow *remote_flow; in tap_flow_isolate() local
1592 remote_flow = LIST_FIRST(&pmd->implicit_flows); in tap_flow_isolate()
1593 if (!remote_flow) in tap_flow_isolate()
1600 if (remote_flow->msg.t.tcm_ifindex == pmd->if_index) in tap_flow_isolate()
1602 if (tap_flow_destroy_pmd(pmd, remote_flow, NULL) < 0) in tap_flow_isolate()
1682 struct rte_flow *remote_flow = NULL; in tap_flow_implicit_create() local
1696 remote_flow = rte_zmalloc(__func__, sizeof(struct rte_flow), 0); in tap_flow_implicit_create()
1697 if (!remote_flow) { in tap_flow_implicit_create()
1701 msg = &remote_flow->msg; in tap_flow_implicit_create()
1732 remote_flow->msg.t.tcm_handle = ISOLATE_HANDLE; in tap_flow_implicit_create()
1734 remote_flow->msg.t.tcm_handle = REMOTE_PROMISCUOUS_HANDLE; in tap_flow_implicit_create()
1736 tap_flow_set_handle(remote_flow); in tap_flow_implicit_create()
1738 remote_flow, implicit_rte_flows[idx].mirred)) { in tap_flow_implicit_create()
1757 LIST_INSERT_HEAD(&pmd->implicit_flows, remote_flow, next); in tap_flow_implicit_create()
1761 if (remote_flow) in tap_flow_implicit_create()
1762 rte_free(remote_flow); in tap_flow_implicit_create()
1779 struct rte_flow *remote_flow; in tap_flow_implicit_destroy() local
1783 for (remote_flow = LIST_FIRST(&pmd->implicit_flows); in tap_flow_implicit_destroy()
1784 remote_flow; in tap_flow_implicit_destroy()
1785 remote_flow = LIST_NEXT(remote_flow, next)) { in tap_flow_implicit_destroy()
1786 cur_prio = (remote_flow->msg.t.tcm_info >> 16) & PRIORITY_MASK; in tap_flow_implicit_destroy()
1789 return tap_flow_destroy_pmd(pmd, remote_flow, NULL); in tap_flow_implicit_destroy()
1802 struct rte_flow *remote_flow; in tap_flow_implicit_flush() local
1805 remote_flow = LIST_FIRST(&pmd->implicit_flows); in tap_flow_implicit_flush()
1806 if (tap_flow_destroy_pmd(pmd, remote_flow, error) < 0) in tap_flow_implicit_flush()