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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
# Copyright (c) 2016 Cisco and/or its affiliates.
# 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.
"""DUT setup library."""
from robot.api import logger
from resources.libraries.python.topology import NodeType
from resources.libraries.python.ssh import SSH
from resources.libraries.python.constants import Constants
from resources.libraries.python.VatExecutor import VatExecutor
class DUTSetup(object):
"""Contains methods for setting up DUTs."""
@staticmethod
def start_vpp_service_on_all_duts(nodes):
"""Start up the VPP service on all nodes."""
ssh = SSH()
for node in nodes.values():
if node['type'] == NodeType.DUT:
ssh.connect(node)
(ret_code, stdout, stderr) = \
ssh.exec_command_sudo('service vpp restart', timeout=120)
if int(ret_code) != 0:
logger.debug('stdout: {0}'.format(stdout))
logger.debug('stderr: {0}'.format(stderr))
raise Exception('DUT {0} failed to start VPP service'.
format(node['host']))
@staticmethod
def vpp_show_version_verbose(node):
"""Run "show version verbose" CLI command.
:param node: Node to run command on.
:type node: dict
"""
vat = VatExecutor()
vat.execute_script("show_version_verbose.vat", node, json_out=False)
@staticmethod
def vpp_api_trace_save(node):
"""Run "api trace save" CLI command.
:param node: Node to run command on.
:type node: dict
"""
vat = VatExecutor()
vat.execute_script("api_trace_save.vat", node, json_out=False)
@staticmethod
def vpp_api_trace_dump(node):
"""Run "api trace custom-dump" CLI command.
:param node: Node to run command on.
:type node: dict
"""
vat = VatExecutor()
vat.execute_script("api_trace_dump.vat", node, json_out=False)
@staticmethod
def setup_all_duts(nodes):
"""Prepare all DUTs in given topology for test execution."""
for node in nodes.values():
if node['type'] == NodeType.DUT:
DUTSetup.setup_dut(node)
@staticmethod
def setup_dut(node):
"""Run script over SSH to setup the DUT node.
:param node: DUT node to set up.
:type node: dict
:raises Exception: If the DUT setup fails.
"""
ssh = SSH()
ssh.connect(node)
(ret_code, stdout, stderr) = \
ssh.exec_command('sudo -Sn bash {0}/{1}/dut_setup.sh'.
format(Constants.REMOTE_FW_DIR,
Constants.RESOURCES_LIB_SH), timeout=120)
logger.trace(stdout)
logger.trace(stderr)
if int(ret_code) != 0:
logger.debug('DUT {0} setup script failed: "{1}"'.
format(node['host'], stdout + stderr))
raise Exception('DUT test setup script failed at node {}'.
format(node['host']))
@staticmethod
def get_vpp_pid(node):
"""Get PID of running VPP process.
:param node: DUT node.
:type node: dict
:return: PID
:rtype: int
:raises RuntimeError if it is not possible to get the PID.
"""
ssh = SSH()
ssh.connect(node)
ret_code, stdout, stderr = ssh.exec_command('pidof vpp')
logger.trace(stdout)
logger.trace(stderr)
if int(ret_code) != 0:
logger.debug('Not possible to get PID of VPP process on node: '
'{0}\n {1}'.format(node['host'], stdout + stderr))
raise RuntimeError('Not possible to get PID of VPP process on node:'
' {}'.format(node['host']))
if len(stdout.splitlines()) == 1:
return int(stdout)
elif len(stdout.splitlines()) == 0:
raise RuntimeError("No VPP PID found on node {0}".
format(node['host']))
else:
raise RuntimeError("More then one VPP PID found on node {0}".
format(node['host']))
@staticmethod
def get_vpp_pids(nodes):
"""Get PID of running VPP process on all DUTs.
:param nodes: DUT nodes.
:type nodes: dict
:return: PIDs
:rtype: dict
"""
pids = dict()
for node in nodes.values():
if node['type'] == NodeType.DUT:
pids[node['host']] = DUTSetup.get_vpp_pid(node)
return pids
|
