In physical_run, there are multiple places where OF flows can be
produced each cycle. Because the desired flow table may not have
been completely cleared first, remove flows created during previous
runs before creating new flows. This avoid collisions.
Signed-off-by: Ryan Moats <rmo...@us.ibm.com>
---
ovn/controller/physical.c | 14 ++++++++++++++
1 file changed, 14 insertions(+)
diff --git a/ovn/controller/physical.c b/ovn/controller/physical.c
index e5df4f2..2e9fb73 100644
--- a/ovn/controller/physical.c
+++ b/ovn/controller/physical.c
@@ -603,6 +603,7 @@ physical_run(struct controller_ctx *ctx, enum mf_field_id
mff_ovn_geneve,
if (!hc_uuid) {
hc_uuid = xmalloc(sizeof(struct uuid));
uuid_generate(hc_uuid);
+ VLOG_INFO("Hard coded uuid is "UUID_FMT, UUID_ARGS(hc_uuid));
}
/* This bool tracks physical mapping changes. */
@@ -750,6 +751,10 @@ physical_run(struct controller_ctx *ctx, enum mf_field_id
mff_ovn_geneve,
const struct sbrec_port_binding *binding;
if (full_binding_processing) {
SBREC_PORT_BINDING_FOR_EACH (binding, ctx->ovnsb_idl) {
+ /* Because it is possible in the above code to enter this
+ * for loop without having cleared the flow table first, we
+ * should clear the old flows to avoid collisions. */
+ ofctrl_remove_flows(&binding->header_.uuid);
consider_port_binding(mff_ovn_geneve, ct_zones, local_datapaths,
patched_datapaths, binding, &ofpacts);
}
@@ -773,12 +778,21 @@ physical_run(struct controller_ctx *ctx, enum mf_field_id
mff_ovn_geneve,
struct ofpbuf remote_ofpacts;
ofpbuf_init(&remote_ofpacts, 0);
SBREC_MULTICAST_GROUP_FOR_EACH (mc, ctx->ovnsb_idl) {
+ /* As multicast groups are always reprocessed each time,
+ * the first step is to clean the old flows for the group
+ * so that we avoid warning messages on collisions. */
+ ofctrl_remove_flows(&mc->header_.uuid);
consider_mc_group(mff_ovn_geneve, ct_zones,
local_datapaths, mc, &ofpacts, &remote_ofpacts);
}
ofpbuf_uninit(&remote_ofpacts);
+ /* Because flows using the hard-coded uuid are recalculated each
+ * cycle, let's first remove the old flows to avoid duplicate flow
+ * warnings. */
+ ofctrl_remove_flows(hc_uuid);
+
/* Table 0, priority 100.
* ======================
*
--
1.9.1
_______________________________________________
dev mailing list
dev@openvswitch.org
http://openvswitch.org/mailman/listinfo/dev
