1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
#!/usr/bin/env python
# Copyright (c) 2018 Orange and others.
#
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
"""
Shaker_ wraps around popular system network testing tools like iperf, iperf3
and netperf (with help of flent). Shaker is able to deploy OpenStack instances
and networks in different topologies. Shaker scenario specifies the deployment
and list of tests to execute.
.. _Shaker: http://pyshaker.readthedocs.io/en/latest/
"""
import logging
import os
import scp
from functest.core import singlevm
class Shaker(singlevm.SingleVm2):
# pylint: disable=too-many-instance-attributes
__logger = logging.getLogger(__name__)
filename = '/home/opnfv/functest/images/shaker-image.qcow2'
flavor_ram = 512
flavor_vcpus = 1
flavor_disk = 3
username = 'ubuntu'
port = 9000
def create_sg_rules(self):
"""
It adds one security group rule allowing ingress 9000/tcp
Raises: Exception on error.
"""
assert self.orig_cloud
super(Shaker, self).create_sg_rules()
self.orig_cloud.create_security_group_rule(
self.sec.id, port_range_min=self.port, port_range_max=self.port,
protocol='tcp', direction='ingress')
def execute(self):
"""
Returns:
- 0 if success
- 1 on operation error
"""
assert self.ssh
scpc = scp.SCPClient(self.ssh.get_transport())
scpc.put('/home/opnfv/functest/conf/env_file', '~/')
(_, stdout, stderr) = self.ssh.exec_command(
'source ~/env_file && export OS_INTERFACE=public &&'
'shaker --server-endpoint {}:9000 --scenario '
'openstack/full_l2,openstack/full_l3_east_west,'
'openstack/full_l3_north_south,openstack/perf_l2,'
'openstack/perf_l3_east_west,openstack/perf_l3_north_south '
'--report report.html --output report.json ; echo $?'.format(
self.sshvm.public_v4))
self.__logger.info("output:\n%s", stdout.read())
self.__logger.info("error:\n%s", stderr.read())
if not os.path.exists(self.res_dir):
os.makedirs(self.res_dir)
try:
scpc.get('report.json', self.res_dir)
scpc.get('report.html', self.res_dir)
except scp.SCPException:
self.__logger.exception("cannot get report files")
return 1
return stdout.channel.recv_exit_status()
|
