[ovs-dev] [PATCH v2] ovn-northd, tests: Adding IPAM to ovn-northd.
Guru Shetty
guru at ovn.org
Fri Jun 24 18:27:34 UTC 2016
On 23 June 2016 at 14:55, Nimay Desai <nimaydesai1 at gmail.com> wrote:
> Added an IPv4 and MAC addresses management system to ovn-northd. When a
> logical
> switch's options:subnet field is set, logical ports attached to that switch
> that do not have a MAC/IPv4 address will automatically be allocated a
> globally
> unique MAC address/unused IPv4 address within the provided subnet. This
> can be useful for a user who wants to deploy many VM's or containers with
> networking capabilities, but does not care about the specific MAC/IPv4
> addresses that are assigned.
>
> Added tests in ovn.at for ipam.
>
> Signed-off-by: Nimay Desai <nimaydesai1 at gmail.com>
> ---
> AUTHORS | 1 +
> ovn/northd/ovn-northd.c | 343
> ++++++++++++++++++++++++++++++++++++++++++++++++
> ovn/ovn-nb.ovsschema | 7 +-
> ovn/ovn-nb.xml | 14 +-
> tests/ovn.at | 145 ++++++++++++++++++++
> 5 files changed, 507 insertions(+), 3 deletions(-)
>
> diff --git a/AUTHORS b/AUTHORS
> index c39fdd3..a0a38a0 100644
> --- a/AUTHORS
> +++ b/AUTHORS
> @@ -162,6 +162,7 @@ Murphy McCauley murphy.mccauley at gmail.com
> Natasha Gude natasha at nicira.com
> Neil McKee neil.mckee at inmon.com
> Neil Zhu zhuj at centecnetworks.com
> +Nimay Desai nimaydesai1 at gmail.com
> Nithin Raju nithin at vmware.com
> Niti Rohilla niti.rohilla at tcs.com
> Numan Siddique nusiddiq at redhat.com
> diff --git a/ovn/northd/ovn-northd.c b/ovn/northd/ovn-northd.c
> index c2cf15e..37c6482 100644
> --- a/ovn/northd/ovn-northd.c
> +++ b/ovn/northd/ovn-northd.c
> @@ -56,6 +56,12 @@ static const char *ovnsb_db;
>
> static const char *default_nb_db(void);
> static const char *default_sb_db(void);
> +
> +#define MAC_ADDR_PREFIX 0x0A0000000000L
> +#define MAC_ADDR_SPACE 0xffffff
> +/* MAC address table of "struct eth_addr"s, that holds the MAC addresses
> + * allocated by the ipam. */
> +static struct hmap macam;
>
> /* Pipeline stages. */
>
> @@ -261,8 +267,41 @@ struct ovn_datapath {
> uint32_t port_key_hint;
>
> bool has_unknown;
> +
> + /* IPAM data. */
> + struct hmap ipam;
> +};
> +
> +struct macam_node {
> + struct hmap_node hmap_node;
> + struct eth_addr mac_addr; /* Allocated MAC address. */
> +};
> +
> +static void
> +destroy_macam(struct hmap *macam)
> +{
> + struct macam_node *node;
> + HMAP_FOR_EACH_POP (node, hmap_node, macam) {
> + free(node);
> + }
> + hmap_destroy(macam);
> +}
> +
> +struct ipam_node {
> + struct hmap_node hmap_node;
> + uint32_t ip_addr; /* Allocated IP address. */
> };
>
> +static void
> +destroy_ipam(struct hmap *ipam)
> +{
> + struct ipam_node *node;
> + HMAP_FOR_EACH_POP (node, hmap_node, ipam) {
> + free(node);
> + }
> + hmap_destroy(ipam);
> +}
> +
> static struct ovn_datapath *
> ovn_datapath_create(struct hmap *datapaths, const struct uuid *key,
> const struct nbrec_logical_switch *nbs,
> @@ -275,6 +314,7 @@ ovn_datapath_create(struct hmap *datapaths, const
> struct uuid *key,
> od->nbs = nbs;
> od->nbr = nbr;
> hmap_init(&od->port_tnlids);
> + hmap_init(&od->ipam);
> od->port_key_hint = 0;
> hmap_insert(datapaths, &od->key_node, uuid_hash(&od->key));
> return od;
> @@ -289,6 +329,7 @@ ovn_datapath_destroy(struct hmap *datapaths, struct
> ovn_datapath *od)
> * use it. */
> hmap_remove(datapaths, &od->key_node);
> destroy_tnlids(&od->port_tnlids);
> + destroy_ipam(&od->ipam);
> free(od->router_ports);
> free(od);
> }
> @@ -2517,6 +2558,307 @@ build_lflows(struct northd_context *ctx, struct
> hmap *datapaths,
> hmap_destroy(&mcgroups);
> }
>
> +
> +static void
> +ipam_insert_mac(struct eth_addr *ea, bool check)
> +{
> + if (!ea) {
> + return;
> + }
> +
> + uint64_t mac64 = eth_addr_to_uint64(*ea);
> + if (check) {
> + /* Checking for duplicate MAC addresses. */
> + struct macam_node *macam_node;
> + HMAP_FOR_EACH_WITH_HASH (macam_node, hmap_node,
> hash_uint64(mac64),
> + &macam) {
> + if (eth_addr_equals(*ea, macam_node->mac_addr)) {
> + static struct vlog_rate_limit rl =
> VLOG_RATE_LIMIT_INIT(1, 1);
> + VLOG_WARN_RL(&rl, "Duplicate MAC set: "ETH_ADDR_FMT,
> + ETH_ADDR_ARGS(macam_node->mac_addr));
> + return;
> + }
> + }
> + }
> +
> + /* Insert new MAC into macam if it is not a duplicate and was
> + * assigned by this address management system. */
> + if (!((mac64 ^ MAC_ADDR_PREFIX) >> 24)) {
> + struct macam_node *new_macam_node = xmalloc(sizeof
> *new_macam_node);
> + new_macam_node->mac_addr = *ea;
> + hmap_insert(&macam, &new_macam_node->hmap_node,
> hash_uint64(mac64));
> + }
> +}
> +
> +static void
> +ipam_insert_ip(struct ovn_datapath *od, uint32_t ip, bool check)
> +{
>
You will need a check her for !od.
> + if (check) {
> + /* Checking for duplicate IP addresses. */
> + struct ipam_node *ipam_node;
> + HMAP_FOR_EACH_WITH_HASH (ipam_node, hmap_node, hash_int(ip, 0),
> + &od->ipam) {
> + if (ipam_node->ip_addr == ip) {
> + static struct vlog_rate_limit rl =
> VLOG_RATE_LIMIT_INIT(1, 1);
> + VLOG_WARN_RL(&rl, "Duplicate IP set: "IP_FMT,
> + IP_ARGS(htonl(ip)));
> + return;
> + }
> + }
> + }
> +
> + struct ipam_node *new_ipam_node = xmalloc(sizeof *new_ipam_node);
> + new_ipam_node->ip_addr = ip;
> + hmap_insert(&od->ipam, &new_ipam_node->hmap_node, hash_int(ip, 0));
> +}
> +
> +static void
> +ipam_add_port_addresses(struct ovn_datapath *od, struct ovn_port *op)
> +{
> + if (!od || !op) {
> + return;
> + }
> +
> + if (op->nbs) {
> + /* Add all the port's addresses to address data structures. */
> + for (size_t i = 0; i < op->nbs->n_addresses; i++) {
> + struct lport_addresses laddrs;
> + if (!extract_lsp_addresses(op->nbs->addresses[i], &laddrs,
> + false)) {
> + static struct vlog_rate_limit rl =
> VLOG_RATE_LIMIT_INIT(1, 1);
> + VLOG_WARN_RL(&rl, "Extract addresses failed.");
> + continue;
> + }
> + ipam_insert_mac(&laddrs.ea, true);
> +
> + for (size_t j = 0; j < laddrs.n_ipv4_addrs; j++) {
> + uint32_t ip = ntohl(laddrs.ipv4_addrs[j].addr);
> + ipam_insert_ip(od, ip, true);
> + }
>
Would it make sense to only call ipam_insert_ip above if options:subnet is
set for that switch? Otherwise, we do not have any use right?
> + }
> + } else if (op->nbr) {
> + struct eth_addr mac;
> + if (!eth_addr_from_string(op->nbr->mac, &mac)) {
> + static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 1);
> + VLOG_WARN_RL(&rl, "bad 'mac' %s", op->nbr->mac);
> + return;
> + }
> + ipam_insert_mac(&mac, true);
> +
> + ovs_be32 ip, mask;
> + char* error = ip_parse_masked(op->nbr->network, &ip, &mask);
> + if (error || mask == OVS_BE32_MAX || !ip_is_cidr(mask)) {
> + static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 1);
> + VLOG_WARN_RL(&rl, "bad 'network' %s", op->nbr->network);
> + free(error);
> + return;
> + }
> + ipam_insert_ip(od, ntohl(ip), true);
> + }
> +}
> +
> +static uint64_t
> +ipam_get_unused_mac(void)
> +{
> + struct macam_node *macam_node;
> + uint64_t mac64;
> + struct eth_addr mac;
> + bool used;
> + for (uint32_t i = 1; i < MAC_ADDR_SPACE; i++) {
> + mac64 = MAC_ADDR_PREFIX | i;
> + eth_addr_from_uint64(mac64, &mac);
> + used = false;
> + HMAP_FOR_EACH_WITH_HASH (macam_node, hmap_node,
> + hash_uint64(mac64),
> + &macam) {
> + if (eth_addr_equals(mac, macam_node->mac_addr)) {
> + used = true;
> + break;
> + }
> + }
> + if (!used) {
> + break;
> + }
> + }
> +
> + if (mac64 == MAC_ADDR_SPACE) {
> + static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 1);
> + VLOG_WARN_RL(&rl, "MAC address space exhausted.");
> + mac64 = 0;
> + }
> +
> + return mac64;
> +}
> +
> +static uint32_t
> +ipam_get_unused_ip(struct ovn_datapath *od, uint32_t subnet, uint32_t
> mask)
> +{
> + if (!od) {
> + return 0;
> + }
> +
> + struct ipam_node *ipam_node;
> + uint32_t ip = 0;
> +
> + /* Find first unused IP address in subnet. x.x.x.1 is reserved for
> + * a logical router port. */
> + bool used;
> + for (uint32_t i = 2; i < mask - 1; i++) {
>
Is the condition "mask - 1" right? Wouldn't 'mask' be something like
"ffffff00"?
> + uint32_t tentative_ip = subnet + i;
> + used = false;
> + /* Check if IP already exists in ipam records. */
> + HMAP_FOR_EACH_WITH_HASH (ipam_node, hmap_node,
> + hash_int(tentative_ip, 0),
> + &od->ipam) {
> + if (ipam_node->ip_addr == tentative_ip) {
> + used = true;
> + break;
> + }
> + }
> + if (!used) {
> + ip = tentative_ip;
> + break;
> + }
> + }
> + if (!ip) {
> + static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(5, 1);
> + VLOG_WARN_RL( &rl, "Subnet address space has been exhausted.");
> + }
> +
> + return ip;
> +}
> +
> +static void
> +ipam_allocate_addresses(struct ovn_datapath *od, struct ovn_port *op,
> + ovs_be32 subnet, ovs_be32 mask)
> +{
> + if (!od || !op || !op->nbs) {
> + return;
> + }
> +
> + /* Allocate MAC address and add it to macam hmap. */
> + struct eth_addr mac;
> + if (!op->nbs->n_addresses) {
> + uint64_t mac64 = ipam_get_unused_mac();
> + eth_addr_from_uint64(mac64, &mac);
>
If mac64 is returned 0 above, it probably makes sense to just return?
Otherwise your ipam_insert_mac() will likely complain.
> + } else {
> + /* If op already has at least one IPv4 address, do not allocate
> any
> + * addresses for it. Otherwise, use one of op's MAC addresses that
> + * does not have an IPv4 address associated with it to construct
> a new
> + * address. */
> + struct lport_addresses laddrs;
> + for (size_t i = 0; i < op->nbs->n_addresses; i++) {
> + if (!extract_lsp_addresses(op->nbs->addresses[i], &laddrs,
> + false)) {
> + static struct vlog_rate_limit rl =
> VLOG_RATE_LIMIT_INIT(1, 1);
> + VLOG_INFO_RL(&rl, "invalid syntax '%s' in addresses. No
> MAC"
> + " address found", op->nbs->addresses[i]);
> + return;
> + } else if (laddrs.n_ipv4_addrs > 0) {
> + return;
> + } else {
> + mac = laddrs.ea;
> + }
> + }
> + }
> + ipam_insert_mac(&mac, true);
> +
> + /* Convert MAC to string form. */
> + struct ds mac_ds;
> + ds_init(&mac_ds);
> + ds_put_format(&mac_ds, ETH_ADDR_FMT, ETH_ADDR_ARGS(mac));
> +
> + /* Allocate ip and add it to ipam hmap. */
> + uint32_t ip = ipam_get_unused_ip(od, ntohl(subnet), ntohl(mask));
>
If ip is zero (that is it is runout of ip addresses), your ipam_insert_ip()
below will insert duplicate record, right?. It may make sense to call
ipam_get_unused_ip() before you do ipam_insert_mac() above and if !ip, just
return?
> + ipam_insert_ip(od, ip, false);
> +
> + /* Convert IP to string form. */
> + struct ds ip_ds;
> + ds_init(&ip_ds);
> + ds_put_format(&ip_ds, IP_FMT, IP_ARGS(htonl(ip)));
> +
> + char *new_addr = xasprintf("%s %s", mac_ds.string, ip_ds.string);
> + nbrec_logical_switch_port_set_addresses(op->nbs, (const char **)
> &new_addr,
> + 1);
> + ds_destroy(&mac_ds);
> + ds_destroy(&ip_ds);
> +}
> +
> +static void
> +build_ipam(struct northd_context *ctx, struct hmap *datapaths,
> + struct hmap *ports)
> +{
> + if (!ctx->ovnnb_txn) {
> + return;
> + }
> + hmap_init(&macam);
> +
> + /* Update data structures with pre-existing addresses. */
> + const struct nbrec_logical_switch *nbs;
> + NBREC_LOGICAL_SWITCH_FOR_EACH (nbs, ctx->ovnnb_idl) {
> + struct ovn_datapath *od = ovn_datapath_find(datapaths,
> + &nbs->header_.uuid);
> + if (!od || !od->nbs) {
> + continue;
> + }
> + for (size_t i = 0; i < od->nbs->n_ports; i++) {
> + const struct nbrec_logical_switch_port *nbs =
> od->nbs->ports[i];
> + struct ovn_port *op = ovn_port_find(ports, nbs->name);
> + if (op) {
> + ipam_add_port_addresses(od, op);
> + }
> +
> + const char *lrp_name = smap_get(&nbs->options, "router-port");
> + if (lrp_name) {
> + op = ovn_port_find(ports, lrp_name);
> + if (op) {
> + ipam_add_port_addresses(od, op);
> + }
> + }
> + }
> + }
> +
> + /* If the switch's options:subnet is set, allocate new addresses for
> ports
> + * that do not have any. */
> + struct ovn_datapath *od;
> + HMAP_FOR_EACH (od, key_node, datapaths) {
> + if (od->nbs) {
> + const char *subnet_str = smap_get(&od->nbs->options,
> "subnet");
> + if (!subnet_str) {
> + continue;
> + }
> +
> + ovs_be32 subnet, mask;
> + char *error = ip_parse_masked(subnet_str, &subnet, &mask);
> + if (error || mask == OVS_BE32_MAX || !ip_is_cidr(mask)) {
> + static struct vlog_rate_limit rl
> + = VLOG_RATE_LIMIT_INIT(5, 1);
> + VLOG_WARN_RL(&rl, "bad 'subnet' %s", subnet_str);
> + free(error);
> + continue;
> + }
> +
> + struct ovn_port *op;
> + for (size_t i = 0; i < od->nbs->n_ports; i++) {
> + const struct nbrec_logical_switch_port *nbs =
> + od->nbs->ports[i];
> +
> + if (!nbs) {
> + continue;
> + }
> +
> + op = ovn_port_find(ports, nbs->name);
> + if (op && !(op->nbs && op->peer)) {
> + /* Allocate addresses for logical switch ports that
> do not
> + * have a peer. */
> + ipam_allocate_addresses(od, op, subnet, mask);
> + }
> + }
> + }
> + }
> + destroy_macam(&macam);
> +}
> +
> static void
> ovnnb_db_run(struct northd_context *ctx)
> {
> @@ -2527,6 +2869,7 @@ ovnnb_db_run(struct northd_context *ctx)
> build_datapaths(ctx, &datapaths);
> build_ports(ctx, &datapaths, &ports);
> build_lflows(ctx, &datapaths, &ports);
> + build_ipam(ctx, &datapaths, &ports);
>
> struct ovn_datapath *dp, *next_dp;
> HMAP_FOR_EACH_SAFE (dp, next_dp, key_node, &datapaths) {
> diff --git a/ovn/ovn-nb.ovsschema b/ovn/ovn-nb.ovsschema
> index 58f04b2..4912b4e 100644
> --- a/ovn/ovn-nb.ovsschema
> +++ b/ovn/ovn-nb.ovsschema
> @@ -1,7 +1,7 @@
> {
> "name": "OVN_Northbound",
> - "version": "3.1.0",
> - "cksum": "1426508118 6135",
> + "version": "3.2.0",
> + "cksum": "1510925926 6290",
> "tables": {
> "Logical_Switch": {
> "columns": {
> @@ -16,6 +16,9 @@
> "refType": "strong"},
> "min": 0,
> "max": "unlimited"}},
> + "options": {
> + "type": {"key": "string", "value": "string",
> + "min": 0, "max": "unlimited"}},
> "external_ids": {
> "type": {"key": "string", "value": "string",
> "min": 0, "max": "unlimited"}}},
> diff --git a/ovn/ovn-nb.xml b/ovn/ovn-nb.xml
> index 6355c44..9b9bdef 100644
> --- a/ovn/ovn-nb.xml
> +++ b/ovn/ovn-nb.xml
> @@ -73,6 +73,18 @@
> Access control rules that apply to packets within the logical
> switch.
> </column>
>
> + <group title="Options">
> + <p>
> + Additional options for the logical switch.
> + </p>
> +
> + <column name="options" key="subnet">
> + If set, logical ports that are attached to this switch that do
> not have
> + a MAC/IPv4 address will automatically be allocated a globally
> unique
> + MAC address/unused IPv4 address within the provided subnet.
> + </column>
> + </group>
> +
> <group title="Common Columns">
> <column name="external_ids">
> See <em>External IDs</em> at the beginning of this document.
> @@ -658,7 +670,7 @@
> </p>
> </column>
> </group>
> -
> +
> <group title="Common Columns">
> <column name="external_ids">
> See <em>External IDs</em> at the beginning of this document.
> diff --git a/tests/ovn.at b/tests/ovn.at
> index a52def4..4ebc246 100644
> --- a/tests/ovn.at
> +++ b/tests/ovn.at
> @@ -3158,3 +3158,148 @@ OVS_APP_EXIT_AND_WAIT([ovs-vswitchd])
> OVS_APP_EXIT_AND_WAIT([ovsdb-server])
>
> AT_CLEANUP
> +
> +AT_SETUP([ovn -- ipam])
> +AT_KEYWORDS([ovnipam])
> +AT_SKIP_IF([test $HAVE_PYTHON = no])
> +ovn_start
> +
> +# Add a port to a switch that does not have a subnet set, then set the
> +# subnet which should result in an address being allocated for the port.
> +ovn-nbctl ls-add sw0
> +ovn-nbctl lsp-add sw0 p0
> +ovn-nbctl add Logical-Switch sw0 options subnet=192.168.1.0/24
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p0 addresses], [0],
> + [[["0a:00:00:00:00:01 192.168.1.2"]]
> +])
> +
> +# Add 9 more ports to sw0, addresses should all be unique.
> +for n in `seq 1 9`; do
> + ovn-nbctl lsp-add sw0 "p$n"
> +done
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p1 addresses], [0],
> + [[["0a:00:00:00:00:02 192.168.1.3"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p2 addresses], [0],
> + [[["0a:00:00:00:00:03 192.168.1.4"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p3 addresses], [0],
> + [[["0a:00:00:00:00:04 192.168.1.5"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p4 addresses], [0],
> + [[["0a:00:00:00:00:05 192.168.1.6"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p5 addresses], [0],
> + [[["0a:00:00:00:00:06 192.168.1.7"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p6 addresses], [0],
> + [[["0a:00:00:00:00:07 192.168.1.8"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p7 addresses], [0],
> + [[["0a:00:00:00:00:08 192.168.1.9"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p8 addresses], [0],
> + [[["0a:00:00:00:00:09 192.168.1.10"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p9 addresses], [0],
> + [[["0a:00:00:00:00:0a 192.168.1.11"]]
> +])
> +
> +# Trying similar tests with a second switch. MAC addresses should be
> unique
> +# across both switches but IP's only need to be unique within the same
> switch.
> +ovn-nbctl ls-add sw1
> +ovn-nbctl lsp-add sw1 p10
> +ovn-nbctl add Logical-Switch sw1 options subnet=192.168.1.0/24
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p10 addresses], [0],
> + [[["0a:00:00:00:00:0b 192.168.1.2"]]
> +])
> +
> +for n in `seq 11 19`; do
> + ovn-nbctl lsp-add sw1 "p$n"
> +done
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p11 addresses], [0],
> + [[["0a:00:00:00:00:0c 192.168.1.3"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p12 addresses], [0],
> + [[["0a:00:00:00:00:0d 192.168.1.4"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p13 addresses], [0],
> + [[["0a:00:00:00:00:0e 192.168.1.5"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p14 addresses], [0],
> + [[["0a:00:00:00:00:0f 192.168.1.6"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p15 addresses], [0],
> + [[["0a:00:00:00:00:10 192.168.1.7"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p16 addresses], [0],
> + [[["0a:00:00:00:00:11 192.168.1.8"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p17 addresses], [0],
> + [[["0a:00:00:00:00:12 192.168.1.9"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p18 addresses], [0],
> + [[["0a:00:00:00:00:13 192.168.1.10"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p19 addresses], [0],
> + [[["0a:00:00:00:00:14 192.168.1.11"]]
> +])
> +
> +# Change a port's address to test for the following: address reuse,
> multiple
> +# ip's for a single address entry, and addresses set by the user.
> +ovn-nbctl lsp-set-addresses p0 "0a:00:00:00:00:15 192.168.1.12
> 192.168.1.14"
> +ovn-nbctl lsp-add sw0 p20
> +ovn-nbctl lsp-add sw0 p21
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p20 addresses], [0],
> + [[["0a:00:00:00:00:01 192.168.1.2"]]
> +])
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p21 addresses], [0],
> + [[["0a:00:00:00:00:16 192.168.1.13"]]
> +])
> +
> +# Test for logical router port address management.
> +ovn-nbctl create Logical_Router name=R1
> +ovn-nbctl -- --id=@lrp create Logical_Router_port name=sw0 \
> +network="192.168.1.1/24" mac=\"0a:00:00:00:00:17\" \
> +-- add Logical_Router R1 ports @lrp -- lsp-add sw0 rp-sw0 \
> +-- set Logical_Switch_Port rp-sw0 type=router options:router-port=sw0
> +ovn-nbctl lsp-add sw0 p22
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p22 addresses], [0],
> + [[["0a:00:00:00:00:18 192.168.1.15"]]
> +])
> +
> +# Test for address reuse after logical port is deleted.
> +ovn-nbctl lsp-del p0
> +ovn-nbctl lsp-add sw0 p23
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p23 addresses], [0],
> + [[["0a:00:00:00:00:15 192.168.1.12"]]
> +])
> +
> +# Test for only MAC address being assigned.
> +ovn-nbctl lsp-add sw0 p24 -- lsp-set-addresses p24 "0a:00:00:00:00:19"
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p24 addresses], [0],
> + [[["0a:00:00:00:00:19 192.168.1.14"]]
> +])
> +ovn-nbctl lsp-add sw0 p25
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p25 addresses], [0],
> + [[["0a:00:00:00:00:1a 192.168.1.16"]]
> +])
> +
> +# Test for multiple addresses to one logical port.
> +ovn-nbctl lsp-set-addresses p25 "0a:00:00:00:00:1a 192.168.1.16" \
> +"0a:00:00:00:00:1b 192.168.1.17"
> +ovn-nbctl lsp-add sw0 p26
> +AT_CHECK([ovn-nbctl get Logical-Switch-Port p26 addresses], [0],
> + [[["0a:00:00:00:00:1c 192.168.1.18"]]
> +])
> +
> +as ovn-sb
> +OVS_APP_EXIT_AND_WAIT([ovsdb-server])
> +
> +as ovn-nb
> +OVS_APP_EXIT_AND_WAIT([ovsdb-server])
> +
> +as northd
> +OVS_APP_EXIT_AND_WAIT([ovn-northd])
> +
> +AT_CLEANUP
> --
> 1.9.1
>
> _______________________________________________
> dev mailing list
> dev at openvswitch.org
> http://openvswitch.org/mailman/listinfo/dev
>
More information about the dev
mailing list