This commit adds the pipeline module to ovn-controller-vtep. The
module will scan through the Binding table, and create the
Ucast_Macs_Remote in vtep database for each logical port's MACs in
the same logical datapath (same as logical switch for vtep). Also
the module will create the physical locators to each HV chassis in
the same logical datapath.
TODO:
- vtep gateway will create entries in the "Ucast_Macs_Local" for
each MAC learned. ovn-controller-vtep should take advantage of
this and notify the ovn-sb database in some way so that all HVs
(in the same logical datapath) are aware of these MACs and will
send all related packets to the vtep gateway. We should achieve
this in the near future.
Signed-off-by: Alex Wang <al...@nicira.com>
---
V2->V3:
- rebase to master.
PATCH->V2:
- split into separate commit.
- few optimizations.
---
ovn/controller-vtep/automake.mk | 2 +
ovn/controller-vtep/ovn-controller-vtep.c | 3 +
ovn/controller-vtep/pipeline.c | 514 +++++++++++++++++++++++++++++
ovn/controller-vtep/pipeline.h | 25 ++
tests/ovn-controller-vtep.at | 39 +++
5 files changed, 583 insertions(+)
create mode 100644 ovn/controller-vtep/pipeline.c
create mode 100644 ovn/controller-vtep/pipeline.h
diff --git a/ovn/controller-vtep/automake.mk b/ovn/controller-vtep/automake.mk
index 33f063f..7f8d33b 100644
--- a/ovn/controller-vtep/automake.mk
+++ b/ovn/controller-vtep/automake.mk
@@ -4,6 +4,8 @@ ovn_controller_vtep_ovn_controller_vtep_SOURCES = \
ovn/controller-vtep/binding.h \
ovn/controller-vtep/gateway.c \
ovn/controller-vtep/gateway.h \
+ ovn/controller-vtep/pipeline.c \
+ ovn/controller-vtep/pipeline.h \
ovn/controller-vtep/ovn-controller-vtep.c \
ovn/controller-vtep/ovn-controller-vtep.h
ovn_controller_vtep_ovn_controller_vtep_LDADD = ovn/lib/libovn.la
lib/libopenvswitch.la vtep/libvtep.la
diff --git a/ovn/controller-vtep/ovn-controller-vtep.c
b/ovn/controller-vtep/ovn-controller-vtep.c
index 712116a..8cd1ee2 100644
--- a/ovn/controller-vtep/ovn-controller-vtep.c
+++ b/ovn/controller-vtep/ovn-controller-vtep.c
@@ -40,6 +40,7 @@
#include "binding.h"
#include "gateway.h"
+#include "pipeline.h"
#include "ovn-controller-vtep.h"
VLOG_DEFINE_THIS_MODULE(ovn_vtep);
@@ -125,6 +126,7 @@ main(int argc, char *argv[])
gateway_run(&ctx);
binding_run(&ctx);
+ pipeline_run(&ctx);
unixctl_server_run(unixctl);
unixctl_server_wait(unixctl);
@@ -140,6 +142,7 @@ main(int argc, char *argv[])
unixctl_server_destroy(unixctl);
gateway_destroy(&ctx);
binding_destroy(&ctx);
+ pipeline_destroy(&ctx);
ovsdb_idl_destroy(ctx.vtep_idl);
ovsdb_idl_destroy(ctx.ovnsb_idl);
diff --git a/ovn/controller-vtep/pipeline.c b/ovn/controller-vtep/pipeline.c
new file mode 100644
index 0000000..392b3e9
--- /dev/null
+++ b/ovn/controller-vtep/pipeline.c
@@ -0,0 +1,514 @@
+/* Copyright (c) 2015 Nicira, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <config.h>
+#include "pipeline.h"
+
+#include "dynamic-string.h"
+#include "lib/hash.h"
+#include "list.h"
+#include "lib/poll-loop.h"
+#include "lib/sset.h"
+#include "lib/util.h"
+#include "lib/uuid.h"
+#include "openvswitch/vlog.h"
+#include "ovn/lib/ovn-sb-idl.h"
+#include "vtep/vtep-idl.h"
+#include "ovn-controller-vtep.h"
+
+VLOG_DEFINE_THIS_MODULE(pipeline);
+
+/*
+ * Scans through the Binding table in ovnsb and creates the Ucast_Macs_Remote
+ * rows in vtep database for each logical port's MACs in the same logical
+ * datapath (logical datapath in ovnsb = logical switch in vtep). Also,
+ * creates the Physical_Locator rows to each HV chassis in the logical
+ * datapath.
+ *
+ * xxx: take advantage of Ucast_Macs_Local.
+ *
+ * vtep gateway will create entries in the Ucast_Macs_Local for
+ * each MAC learned. ovn-controller-vtep should take advantage of
+ * this and notify the ovn-sb database in some way so that all HVs
+ * (in the same logical datapath) are aware of these MACs and will
+ * send all related packets to the vtep gateway. We should achieve
+ * this in the near future.
+ *
+ */
+
+/* A binding within a logical datapath. */
+struct binding_list_node {
+ struct ovs_list list_node;
+ const struct sbrec_binding *binding;
+};
+
+/* Stores all info related to one logical switch in vtep. */
+struct lswitch {
+ struct hmap_node hmap_node;
+ /* logical switch reference in vtep. */
+ const struct vteprec_logical_switch *lswitch;
+ /* corresponding logical datapath uuid in ovn-sb. */
+ struct uuid ldp_uuid;
+ /* all macs in the logical datapath */
+ struct sset macs;
+ struct ovs_list bd_list; /* stores 'struct binding_list_node's. */
+};
+
+/* An 'Ucast_Macs_Remote' entry in vtep. */
+struct ucast_macs_rmt {
+ struct hmap_node hmap_node;
+ const struct vteprec_ucast_macs_remote *umr;
+};
+
+/* An 'Physical_Locator' entry in vtep. */
+struct physical_locator {
+ struct hmap_node hmap_node;
+ const struct vteprec_physical_locator *pl;
+};
+
+
+/* Returns true if the 'binding's logical datapath has already been
+ * stored in 'ls_map', also saves found record in 'lsp'. Otherwise,
+ * returns false.*/
+static bool
+get_lswitch_from_binding(struct hmap *ls_map,
+ const struct sbrec_binding *binding,
+ struct lswitch **lsp)
+{
+ struct lswitch *ls;
+
+ HMAP_FOR_EACH_WITH_HASH (ls, hmap_node,
+ uuid_hash(&binding->logical_datapath), ls_map) {
+ if (uuid_equals(&ls->ldp_uuid, &binding->logical_datapath)) {
+ *lsp = ls;
+ return true;
+ }
+ }
+ return false;
+}
+
+/* Finds and returns the reference to logical switch in vtep with same name
+ * as 'uuid'. */
+static const struct vteprec_logical_switch *
+find_vtep_lswitch(struct controller_vtep_ctx *ctx, const struct uuid *uuid)
+{
+ const struct vteprec_logical_switch *vtep_lswitch;
+
+ VTEPREC_LOGICAL_SWITCH_FOR_EACH (vtep_lswitch, ctx->vtep_idl) {
+ struct uuid uuid_;
+
+ uuid_from_string(&uuid_, vtep_lswitch->name);
+ if (!memcmp(uuid, &uuid_, sizeof *uuid)) {
+ return vtep_lswitch;
+ }
+ }
+ return NULL;
+}
+
+/* Returns true if the logical switch containing the logical port represented
+ * by 'binding_rec' is also defined in VTEP. */
+static bool
+binding_pipeline_use_vtep(struct controller_vtep_ctx *ctx,
+ const struct sbrec_binding *binding)
+{
+ return find_vtep_lswitch(ctx, &binding->logical_datapath)
+ ? true : false;
+}
+
+/* Creates an entry in 'ls->bd_list' for each mac in 'binding'. */
+static void
+lswitch_add_binding(struct lswitch *ls, const struct sbrec_binding *binding)
+{
+ struct binding_list_node *bd;
+ int i;
+
+ for (i = 0; i < binding->n_mac; i++) {
+ char *mac = binding->mac[i];
+
+ if (sset_find(&ls->macs, mac)) {
+ VLOG_ERR("MAC address (%s) already exists in logical "
+ "switch (%s), ignore all macs from binding (%s)",
+ mac, ls->lswitch->name, binding->logical_port);
+ return;
+ }
+ }
+
+ bd = xmalloc(sizeof *bd);
+ bd->binding = binding;
+ /* Uses chassis name as hash key. */
+ list_insert(&ls->bd_list, &bd->list_node);
+}
+
+/* Destroys the 'ls'. */
+static void
+lswitch_destroy(struct lswitch *ls)
+{
+ struct binding_list_node *iter, *next;
+
+ sset_destroy(&ls->macs);
+ LIST_FOR_EACH_SAFE (iter, next, list_node, &ls->bd_list) {
+ list_remove(&iter->list_node);
+ free(iter);
+ }
+}
+
+/* Destroys the 'ls_map' containing 'struct lswitch *'. */
+static void
+lswitch_map_destroy(struct hmap *ls_map)
+{
+ struct lswitch *ls, *next;
+
+ HMAP_FOR_EACH_SAFE (ls, next, hmap_node, ls_map) {
+ hmap_remove(ls_map, &ls->hmap_node);
+ lswitch_destroy(ls);
+ free(ls);
+
+ }
+ hmap_destroy(ls_map);
+}
+
+/* Creates and adds an 'struct ucast_macs_rmt' entry to 'umr_map'. */
+static void
+ucast_macs_rmt_map_add(const struct vteprec_ucast_macs_remote *vteprec_umr,
+ struct hmap *umr_map)
+{
+ struct ucast_macs_rmt *umr = xmalloc(sizeof *umr);
+
+ umr->umr = vteprec_umr;
+ hmap_insert(umr_map, &umr->hmap_node, hash_string(vteprec_umr->MAC, 0));
+}
+
+/* Destroys the 'umr_map' containing 'struct ucast_macs_remote *'. */
+static void
+ucast_macs_rmt_map_destory(struct hmap *umr_map)
+{
+ struct ucast_macs_rmt *umr, *next;
+
+ HMAP_FOR_EACH_SAFE (umr, next, hmap_node, umr_map) {
+ hmap_remove(umr_map, &umr->hmap_node);
+ free(umr);
+ }
+ hmap_destroy(umr_map);
+}
+
+/* Creates and adds an 'struct physical_locator' entry to 'pl_map'. */
+static void
+physical_locator_map_add(const struct vteprec_physical_locator *vteprec_pl,
+ struct hmap *pl_map)
+{
+ struct physical_locator *pl = xmalloc(sizeof *pl);
+
+ pl->pl = vteprec_pl;
+ hmap_insert(pl_map, &pl->hmap_node, hash_string(vteprec_pl->dst_ip, 0));
+}
+
+/* Destroys the 'pl_map' containing 'struct physical_locator *'. */
+static void
+physical_locator_map_destory(struct hmap *pl_map)
+{
+ struct physical_locator *pl, *next;
+
+ HMAP_FOR_EACH_SAFE (pl, next, hmap_node, pl_map) {
+ hmap_remove(pl_map, &pl->hmap_node);
+ free(pl);
+ }
+ hmap_destroy(pl_map);
+}
+
+/* Returns true if there is 'umr' with same 'mac' in 'umr_map'
+ * and sets the 'umrp'. Returns false otherwise. */
+static bool
+get_umr_by_mac(struct hmap *umr_map, const char *mac,
+ struct ucast_macs_rmt **umrp)
+{
+ struct ucast_macs_rmt *umr;
+
+ HMAP_FOR_EACH_WITH_HASH (umr, hmap_node, hash_string(mac, 0), umr_map) {
+ if (!strcmp(mac, umr->umr->MAC)) {
+ *umrp = umr;
+ return true;
+ }
+ }
+ return false;
+}
+
+/* Returns true if there is 'pl' with same 'ip' in 'pl_map'
+ * and sets the 'plp'. Returns false otherwise. */
+static bool
+get_pl_by_ip(struct hmap *pl_map, const char *ip,
+ struct physical_locator **plp)
+{
+ struct physical_locator *pl;
+
+ HMAP_FOR_EACH_WITH_HASH (pl, hmap_node, hash_string(ip, 0), pl_map) {
+ if (!strcmp(ip, pl->pl->dst_ip)) {
+ *plp = pl;
+ return true;
+ }
+ }
+ return false;
+}
+
+/* Searches the 'chassis_rec->encaps' for the first vtep tunnel
+ * configuration, returns the 'ip'. */
+static const char *
+get_chassis_vtep_ip(const struct sbrec_chassis *chassis_rec)
+{
+ size_t i;
+
+ for (i = 0; i < chassis_rec->n_encaps; i++) {
+ if (!strcmp(chassis_rec->encaps[i]->type, "vxlan")) {
+ return chassis_rec->encaps[i]->ip;
+ }
+ }
+
+ return NULL;
+}
+
+
+/* Collects and categorizes bindings from ovnsb based on their
+ * logical datapath (which is also the lswitch name in vtep).
+ * Returns a hmap containing 'struct lswitch's. */
+static struct hmap *
+collect_lswitch(struct controller_vtep_ctx *ctx)
+{
+ struct hmap *vtep_lswitches, *other_lswitches;
+ const struct sbrec_binding *binding_rec;
+
+ vtep_lswitches = xmalloc(sizeof *vtep_lswitches);
+ other_lswitches = xmalloc(sizeof *other_lswitches);
+ hmap_init(vtep_lswitches);
+ hmap_init(other_lswitches);
+ SBREC_BINDING_FOR_EACH (binding_rec, ctx->ovnsb_idl) {
+ struct lswitch *ls;
+
+ if (get_lswitch_from_binding(other_lswitches, binding_rec, &ls)) {
+ /* Do not care if 'binding_rec' is not on a logical switch
+ * specified in vtep. */
+ continue;
+ } else if (get_lswitch_from_binding(vtep_lswitches, binding_rec, &ls))
{
+ /* The logical switch is already registered, just update the
+ * bindings. */
+ lswitch_add_binding(ls, binding_rec);
+ } else {
+ struct lswitch *ls = xmalloc(sizeof *ls);
+
+ sset_init(&ls->macs);
+ list_init(&ls->bd_list);
+ /* If the binding is in the same logical switch as vtep,
+ * add 'ls' to 'vtep_lswitches'. */
+ if (binding_pipeline_use_vtep(ctx, binding_rec)) {
+ ls->ldp_uuid = binding_rec->logical_datapath;
+ ls->lswitch = find_vtep_lswitch(ctx, &ls->ldp_uuid);
+ hmap_insert(vtep_lswitches, &ls->hmap_node,
+ uuid_hash(&ls->ldp_uuid));
+ lswitch_add_binding(ls, binding_rec);
+ } else {
+ ls->ldp_uuid = binding_rec->logical_datapath;
+ hmap_insert(other_lswitches, &ls->hmap_node,
+ uuid_hash(&ls->ldp_uuid));
+ }
+ }
+ }
+ lswitch_map_destroy(other_lswitches);
+ free(other_lswitches);
+
+ return vtep_lswitches;
+}
+
+/* Collects all 'ucast_macs_remote's from vtep. */
+static struct hmap *
+collect_umrs(struct controller_vtep_ctx *ctx)
+{
+ const struct vteprec_ucast_macs_remote *vteprec_umr;
+ struct hmap *ucast_macs_rmts = xmalloc(sizeof *ucast_macs_rmts);
+
+ hmap_init(ucast_macs_rmts);
+ VTEPREC_UCAST_MACS_REMOTE_FOR_EACH (vteprec_umr, ctx->vtep_idl) {
+ ucast_macs_rmt_map_add(vteprec_umr, ucast_macs_rmts);
+ }
+
+ return ucast_macs_rmts;
+}
+
+/* Collects all 'physical_locator's from vtep. */
+static struct hmap *
+collect_pl(struct controller_vtep_ctx *ctx)
+{
+ const struct vteprec_physical_locator *vteprec_pl;
+ struct hmap *physical_locators = xmalloc(sizeof *physical_locators);
+
+ hmap_init(physical_locators);
+ VTEPREC_PHYSICAL_LOCATOR_FOR_EACH (vteprec_pl, ctx->vtep_idl) {
+ physical_locator_map_add(vteprec_pl, physical_locators);
+ }
+
+ return physical_locators;
+}
+
+
+/* First collects required info from ovnsb and vtep. Then updates the
+ * 'Ucast_Macs_Remote' and 'Physical_Locator' tables in vtep. */
+void
+pipeline_run(struct controller_vtep_ctx *ctx)
+{
+ struct hmap *vtep_lswitches = collect_lswitch(ctx);
+ struct hmap *ucast_macs_rmts = collect_umrs(ctx);
+ struct hmap *physical_locators = collect_pl(ctx);
+ struct ovsdb_idl_txn *txn;
+ struct lswitch *ls;
+
+ txn = ovsdb_idl_txn_create(ctx->vtep_idl);
+ ovsdb_idl_txn_add_comment(txn,
+ "ovn-controller-vtep: update Ucast_Macs_Remote "
+ "and Physical_Locator");
+ /* Updates the 'Ucast_Macs_Remote' table and 'Physical_Locator' table. */
+ HMAP_FOR_EACH (ls, hmap_node, vtep_lswitches) {
+ struct binding_list_node *bd;
+
+ LIST_FOR_EACH (bd, list_node, &ls->bd_list) {
+ const struct sbrec_chassis *chassis_rec;
+ struct ucast_macs_rmt *umr;
+ const char *chassis_ip;
+ int i;
+
+ chassis_rec = bd->binding->chassis;
+ chassis_ip = get_chassis_vtep_ip(chassis_rec);
+ for (i = 0; i < bd->binding->n_mac; i++) {
+ char *mac = bd->binding->mac[i];
+
+ /* Checks if there is a 'Ucast_Macs_Remote' entry. */
+ if (get_umr_by_mac(ucast_macs_rmts, mac, &umr)) {
+ /* Checks if 'chassis' entry is empty. */
+ if (chassis_rec && chassis_ip) {
+ struct physical_locator *pl;
+
+ /* Checks the logical_switch consistency. */
+ if (umr->umr->logical_switch != ls->lswitch) {
+
vteprec_ucast_macs_remote_set_logical_switch(umr->umr,
+
ls->lswitch);
+ }
+ /* Checks the physical_locator consistency. */
+ if (get_pl_by_ip(physical_locators, chassis_ip, &pl)) {
+ if (umr->umr->locator != pl->pl) {
+ vteprec_ucast_macs_remote_set_locator(umr->umr,
+ pl->pl);
+ } else {
+ /* Do nothing, since ucast_macs_remote entry,
+ * chassis and physical_locator are all there.
*/
+ }
+ } else {
+ struct vteprec_physical_locator *new_pl;
+
+ /* Creates a new 'Physical_Locator' row and updates
+ * the umr. */
+ new_pl = vteprec_physical_locator_insert(txn);
+ vteprec_physical_locator_set_dst_ip(new_pl,
chassis_ip);
+
vteprec_physical_locator_set_encapsulation_type(new_pl,
+
VTEP_ENCAP_TYPE);
+ vteprec_ucast_macs_remote_set_locator(umr->umr,
new_pl);
+ physical_locator_map_add(new_pl,
physical_locators);
+ }
+ } else {
+ /* Removes the 'Ucast_Macs_Remote' entry in vtep, since
+ * there is no chassis or no vxlan encap. */
+ vteprec_ucast_macs_remote_delete(umr->umr);
+ }
+ } else {
+ /* Checks if 'chassis' entry is empty. */
+ if (chassis_rec && chassis_ip) {
+ struct vteprec_ucast_macs_remote *new_umr;
+ struct physical_locator *pl;
+
+ new_umr = vteprec_ucast_macs_remote_insert(txn);
+ vteprec_ucast_macs_remote_set_MAC(new_umr, mac);
+ vteprec_ucast_macs_remote_set_logical_switch(new_umr,
+
ls->lswitch);
+ /* Checks if physical_locator already exists. */
+ if (get_pl_by_ip(physical_locators, chassis_ip, &pl)) {
+ vteprec_ucast_macs_remote_set_locator(new_umr,
+ pl->pl);
+ } else {
+ struct vteprec_physical_locator *new_pl;
+
+ /* Creates a new 'Physical_Locator' row and updates
+ * the umr. */
+ new_pl = vteprec_physical_locator_insert(txn);
+ vteprec_physical_locator_set_dst_ip(new_pl,
+ chassis_ip);
+
vteprec_physical_locator_set_encapsulation_type(new_pl,
+
VTEP_ENCAP_TYPE);
+ vteprec_ucast_macs_remote_set_locator(new_umr,
+ new_pl);
+ physical_locator_map_add(new_pl,
physical_locators);
+ }
+ ucast_macs_rmt_map_add(new_umr, ucast_macs_rmts);
+ } else {
+ /* Do nothing, since the chassis has not been
+ * identified yet. */
+ }
+ }
+ }
+ }
+ }
+
+ int retval;
+ retval = ovsdb_idl_txn_commit_block(txn);
+ if (retval != TXN_SUCCESS && retval != TXN_UNCHANGED) {
+ VLOG_INFO("Problem registering chassis: %s",
+ ovsdb_idl_txn_status_to_string(retval));
+ poll_immediate_wake();
+ }
+ ovsdb_idl_txn_destroy(txn);
+
+ /* Cleans up. */
+ lswitch_map_destroy(vtep_lswitches);
+ ucast_macs_rmt_map_destory(ucast_macs_rmts);
+ physical_locator_map_destory(physical_locators);
+ free(vtep_lswitches);
+ free(ucast_macs_rmts);
+ free(physical_locators);
+}
+
+/* First collects required info from vtep. Then remove the
+ * unused 'Ucast_Macs_Remote' and 'Physical_Locator' entries in vtep. */
+void
+pipeline_destroy(struct controller_vtep_ctx *ctx)
+{
+ struct hmap *ucast_macs_rmts = collect_umrs(ctx);
+ struct ucast_macs_rmt *umr;
+ struct ovsdb_idl_txn *txn;
+
+ txn = ovsdb_idl_txn_create(ctx->vtep_idl);
+ ovsdb_idl_txn_add_comment(txn,
+ "ovn-controller-vtep: clean up Ucast_Macs_Remote
"
+ "and Physical_Locator");
+ /* Cleans up all 'Ucast_Macs_Remote' entires. */
+ HMAP_FOR_EACH (umr, hmap_node, ucast_macs_rmts) {
+ vteprec_ucast_macs_remote_delete(umr->umr);
+ }
+
+ int retval;
+ retval = ovsdb_idl_txn_commit_block(txn);
+ if (retval != TXN_SUCCESS && retval != TXN_UNCHANGED) {
+ VLOG_INFO("Problem registering chassis: %s",
+ ovsdb_idl_txn_status_to_string(retval));
+ poll_immediate_wake();
+ }
+ ovsdb_idl_txn_destroy(txn);
+
+ ucast_macs_rmt_map_destory(ucast_macs_rmts);
+ free(ucast_macs_rmts);
+}
diff --git a/ovn/controller-vtep/pipeline.h b/ovn/controller-vtep/pipeline.h
new file mode 100644
index 0000000..ba0ba9e
--- /dev/null
+++ b/ovn/controller-vtep/pipeline.h
@@ -0,0 +1,25 @@
+/* Copyright (c) 2015 Nicira, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+
+#ifndef OVN_PIPELINE_H
+#define OVN_PIPELINE_H 1
+
+struct controller_vtep_ctx;
+
+void pipeline_run(struct controller_vtep_ctx *);
+void pipeline_destroy(struct controller_vtep_ctx *);
+
+#endif /* ovn/controller-gw/pipeline.h */
diff --git a/tests/ovn-controller-vtep.at b/tests/ovn-controller-vtep.at
index 819bdc3..4ab633e 100644
--- a/tests/ovn-controller-vtep.at
+++ b/tests/ovn-controller-vtep.at
@@ -198,3 +198,42 @@ AT_CHECK_UNQUOTED([ovn-sbctl --columns=chassis list
Binding | cut -d ':' -f2 | t
OVN_CONTROLLER_VTEP_STOP(["/already has logical port from the same chassis/d"])
AT_CLEANUP
+
+
+# Tests pipeline updates.
+AT_SETUP([ovn-controller-vtep - test pipeline])
+OVN_CONTROLLER_VTEP_START
+
+# creates a simple logical network with the vtep device and a fake hv chassis
+# 'ch0'.
+AT_CHECK([ovn-nbctl lport-add br-test vif0])
+AT_CHECK([ovn-nbctl lport-set-macs vif0 f0:ab:cd:ef:01:02])
+AT_CHECK([ovn-nbctl lport-add br-test vif0])
+AT_CHECK([ovn-sbctl add-chassis ch0 vxlan 1.2.3.5])
+AT_CHECK([ovn-sbctl bind-lport vif0 ch0])
+
+# vtep logical switch name must be the same as logical_datapath uuid.
+uuid=$(ovn-sbctl --columns=logical_datapath list Binding vif0 | cut -d ':' -f2
| tr -d ' ')
+AT_CHECK([vtep-ctl add-ls ${uuid} -- set Logical_Switch ${uuid} tunnel_key=1
-- bind-ls br-vtep p0 100 ${uuid}])
+
+# checks Ucast Macs Remote creation.
+OVS_WAIT_UNTIL([test -n "`vtep-ctl list Ucast_Macs_Remote | grep _uuid`"])
+AT_CHECK([vtep-ctl --columns=MAC list Ucast_Macs_Remote | cut -d ':' -f2- | tr
-d ' '], [0], [dnl
+"f0:ab:cd:ef:01:02"
+])
+
+# checks physical locator creation.
+OVS_WAIT_UNTIL([test -n "`vtep-ctl list Physical_Locator | grep _uuid`"])
+AT_CHECK([vtep-ctl --columns=dst_ip,encapsulation_type list Physical_Locator |
cut -d ':' -f2 | tr -d ' '], [0], [dnl
+"1.2.3.5"
+"vxlan_over_ipv4"
+])
+
+# checks tunnel creation by ovs-vtep.
+OVS_WAIT_UNTIL([test -n "`ovs-vsctl list Interface bfd1.2.3.5`"])
+AT_CHECK([ovs-vsctl --columns=options list Interface bfd1.2.3.5 | cut -d ':'
-f2 | tr -d ' '], [0], [dnl
+{remote_ip="1.2.3.5"}
+])
+
+OVN_CONTROLLER_VTEP_STOP
+AT_CLEANUP
--
1.7.9.5
_______________________________________________
dev mailing list
dev@openvswitch.org
http://openvswitch.org/mailman/listinfo/dev
