X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=vswitchd%2Fbridge.c;h=e5b546bf4082faa12edd70916e33452cd9736191;hb=7e041ba51410125ec74cba2b5f0b6f1b0481baa9;hp=265410fcb80673d9ce786b97f4783e5d9f892597;hpb=5bd31620685801af66c022878b6029faa16d12b1;p=sliver-openvswitch.git diff --git a/vswitchd/bridge.c b/vswitchd/bridge.c index 265410fcb..e5b546bf4 100644 --- a/vswitchd/bridge.c +++ b/vswitchd/bridge.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2008, 2009, 2010, 2011 Nicira Networks +/* Copyright (c) 2008, 2009, 2010, 2011, 2012 Nicira Networks * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -32,6 +32,8 @@ #include "jsonrpc.h" #include "lacp.h" #include "list.h" +#include "mac-learning.h" +#include "meta-flow.h" #include "netdev.h" #include "ofp-print.h" #include "ofpbuf.h" @@ -48,7 +50,7 @@ #include "util.h" #include "unixctl.h" #include "vlandev.h" -#include "vswitchd/vswitch-idl.h" +#include "lib/vswitch-idl.h" #include "xenserver.h" #include "vlog.h" #include "sflow_api.h" @@ -73,6 +75,7 @@ struct iface { struct netdev *netdev; /* Network device. */ const char *type; /* Usually same as cfg->type. */ const struct ovsrec_interface *cfg; + bool need_refresh; /* Refresh iface after create. */ }; struct mirror { @@ -84,8 +87,8 @@ struct mirror { }; struct port { - struct bridge *bridge; struct hmap_node hmap_node; /* Element in struct bridge's "ports" hmap. */ + struct bridge *bridge; char *name; const struct ovsrec_port *cfg; @@ -126,6 +129,9 @@ static struct hmap all_bridges = HMAP_INITIALIZER(&all_bridges); /* OVSDB IDL used to obtain configuration. */ static struct ovsdb_idl *idl; +/* Most recently processed IDL sequence number. */ +static unsigned int idl_seqno; + /* Each time this timer expires, the bridge fetches systems and interface * statistics and pushes them into the database. */ #define STATS_INTERVAL (5 * 1000) /* In milliseconds. */ @@ -156,8 +162,10 @@ static void bridge_configure_datapath_id(struct bridge *); static void bridge_configure_flow_eviction_threshold(struct bridge *); static void bridge_configure_netflow(struct bridge *); static void bridge_configure_forward_bpdu(struct bridge *); +static void bridge_configure_mac_idle_time(struct bridge *); static void bridge_configure_sflow(struct bridge *, int *sflow_bridge_number); static void bridge_configure_stp(struct bridge *); +static void bridge_configure_tables(struct bridge *); static void bridge_configure_remotes(struct bridge *, const struct sockaddr_in *managers, size_t n_managers); @@ -167,11 +175,6 @@ static void bridge_pick_local_hw_addr(struct bridge *, static uint64_t bridge_pick_datapath_id(struct bridge *, const uint8_t bridge_ea[ETH_ADDR_LEN], struct iface *hw_addr_iface); -static const char *bridge_get_other_config(const struct ovsrec_bridge *, - const char *key); -static const char *get_port_other_config(const struct ovsrec_port *, - const char *key, - const char *default_value); static uint64_t dpid_from_hash(const void *, size_t nbytes); static bool bridge_has_bond_fake_iface(const struct bridge *, const char *name); @@ -215,10 +218,6 @@ static void iface_refresh_cfm_stats(struct iface *); static void iface_refresh_stats(struct iface *); static void iface_refresh_status(struct iface *); static bool iface_is_synthetic(const struct iface *); -static const char *get_interface_other_config(const struct ovsrec_interface *, - const char *key, - const char *default_value); - static void shash_from_ovs_idl_map(char **keys, char **values, size_t n, struct shash *); static void shash_to_ovs_idl_map(struct shash *, @@ -252,6 +251,7 @@ bridge_init(const char *remote) { /* Create connection to database. */ idl = ovsdb_idl_create(remote, &ovsrec_idl_class, true); + idl_seqno = ovsdb_idl_get_seqno(idl); ovsdb_idl_set_lock(idl, "ovs_vswitchd"); ovsdb_idl_omit_alert(idl, &ovsrec_open_vswitch_col_cur_cfg); @@ -281,7 +281,9 @@ bridge_init(const char *remote) ovsdb_idl_omit_alert(idl, &ovsrec_interface_col_statistics); ovsdb_idl_omit_alert(idl, &ovsrec_interface_col_status); ovsdb_idl_omit_alert(idl, &ovsrec_interface_col_cfm_fault); + ovsdb_idl_omit_alert(idl, &ovsrec_interface_col_cfm_fault_status); ovsdb_idl_omit_alert(idl, &ovsrec_interface_col_cfm_remote_mpids); + ovsdb_idl_omit_alert(idl, &ovsrec_interface_col_cfm_health); ovsdb_idl_omit_alert(idl, &ovsrec_interface_col_lacp_current); ovsdb_idl_omit(idl, &ovsrec_interface_col_external_ids); @@ -319,6 +321,7 @@ bridge_init(const char *remote) lacp_init(); bond_init(); cfm_init(); + stp_init(); } void @@ -432,8 +435,12 @@ bridge_reconfigure(const struct ovsrec_open_vswitch *ovs_cfg) * has at least one iface, every "struct iface" has a valid ofp_port and * netdev. */ HMAP_FOR_EACH_SAFE (br, next, node, &all_bridges) { - if (!br->ofproto && !bridge_add_ofprotos(br)) { - bridge_destroy(br); + if (!br->ofproto) { + if (bridge_add_ofprotos(br)) { + bridge_del_ofproto_ports(br); + } else { + bridge_destroy(br); + } } } HMAP_FOR_EACH (br, node, &all_bridges) { @@ -465,10 +472,12 @@ bridge_reconfigure(const struct ovsrec_open_vswitch *ovs_cfg) bridge_configure_mirrors(br); bridge_configure_flow_eviction_threshold(br); bridge_configure_forward_bpdu(br); + bridge_configure_mac_idle_time(br); bridge_configure_remotes(br, managers, n_managers); bridge_configure_netflow(br); bridge_configure_sflow(br, &sflow_bridge_number); bridge_configure_stp(br); + bridge_configure_tables(br); } free(managers); @@ -577,7 +586,7 @@ port_configure(struct port *port) s.vlan_mode = PORT_VLAN_TRUNK; } } - s.use_priority_tags = !strcmp("true", get_port_other_config( + s.use_priority_tags = !strcmp("true", ovsrec_port_get_other_config_value( cfg, "priority-tags", "")); /* Get LACP settings. */ @@ -768,7 +777,8 @@ port_configure_stp(const struct ofproto *ofproto, struct port *port, const char *config_str; struct iface *iface; - config_str = get_port_other_config(port->cfg, "stp-enable", NULL); + config_str = ovsrec_port_get_other_config_value(port->cfg, "stp-enable", + NULL); if (config_str && !strcmp(config_str, "false")) { port_s->enable = false; return; @@ -801,7 +811,8 @@ port_configure_stp(const struct ofproto *ofproto, struct port *port, return; } - config_str = get_port_other_config(port->cfg, "stp-port-num", NULL); + config_str = ovsrec_port_get_other_config_value(port->cfg, "stp-port-num", + NULL); if (config_str) { unsigned long int port_num = strtoul(config_str, NULL, 0); int port_idx = port_num - 1; @@ -830,11 +841,12 @@ port_configure_stp(const struct ofproto *ofproto, struct port *port, port_s->port_num = (*port_num_counter)++; } - config_str = get_port_other_config(port->cfg, "stp-path-cost", NULL); + config_str = ovsrec_port_get_other_config_value(port->cfg, "stp-path-cost", + NULL); if (config_str) { port_s->path_cost = strtoul(config_str, NULL, 10); } else { - uint32_t current; + enum netdev_features current; if (netdev_get_features(iface->netdev, ¤t, NULL, NULL, NULL)) { /* Couldn't get speed, so assume 100Mb/s. */ @@ -847,7 +859,9 @@ port_configure_stp(const struct ofproto *ofproto, struct port *port, } } - config_str = get_port_other_config(port->cfg, "stp-port-priority", NULL); + config_str = ovsrec_port_get_other_config_value(port->cfg, + "stp-port-priority", + NULL); if (config_str) { port_s->priority = strtoul(config_str, NULL, 0); } else { @@ -868,7 +882,9 @@ bridge_configure_stp(struct bridge *br) int port_num_counter; unsigned long *port_num_bitmap; - config_str = bridge_get_other_config(br->cfg, "stp-system-id"); + config_str = ovsrec_bridge_get_other_config_value(br->cfg, + "stp-system-id", + NULL); if (config_str) { uint8_t ea[ETH_ADDR_LEN]; @@ -883,28 +899,36 @@ bridge_configure_stp(struct bridge *br) br_s.system_id = eth_addr_to_uint64(br->ea); } - config_str = bridge_get_other_config(br->cfg, "stp-priority"); + config_str = ovsrec_bridge_get_other_config_value(br->cfg, + "stp-priority", + NULL); if (config_str) { br_s.priority = strtoul(config_str, NULL, 0); } else { br_s.priority = STP_DEFAULT_BRIDGE_PRIORITY; } - config_str = bridge_get_other_config(br->cfg, "stp-hello-time"); + config_str = ovsrec_bridge_get_other_config_value(br->cfg, + "stp-hello-time", + NULL); if (config_str) { br_s.hello_time = strtoul(config_str, NULL, 10) * 1000; } else { br_s.hello_time = STP_DEFAULT_HELLO_TIME; } - config_str = bridge_get_other_config(br->cfg, "stp-max-age"); + config_str = ovsrec_bridge_get_other_config_value(br->cfg, + "stp-max-age", + NULL); if (config_str) { br_s.max_age = strtoul(config_str, NULL, 10) * 1000; } else { br_s.max_age = STP_DEFAULT_MAX_AGE; } - config_str = bridge_get_other_config(br->cfg, "stp-forward-delay"); + config_str = ovsrec_bridge_get_other_config_value(br->cfg, + "stp-forward-delay", + NULL); if (config_str) { br_s.fwd_delay = strtoul(config_str, NULL, 10) * 1000; } else { @@ -1170,9 +1194,10 @@ bridge_add_ofproto_ports(struct bridge *br) } /* Populate stats columns in new Interface rows. */ - if (iface->netdev && !iface->cfg->mtu) { + if (iface->netdev && iface->need_refresh) { iface_refresh_stats(iface); iface_refresh_status(iface); + iface->need_refresh = false; } /* Delete the iface if we failed. */ @@ -1187,6 +1212,11 @@ bridge_add_ofproto_ports(struct bridge *br) /* We already reported a related error, don't bother * duplicating it. */ } + if (!ofproto_port_query_by_name(br->ofproto, port->name, + &ofproto_port)) { + ofproto_port_del(br->ofproto, ofproto_port.ofp_port); + ofproto_port_destroy(&ofproto_port); + } iface_clear_db_record(iface->cfg); iface_destroy(iface); } @@ -1220,27 +1250,6 @@ bridge_add_ofproto_ports(struct bridge *br) } } -static const char * -get_ovsrec_key_value(char **keys, char **values, size_t n, const char *key) -{ - size_t i; - - for (i = 0; i < n; i++) { - if (!strcmp(keys[i], key)) { - return values[i]; - } - } - return NULL; -} - -static const char * -bridge_get_other_config(const struct ovsrec_bridge *br_cfg, const char *key) -{ - return get_ovsrec_key_value(br_cfg->key_other_config, - br_cfg->value_other_config, - br_cfg->n_other_config, key); -} - /* Set Flow eviction threshold */ static void bridge_configure_flow_eviction_threshold(struct bridge *br) @@ -1248,7 +1257,10 @@ bridge_configure_flow_eviction_threshold(struct bridge *br) const char *threshold_str; unsigned threshold; - threshold_str = bridge_get_other_config(br->cfg, "flow-eviction-threshold"); + threshold_str = + ovsrec_bridge_get_other_config_value(br->cfg, + "flow-eviction-threshold", + NULL); if (threshold_str) { threshold = strtoul(threshold_str, NULL, 10); } else { @@ -1264,13 +1276,31 @@ bridge_configure_forward_bpdu(struct bridge *br) const char *forward_bpdu_str; bool forward_bpdu = false; - forward_bpdu_str = bridge_get_other_config(br->cfg, "forward-bpdu"); + forward_bpdu_str = ovsrec_bridge_get_other_config_value(br->cfg, + "forward-bpdu", + NULL); if (forward_bpdu_str && !strcmp(forward_bpdu_str, "true")) { forward_bpdu = true; } ofproto_set_forward_bpdu(br->ofproto, forward_bpdu); } +/* Set MAC aging time for 'br'. */ +static void +bridge_configure_mac_idle_time(struct bridge *br) +{ + const char *idle_time_str; + int idle_time; + + idle_time_str = ovsrec_bridge_get_other_config_value(br->cfg, + "mac-aging-time", + NULL); + idle_time = (idle_time_str && atoi(idle_time_str) + ? atoi(idle_time_str) + : MAC_ENTRY_DEFAULT_IDLE_TIME); + ofproto_set_mac_idle_time(br->ofproto, idle_time); +} + static void bridge_pick_local_hw_addr(struct bridge *br, uint8_t ea[ETH_ADDR_LEN], struct iface **hw_addr_iface) @@ -1285,7 +1315,7 @@ bridge_pick_local_hw_addr(struct bridge *br, uint8_t ea[ETH_ADDR_LEN], *hw_addr_iface = NULL; /* Did the user request a particular MAC? */ - hwaddr = bridge_get_other_config(br->cfg, "hwaddr"); + hwaddr = ovsrec_bridge_get_other_config_value(br->cfg, "hwaddr", NULL); if (hwaddr && eth_addr_from_string(hwaddr, ea)) { if (eth_addr_is_multicast(ea)) { VLOG_ERR("bridge %s: cannot set MAC address to multicast " @@ -1375,10 +1405,11 @@ bridge_pick_local_hw_addr(struct bridge *br, uint8_t ea[ETH_ADDR_LEN], VLOG_DBG("bridge %s: using bridge Ethernet address "ETH_ADDR_FMT, br->name, ETH_ADDR_ARGS(ea)); } else { + static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 10); memcpy(ea, br->default_ea, ETH_ADDR_LEN); *hw_addr_iface = NULL; - VLOG_WARN("bridge %s: using default bridge Ethernet " - "address "ETH_ADDR_FMT, br->name, ETH_ADDR_ARGS(ea)); + VLOG_WARN_RL(&rl, "bridge %s: using default bridge Ethernet " + "address "ETH_ADDR_FMT, br->name, ETH_ADDR_ARGS(ea)); } hmapx_destroy(&mirror_output_ports); @@ -1409,7 +1440,8 @@ bridge_pick_datapath_id(struct bridge *br, const char *datapath_id; uint64_t dpid; - datapath_id = bridge_get_other_config(br->cfg, "datapath-id"); + datapath_id = ovsrec_bridge_get_other_config_value(br->cfg, "datapath-id", + NULL); if (datapath_id && dpid_from_string(datapath_id, &dpid)) { return dpid; } @@ -1457,8 +1489,8 @@ iface_refresh_status(struct iface *iface) { struct shash sh; + enum netdev_features current; enum netdev_flags flags; - uint32_t current; int64_t bps; int mtu; int64_t mtu_64; @@ -1470,7 +1502,7 @@ iface_refresh_status(struct iface *iface) shash_init(&sh); - if (!netdev_get_status(iface->netdev, &sh)) { + if (!netdev_get_drv_info(iface->netdev, &sh)) { size_t n; char **keys, **values; @@ -1487,7 +1519,8 @@ iface_refresh_status(struct iface *iface) error = netdev_get_flags(iface->netdev, &flags); if (!error) { - ovsrec_interface_set_admin_state(iface->cfg, flags & NETDEV_UP ? "up" : "down"); + ovsrec_interface_set_admin_state(iface->cfg, + flags & NETDEV_UP ? "up" : "down"); } else { ovsrec_interface_set_admin_state(iface->cfg, NULL); @@ -1525,6 +1558,7 @@ iface_refresh_cfm_stats(struct iface *iface) int fault, error; const uint64_t *rmps; size_t n_rmps; + int health; if (iface_is_synthetic(iface)) { return; @@ -1533,10 +1567,23 @@ iface_refresh_cfm_stats(struct iface *iface) fault = ofproto_port_get_cfm_fault(iface->port->bridge->ofproto, iface->ofp_port); if (fault >= 0) { + const char *reasons[CFM_FAULT_N_REASONS]; bool fault_bool = fault; + size_t i, j; + + j = 0; + for (i = 0; i < CFM_FAULT_N_REASONS; i++) { + int reason = 1 << i; + if (fault & reason) { + reasons[j++] = cfm_fault_reason_to_str(reason); + } + } + ovsrec_interface_set_cfm_fault(cfg, &fault_bool, 1); + ovsrec_interface_set_cfm_fault_status(cfg, (char **) reasons, j); } else { ovsrec_interface_set_cfm_fault(cfg, NULL, 0); + ovsrec_interface_set_cfm_fault_status(cfg, NULL, 0); } error = ofproto_port_get_cfm_remote_mpids(iface->port->bridge->ofproto, @@ -1547,6 +1594,15 @@ iface_refresh_cfm_stats(struct iface *iface) } else { ovsrec_interface_set_cfm_remote_mpids(cfg, NULL, 0); } + + health = ofproto_port_get_cfm_health(iface->port->bridge->ofproto, + iface->ofp_port); + if (health >= 0) { + int64_t cfm_health = health; + ovsrec_interface_set_cfm_health(cfg, &cfm_health, 1); + } else { + ovsrec_interface_set_cfm_health(cfg, NULL, 0); + } } static void @@ -1589,7 +1645,8 @@ iface_refresh_stats(struct iface *iface) #undef IFACE_STAT assert(i == ARRAY_SIZE(keys)); - ovsrec_interface_set_statistics(iface->cfg, keys, values, ARRAY_SIZE(keys)); + ovsrec_interface_set_statistics(iface->cfg, keys, values, + ARRAY_SIZE(keys)); #undef IFACE_STATS } @@ -1692,10 +1749,9 @@ enable_system_stats(const struct ovsrec_open_vswitch *cfg) const char *enable; /* Use other-config:enable-system-stats by preference. */ - enable = get_ovsrec_key_value(cfg->key_other_config, - cfg->value_other_config, - cfg->n_other_config, - "enable-statistics"); + enable = ovsrec_open_vswitch_get_other_config_value(cfg, + "enable-statistics", + NULL); if (enable) { return !strcmp(enable, "true"); } @@ -1817,11 +1873,10 @@ bridge_run(void) const struct ovsrec_open_vswitch *cfg; bool vlan_splinters_changed; - bool database_changed; struct bridge *br; /* (Re)configure if necessary. */ - database_changed = ovsdb_idl_run(idl); + ovsdb_idl_run(idl); if (ovsdb_idl_is_lock_contended(idl)) { static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 1); struct bridge *br, *next_br; @@ -1868,7 +1923,8 @@ bridge_run(void) } } - if (database_changed || vlan_splinters_changed) { + if (ovsdb_idl_get_seqno(idl) != idl_seqno || vlan_splinters_changed) { + idl_seqno = ovsdb_idl_get_seqno(idl); if (cfg) { struct ovsdb_idl_txn *txn = ovsdb_idl_txn_create(idl); @@ -2049,7 +2105,7 @@ qos_unixctl_show(struct unixctl_conn *conn, int argc OVS_UNUSED, iface = iface_find(argv[1]); if (!iface) { - unixctl_command_reply(conn, 501, "no such interface"); + unixctl_command_reply_error(conn, "no such interface"); return; } @@ -2069,10 +2125,10 @@ qos_unixctl_show(struct unixctl_conn *conn, int argc OVS_UNUSED, if (error) { ds_put_format(&ds, "failed to dump queues: %s", strerror(error)); } - unixctl_command_reply(conn, 200, ds_cstr(&ds)); + unixctl_command_reply(conn, ds_cstr(&ds)); } else { ds_put_format(&ds, "QoS not configured on %s\n", iface->name); - unixctl_command_reply(conn, 501, ds_cstr(&ds)); + unixctl_command_reply_error(conn, ds_cstr(&ds)); } shash_destroy_free_data(&sh); @@ -2154,14 +2210,14 @@ bridge_unixctl_dump_flows(struct unixctl_conn *conn, int argc OVS_UNUSED, br = bridge_lookup(argv[1]); if (!br) { - unixctl_command_reply(conn, 501, "Unknown bridge"); + unixctl_command_reply_error(conn, "Unknown bridge"); return; } ds_init(&results); ofproto_get_all_flows(br->ofproto, &results); - unixctl_command_reply(conn, 200, ds_cstr(&results)); + unixctl_command_reply(conn, ds_cstr(&results)); ds_destroy(&results); } @@ -2176,7 +2232,7 @@ bridge_unixctl_reconnect(struct unixctl_conn *conn, int argc, if (argc > 1) { br = bridge_lookup(argv[1]); if (!br) { - unixctl_command_reply(conn, 501, "Unknown bridge"); + unixctl_command_reply_error(conn, "Unknown bridge"); return; } ofproto_reconnect_controllers(br->ofproto); @@ -2185,7 +2241,7 @@ bridge_unixctl_reconnect(struct unixctl_conn *conn, int argc, ofproto_reconnect_controllers(br->ofproto); } } - unixctl_command_reply(conn, 200, NULL); + unixctl_command_reply(conn, NULL); } static size_t @@ -2293,6 +2349,7 @@ bridge_ofproto_controller_for_mgmt(const struct bridge *br, oc->band = OFPROTO_OUT_OF_BAND; oc->rate_limit = 0; oc->burst_limit = 0; + oc->enable_async_msgs = true; } /* Converts ovsrec_controller 'c' into an ofproto_controller in 'oc'. */ @@ -2300,6 +2357,8 @@ static void bridge_ofproto_controller_from_ovsrec(const struct ovsrec_controller *c, struct ofproto_controller *oc) { + const char *config_str; + oc->target = c->target; oc->max_backoff = c->max_backoff ? *c->max_backoff / 1000 : 8; oc->probe_interval = c->inactivity_probe ? *c->inactivity_probe / 1000 : 5; @@ -2308,6 +2367,14 @@ bridge_ofproto_controller_from_ovsrec(const struct ovsrec_controller *c, oc->rate_limit = c->controller_rate_limit ? *c->controller_rate_limit : 0; oc->burst_limit = (c->controller_burst_limit ? *c->controller_burst_limit : 0); + oc->enable_async_msgs = (!c->enable_async_messages + || *c->enable_async_messages); + config_str = ovsrec_controller_get_other_config_value(c, "dscp", NULL); + if (config_str) { + oc->dscp = atoi(config_str); + } else { + oc->dscp = DSCP_DEFAULT; + } } /* Configures the IP stack for 'br''s local interface properly according to the @@ -2392,13 +2459,17 @@ bridge_configure_remotes(struct bridge *br, size_t i; /* Check if we should disable in-band control on this bridge. */ - disable_ib_str = bridge_get_other_config(br->cfg, "disable-in-band"); + disable_ib_str = ovsrec_bridge_get_other_config_value(br->cfg, + "disable-in-band", + NULL); if (disable_ib_str && !strcmp(disable_ib_str, "true")) { disable_in_band = true; } /* Set OpenFlow queue ID for in-band control. */ - queue_id_str = bridge_get_other_config(br->cfg, "in-band-queue"); + queue_id_str = ovsrec_bridge_get_other_config_value(br->cfg, + "in-band-queue", + NULL); queue_id = queue_id_str ? strtol(queue_id_str, NULL, 10) : -1; ofproto_set_in_band_queue(br->ofproto, queue_id); @@ -2472,6 +2543,66 @@ bridge_configure_remotes(struct bridge *br, sset_destroy(&snoops); } } + +static void +bridge_configure_tables(struct bridge *br) +{ + static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 5); + int n_tables; + int i, j; + + n_tables = ofproto_get_n_tables(br->ofproto); + j = 0; + for (i = 0; i < n_tables; i++) { + struct ofproto_table_settings s; + + s.name = NULL; + s.max_flows = UINT_MAX; + s.groups = NULL; + s.n_groups = 0; + + if (j < br->cfg->n_flow_tables && i == br->cfg->key_flow_tables[j]) { + struct ovsrec_flow_table *cfg = br->cfg->value_flow_tables[j++]; + + s.name = cfg->name; + if (cfg->n_flow_limit && *cfg->flow_limit < UINT_MAX) { + s.max_flows = *cfg->flow_limit; + } + if (cfg->overflow_policy + && !strcmp(cfg->overflow_policy, "evict")) { + size_t k; + + s.groups = xmalloc(cfg->n_groups * sizeof *s.groups); + for (k = 0; k < cfg->n_groups; k++) { + const char *string = cfg->groups[k]; + char *msg; + + msg = mf_parse_subfield__(&s.groups[k], &string); + if (msg) { + VLOG_WARN_RL(&rl, "bridge %s table %d: error parsing " + "'groups' (%s)", br->name, i, msg); + free(msg); + } else if (*string) { + VLOG_WARN_RL(&rl, "bridge %s table %d: 'groups' " + "element '%s' contains trailing garbage", + br->name, i, cfg->groups[k]); + } else { + s.n_groups++; + } + } + } + } + + ofproto_configure_table(br->ofproto, i, &s); + + free(s.groups); + } + for (; j < br->cfg->n_flow_tables; j++) { + VLOG_WARN_RL(&rl, "bridge %s: ignoring configuration for flow table " + "%"PRId64" not supported by this datapath", br->name, + br->cfg->key_flow_tables[j]); + } +} /* Port functions. */ @@ -2493,30 +2624,6 @@ port_create(struct bridge *br, const struct ovsrec_port *cfg) return port; } -static const char * -get_port_other_config(const struct ovsrec_port *port, const char *key, - const char *default_value) -{ - const char *value; - - value = get_ovsrec_key_value(port->key_other_config, - port->value_other_config, - port->n_other_config, key); - return value ? value : default_value; -} - -static const char * -get_interface_other_config(const struct ovsrec_interface *iface, - const char *key, const char *default_value) -{ - const char *value; - - value = get_ovsrec_key_value(iface->key_other_config, - iface->value_other_config, - iface->n_other_config, key); - return value ? value : default_value; -} - /* Deletes interfaces from 'port' that are no longer configured for it. */ static void port_del_ifaces(struct port *port) @@ -2663,10 +2770,16 @@ port_configure_lacp(struct port *port, struct lacp_settings *s) s->name = port->name; - system_id = get_port_other_config(port->cfg, "lacp-system-id", NULL); - if (!system_id - || sscanf(system_id, ETH_ADDR_SCAN_FMT, - ETH_ADDR_SCAN_ARGS(s->id)) != ETH_ADDR_SCAN_COUNT) { + system_id = ovsrec_port_get_other_config_value(port->cfg, "lacp-system-id", + NULL); + if (system_id) { + if (sscanf(system_id, ETH_ADDR_SCAN_FMT, + ETH_ADDR_SCAN_ARGS(s->id)) != ETH_ADDR_SCAN_COUNT) { + VLOG_WARN("port %s: LACP system ID (%s) must be an Ethernet" + " address.", port->name, system_id); + return NULL; + } + } else { memcpy(s->id, port->bridge->ea, ETH_ADDR_LEN); } @@ -2676,17 +2789,20 @@ port_configure_lacp(struct port *port, struct lacp_settings *s) } /* Prefer bondable links if unspecified. */ - priority = atoi(get_port_other_config(port->cfg, "lacp-system-priority", - "0")); + priority = atoi(ovsrec_port_get_other_config_value(port->cfg, + "lacp-system-priority", + "0")); s->priority = (priority > 0 && priority <= UINT16_MAX ? priority : UINT16_MAX - !list_is_short(&port->ifaces)); - s->heartbeat = !strcmp(get_port_other_config(port->cfg, - "lacp-heartbeat", - "false"), "true"); + s->heartbeat = !strcmp(ovsrec_port_get_other_config_value(port->cfg, + "lacp-heartbeat", + "false"), + "true"); - lacp_time = get_port_other_config(port->cfg, "lacp-time", "slow"); + lacp_time = ovsrec_port_get_other_config_value(port->cfg, "lacp-time", + "slow"); custom_time = atoi(lacp_time); if (!strcmp(lacp_time, "fast")) { s->lacp_time = LACP_TIME_FAST; @@ -2707,11 +2823,16 @@ iface_configure_lacp(struct iface *iface, struct lacp_slave_settings *s) { int priority, portid, key; - portid = atoi(get_interface_other_config(iface->cfg, "lacp-port-id", "0")); - priority = atoi(get_interface_other_config(iface->cfg, - "lacp-port-priority", "0")); - key = atoi(get_interface_other_config(iface->cfg, "lacp-aggregation-key", - "0")); + portid = atoi(ovsrec_interface_get_other_config_value(iface->cfg, + "lacp-port-id", + "0")); + priority = + atoi(ovsrec_interface_get_other_config_value(iface->cfg, + "lacp-port-priority", + "0")); + key = atoi(ovsrec_interface_get_other_config_value(iface->cfg, + "lacp-aggregation-key", + "0")); if (portid <= 0 || portid > UINT16_MAX) { portid = iface->ofp_port; @@ -2741,7 +2862,7 @@ port_configure_bond(struct port *port, struct bond_settings *s, size_t i; s->name = port->name; - s->balance = BM_SLB; + s->balance = BM_AB; if (port->cfg->bond_mode) { if (!bond_mode_from_string(&s->balance, port->cfg->bond_mode)) { VLOG_WARN("port %s: unknown bond_mode %s, defaulting to %s", @@ -2751,11 +2872,11 @@ port_configure_bond(struct port *port, struct bond_settings *s, } else { static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 1); - /* XXX: Post version 1.4.*, change the default bond_mode to - * active-backup. Until then, warn that the change is imminent. */ + /* XXX: Post version 1.5.*, the default bond_mode changed from SLB to + * active-backup. At some point we should remove this warning. */ VLOG_WARN_RL(&rl, "port %s: Using the default bond_mode %s. Note that" - " in future versions, the default bond_mode is expected" - " to change to active-backup", port->name, + " in previous versions, the default bond_mode was" + " balance-slb", port->name, bond_mode_to_string(s->balance)); } if (s->balance == BM_SLB && port->bridge->cfg->n_flood_vlans) { @@ -2764,13 +2885,16 @@ port_configure_bond(struct port *port, struct bond_settings *s, port->name); } - miimon_interval = atoi(get_port_other_config(port->cfg, - "bond-miimon-interval", "0")); + miimon_interval = + atoi(ovsrec_port_get_other_config_value(port->cfg, + "bond-miimon-interval", "0")); if (miimon_interval <= 0) { miimon_interval = 200; } - detect_s = get_port_other_config(port->cfg, "bond-detect-mode", "carrier"); + detect_s = ovsrec_port_get_other_config_value(port->cfg, + "bond-detect-mode", + "carrier"); if (!strcmp(detect_s, "carrier")) { miimon_interval = 0; } else if (strcmp(detect_s, "miimon")) { @@ -2781,10 +2905,14 @@ port_configure_bond(struct port *port, struct bond_settings *s, s->up_delay = MAX(0, port->cfg->bond_updelay); s->down_delay = MAX(0, port->cfg->bond_downdelay); - s->basis = atoi(get_port_other_config(port->cfg, "bond-hash-basis", "0")); + s->basis = atoi(ovsrec_port_get_other_config_value(port->cfg, + "bond-hash-basis", + "0")); s->rebalance_interval = atoi( - get_port_other_config(port->cfg, "bond-rebalance-interval", "10000")); - if (s->rebalance_interval < 1000) { + ovsrec_port_get_other_config_value(port->cfg, + "bond-rebalance-interval", + "10000")); + if (s->rebalance_interval && s->rebalance_interval < 1000) { s->rebalance_interval = 1000; } @@ -2794,8 +2922,10 @@ port_configure_bond(struct port *port, struct bond_settings *s, LIST_FOR_EACH (iface, port_elem, &port->ifaces) { long long stable_id; - stable_id = atoll(get_interface_other_config(iface->cfg, - "bond-stable-id", "0")); + stable_id = + atoll(ovsrec_interface_get_other_config_value(iface->cfg, + "bond-stable-id", + "0")); if (stable_id <= 0 || stable_id >= UINT32_MAX) { stable_id = iface->ofp_port; } @@ -2829,6 +2959,7 @@ iface_create(struct port *port, const struct ovsrec_interface *if_cfg) iface->tag = tag_create_random(); iface->netdev = NULL; iface->cfg = if_cfg; + iface->need_refresh = true; hmap_insert(&br->iface_by_name, &iface->name_node, hash_string(name, 0)); @@ -2960,6 +3091,7 @@ iface_clear_db_record(const struct ovsrec_interface *if_cfg) ovsrec_interface_set_link_state(if_cfg, NULL); ovsrec_interface_set_mtu(if_cfg, NULL, 0); ovsrec_interface_set_cfm_fault(if_cfg, NULL, 0); + ovsrec_interface_set_cfm_fault_status(if_cfg, NULL, 0); ovsrec_interface_set_cfm_remote_mpids(if_cfg, NULL, 0); ovsrec_interface_set_lacp_current(if_cfg, NULL, 0); ovsrec_interface_set_statistics(if_cfg, NULL, NULL, 0); @@ -3092,11 +3224,9 @@ iface_configure_qos(struct iface *iface, const struct ovsrec_qos *qos) shash_destroy(&details); } if (!queue_zero) { - static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(1, 1); - VLOG_WARN_RL(&rl, "interface %s: QoS configured without a default " - "queue (queue 0). Packets not directed to a " - "correctly configured queue may be dropped.", - iface->name); + shash_init(&details); + netdev_set_queue(iface->netdev, 0, &details); + shash_destroy(&details); } } @@ -3120,6 +3250,7 @@ iface_configure_cfm(struct iface *iface) { const struct ovsrec_interface *cfg = iface->cfg; const char *extended_str, *opstate_str; + const char *cfm_ccm_vlan; struct cfm_settings s; if (!cfg->n_cfm_mpid) { @@ -3128,19 +3259,36 @@ iface_configure_cfm(struct iface *iface) } s.mpid = *cfg->cfm_mpid; - s.interval = atoi(get_interface_other_config(iface->cfg, "cfm_interval", - "0")); - s.ccm_vlan = atoi(get_interface_other_config(iface->cfg, "cfm_ccm_vlan", - "0")); + s.interval = atoi(ovsrec_interface_get_other_config_value(iface->cfg, + "cfm_interval", + "0")); + cfm_ccm_vlan = ovsrec_interface_get_other_config_value(iface->cfg, + "cfm_ccm_vlan", + "0"); + s.ccm_pcp = atoi(ovsrec_interface_get_other_config_value(iface->cfg, + "cfm_ccm_pcp", + "0")); if (s.interval <= 0) { s.interval = 1000; } - extended_str = get_interface_other_config(iface->cfg, "cfm_extended", - "false"); + if (!strcasecmp("random", cfm_ccm_vlan)) { + s.ccm_vlan = CFM_RANDOM_VLAN; + } else { + s.ccm_vlan = atoi(cfm_ccm_vlan); + if (s.ccm_vlan == CFM_RANDOM_VLAN) { + s.ccm_vlan = 0; + } + } + + extended_str = ovsrec_interface_get_other_config_value(iface->cfg, + "cfm_extended", + "false"); s.extended = !strcasecmp("true", extended_str); - opstate_str = get_interface_other_config(iface->cfg, "cfm_opstate", "up"); + opstate_str = ovsrec_interface_get_other_config_value(iface->cfg, + "cfm_opstate", + "up"); s.opup = !strcasecmp("up", opstate_str); ofproto_port_set_cfm(iface->port->bridge->ofproto, iface->ofp_port, &s); @@ -3153,6 +3301,7 @@ iface_is_synthetic(const struct iface *iface) { return ovsdb_idl_row_is_synthetic(&iface->cfg->header_); } + /* Port mirroring. */ @@ -3381,7 +3530,9 @@ vlan_splinters_is_enabled(const struct ovsrec_interface *iface_cfg) { const char *value; - value = get_interface_other_config(iface_cfg, "enable-vlan-splinters", ""); + value = ovsrec_interface_get_other_config_value(iface_cfg, + "enable-vlan-splinters", + ""); return !strcmp(value, "true"); } @@ -3412,8 +3563,9 @@ collect_splinter_vlans(const struct ovsrec_open_vswitch *ovs_cfg) * in the process of reconstructing all of them. */ free_registered_blocks(); - splinter_vlans = NULL; + splinter_vlans = bitmap_allocate(4096); sset_init(&splinter_ifaces); + vlan_splinters_enabled_anywhere = false; for (i = 0; i < ovs_cfg->n_bridges; i++) { struct ovsrec_bridge *br_cfg = ovs_cfg->bridges[i]; size_t j; @@ -3426,21 +3578,22 @@ collect_splinter_vlans(const struct ovsrec_open_vswitch *ovs_cfg) struct ovsrec_interface *iface_cfg = port_cfg->interfaces[k]; if (vlan_splinters_is_enabled(iface_cfg)) { + vlan_splinters_enabled_anywhere = true; sset_add(&splinter_ifaces, iface_cfg->name); - - if (!splinter_vlans) { - splinter_vlans = bitmap_allocate(4096); - } vlan_bitmap_from_array__(port_cfg->trunks, port_cfg->n_trunks, splinter_vlans); } } + + if (port_cfg->tag && *port_cfg->tag > 0 && *port_cfg->tag < 4095) { + bitmap_set1(splinter_vlans, *port_cfg->tag); + } } } - vlan_splinters_enabled_anywhere = splinter_vlans != NULL; - if (!splinter_vlans) { + if (!vlan_splinters_enabled_anywhere) { + free(splinter_vlans); sset_destroy(&splinter_ifaces); return NULL; } @@ -3524,7 +3677,8 @@ configure_splinter_port(struct port *port) vlandev = CONTAINER_OF(list_front(&port->ifaces), struct iface, port_elem); - realdev_name = get_port_other_config(port->cfg, "realdev", NULL); + realdev_name = ovsrec_port_get_other_config_value(port->cfg, + "realdev", NULL); realdev = iface_lookup(port->bridge, realdev_name); realdev_ofp_port = realdev ? realdev->ofp_port : 0;