12cd47abcc
As tempest.scenario.manager was announced stable interface in Tempest
27.0.0[1] it can be now reused in plugins.
Removed methods:
* _get_server_port_id_and_ip4
* check_vm_connectivity
There is a slight difference between tempest's
_get_server_port_id_and_ip4 and this one.
Most changes are just fixes, without bigger logical interference.
See some of the related patches below.[2][3]
Etherpad concerning this effort:
https://etherpad.opendev.org/p/tempest-scenario-manager-cleanup
[1] https://docs.openstack.org/releasenotes/tempest/v27.0.0.html#release-notes-27-0-0
[2] 5c191faae7
[3] 95a3169e17
Change-Id: I6a7268784b8a915aab665db1bc00e764f40986ef
1255 lines
50 KiB
Python
1255 lines
50 KiB
Python
# Copyright 2016 Futurewei. All rights reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
import time
|
|
|
|
from neutron_lib.utils import test
|
|
from oslo_log import log
|
|
from tempest.common import utils
|
|
from tempest import config
|
|
from tempest.lib.common.utils import test_utils
|
|
from tempest.lib import decorators
|
|
|
|
from neutron_tempest_plugin.sfc.tests.scenario import base
|
|
|
|
CONF = config.CONF
|
|
LOG = log.getLogger(__name__)
|
|
|
|
|
|
class TestSfc(base.SfcScenarioTest):
|
|
@classmethod
|
|
def skip_checks(cls):
|
|
super(TestSfc, cls).skip_checks()
|
|
if not (CONF.network.project_networks_reachable or
|
|
CONF.network.public_network_id):
|
|
msg = ('Either project_networks_reachable must be "true", or '
|
|
'public_network_id must be defined.')
|
|
raise cls.skipException(msg)
|
|
required_exts = ['sfc', 'flow_classifier']
|
|
for ext in required_exts:
|
|
if not utils.is_extension_enabled(ext, 'network'):
|
|
msg = "%s Extension not enabled." % ext
|
|
raise cls.skipException(msg)
|
|
|
|
@classmethod
|
|
def setup_credentials(cls):
|
|
# Create no network resources for these tests.
|
|
cls.set_network_resources()
|
|
super(TestSfc, cls).setup_credentials()
|
|
|
|
def setUp(self):
|
|
super(TestSfc, self).setUp()
|
|
|
|
self.multi_node = CONF.compute.min_compute_nodes > 1
|
|
if self.multi_node:
|
|
LOG.info("Running test on multi node")
|
|
else:
|
|
LOG.info("Running test on single node")
|
|
# Save servers UUIDs
|
|
self.servers = []
|
|
|
|
self.ssh_user = CONF.validation.image_ssh_user
|
|
self.keypair = self.create_keypair()
|
|
self.net1, self.subnet1, self.router1 = (
|
|
self.setup_network_subnet_with_router(port_security_enabled=False)
|
|
)
|
|
self.router2 = self._create_router()
|
|
self.router3 = self._create_router()
|
|
self.router2_net1 = self.create_port(self.net1['id'])
|
|
self._add_router_interface(
|
|
self.router2['id'], self.router2_net1['id'])
|
|
self.router3_net1 = self.create_port(self.net1['id'])
|
|
self._add_router_interface(
|
|
self.router3['id'], self.router3_net1['id'])
|
|
self.router2_net1_fixed_ip = self.router2_net1[
|
|
'fixed_ips'][0]['ip_address']
|
|
self.router3_net1_fixed_ip = self.router3_net1[
|
|
'fixed_ips'][0]['ip_address']
|
|
|
|
def _setup_server(self, network):
|
|
server = self._create_server(network=self.net1)
|
|
floating_ip = self._create_floating_ip(
|
|
server)
|
|
port_id, fixed_ip = (
|
|
self.get_server_port_id_and_ip4(server))
|
|
return floating_ip, port_id, fixed_ip
|
|
|
|
def _create_floating_ip(self, server, client=None):
|
|
floating_ip = self.create_floating_ip(
|
|
server, client=client)
|
|
self.check_floating_ip_status(floating_ip, 'ACTIVE')
|
|
floating_ip_addr = floating_ip['floating_ip_address']
|
|
self.check_public_network_connectivity(
|
|
floating_ip_addr, self.ssh_user,
|
|
self.keypair['private_key'], True,
|
|
servers=[server])
|
|
return floating_ip_addr
|
|
|
|
def _wait_for_port_chain_status(self, port_chain, status):
|
|
time.sleep(10)
|
|
|
|
def _create_port_chain_helper(self, symmetric):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
if symmetric:
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
logical_destination_port=server2_port_id,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
else:
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
port_pair = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair_group = self._create_port_pair_group(
|
|
port_pairs=[port_pair['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group['id']],
|
|
flow_classifiers=[fc['id']],
|
|
chain_parameters={'symmetric': symmetric}
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.delete_port_chain(port_chain['id'])
|
|
self._wait_for_port_chain_status(port_chain, 'DELETED')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21a8')
|
|
@utils.services('compute', 'network')
|
|
def test_create_port_chain(self):
|
|
self._create_port_chain_helper(False)
|
|
|
|
@decorators.idempotent_id('35927961-1904-4a6b-9d08-ad819f1cf812')
|
|
@utils.services('compute', 'network')
|
|
def test_create_port_chain_symmetric(self):
|
|
self._create_port_chain_helper(True)
|
|
|
|
def _create_port_chain_multi_fc_helper(self, symmetric):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
if symmetric:
|
|
fc1 = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
logical_destination_port=server2_port_id,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
fc2 = self._create_flowclassifier(
|
|
logical_source_port=server2_port_id,
|
|
source_ip_prefix='%s/32' % server2_fixed_ip,
|
|
logical_destination_port=server1_port_id,
|
|
destination_ip_prefix='%s/32' % server1_fixed_ip
|
|
)
|
|
else:
|
|
fc1 = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
fc2 = self._create_flowclassifier(
|
|
logical_source_port=server2_port_id,
|
|
source_ip_prefix='%s/32' % server2_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server1_fixed_ip
|
|
)
|
|
port_pair = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair_group = self._create_port_pair_group(
|
|
port_pairs=[port_pair['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group['id']],
|
|
flow_classifiers=[fc1['id'], fc2['id']],
|
|
chain_parameters={'symmetric': symmetric}
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.delete_port_chain(port_chain['id'])
|
|
self._wait_for_port_chain_status(port_chain, 'DELETED')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21a9')
|
|
@utils.services('compute', 'network')
|
|
def test_create_port_chain_multi_flow_classifiers(self):
|
|
self._create_port_chain_multi_fc_helper(False)
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21b1')
|
|
@utils.services('compute', 'network')
|
|
def test_create_port_chain_multi_flow_classifiers_symmetric(self):
|
|
self._create_port_chain_multi_fc_helper(True)
|
|
|
|
def _create_port_chain_multi_port_pairs_helper(self, symmetric):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
if symmetric:
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
logical_destination_port=server2_port_id,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
else:
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id'], port_pair2['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group['id']],
|
|
flow_classifiers=[fc['id']],
|
|
chain_parameters={'symmetric': symmetric}
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip, self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.delete_port_chain(port_chain['id'])
|
|
self._wait_for_port_chain_status(port_chain, 'DELETED')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21aa')
|
|
@utils.services('compute', 'network')
|
|
def test_create_port_chain_multi_port_pairs(self):
|
|
self._create_port_chain_multi_port_pairs_helper(False)
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f869be1e21ad')
|
|
@utils.services('compute', 'network')
|
|
def test_create_port_chain_multi_port_pairs_symmetric(self):
|
|
self._create_port_chain_multi_port_pairs_helper(True)
|
|
|
|
def _create_port_chain_multi_ppg_helper(self, symmetric):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
if symmetric:
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix="%s/32" % server1_fixed_ip,
|
|
logical_destination_port=server2_port_id,
|
|
destination_ip_prefix="%s/32" % server2_fixed_ip
|
|
)
|
|
else:
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix="%s/32" % server1_fixed_ip,
|
|
destination_ip_prefix="%s/32" % server2_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group1 = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id']]
|
|
)
|
|
port_pair_group2 = self._create_port_pair_group(
|
|
port_pairs=[port_pair2['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group1['id'], port_pair_group2['id']],
|
|
flow_classifiers=[fc['id']],
|
|
chain_parameters={'symmetric': symmetric}
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip], [self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.delete_port_chain(port_chain['id'])
|
|
self._wait_for_port_chain_status(port_chain, 'DELETED')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21ab')
|
|
@utils.services('compute', 'network')
|
|
def test_create_port_chain_multi_port_pair_groups(self):
|
|
self._create_port_chain_multi_ppg_helper(False)
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21b0')
|
|
@utils.services('compute', 'network')
|
|
def test_create_port_chain_multi_port_pair_groups_symmetric(self):
|
|
self._create_port_chain_multi_ppg_helper(True)
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e22ab')
|
|
@utils.services('compute', 'network')
|
|
def test_create_multi_port_chain(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc1 = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
fc2 = self._create_flowclassifier(
|
|
logical_source_port=server2_port_id,
|
|
source_ip_prefix='%s/32' % server2_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server1_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group1 = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id']]
|
|
)
|
|
port_pair_group2 = self._create_port_pair_group(
|
|
port_pairs=[port_pair2['id']]
|
|
)
|
|
port_chain1 = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group1['id'], port_pair_group2['id']],
|
|
flow_classifiers=[fc1['id']]
|
|
)
|
|
port_chain2 = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group2['id'], port_pair_group1['id']],
|
|
flow_classifiers=[fc2['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip], [self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[[self.router3_net1_fixed_ip], [self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.delete_port_chain(port_chain1['id'])
|
|
self.portchain_client.delete_port_chain(port_chain2['id'])
|
|
self._wait_for_port_chain_status(port_chain1, 'DELETED')
|
|
self._wait_for_port_chain_status(port_chain2, 'DELETED')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21ac')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_chain_add_flow_classifiers(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc1 = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
fc2 = self._create_flowclassifier(
|
|
logical_source_port=server2_port_id,
|
|
source_ip_prefix='%s/32' % server2_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server1_fixed_ip
|
|
)
|
|
port_pair = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair_group = self._create_port_pair_group(
|
|
port_pairs=[port_pair['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group['id']],
|
|
flow_classifiers=[fc1['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.update_port_chain(
|
|
port_chain['id'], flow_classifiers=[fc1['id'], fc2['id']])
|
|
self._wait_for_port_chain_status(port_chain, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21ad')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_chain_remove_flow_classifiers(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc1 = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
fc2 = self._create_flowclassifier(
|
|
logical_source_port=server2_port_id,
|
|
source_ip_prefix='%s/32' % server2_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server1_fixed_ip
|
|
)
|
|
port_pair = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair_group = self._create_port_pair_group(
|
|
port_pairs=[port_pair['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group['id']],
|
|
flow_classifiers=[fc1['id'], fc2['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.update_port_chain(
|
|
port_chain['id'], flow_classifiers=[fc1['id']])
|
|
self._wait_for_port_chain_status(port_chain, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21ae')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_chain_replace_flow_classifiers(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc1 = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
fc2 = self._create_flowclassifier(
|
|
logical_source_port=server2_port_id,
|
|
source_ip_prefix='%s/32' % server2_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server1_fixed_ip
|
|
)
|
|
port_pair = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair_group = self._create_port_pair_group(
|
|
port_pairs=[port_pair['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group['id']],
|
|
flow_classifiers=[fc1['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.update_port_chain(
|
|
port_chain['id'], flow_classifiers=[fc2['id']])
|
|
self._wait_for_port_chain_status(port_chain, 'DELETED')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21af')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_chain_add_port_pair_groups(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group1 = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id']]
|
|
)
|
|
port_pair_group2 = self._create_port_pair_group(
|
|
port_pairs=[port_pair2['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[port_pair_group1['id']],
|
|
flow_classifiers=[fc['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.update_port_chain(
|
|
port_chain['id'],
|
|
port_pair_groups=[
|
|
port_pair_group1['id'], port_pair_group2['id']
|
|
]
|
|
)
|
|
self._wait_for_port_chain_status(port_chain, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip], [self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21bf')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_chain_remove_port_pair_groups(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group1 = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id']]
|
|
)
|
|
port_pair_group2 = self._create_port_pair_group(
|
|
port_pairs=[port_pair2['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[
|
|
port_pair_group1['id'], port_pair_group2['id']
|
|
],
|
|
flow_classifiers=[fc['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip], [self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.update_port_chain(
|
|
port_chain['id'],
|
|
port_pair_groups=[
|
|
port_pair_group1['id']
|
|
]
|
|
)
|
|
self._wait_for_port_chain_status(port_chain, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21be')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_chain_replace_port_pair_groups(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group1 = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id']]
|
|
)
|
|
port_pair_group2 = self._create_port_pair_group(
|
|
port_pairs=[port_pair2['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[
|
|
port_pair_group1['id']
|
|
],
|
|
flow_classifiers=[fc['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.update_port_chain(
|
|
port_chain['id'],
|
|
port_pair_groups=[
|
|
port_pair_group2['id']
|
|
]
|
|
)
|
|
self._wait_for_port_chain_status(port_chain, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21bc')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_chain_replace_port_pair_groups_flow_classifiers(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc1 = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
fc2 = self._create_flowclassifier(
|
|
logical_source_port=server2_port_id,
|
|
source_ip_prefix='%s/32' % server2_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server1_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group1 = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id']]
|
|
)
|
|
port_pair_group2 = self._create_port_pair_group(
|
|
port_pairs=[port_pair2['id']]
|
|
)
|
|
port_chain = self._create_port_chain(
|
|
port_pair_groups=[
|
|
port_pair_group1['id']
|
|
],
|
|
flow_classifiers=[fc1['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portchain_client.update_port_chain(
|
|
port_chain['id'],
|
|
port_pair_groups=[port_pair_group2['id']],
|
|
flow_classifiers=[fc2['id']])
|
|
self._wait_for_port_chain_status(port_chain, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[[self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
def _wait_for_port_pair_group_status(self, port_pair_group, status):
|
|
time.sleep(10)
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21bb')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_pair_group_add_port_pairs(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id']]
|
|
)
|
|
self._create_port_chain(
|
|
port_pair_groups=[
|
|
port_pair_group['id']
|
|
],
|
|
flow_classifiers=[fc['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portpairgroup_client.update_port_pair_group(
|
|
port_pair_group['id'],
|
|
port_pairs=[
|
|
port_pair1['id'], port_pair2['id']
|
|
]
|
|
)
|
|
self._wait_for_port_pair_group_status(port_pair_group, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip, self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@test.unstable_test("bug 1897753")
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21ba')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_pair_group_remove_port_pairs(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id'], port_pair2['id']]
|
|
)
|
|
self._create_port_chain(
|
|
port_pair_groups=[
|
|
port_pair_group['id']
|
|
],
|
|
flow_classifiers=[fc['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip, self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portpairgroup_client.update_port_pair_group(
|
|
port_pair_group['id'],
|
|
port_pairs=[port_pair1['id']])
|
|
self._wait_for_port_pair_group_status(port_pair_group, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('f970f6b3-6541-47ac-a9ea-f769be1e21b9')
|
|
@utils.services('compute', 'network')
|
|
def test_update_port_pair_group_replace_port_pairs(self):
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair_group = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id']]
|
|
)
|
|
self._create_port_chain(
|
|
port_pair_groups=[
|
|
port_pair_group['id']
|
|
],
|
|
flow_classifiers=[fc['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portpairgroup_client.update_port_pair_group(
|
|
port_pair_group['id'],
|
|
port_pairs=[port_pair2['id']])
|
|
self._wait_for_port_pair_group_status(port_pair_group, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
@decorators.idempotent_id('69f8f427-a3a1-4f8f-814f-87e6faea9d54')
|
|
@utils.services('compute', 'network')
|
|
def test_multi_port_chains_update_port_pair_group_replace_port_pairs(
|
|
self
|
|
):
|
|
self.router4 = self._create_router()
|
|
self.router4_net1 = self.create_port(self.net1['id'])
|
|
self._add_router_interface(
|
|
self.router4['id'], self.router4_net1['id'])
|
|
self.router4_net1_fixed_ip = self.router4_net1[
|
|
'fixed_ips'][0]['ip_address']
|
|
self.router5 = self._create_router()
|
|
self.router5_net1 = self.create_port(self.net1['id'])
|
|
self._add_router_interface(
|
|
self.router5['id'], self.router5_net1['id'])
|
|
self.router5_net1_fixed_ip = self.router5_net1[
|
|
'fixed_ips'][0]['ip_address']
|
|
(
|
|
server1_floating_ip, server1_port_id, server1_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
(
|
|
server2_floating_ip, server2_port_id, server2_fixed_ip
|
|
) = self._setup_server(self.net1)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
fc1 = self._create_flowclassifier(
|
|
logical_source_port=server1_port_id,
|
|
source_ip_prefix='%s/32' % server1_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server2_fixed_ip
|
|
)
|
|
fc2 = self._create_flowclassifier(
|
|
logical_source_port=server2_port_id,
|
|
source_ip_prefix='%s/32' % server2_fixed_ip,
|
|
destination_ip_prefix='%s/32' % server1_fixed_ip
|
|
)
|
|
port_pair1 = self._create_port_pair(
|
|
ingress=self.router2_net1['id'],
|
|
egress=self.router2_net1['id']
|
|
)
|
|
port_pair2 = self._create_port_pair(
|
|
ingress=self.router3_net1['id'],
|
|
egress=self.router3_net1['id']
|
|
)
|
|
port_pair3 = self._create_port_pair(
|
|
ingress=self.router4_net1['id'],
|
|
egress=self.router4_net1['id']
|
|
)
|
|
port_pair4 = self._create_port_pair(
|
|
ingress=self.router5_net1['id'],
|
|
egress=self.router5_net1['id']
|
|
)
|
|
port_pair_group1 = self._create_port_pair_group(
|
|
port_pairs=[port_pair1['id']]
|
|
)
|
|
port_pair_group2 = self._create_port_pair_group(
|
|
port_pairs=[port_pair2['id']]
|
|
)
|
|
self._create_port_chain(
|
|
port_pair_groups=[
|
|
port_pair_group1['id'], port_pair_group2['id']
|
|
],
|
|
flow_classifiers=[fc1['id']]
|
|
)
|
|
self._create_port_chain(
|
|
port_pair_groups=[
|
|
port_pair_group2['id'], port_pair_group1['id']
|
|
],
|
|
flow_classifiers=[fc2['id']]
|
|
)
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router2_net1_fixed_ip], [self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[[self.router3_net1_fixed_ip], [self.router2_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portpairgroup_client.update_port_pair_group(
|
|
port_pair_group1['id'],
|
|
port_pairs=[port_pair3['id']])
|
|
self._wait_for_port_pair_group_status(port_pair_group1, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router4_net1_fixed_ip], [self.router3_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[[self.router3_net1_fixed_ip], [self.router4_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self.portpairgroup_client.update_port_pair_group(
|
|
port_pair_group2['id'],
|
|
port_pairs=[port_pair4['id']])
|
|
self._wait_for_port_pair_group_status(port_pair_group1, 'ACTIVE')
|
|
self._check_connectivity(
|
|
server1_floating_ip, server2_fixed_ip,
|
|
[[self.router4_net1_fixed_ip], [self.router5_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
self._check_connectivity(
|
|
server2_floating_ip, server1_fixed_ip,
|
|
[[self.router5_net1_fixed_ip], [self.router4_net1_fixed_ip]],
|
|
username=self.ssh_user,
|
|
private_key=self.keypair['private_key'])
|
|
|
|
def _create_server(self, network):
|
|
kwargs = {}
|
|
if self.multi_node:
|
|
kwargs["scheduler_hints"] = {'different_host': self.servers}
|
|
|
|
inst = self.create_server(
|
|
networks=[{'uuid': network['id']}],
|
|
key_name=self.keypair['name'],
|
|
wait_until='ACTIVE',
|
|
**kwargs)
|
|
|
|
adm_get_server = self.os_admin.servers_client.show_server
|
|
server = adm_get_server(inst['id'])['server']
|
|
|
|
self.check_tenant_network_connectivity(
|
|
server, self.ssh_user, self.keypair['private_key'])
|
|
|
|
# Check server is on different node
|
|
if self.multi_node:
|
|
new_host = server["OS-EXT-SRV-ATTR:host"]
|
|
host_list = [adm_get_server(s)["server"]["OS-EXT-SRV-ATTR:host"]
|
|
for s in self.servers]
|
|
self.assertNotIn(new_host, host_list,
|
|
message="Failed to create servers on different "
|
|
"Compute nodes.")
|
|
|
|
self.servers.append(server["id"])
|
|
|
|
return server
|
|
|
|
def _add_router_interface(self, router_id, port_id):
|
|
interface = self.routers_client.add_router_interface(
|
|
router_id, port_id=port_id)
|
|
self.addCleanup(self._remove_router_interface, router_id, port_id)
|
|
return interface
|
|
|
|
def _remove_router_interface(self, router_id, port_id):
|
|
self.routers_client.remove_router_interface(
|
|
router_id, port_id=port_id)
|
|
|
|
def _create_flowclassifier(
|
|
self, flowclassifier_client=None,
|
|
**kwargs
|
|
):
|
|
if not flowclassifier_client:
|
|
flowclassifier_client = self.flowclassifier_client
|
|
result = flowclassifier_client.create_flowclassifier(**kwargs)
|
|
fc = result['flow_classifier']
|
|
self.addCleanup(
|
|
test_utils.call_and_ignore_notfound_exc,
|
|
flowclassifier_client.delete_flowclassifier, fc['id'])
|
|
return fc
|
|
|
|
def _create_port_pair(self, portpair_client=None, **kwargs):
|
|
if not portpair_client:
|
|
portpair_client = self.portpair_client
|
|
result = portpair_client.create_port_pair(**kwargs)
|
|
pp = result['port_pair']
|
|
self.addCleanup(
|
|
test_utils.call_and_ignore_notfound_exc,
|
|
portpair_client.delete_port_pair, pp['id'])
|
|
return pp
|
|
|
|
def _create_port_pair_group(self, portpairgroup_client=None, **kwargs):
|
|
if not portpairgroup_client:
|
|
portpairgroup_client = self.portpairgroup_client
|
|
result = portpairgroup_client.create_port_pair_group(**kwargs)
|
|
pg = result['port_pair_group']
|
|
self.addCleanup(
|
|
test_utils.call_and_ignore_notfound_exc,
|
|
portpairgroup_client.delete_port_pair_group, pg['id'])
|
|
return pg
|
|
|
|
def _create_port_chain(self, portchain_client=None, **kwargs):
|
|
if not portchain_client:
|
|
portchain_client = self.portchain_client
|
|
result = portchain_client.create_port_chain(**kwargs)
|
|
pc = result['port_chain']
|
|
self.addCleanup(
|
|
test_utils.call_and_ignore_notfound_exc,
|
|
portchain_client.delete_port_chain, pc['id'])
|
|
self._wait_for_port_chain_status(pc, 'ACTIVE')
|
|
return pc
|