Browse Source
This adds a basic rally scenario to create a trunk with a bunch of subports so we can keep an eye on the performance of the trunk API. Change-Id: I12aaf6121b677e9696131601b3539a7091e2858cchanges/65/392265/12
2 changed files with 70 additions and 1 deletions
@ -0,0 +1,54 @@
|
||||
# |
||||
# 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. |
||||
|
||||
from rally import consts |
||||
from rally.plugins.openstack import scenario |
||||
from rally.plugins.openstack.scenarios.neutron import utils |
||||
from rally.task import atomic |
||||
from rally.task import validation |
||||
|
||||
|
||||
"""Scenarios for VLAN Aware VMs.""" |
||||
|
||||
|
||||
@validation.required_services(consts.Service.NEUTRON) |
||||
@validation.required_openstack(users=True) |
||||
@scenario.configure(context={"cleanup": ["neutron"]}, |
||||
name="NeutronTrunks.create_and_list_trunk_subports") |
||||
class TrunkLifeCycle(utils.NeutronScenario): |
||||
|
||||
def run(self, subport_count=50): |
||||
net = self._create_network({}) |
||||
ports = [self._create_port(net, {}) for i in range(subport_count)] |
||||
parent, subports = ports[0], ports[1:] |
||||
subport_payload = [{'port_id': p['port']['id'], |
||||
'segmentation_type': 'vlan', |
||||
'segmentation_id': seg_id} |
||||
for seg_id, p in enumerate(subports, start=1)] |
||||
trunk_payload = {'port_id': parent['port']['id'], |
||||
'sub_ports': subport_payload} |
||||
trunk = self._create_trunk(trunk_payload) |
||||
self._list_trunks(id=trunk['trunk']['id']) |
||||
self._delete_trunk(trunk['trunk']['id']) |
||||
|
||||
@atomic.action_timer("neutron.delete_trunk") |
||||
def _delete_trunk(self, trunk_id): |
||||
self.clients("neutron").delete_trunk(trunk_id) |
||||
|
||||
@atomic.action_timer("neutron.create_trunk") |
||||
def _create_trunk(self, trunk_payload): |
||||
return self.clients("neutron").create_trunk({'trunk': trunk_payload}) |
||||
|
||||
@atomic.optional_action_timer("neutron.list_trunks") |
||||
def _list_trunks(self, **kwargs): |
||||
return self.clients("neutron").list_trunks(**kwargs)["trunks"] |
Loading…
Reference in new issue