When ovn-nbd gets notified that the contents of the OVN_Northbound
database have changed, it will now ensure that the contents of the
Bindings table in the OVN database are up to date. It will create a
binding if none exists. If one does exist, it will update its
contents as necessary, though today the only thing supported is the
list of MAC addresses. Finally, any binding associated with a logical
port that has been deleted will be removed from the OVN database.
Signed-off-by: Russell Bryant <rbry...@redhat.com>
---
ovn/ovn-nbd.c | 99 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++--
1 file changed, 96 insertions(+), 3 deletions(-)
diff --git a/ovn/ovn-nbd.c b/ovn/ovn-nbd.c
index 344acb1..1910c2c 100644
--- a/ovn/ovn-nbd.c
+++ b/ovn/ovn-nbd.c
@@ -22,12 +22,15 @@
#include "daemon.h"
#include "dirs.h"
#include "fatal-signal.h"
+#include "hash.h"
+#include "hmap.h"
#include "ovn/ovn-idl.h"
#include "ovn/ovn-nb-idl.h"
#include "poll-loop.h"
#include "stream.h"
#include "stream-ssl.h"
#include "util.h"
+#include "uuid.h"
#include "openvswitch/vlog.h"
VLOG_DEFINE_THIS_MODULE(ovn_nbd);
@@ -65,11 +68,100 @@ Options:\n\
stream_usage("database", true, true, false);
}
+/*
+ * When a change has occurred in the OVN_Northbound database, we go through and
+ * make sure that the contents of the Bindings table in the OVN database are up
+ * to date with the logical ports defined in the OVN_Northbound database.
+ */
+static void
+set_bindings(struct nbd_context *ctx)
+{
+ struct hmap bindings_hmap;
+ const struct ovnrec_bindings *binding;
+ const struct nbrec_logical_port *lport;
+
+ struct binding_hash_node {
+ struct hmap_node node;
+ const struct ovnrec_bindings *binding;
+ } *hash_node, *hash_node_next;
+
+ /*
+ * We will need to look up a binding for every logical port. We don't want
+ * to have to do an O(n) search for every binding, so start out by hashing
+ * them on the logical port.
+ *
+ * As we go through every logical port, we will update the binding if it
+ * exists or create one otherwise. When the update is done, we'll remove
it
+ * from the hashmap. At the end, any bindings left in the hashmap are for
+ * logical ports that have been deleted.
+ */
+ hmap_init(&bindings_hmap);
+
+ OVNREC_BINDINGS_FOR_EACH(binding, ctx->ovn_idl) {
+ struct binding_hash_node *hash_node = xzalloc(sizeof *hash_node);
+ struct uuid lport_uuid;
+
+ if (!uuid_from_string(&lport_uuid, binding->logical_port)) {
+ VLOG_WARN("Invalid logical port UUID '%s' in Bindings table.",
+ binding->logical_port);
+ continue;
+ }
+
+ hash_node->binding = binding;
+ hmap_insert(&bindings_hmap, &hash_node->node, uuid_hash(&lport_uuid));
+ }
+
+ NBREC_LOGICAL_PORT_FOR_EACH(lport, ctx->ovnnb_idl) {
+ HMAP_FOR_EACH_WITH_HASH(hash_node, node,
+ uuid_hash(&lport->header_.uuid), &bindings_hmap) {
+ struct uuid lport_uuid;
+ if (uuid_from_string(&lport_uuid,
hash_node->binding->logical_port) &&
+ uuid_equals(&lport_uuid, &lport->header_.uuid)) {
+ break;
+ }
+ }
+
+ if (hash_node) {
+ /* We found an existing binding for this logical port. Update its
+ * contents. Right now the only thing we expect that could change
+ * is the list of MAC addresses. */
+
+ binding = hash_node->binding;
+ hmap_remove(&bindings_hmap, &hash_node->node);
+ free(hash_node);
+ hash_node = NULL;
+
+ ovnrec_bindings_set_mac(binding,
+ (const char **) lport->macs, lport->n_macs);
+ } else {
+ char uuid_str[UUID_LEN + 1];
+
+ /* There is no binding for this logical port, so create one. */
+
+ snprintf(uuid_str, sizeof uuid_str, UUID_FMT,
+ UUID_ARGS(&lport->header_.uuid));
+
+ binding = ovnrec_bindings_insert(ctx->ovn_txn);
+ ovnrec_bindings_set_logical_port(binding, uuid_str);
+ ovnrec_bindings_set_mac(binding,
+ (const char **) lport->macs, lport->n_macs);
+ }
+ }
+
+ HMAP_FOR_EACH_SAFE(hash_node, hash_node_next, node, &bindings_hmap) {
+ hmap_remove(&bindings_hmap, &hash_node->node);
+ ovnrec_bindings_delete(hash_node->binding);
+ free(hash_node);
+ }
+ hmap_destroy(&bindings_hmap);
+}
+
static void
-ovnnb_db_changed(struct nbd_context *ctx OVS_UNUSED)
+ovnnb_db_changed(struct nbd_context *ctx)
{
- /* XXX */
- printf("ovn-nbd: ovn-nb db contents have changed.\n");
+ VLOG_DBG("ovn-nbd: ovn-nb db contents have changed.\n");
+
+ set_bindings(ctx);
}
/*
@@ -225,6 +317,7 @@ main(int argc, char *argv[])
ovsdb_idl_add_table(ovn_idl, &ovnrec_table_bindings);
ovsdb_idl_add_column(ovn_idl, &ovnrec_bindings_col_logical_port);
ovsdb_idl_add_column(ovn_idl, &ovnrec_bindings_col_chassis);
+ ovsdb_idl_add_column(ovn_idl, &ovnrec_bindings_col_mac);
/*
* The loop here just runs the IDL in a loop waiting for the seqno to
--
2.1.0
_______________________________________________
dev mailing list
dev@openvswitch.org
http://openvswitch.org/mailman/listinfo/dev
