3 # Copyright (c) 2015 All rights reserved
4 # This program and the accompanying materials
5 # are made available under the terms of the Apache License, Version 2.0
6 # which accompanies this distribution, and is available at
8 # http://www.apache.org/licenses/LICENSE-2.0
11 Test whether router assoc can coexist with floating IP
12 - Create two VMs, one in a subnet with a router
13 - Assoc the two networks in a VPN iRT=eRT
14 One with router assoc, other with net assoc
15 - Try to ping from one VM to the other
16 - Assign a floating IP to the VM in the router assoc network
21 import functest.utils.functest_logger as ft_logger
22 import functest.utils.openstack_utils as os_utils
24 import sdnvpn.lib.utils as test_utils
25 from sdnvpn.lib.results import Results
26 import sdnvpn.lib.config as sdnvpn_config
28 parser = argparse.ArgumentParser()
30 parser.add_argument("-r", "--report",
31 help="Create json result file",
34 args = parser.parse_args()
36 logger = ft_logger.Logger("sdnvpn-testcase-8").getLogger()
38 COMMON_CONFIG = sdnvpn_config.CommonConfig()
39 TESTCASE_CONFIG = sdnvpn_config.TestcaseConfig('testcase_8')
43 results = Results(COMMON_CONFIG.line_length)
45 results.add_to_summary(0, "=")
46 results.add_to_summary(2, "STATUS", "SUBTEST")
47 results.add_to_summary(0, "=")
49 nova_client = os_utils.get_nova_client()
50 neutron_client = os_utils.get_neutron_client()
51 glance_client = os_utils.get_glance_client()
53 image_id = os_utils.create_glance_image(glance_client,
54 TESTCASE_CONFIG.image_name,
55 COMMON_CONFIG.image_path,
56 disk=COMMON_CONFIG.image_format,
59 network_1_id, _, router_1_id = test_utils.create_network(
61 TESTCASE_CONFIG.net_1_name,
62 TESTCASE_CONFIG.subnet_1_name,
63 TESTCASE_CONFIG.subnet_1_cidr,
64 TESTCASE_CONFIG.router_1_name)
65 network_2_id = test_utils.create_net(
67 TESTCASE_CONFIG.net_2_name)
68 test_utils.create_subnet(neutron_client,
69 TESTCASE_CONFIG.subnet_2_name,
70 TESTCASE_CONFIG.subnet_2_cidr,
73 sg_id = os_utils.create_security_group_full(neutron_client,
74 TESTCASE_CONFIG.secgroup_name,
75 TESTCASE_CONFIG.secgroup_descr)
76 test_utils.open_icmp_ssh(neutron_client, sg_id)
77 vm_2 = test_utils.create_instance(
79 TESTCASE_CONFIG.instance_2_name,
83 secgroup_name=TESTCASE_CONFIG.secgroup_name)
84 vm_2_ip = vm_2.networks.itervalues().next()[0]
86 u1 = test_utils.generate_ping_userdata([vm_2_ip])
87 vm_1 = test_utils.create_instance(
89 TESTCASE_CONFIG.instance_1_name,
93 secgroup_name=TESTCASE_CONFIG.secgroup_name,
96 results.record_action("Create VPN with eRT==iRT")
98 kwargs = {"import_targets": TESTCASE_CONFIG.targets,
99 "export_targets": TESTCASE_CONFIG.targets,
100 "route_distinguishers": TESTCASE_CONFIG.route_distinguishers,
102 bgpvpn = os_utils.create_bgpvpn(neutron_client, **kwargs)
103 bgpvpn_id = bgpvpn['bgpvpn']['id']
104 logger.debug("VPN created details: %s" % bgpvpn)
106 msg = ("Associate router '%s' and net '%s' to the VPN."
107 % (TESTCASE_CONFIG.router_1_name,
108 TESTCASE_CONFIG.net_2_name))
109 results.record_action(msg)
110 results.add_to_summary(0, "-")
112 os_utils.create_router_association(
113 neutron_client, bgpvpn_id, router_1_id)
114 os_utils.create_network_association(
115 neutron_client, bgpvpn_id, network_2_id)
117 test_utils.wait_for_bgp_router_assoc(
118 neutron_client, bgpvpn_id, router_1_id)
119 test_utils.wait_for_bgp_net_assoc(
120 neutron_client, bgpvpn_id, network_2_id)
122 instances_up = test_utils.wait_for_instances_up(vm_1, vm_2)
124 logger.error("One or more instances is down")
126 logger.info("Waiting for the VMs to connect to each other using the"
127 " updated network configuration")
128 test_utils.wait_before_subtest()
130 results.get_ping_status(vm_1, vm_2, expected="PASS", timeout=200)
131 results.add_to_summary(0, "=")
133 msg = "Assign a Floating IP to %s" % vm_1.name
134 results.record_action(msg)
136 fip = os_utils.create_floating_ip(neutron_client)
137 fip_added = os_utils.add_floating_ip(nova_client, vm_1.id, fip['fip_addr'])
139 results.add_success(msg)
141 results.add_failure(msg)
143 results.record_action("Ping %s via Floating IP" % vm_1.name)
144 results.add_to_summary(0, "-")
145 results.ping_ip_test(fip['fip_addr'])
147 return results.compile_summary()
150 if __name__ == '__main__':