diff --git a/ovn/TODO b/ovn/TODO index 07d66da3ded..e46a7bcea6d 100644 --- a/ovn/TODO +++ b/ovn/TODO @@ -48,7 +48,7 @@ Currently, clients monitor the entire contents of a table. It might make sense to allow clients to monitor only rows that satisfy specific criteria, e.g. to allow an ovn-controller to - receive only Pipeline rows for logical networks on its hypervisor. + receive only Logical_Flow rows for logical networks on its hypervisor. *** Reducing redundant data and code within ovsdb-server. diff --git a/ovn/controller/automake.mk b/ovn/controller/automake.mk index 9ed6bec0eb1..9c9142008a6 100644 --- a/ovn/controller/automake.mk +++ b/ovn/controller/automake.mk @@ -6,12 +6,12 @@ ovn_controller_ovn_controller_SOURCES = \ ovn/controller/chassis.h \ ovn/controller/encaps.c \ ovn/controller/encaps.h \ + ovn/controller/lflow.c \ + ovn/controller/lflow.h \ ovn/controller/ofctrl.c \ ovn/controller/ofctrl.h \ ovn/controller/ovn-controller.c \ ovn/controller/ovn-controller.h \ - ovn/controller/pipeline.c \ - ovn/controller/pipeline.h \ ovn/controller/physical.c \ ovn/controller/physical.h ovn_controller_ovn_controller_LDADD = ovn/lib/libovn.la lib/libopenvswitch.la diff --git a/ovn/controller/pipeline.c b/ovn/controller/lflow.c similarity index 89% rename from ovn/controller/pipeline.c rename to ovn/controller/lflow.c index 867c32319bc..bb2e7d1f094 100644 --- a/ovn/controller/pipeline.c +++ b/ovn/controller/lflow.c @@ -14,7 +14,7 @@ */ #include -#include "pipeline.h" +#include "lflow.h" #include "dynamic-string.h" #include "ofctrl.h" #include "ofp-actions.h" @@ -26,11 +26,11 @@ #include "ovn/lib/ovn-sb-idl.h" #include "simap.h" -VLOG_DEFINE_THIS_MODULE(pipeline); +VLOG_DEFINE_THIS_MODULE(lflow); /* Symbol table. */ -/* Contains "struct expr_symbol"s for fields supported by OVN pipeline. */ +/* Contains "struct expr_symbol"s for fields supported by OVN lflows. */ static struct shash symtab; static void @@ -244,31 +244,31 @@ ldp_destroy(void) } void -pipeline_init(void) +lflow_init(void) { symtab_init(); } -/* Translates logical flows in the Pipeline table in the OVN_SB database +/* Translates logical flows in the Logical_Flow table in the OVN_SB database * into OpenFlow flows, adding the OpenFlow flows to 'flow_table'. * - * We put the Pipeline flows into OpenFlow tables 16 through 47 (inclusive). */ + * We put the logical flows into OpenFlow tables 16 through 47 (inclusive). */ void -pipeline_run(struct controller_ctx *ctx, struct hmap *flow_table) +lflow_run(struct controller_ctx *ctx, struct hmap *flow_table) { struct hmap flows = HMAP_INITIALIZER(&flows); uint32_t conj_id_ofs = 1; ldp_run(ctx); - const struct sbrec_pipeline *pipeline; - SBREC_PIPELINE_FOR_EACH (pipeline, ctx->ovnsb_idl) { - /* Find the "struct logical_datapath" asssociated with this Pipeline - * row. If there's no such struct, that must be because no logical - * ports are bound to that logical datapath, so there's no point in - * maintaining any flows for it anyway, so skip it. */ + const struct sbrec_logical_flow *lflow; + SBREC_LOGICAL_FLOW_FOR_EACH (lflow, ctx->ovnsb_idl) { + /* Find the "struct logical_datapath" asssociated with this + * Logical_Flow row. If there's no such struct, that must be because + * no logical ports are bound to that logical datapath, so there's no + * point in maintaining any flows for it anyway, so skip it. */ const struct logical_datapath *ldp; - ldp = ldp_lookup(&pipeline->logical_datapath); + ldp = ldp_lookup(&lflow->logical_datapath); if (!ldp) { continue; } @@ -281,13 +281,13 @@ pipeline_run(struct controller_ctx *ctx, struct hmap *flow_table) char *error; ofpbuf_use_stub(&ofpacts, ofpacts_stub, sizeof ofpacts_stub); - next_table_id = pipeline->table_id < 31 ? pipeline->table_id + 17 : 0; - error = actions_parse_string(pipeline->actions, &symtab, &ldp->ports, + next_table_id = lflow->table_id < 31 ? lflow->table_id + 17 : 0; + error = actions_parse_string(lflow->actions, &symtab, &ldp->ports, next_table_id, &ofpacts, &prereqs); if (error) { static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 1); VLOG_WARN_RL(&rl, "error parsing actions \"%s\": %s", - pipeline->actions, error); + lflow->actions, error); free(error); continue; } @@ -296,7 +296,7 @@ pipeline_run(struct controller_ctx *ctx, struct hmap *flow_table) struct hmap matches; struct expr *expr; - expr = expr_parse_string(pipeline->match, &symtab, &error); + expr = expr_parse_string(lflow->match, &symtab, &error); if (!error) { if (prereqs) { expr = expr_combine(EXPR_T_AND, expr, prereqs); @@ -307,7 +307,7 @@ pipeline_run(struct controller_ctx *ctx, struct hmap *flow_table) if (error) { static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 1); VLOG_WARN_RL(&rl, "error parsing match \"%s\": %s", - pipeline->match, error); + lflow->match, error); expr_destroy(prereqs); ofpbuf_uninit(&ofpacts); free(error); @@ -327,8 +327,8 @@ pipeline_run(struct controller_ctx *ctx, struct hmap *flow_table) m->match.flow.conj_id += conj_id_ofs; } if (!m->n) { - ofctrl_add_flow(flow_table, pipeline->table_id + 16, - pipeline->priority, &m->match, &ofpacts); + ofctrl_add_flow(flow_table, lflow->table_id + 16, + lflow->priority, &m->match, &ofpacts); } else { uint64_t conj_stubs[64 / 8]; struct ofpbuf conj; @@ -343,8 +343,8 @@ pipeline_run(struct controller_ctx *ctx, struct hmap *flow_table) dst->clause = src->clause; dst->n_clauses = src->n_clauses; } - ofctrl_add_flow(flow_table, pipeline->table_id + 16, - pipeline->priority, &m->match, &conj); + ofctrl_add_flow(flow_table, lflow->table_id + 16, + lflow->priority, &m->match, &conj); ofpbuf_uninit(&conj); } } @@ -357,7 +357,7 @@ pipeline_run(struct controller_ctx *ctx, struct hmap *flow_table) } void -pipeline_destroy(void) +lflow_destroy(void) { expr_symtab_destroy(&symtab); ldp_destroy(); diff --git a/ovn/controller/pipeline.h b/ovn/controller/lflow.h similarity index 61% rename from ovn/controller/pipeline.h rename to ovn/controller/lflow.h index 7d33341af37..4659004519f 100644 --- a/ovn/controller/pipeline.h +++ b/ovn/controller/lflow.h @@ -14,17 +14,18 @@ */ -#ifndef OVN_PIPELINE_H -#define OVN_PIPELINE_H 1 +#ifndef OVN_LFLOW_H +#define OVN_LFLOW_H 1 -/* Pipeline table translation to OpenFlow - * ====================================== +/* Logical_Flow table translation to OpenFlow + * ========================================== * - * The Pipeline table obtained from the OVN_Southbound database works in terms - * of logical entities, that is, logical flows among logical datapaths and - * logical ports. This code translates these logical flows into OpenFlow flows - * that, again, work in terms of logical entities implemented through OpenFlow - * extensions (e.g. registers represent the logical input and output ports). + * The Logical_Flow table obtained from the OVN_Southbound database works in + * terms of logical entities, that is, logical flows among logical datapaths + * and logical ports. This code translates these logical flows into OpenFlow + * flows that, again, work in terms of logical entities implemented through + * OpenFlow extensions (e.g. registers represent the logical input and output + * ports). * * Physical-to-logical and logical-to-physical translation are implemented in * physical.[ch] as separate OpenFlow tables that run before and after, @@ -41,10 +42,10 @@ struct uuid; #define MFF_LOG_INPORT MFF_REG6 /* Logical input port. */ #define MFF_LOG_OUTPORT MFF_REG7 /* Logical output port. */ -void pipeline_init(void); -void pipeline_run(struct controller_ctx *, struct hmap *flow_table); -void pipeline_destroy(void); +void lflow_init(void); +void lflow_run(struct controller_ctx *, struct hmap *flow_table); +void lflow_destroy(void); uint32_t ldp_to_integer(const struct uuid *logical_datapath); -#endif /* ovn/pipeline.h */ +#endif /* ovn/lflow.h */ diff --git a/ovn/controller/ovn-controller.c b/ovn/controller/ovn-controller.c index 5548e2a1229..84eeba8689e 100644 --- a/ovn/controller/ovn-controller.c +++ b/ovn/controller/ovn-controller.c @@ -44,7 +44,7 @@ #include "chassis.h" #include "encaps.h" #include "physical.h" -#include "pipeline.h" +#include "lflow.h" VLOG_DEFINE_THIS_MODULE(main); @@ -238,7 +238,7 @@ main(int argc, char *argv[]) sbrec_init(); ofctrl_init(); - pipeline_init(); + lflow_init(); /* Connect to OVS OVSDB instance. We do not monitor all tables by * default, so modules must register their interest explicitly. */ @@ -280,7 +280,7 @@ main(int argc, char *argv[]) if (br_int) { struct hmap flow_table = HMAP_INITIALIZER(&flow_table); - pipeline_run(&ctx, &flow_table); + lflow_run(&ctx, &flow_table); if (chassis_id) { physical_run(&ctx, br_int, chassis_id, &flow_table); } @@ -332,7 +332,7 @@ main(int argc, char *argv[]) } unixctl_server_destroy(unixctl); - pipeline_destroy(); + lflow_destroy(); ofctrl_destroy(); idl_loop_destroy(&ovs_idl_loop); diff --git a/ovn/controller/physical.c b/ovn/controller/physical.c index 77f5ff61f3e..b0ed1c887ed 100644 --- a/ovn/controller/physical.c +++ b/ovn/controller/physical.c @@ -15,13 +15,13 @@ #include #include "physical.h" +#include "lflow.h" #include "match.h" #include "ofctrl.h" #include "ofp-actions.h" #include "ofpbuf.h" #include "ovn-controller.h" #include "ovn/lib/ovn-sb-idl.h" -#include "pipeline.h" #include "simap.h" #include "vswitch-idl.h" diff --git a/ovn/lib/actions.c b/ovn/lib/actions.c index 28be68845e4..ea8dfc9e851 100644 --- a/ovn/lib/actions.c +++ b/ovn/lib/actions.c @@ -176,8 +176,8 @@ parse_actions(struct action_context *ctx) } /* Parses OVN actions, in the format described for the "actions" column in the - * Pipeline table in ovn-sb(5), and appends the parsed versions of the actions - * to 'ofpacts' as "struct ofpact"s. + * Logical_Flow table in ovn-sb(5), and appends the parsed versions of the + * actions to 'ofpacts' as "struct ofpact"s. * * 'symtab' provides a table of "struct expr_symbol"s to support (as one would * provide to expr_parse()). diff --git a/ovn/northd/ovn-northd.c b/ovn/northd/ovn-northd.c index 757afcad33e..aa58134b9f3 100644 --- a/ovn/northd/ovn-northd.c +++ b/ovn/northd/ovn-northd.c @@ -120,35 +120,35 @@ macs_equal(char **binding_macs_, size_t b_n_macs, return (i == b_n_macs) ? true : false; } -/* Pipeline generation. +/* Logical flow generation. * - * This code generates the Pipeline table in the southbound database, as a + * This code generates the Logical_Flow table in the southbound database, as a * function of most of the northbound database. */ -/* Enough context to add a Pipeline row, using pipeline_add(). */ -struct pipeline_ctx { +/* Enough context to add a Logical_Flow row, using lflow_add(). */ +struct lflow_ctx { /* From northd_context. */ struct ovsdb_idl *ovnsb_idl; struct ovsdb_idl_txn *ovnsb_txn; - /* Contains "struct pipeline_hash_node"s. Used to figure out what existing - * Pipeline rows should be deleted: we index all of the Pipeline rows into - * this data structure, then as existing rows are generated we remove them. - * After generating all the rows, any remaining in 'pipeline_hmap' must be - * deleted from the database. */ - struct hmap pipeline_hmap; + /* Contains "struct lflow_hash_node"s. Used to figure out what existing + * Logical_Flow rows should be deleted: we index all of the Logical_Flow + * rows into this data structure, then as existing rows are generated we + * remove them. After generating all the rows, any remaining in + * 'lflow_hmap' must be deleted from the database. */ + struct hmap lflow_hmap; }; -/* A row in the Pipeline table, indexed by its full contents, */ -struct pipeline_hash_node { +/* A row in the Logical_Flow table, indexed by its full contents, */ +struct lflow_hash_node { struct hmap_node node; - const struct sbrec_pipeline *pipeline; + const struct sbrec_logical_flow *lflow; }; static size_t -pipeline_hash(const struct uuid *logical_datapath, uint8_t table_id, - uint16_t priority, const char *match, const char *actions) +lflow_hash(const struct uuid *logical_datapath, uint8_t table_id, + uint16_t priority, const char *match, const char *actions) { size_t hash = uuid_hash(logical_datapath); hash = hash_2words((table_id << 16) | priority, hash); @@ -157,52 +157,52 @@ pipeline_hash(const struct uuid *logical_datapath, uint8_t table_id, } static size_t -pipeline_hash_rec(const struct sbrec_pipeline *pipeline) +lflow_hash_rec(const struct sbrec_logical_flow *lflow) { - return pipeline_hash(&pipeline->logical_datapath, pipeline->table_id, - pipeline->priority, pipeline->match, - pipeline->actions); + return lflow_hash(&lflow->logical_datapath, lflow->table_id, + lflow->priority, lflow->match, + lflow->actions); } -/* Adds a row with the specified contents to the Pipeline table. */ +/* Adds a row with the specified contents to the Logical_Flow table. */ static void -pipeline_add(struct pipeline_ctx *ctx, - const struct nbrec_logical_switch *logical_datapath, - uint8_t table_id, - uint16_t priority, - const char *match, - const char *actions) +lflow_add(struct lflow_ctx *ctx, + const struct nbrec_logical_switch *logical_datapath, + uint8_t table_id, + uint16_t priority, + const char *match, + const char *actions) { - struct pipeline_hash_node *hash_node; + struct lflow_hash_node *hash_node; - /* Check whether such a row already exists in the Pipeline table. If so, - * remove it from 'ctx->pipeline_hmap' and we're done. */ + /* Check whether such a row already exists in the Logical_Flow table. If + * so, remove it from 'ctx->lflow_hmap' and we're done. */ HMAP_FOR_EACH_WITH_HASH (hash_node, node, - pipeline_hash(&logical_datapath->header_.uuid, - table_id, priority, match, actions), - &ctx->pipeline_hmap) { - const struct sbrec_pipeline *pipeline = hash_node->pipeline; - if (uuid_equals(&pipeline->logical_datapath, + lflow_hash(&logical_datapath->header_.uuid, + table_id, priority, match, actions), + &ctx->lflow_hmap) { + const struct sbrec_logical_flow *lflow = hash_node->lflow; + if (uuid_equals(&lflow->logical_datapath, &logical_datapath->header_.uuid) - && pipeline->table_id == table_id - && pipeline->priority == priority - && !strcmp(pipeline->match, match) - && !strcmp(pipeline->actions, actions)) { - hmap_remove(&ctx->pipeline_hmap, &hash_node->node); + && lflow->table_id == table_id + && lflow->priority == priority + && !strcmp(lflow->match, match) + && !strcmp(lflow->actions, actions)) { + hmap_remove(&ctx->lflow_hmap, &hash_node->node); free(hash_node); return; } } - /* No such Pipeline row. Add one. */ - const struct sbrec_pipeline *pipeline; - pipeline = sbrec_pipeline_insert(ctx->ovnsb_txn); - sbrec_pipeline_set_logical_datapath(pipeline, - logical_datapath->header_.uuid); - sbrec_pipeline_set_table_id(pipeline, table_id); - sbrec_pipeline_set_priority(pipeline, priority); - sbrec_pipeline_set_match(pipeline, match); - sbrec_pipeline_set_actions(pipeline, actions); + /* No such Logical_Flow row. Add one. */ + const struct sbrec_logical_flow *lflow; + lflow = sbrec_logical_flow_insert(ctx->ovnsb_txn); + sbrec_logical_flow_set_logical_datapath(lflow, + logical_datapath->header_.uuid); + sbrec_logical_flow_set_table_id(lflow, table_id); + sbrec_logical_flow_set_priority(lflow, priority); + sbrec_logical_flow_set_match(lflow, match); + sbrec_logical_flow_set_actions(lflow, actions); } /* Appends port security constraints on L2 address field 'eth_addr_field' @@ -241,43 +241,43 @@ lport_is_enabled(const struct nbrec_logical_port *lport) return !lport->enabled || *lport->enabled; } -/* Updates the Pipeline table in the OVN_SB database, constructing its contents - * based on the OVN_NB database. */ +/* Updates the Logical_Flow table in the OVN_SB database, constructing its + * contents based on the OVN_NB database. */ static void -build_pipeline(struct northd_context *ctx) +build_lflow(struct northd_context *ctx) { - struct pipeline_ctx pc = { + struct lflow_ctx pc = { .ovnsb_idl = ctx->ovnsb_idl, .ovnsb_txn = ctx->ovnsb_txn, - .pipeline_hmap = HMAP_INITIALIZER(&pc.pipeline_hmap) + .lflow_hmap = HMAP_INITIALIZER(&pc.lflow_hmap) }; - /* Add all the Pipeline entries currently in the southbound database to - * 'pc.pipeline_hmap'. We remove entries that we generate from the hmap, + /* Add all the Logical_Flow entries currently in the southbound database to + * 'pc.lflow_hmap'. We remove entries that we generate from the hmap, * thus by the time we're done only entries that need to be removed * remain. */ - const struct sbrec_pipeline *pipeline; - SBREC_PIPELINE_FOR_EACH (pipeline, ctx->ovnsb_idl) { - struct pipeline_hash_node *hash_node = xzalloc(sizeof *hash_node); - hash_node->pipeline = pipeline; - hmap_insert(&pc.pipeline_hmap, &hash_node->node, - pipeline_hash_rec(pipeline)); + const struct sbrec_logical_flow *lflow; + SBREC_LOGICAL_FLOW_FOR_EACH (lflow, ctx->ovnsb_idl) { + struct lflow_hash_node *hash_node = xzalloc(sizeof *hash_node); + hash_node->lflow = lflow; + hmap_insert(&pc.lflow_hmap, &hash_node->node, + lflow_hash_rec(lflow)); } /* Table 0: Admission control framework. */ const struct nbrec_logical_switch *lswitch; NBREC_LOGICAL_SWITCH_FOR_EACH (lswitch, ctx->ovnnb_idl) { /* Logical VLANs not supported. */ - pipeline_add(&pc, lswitch, 0, 100, "vlan.present", "drop;"); + lflow_add(&pc, lswitch, 0, 100, "vlan.present", "drop;"); /* Broadcast/multicast source address is invalid. */ - pipeline_add(&pc, lswitch, 0, 100, "eth.src[40]", "drop;"); + lflow_add(&pc, lswitch, 0, 100, "eth.src[40]", "drop;"); /* Port security flows have priority 50 (see below) and will continue * to the next table if packet source is acceptable. */ /* Otherwise drop the packet. */ - pipeline_add(&pc, lswitch, 0, 0, "1", "drop;"); + lflow_add(&pc, lswitch, 0, 0, "1", "drop;"); } /* Table 0: Ingress port security. */ @@ -290,8 +290,8 @@ build_pipeline(struct northd_context *ctx) build_port_security("eth.src", lport->port_security, lport->n_port_security, &match); - pipeline_add(&pc, lswitch, 0, 50, ds_cstr(&match), - lport_is_enabled(lport) ? "next;" : "drop;"); + lflow_add(&pc, lswitch, 0, 50, ds_cstr(&match), + lport_is_enabled(lport) ? "next;" : "drop;"); ds_destroy(&match); } } @@ -329,8 +329,8 @@ build_pipeline(struct northd_context *ctx) ds_put_cstr(&unicast, "outport = "); json_string_escape(lport->name, &unicast); ds_put_cstr(&unicast, "; next;"); - pipeline_add(&pc, lswitch, 1, 50, - ds_cstr(&match), ds_cstr(&unicast)); + lflow_add(&pc, lswitch, 1, 50, + ds_cstr(&match), ds_cstr(&unicast)); ds_destroy(&unicast); ds_destroy(&match); } else if (!strcmp(s, "unknown")) { @@ -347,12 +347,12 @@ build_pipeline(struct northd_context *ctx) } ds_chomp(&bcast, ' '); - pipeline_add(&pc, lswitch, 1, 100, "eth.dst[40]", ds_cstr(&bcast)); + lflow_add(&pc, lswitch, 1, 100, "eth.dst[40]", ds_cstr(&bcast)); ds_destroy(&bcast); if (unknown.length) { ds_chomp(&unknown, ' '); - pipeline_add(&pc, lswitch, 1, 0, "1", ds_cstr(&unknown)); + lflow_add(&pc, lswitch, 1, 0, "1", ds_cstr(&unknown)); } ds_destroy(&unknown); } @@ -363,19 +363,19 @@ build_pipeline(struct northd_context *ctx) const struct nbrec_acl *acl = lswitch->acls[i]; NBREC_ACL_FOR_EACH (acl, ctx->ovnnb_idl) { - pipeline_add(&pc, lswitch, 2, acl->priority, acl->match, - (!strcmp(acl->action, "allow") || - !strcmp(acl->action, "allow-related") - ? "next;" : "drop;")); + lflow_add(&pc, lswitch, 2, acl->priority, acl->match, + (!strcmp(acl->action, "allow") || + !strcmp(acl->action, "allow-related") + ? "next;" : "drop;")); } } - pipeline_add(&pc, lswitch, 2, 0, "1", "next;"); + lflow_add(&pc, lswitch, 2, 0, "1", "next;"); } /* Table 3: Egress port security. */ NBREC_LOGICAL_SWITCH_FOR_EACH (lswitch, ctx->ovnnb_idl) { - pipeline_add(&pc, lswitch, 3, 100, "eth.dst[40]", "output;"); + lflow_add(&pc, lswitch, 3, 100, "eth.dst[40]", "output;"); for (size_t i = 0; i < lswitch->n_ports; i++) { const struct nbrec_logical_port *lport = lswitch->ports[i]; @@ -388,21 +388,21 @@ build_pipeline(struct northd_context *ctx) lport->port_security, lport->n_port_security, &match); - pipeline_add(&pc, lswitch, 3, 50, ds_cstr(&match), - lport_is_enabled(lport) ? "output;" : "drop;"); + lflow_add(&pc, lswitch, 3, 50, ds_cstr(&match), + lport_is_enabled(lport) ? "output;" : "drop;"); ds_destroy(&match); } } - /* Delete any existing Pipeline rows that were not re-generated. */ - struct pipeline_hash_node *hash_node, *next_hash_node; - HMAP_FOR_EACH_SAFE (hash_node, next_hash_node, node, &pc.pipeline_hmap) { - hmap_remove(&pc.pipeline_hmap, &hash_node->node); - sbrec_pipeline_delete(hash_node->pipeline); + /* Delete any existing Logical_Flow rows that were not re-generated. */ + struct lflow_hash_node *hash_node, *next_hash_node; + HMAP_FOR_EACH_SAFE (hash_node, next_hash_node, node, &pc.lflow_hmap) { + hmap_remove(&pc.lflow_hmap, &hash_node->node); + sbrec_logical_flow_delete(hash_node->lflow); free(hash_node); } - hmap_destroy(&pc.pipeline_hmap); + hmap_destroy(&pc.lflow_hmap); } /* @@ -628,7 +628,7 @@ ovnnb_db_changed(struct northd_context *ctx) VLOG_DBG("ovn-nb db contents have changed."); set_port_bindings(ctx); - build_pipeline(ctx); + build_lflow(ctx); } /* @@ -824,16 +824,16 @@ main(int argc, char *argv[]) ovsdb_idl_add_column(ovnsb_idl, &sbrec_port_binding_col_tunnel_key); ovsdb_idl_add_column(ovnsb_idl, &sbrec_port_binding_col_type); ovsdb_idl_add_column(ovnsb_idl, &sbrec_port_binding_col_options); - ovsdb_idl_add_column(ovnsb_idl, &sbrec_pipeline_col_logical_datapath); - ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_pipeline_col_logical_datapath); - ovsdb_idl_add_column(ovnsb_idl, &sbrec_pipeline_col_table_id); - ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_pipeline_col_table_id); - ovsdb_idl_add_column(ovnsb_idl, &sbrec_pipeline_col_priority); - ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_pipeline_col_priority); - ovsdb_idl_add_column(ovnsb_idl, &sbrec_pipeline_col_match); - ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_pipeline_col_match); - ovsdb_idl_add_column(ovnsb_idl, &sbrec_pipeline_col_actions); - ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_pipeline_col_actions); + ovsdb_idl_add_column(ovnsb_idl, &sbrec_logical_flow_col_logical_datapath); + ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_logical_flow_col_logical_datapath); + ovsdb_idl_add_column(ovnsb_idl, &sbrec_logical_flow_col_table_id); + ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_logical_flow_col_table_id); + ovsdb_idl_add_column(ovnsb_idl, &sbrec_logical_flow_col_priority); + ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_logical_flow_col_priority); + ovsdb_idl_add_column(ovnsb_idl, &sbrec_logical_flow_col_match); + ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_logical_flow_col_match); + ovsdb_idl_add_column(ovnsb_idl, &sbrec_logical_flow_col_actions); + ovsdb_idl_omit_alert(ovnsb_idl, &sbrec_logical_flow_col_actions); /* * The loop here just runs the IDL in a loop waiting for the seqno to diff --git a/ovn/ovn-architecture.7.xml b/ovn/ovn-architecture.7.xml index 13470bc9cd6..6e976ab100a 100644 --- a/ovn/ovn-architecture.7.xml +++ b/ovn/ovn-architecture.7.xml @@ -346,7 +346,7 @@ ovn-northd receives the OVN Northbound database update. In turn, it makes the corresponding updates to the OVN Southbound database, by adding rows to the OVN Southbound database - Pipeline table to reflect the new port, e.g. add a + Logical_Flow table to reflect the new port, e.g. add a flow to recognize that packets destined to the new port's MAC address should be delivered to it, and update the flow that delivers broadcast and multicast packets to include the new port. @@ -357,7 +357,7 @@
  • On every hypervisor, ovn-controller receives the - Pipeline table updates that ovn-northd made + Logical_Flow table updates that ovn-northd made in the previous step. As long as the VM that owns the VIF is powered off, ovn-controller cannot do much; it cannot, for example, arrange to send packets to or receive packets from the VIF, because the @@ -404,7 +404,7 @@ Binding table. This provides ovn-controller the physical location of the logical port, so each instance updates the OpenFlow tables of its switch (based on logical datapath flows in the OVN - DB Pipeline table) so that packets to and from the VIF can + DB Logical_Flow table) so that packets to and from the VIF can be properly handled via tunnels.
    • @@ -444,13 +444,13 @@ ovn-northd receives the OVN Northbound update and in turn updates the OVN Southbound database accordingly, by removing or updating the rows from the OVN Southbound database - Pipeline table and Binding table that + Logical_Flow table and Binding table that were related to the now-destroyed VIF.
  • On every hypervisor, ovn-controller receives the - Pipeline table updates that ovn-northd made + Logical_Flow table updates that ovn-northd made in the previous step. ovn-controller updates OpenFlow tables to reflect the update, although there may not be much to do, since the VIF had already become unreachable when it was removed from the @@ -541,7 +541,7 @@ ovn-northd receives the OVN Northbound database update. In turn, it makes the corresponding updates to the OVN Southbound database, by adding rows to the OVN Southbound database's - Pipeline table to reflect the new port and also by + Logical_Flow table to reflect the new port and also by creating a new row in the Binding table and populating all its columns except the column that identifies the chassis. @@ -582,16 +582,16 @@ ovn-northd receives the OVN Northbound update and in turn updates the OVN Southbound database accordingly, by removing or updating the rows from the OVN Southbound database - Pipeline table that were related to the now-destroyed + Logical_Flow table that were related to the now-destroyed CIF. It also deletes the row in the Binding table for that CIF.
  • On every hypervisor, ovn-controller receives the - Pipeline table updates that ovn-northd made - in the previous step. ovn-controller updates OpenFlow tables - to reflect the update. + Logical_Flow table updates that ovn-northd made + in the previous step. ovn-controller updates OpenFlow + tables to reflect the update.
    • diff --git a/ovn/ovn-nb.xml b/ovn/ovn-nb.xml index fac6ad07038..7b9fbb2a63e 100644 --- a/ovn/ovn-nb.xml +++ b/ovn/ovn-nb.xml @@ -219,9 +219,9 @@ The packets that the ACL should match, in the same expression - language used for the column in the OVN Southbound database's table. Match + table="Logical_Flow" db="OVN_Southbound"/> table. Match inport and outport against names of logical ports within to implement ingress and egress ACLs, respectively. In logical switches connected to diff --git a/ovn/ovn-sb.ovsschema b/ovn/ovn-sb.ovsschema index 3c45658d08c..e5c1812e70f 100644 --- a/ovn/ovn-sb.ovsschema +++ b/ovn/ovn-sb.ovsschema @@ -32,7 +32,7 @@ "value": {"type": "string"}, "min": 0, "max": "unlimited"}}}}, - "Pipeline": { + "Logical_Flow": { "columns": { "logical_datapath": {"type": "uuid"}, "table_id": {"type": {"key": {"type": "integer", diff --git a/ovn/ovn-sb.xml b/ovn/ovn-sb.xml index 9dddf725a45..4860ec72ded 100644 --- a/ovn/ovn-sb.xml +++ b/ovn/ovn-sb.xml @@ -74,7 +74,7 @@

    - The table is currently the only LN table. + The table is currently the only LN table.

    Bindings data

    @@ -198,7 +198,7 @@     - +

    Each row in this table represents one logical flow. The cloud management system, via its OVN integration, populates this table with logical flows @@ -663,7 +663,7 @@ The logical datapath to which the logical port belongs. A logical datapath implements a logical pipeline via logical flows in the table. (No table represents a logical datapath.) + table="Logical_Flow"/> table. (No table represents a logical datapath.)