Skip to content

Commit

Permalink
controller: Rename flow_output node to controller_output
Browse files Browse the repository at this point in the history
The keep the naming of the "dummy" nodes aligned use
controller_output, because we have northd_output in northd.

Signed-off-by: Ales Musil <[email protected]>
Signed-off-by: Dumitru Ceara <[email protected]>
  • Loading branch information
almusil authored and dceara committed Mar 8, 2023
1 parent be2f0c9 commit 6d59ad9
Showing 1 changed file with 15 additions and 14 deletions.
29 changes: 15 additions & 14 deletions controller/ovn-controller.c
Original file line number Diff line number Diff line change
Expand Up @@ -4306,35 +4306,36 @@ pflow_output_debug_handler(struct engine_node *node, void *data)
}

static void *
en_flow_output_init(struct engine_node *node OVS_UNUSED,
struct engine_arg *arg OVS_UNUSED)
en_controller_output_init(struct engine_node *node OVS_UNUSED,
struct engine_arg *arg OVS_UNUSED)
{
return NULL;
}

static void
en_flow_output_cleanup(void *data OVS_UNUSED)
en_controller_output_cleanup(void *data OVS_UNUSED)
{

}

static void
en_flow_output_run(struct engine_node *node OVS_UNUSED, void *data OVS_UNUSED)
en_controller_output_run(struct engine_node *node OVS_UNUSED,
void *data OVS_UNUSED)
{
engine_set_node_state(node, EN_UPDATED);
}

static bool
flow_output_pflow_output_handler(struct engine_node *node,
void *data OVS_UNUSED)
controller_output_pflow_output_handler(struct engine_node *node,
void *data OVS_UNUSED)
{
engine_set_node_state(node, EN_UPDATED);
return true;
}

static bool
flow_output_lflow_output_handler(struct engine_node *node,
void *data OVS_UNUSED)
controller_output_lflow_output_handler(struct engine_node *node,
void *data OVS_UNUSED)
{
engine_set_node_state(node, EN_UPDATED);
return true;
Expand Down Expand Up @@ -4606,7 +4607,7 @@ main(int argc, char *argv[])
ENGINE_NODE(postponed_ports, "postponed_ports");
ENGINE_NODE(pflow_output, "physical_flow_output");
ENGINE_NODE_WITH_CLEAR_TRACK_DATA(lflow_output, "logical_flow_output");
ENGINE_NODE(flow_output, "flow_output");
ENGINE_NODE(controller_output, "controller_output");
ENGINE_NODE_WITH_CLEAR_TRACK_DATA(addr_sets, "addr_sets");
ENGINE_NODE_WITH_CLEAR_TRACK_DATA(port_groups, "port_groups");
ENGINE_NODE(northd_options, "northd_options");
Expand Down Expand Up @@ -4784,16 +4785,16 @@ main(int argc, char *argv[])
engine_add_input(&en_runtime_data, &en_ovs_interface_shadow,
runtime_data_ovs_interface_shadow_handler);

engine_add_input(&en_flow_output, &en_lflow_output,
flow_output_lflow_output_handler);
engine_add_input(&en_flow_output, &en_pflow_output,
flow_output_pflow_output_handler);
engine_add_input(&en_controller_output, &en_lflow_output,
controller_output_lflow_output_handler);
engine_add_input(&en_controller_output, &en_pflow_output,
controller_output_pflow_output_handler);

struct engine_arg engine_arg = {
.sb_idl = ovnsb_idl_loop.idl,
.ovs_idl = ovs_idl_loop.idl,
};
engine_init(&en_flow_output, &engine_arg);
engine_init(&en_controller_output, &engine_arg);

engine_ovsdb_node_add_index(&en_sb_chassis, "name", sbrec_chassis_by_name);
engine_ovsdb_node_add_index(&en_sb_multicast_group, "name_datapath",
Expand Down

0 comments on commit 6d59ad9

Please sign in to comment.