ofproto_port_open_type() was surprisingly slow because it called the
function ofproto_class_find__(), which itself was surprisingly slow because
it actually creates a set of strings and enumerates all of the available
classes.
This patch improves performance by eliminating the call to
ofproto_class_find__() from ofproto_port_open_type(). In turn that
required changing a parameter type and updating all the callers.
Possibly it would be worth making ofproto_class_find__() itself faster,
but it doesn't look like any of its other callers would be used in inner
loops.
For more background, see also
https://mail.openvswitch.org/pipermail/ovs-discuss/2018-February/046140.html
This patch arises as a result of testing done by Ali Ginwala and Han Zhou.
Their test showed that commit
2d4beba resulted in slower performance of
ovs-vswitchd than was seen in previous versions of OVS.
With this patch, Ali retested and reported that performance drastically
improved by ~60%. The test for 10k lports, 40 LSs and 8 LRs and 1k HVs just
got completed in 3 hours 39 min vs 8+ hours for branch-2.9. Cpu utilization
graph of a farm comparing Ben's ofproto patch vs branch-2.9 is available @
https://raw.githubusercontent.com/noah8713/ovn-scale-test/scale_results/results/ovs_2.9_vs_ben_ofproto.png
Reported-by: Mark Michelson <mmichels@redhat.com>
Acked-by: Mark Michelson <mmichels@redhat.com>
Tested-by: aginwala <aginwala@asu.edu>
Signed-off-by: Ben Pfaff <blp@ovn.org>
struct in_band *in_band;
struct netdev *local_netdev;
int error;
- const char *type = ofproto_port_open_type(ofproto->type, "internal");
+ const char *type = ofproto_port_open_type(ofproto, "internal");
*in_bandp = NULL;
error = netdev_open(local_name, type, &local_netdev);
return dump->error == EOF ? 0 : dump->error;
}
-/* Returns the type to pass to netdev_open() when a datapath of type
- * 'datapath_type' has a port of type 'port_type', for a few special
- * cases when a netdev type differs from a port type. For example, when
- * using the userspace datapath, a port of type "internal" needs to be
- * opened as "tap".
+/* Returns the type to pass to netdev_open() when 'ofproto' has a port of type
+ * 'port_type', for a few special cases when a netdev type differs from a port
+ * type. For example, when using the userspace datapath, a port of type
+ * "internal" needs to be opened as "tap".
*
* Returns either 'type' itself or a string literal, which must not be
* freed. */
const char *
-ofproto_port_open_type(const char *datapath_type, const char *port_type)
+ofproto_port_open_type(const struct ofproto *ofproto, const char *port_type)
{
- const struct ofproto_class *class;
-
- datapath_type = ofproto_normalize_type(datapath_type);
- class = ofproto_class_find__(datapath_type);
- if (!class) {
- return port_type;
- }
-
- return (class->port_open_type
- ? class->port_open_type(datapath_type, port_type)
+ return (ofproto->ofproto_class->port_open_type
+ ? ofproto->ofproto_class->port_open_type(ofproto->type, port_type)
: port_type);
}
static bool
ofport_is_internal_or_patch(const struct ofproto *p, const struct ofport *port)
{
- return !strcmp(netdev_get_type(port->netdev),
- ofproto_port_open_type(p->type, "internal")) ||
- !strcmp(netdev_get_type(port->netdev),
- ofproto_port_open_type(p->type, "patch"));
+ const char *netdev_type = netdev_get_type(port->netdev);
+ return !strcmp(netdev_type, ofproto_port_open_type(p, "internal")) ||
+ !strcmp(netdev_type, ofproto_port_open_type(p, "patch"));
}
/* If 'port' is internal or patch and if the user didn't explicitly specify an
#define OFPROTO_FLOW_LIMIT_DEFAULT 200000
#define OFPROTO_MAX_IDLE_DEFAULT 10000 /* ms */
-const char *ofproto_port_open_type(const char *datapath_type,
+const char *ofproto_port_open_type(const struct ofproto *,
const char *port_type);
int ofproto_port_add(struct ofproto *, struct netdev *, ofp_port_t *ofp_portp);
int ofproto_port_del(struct ofproto *, ofp_port_t ofp_port);
/* These members are valid only within bridge_reconfigure(). */
const char *type; /* Usually same as cfg->type. */
- const char *netdev_type; /* type that should be used for netdev_open. */
const struct ovsrec_interface *cfg;
};
goto delete;
}
- if (strcmp(ofproto_port.type, iface->netdev_type)
+ const char *netdev_type = ofproto_port_open_type(br->ofproto,
+ iface->type);
+ if (strcmp(ofproto_port.type, netdev_type)
|| netdev_set_config(iface->netdev, &iface->cfg->options, NULL)) {
/* The interface is the wrong type or can't be configured.
* Delete it. */
goto error;
}
- type = ofproto_port_open_type(br->cfg->datapath_type,
+ type = ofproto_port_open_type(br->ofproto,
iface_get_type(iface_cfg, br->cfg));
error = netdev_open(iface_cfg->name, type, &netdev);
if (error) {
iface->ofp_port = ofp_port;
iface->netdev = netdev;
iface->type = iface_get_type(iface_cfg, br->cfg);
- iface->netdev_type = ofproto_port_open_type(br->cfg->datapath_type,
- iface->type);
iface->cfg = iface_cfg;
hmap_insert(&br->ifaces, &iface->ofp_port_node,
hash_ofp_port(ofp_port));
const struct ovsrec_interface *cfg = port_rec->interfaces[i];
struct iface *iface = iface_lookup(br, cfg->name);
const char *type = iface_get_type(cfg, br->cfg);
- const char *dp_type = br->cfg->datapath_type;
- const char *netdev_type = ofproto_port_open_type(dp_type, type);
if (iface) {
iface->cfg = cfg;
iface->type = type;
- iface->netdev_type = netdev_type;
} else if (!strcmp(type, "null")) {
VLOG_WARN_ONCE("%s: The null interface type is deprecated and"
" may be removed in February 2013. Please email"