+
+ const struct sbrec_port_binding *binding;
+ SBREC_PORT_BINDING_FOR_EACH (binding, ctx->ovnsb_idl) {
+ if (strcmp(binding->type, "localnet")) {
+ /* Not a binding for a localnet port. */
+ continue;
+ }
+
+ struct local_datapath *ld;
+ ld = CONTAINER_OF(hmap_first_with_hash(local_datapaths,
+ binding->datapath->tunnel_key),
+ struct local_datapath, hmap_node);
+ if (!ld) {
+ /* This localnet port is on a datapath with no
+ * logical ports bound to this chassis, so there's no need
+ * to create patch ports for it. */
+ continue;
+ }
+ if (ld->localnet_port) {
+ static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 1);
+ VLOG_WARN_RL(&rl, "localnet port '%s' already set for datapath "
+ "'%"PRId64"', skipping the new port '%s'.",
+ ld->localnet_port->logical_port,
+ binding->datapath->tunnel_key,
+ binding->logical_port);
+ continue;
+ }
+ ld->localnet_port = binding;
+
+ const char *network = smap_get(&binding->options, "network_name");
+ if (!network) {
+ static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 1);
+ VLOG_ERR_RL(&rl, "localnet port '%s' has no network name.",
+ binding->logical_port);
+ continue;
+ }
+ struct ovsrec_bridge *br_ln = shash_find_data(&bridge_mappings, network);
+ if (!br_ln) {
+ static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 1);
+ VLOG_ERR_RL(&rl, "bridge not found for localnet port '%s' "
+ "with network name '%s'", binding->logical_port, network);
+ continue;
+ }
+
+ char *name1 = patch_port_name(br_int->name, binding->logical_port);
+ char *name2 = patch_port_name(binding->logical_port, br_int->name);
+ create_patch_port(ctx, "ovn-localnet-port", binding->logical_port,
+ br_int, name1, br_ln, name2, existing_ports);
+ create_patch_port(ctx, "ovn-localnet-port", binding->logical_port,
+ br_ln, name2, br_int, name1, existing_ports);
+ free(name1);
+ free(name2);
+ }
+
+ shash_destroy(&bridge_mappings);
+}
+
+/* Add one OVS patch port for each OVN logical patch port.
+ *
+ * This is suboptimal for several reasons. First, it creates an OVS port for
+ * every OVN logical patch port, not just for the ones that are actually useful
+ * on this hypervisor. Second, it's wasteful to create an OVS patch port per
+ * OVN logical patch port, when really there's no benefit to them beyond a way
+ * to identify how a packet ingressed into a logical datapath.
+ *
+ * There are two obvious ways to improve the situation here, by modifying
+ * OVS:
+ *
+ * 1. Add a way to configure in OVS which fields are preserved on a hop
+ * across an OVS patch port. If MFF_LOG_DATAPATH and MFF_LOG_INPORT
+ * were preserved, then only a single pair of OVS patch ports would be
+ * required regardless of the number of OVN logical patch ports.
+ *
+ * 2. Add a new OpenFlow extension action modeled on "resubmit" that also
+ * saves and restores the packet data and metadata (the inability to do
+ * this is the only reason that "resubmit" can't be used already). Or
+ * add OpenFlow extension actions to otherwise save and restore packet
+ * data and metadata.
+ */
+static void
+add_logical_patch_ports(struct controller_ctx *ctx,
+ const struct ovsrec_bridge *br_int,
+ struct shash *existing_ports)
+{
+ const struct sbrec_port_binding *binding;
+ SBREC_PORT_BINDING_FOR_EACH (binding, ctx->ovnsb_idl) {
+ if (!strcmp(binding->type, "patch")) {
+ const char *local = binding->logical_port;
+ const char *peer = smap_get(&binding->options, "peer");
+ if (!peer) {
+ continue;
+ }
+
+ char *src_name = patch_port_name(local, peer);
+ char *dst_name = patch_port_name(peer, local);
+ create_patch_port(ctx, "ovn-logical-patch-port", local,
+ br_int, src_name, br_int, dst_name,
+ existing_ports);
+ free(dst_name);
+ free(src_name);
+ }
+ }