Neels Hofmeyr | 3531a19 | 2017-03-28 14:30:28 +0200 | [diff] [blame] | 1 | # osmo_gsm_tester: context for individual test runs |
Neels Hofmeyr | dae3d3c | 2017-03-28 12:16:58 +0200 | [diff] [blame] | 2 | # |
| 3 | # Copyright (C) 2016-2017 by sysmocom - s.f.m.c. GmbH |
| 4 | # |
| 5 | # Author: Neels Hofmeyr <neels@hofmeyr.de> |
| 6 | # |
| 7 | # This program is free software: you can redistribute it and/or modify |
Harald Welte | 2720534 | 2017-06-03 09:51:45 +0200 | [diff] [blame] | 8 | # it under the terms of the GNU General Public License as |
Neels Hofmeyr | dae3d3c | 2017-03-28 12:16:58 +0200 | [diff] [blame] | 9 | # published by the Free Software Foundation, either version 3 of the |
| 10 | # License, or (at your option) any later version. |
| 11 | # |
| 12 | # This program is distributed in the hope that it will be useful, |
| 13 | # but WITHOUT ANY WARRANTY; without even the implied warranty of |
| 14 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
Harald Welte | 2720534 | 2017-06-03 09:51:45 +0200 | [diff] [blame] | 15 | # GNU General Public License for more details. |
Neels Hofmeyr | dae3d3c | 2017-03-28 12:16:58 +0200 | [diff] [blame] | 16 | # |
Harald Welte | 2720534 | 2017-06-03 09:51:45 +0200 | [diff] [blame] | 17 | # You should have received a copy of the GNU General Public License |
Neels Hofmeyr | dae3d3c | 2017-03-28 12:16:58 +0200 | [diff] [blame] | 18 | # along with this program. If not, see <http://www.gnu.org/licenses/>. |
| 19 | |
Neels Hofmeyr | 3531a19 | 2017-03-28 14:30:28 +0200 | [diff] [blame] | 20 | # These will be initialized before each test run. |
| 21 | # A test script can thus establish its context by doing: |
Pau Espin Pedrol | dfe38ad | 2017-11-09 13:57:39 +0100 | [diff] [blame] | 22 | # from osmo_gsm_tester.testenv import * |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 23 | |
| 24 | import sys |
| 25 | |
Pau Espin Pedrol | 7cb6bad | 2020-09-18 15:17:08 +0200 | [diff] [blame] | 26 | from .core import util |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 27 | from .core import process |
Pau Espin Pedrol | 166dc10 | 2020-06-04 18:44:42 +0200 | [diff] [blame] | 28 | from .core import template |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 29 | from .core import log as log_module |
| 30 | from .core import process as process_module |
| 31 | from .core import resource |
| 32 | from .core.event_loop import MainLoop |
| 33 | |
Neels Hofmeyr | 3531a19 | 2017-03-28 14:30:28 +0200 | [diff] [blame] | 34 | suite = None |
Neels Hofmeyr | 3531a19 | 2017-03-28 14:30:28 +0200 | [diff] [blame] | 35 | log = None |
| 36 | dbg = None |
| 37 | err = None |
| 38 | wait = None |
Pau Espin Pedrol | 927344b | 2017-05-22 16:38:49 +0200 | [diff] [blame] | 39 | wait_no_raise = None |
Neels Hofmeyr | 3531a19 | 2017-03-28 14:30:28 +0200 | [diff] [blame] | 40 | sleep = None |
| 41 | poll = None |
| 42 | prompt = None |
Pau Espin Pedrol | 2d16f6f | 2017-05-30 15:33:57 +0200 | [diff] [blame] | 43 | Sms = None |
Pau Espin Pedrol | 878b2c6 | 2018-05-18 15:57:06 +0200 | [diff] [blame] | 44 | process = None |
Pau Espin Pedrol | 40c7bc7 | 2020-05-05 13:41:42 +0200 | [diff] [blame] | 45 | tenv = None |
Neels Hofmeyr | dae3d3c | 2017-03-28 12:16:58 +0200 | [diff] [blame] | 46 | |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 47 | class Timeout(Exception): |
| 48 | pass |
| 49 | |
| 50 | class TestEnv(log_module.Origin): |
| 51 | def __init__(self, suite_run, test): |
| 52 | super().__init__(log_module.C_TST, test.name()) |
| 53 | self.suite_run = suite_run |
| 54 | self._test = test |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 55 | self._processes = [] |
| 56 | self.test_import_modules_to_clean_up = [] |
| 57 | self.objects_to_clean_up = None |
| 58 | MainLoop.register_poll_func(self.poll) |
Pau Espin Pedrol | c3cf682 | 2020-06-12 17:54:55 +0200 | [diff] [blame] | 59 | if self._test.timeout is not None: # aimed at firing once |
Pau Espin Pedrol | 683d196 | 2020-06-15 11:39:41 +0200 | [diff] [blame] | 60 | MainLoop.register_poll_func(self._timeout_expired, timestep=self._test.timeout) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 61 | |
Pau Espin Pedrol | a442cb8 | 2020-05-05 12:54:37 +0200 | [diff] [blame] | 62 | def test(self): |
| 63 | return self._test |
| 64 | |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 65 | def suite(self): |
| 66 | return self.suite_run |
| 67 | |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 68 | def remember_to_stop(self, process, respawn=False): |
| 69 | '''Ask suite to monitor and manage lifecycle of the Process object. If a |
| 70 | process managed by suite finishes before cleanup time, the current test |
| 71 | will be marked as FAIL and end immediatelly. If respwan=True, then suite |
| 72 | will respawn() the process instead.''' |
| 73 | self._processes.insert(0, (process, respawn)) |
| 74 | |
| 75 | def stop_processes(self): |
| 76 | if len(self._processes) == 0: |
| 77 | return |
| 78 | strategy = process_module.ParallelTerminationStrategy() |
| 79 | while self._processes: |
| 80 | proc, _ = self._processes.pop() |
| 81 | strategy.add_process(proc) |
| 82 | strategy.terminate_all() |
| 83 | |
| 84 | def stop_process(self, process): |
| 85 | 'Remove process from monitored list and stop it' |
| 86 | for proc_respawn in self._processes: |
| 87 | proc, respawn = proc_respawn |
| 88 | if proc == process: |
| 89 | self._processes.remove(proc_respawn) |
| 90 | proc.terminate() |
| 91 | |
| 92 | def register_for_cleanup(self, *obj): |
| 93 | assert all([hasattr(o, 'cleanup') for o in obj]) |
| 94 | self.objects_to_clean_up = self.objects_to_clean_up or [] |
| 95 | self.objects_to_clean_up.extend(obj) |
| 96 | |
| 97 | def objects_cleanup(self): |
| 98 | while self.objects_to_clean_up: |
| 99 | obj = self.objects_to_clean_up.pop() |
| 100 | try: |
| 101 | obj.cleanup() |
| 102 | except Exception: |
| 103 | log_module.log_exn() |
| 104 | |
| 105 | def test_import_modules_register_for_cleanup(self, mod): |
| 106 | ''' |
| 107 | Tests are required to call this API for any module loaded from its own |
| 108 | lib subdir, because they are loaded in the global namespace. Otherwise |
| 109 | later tests importing modules with the same name will re-use an already |
| 110 | loaded module. |
| 111 | ''' |
| 112 | if mod not in self.test_import_modules_to_clean_up: |
| 113 | self.dbg('registering module %r for cleanup' % mod) |
| 114 | self.test_import_modules_to_clean_up.append(mod) |
| 115 | |
| 116 | def test_import_modules_cleanup(self): |
| 117 | while self.test_import_modules_to_clean_up: |
| 118 | mod = self.test_import_modules_to_clean_up.pop() |
| 119 | try: |
| 120 | self.dbg('Cleaning up module %r' % mod) |
| 121 | del sys.modules[mod.__name__] |
| 122 | del mod |
| 123 | except Exception: |
| 124 | log_module.log_exn() |
| 125 | |
Pau Espin Pedrol | 683d196 | 2020-06-15 11:39:41 +0200 | [diff] [blame] | 126 | def _timeout_expired(self): |
Pau Espin Pedrol | c3cf682 | 2020-06-12 17:54:55 +0200 | [diff] [blame] | 127 | # Avoid timeout being called several times: |
Pau Espin Pedrol | 683d196 | 2020-06-15 11:39:41 +0200 | [diff] [blame] | 128 | MainLoop.unregister_poll_func(self._timeout_expired) |
Pau Espin Pedrol | c3cf682 | 2020-06-12 17:54:55 +0200 | [diff] [blame] | 129 | raise log_module.Error('Test Timeout triggered: %d seconds elapsed' % self._test.elapsed_time()) |
| 130 | |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 131 | def poll(self): |
| 132 | for proc, respawn in self._processes: |
| 133 | if proc.terminated(): |
| 134 | if respawn == True: |
| 135 | proc.respawn() |
| 136 | else: |
| 137 | proc.log_stdout_tail() |
| 138 | proc.log_stderr_tail() |
| 139 | log_module.ctx(proc) |
| 140 | raise log_module.Error('Process ended prematurely: %s' % proc.name()) |
| 141 | |
| 142 | def stop(self): |
| 143 | # if sys.exit() called from signal handler (e.g. SIGINT), SystemExit |
| 144 | # base exception is raised. Make sure to stop processes in this |
| 145 | # finally section. Resources are automatically freed with 'atexit'. |
| 146 | self.stop_processes() |
| 147 | self.objects_cleanup() |
| 148 | self.suite_run.reserved_resources.put_all() |
| 149 | MainLoop.unregister_poll_func(self.poll) |
Pau Espin Pedrol | 683d196 | 2020-06-15 11:39:41 +0200 | [diff] [blame] | 150 | MainLoop.unregister_poll_func(self._timeout_expired) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 151 | self.test_import_modules_cleanup() |
Pau Espin Pedrol | 166dc10 | 2020-06-04 18:44:42 +0200 | [diff] [blame] | 152 | self.set_overlay_template_dir(None) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 153 | |
Pau Espin Pedrol | 3063730 | 2020-05-06 21:11:02 +0200 | [diff] [blame] | 154 | def config_suite_specific(self): |
| 155 | return self.suite_run.config_suite_specific() |
| 156 | |
| 157 | def config_test_specific(self): |
Pau Espin Pedrol | a75f85a | 2020-06-12 17:13:26 +0200 | [diff] [blame] | 158 | return self._test.config_test_specific() |
Pau Espin Pedrol | 3063730 | 2020-05-06 21:11:02 +0200 | [diff] [blame] | 159 | |
Pau Espin Pedrol | 166dc10 | 2020-06-04 18:44:42 +0200 | [diff] [blame] | 160 | def set_overlay_template_dir(self, template_dir=None): |
| 161 | '''Overlay a directory on top of default one when looking for |
| 162 | directories. It must be called everytime a template file is updated.''' |
| 163 | if template_dir is None: |
| 164 | template.set_templates_dir(template.default_templates_dir()) |
| 165 | else: |
Pau Espin Pedrol | a4bb6d3 | 2020-06-11 16:14:47 +0200 | [diff] [blame] | 166 | self.dbg('template dir overlay set: %s' % template_dir) |
Pau Espin Pedrol | 166dc10 | 2020-06-04 18:44:42 +0200 | [diff] [blame] | 167 | template.set_templates_dir(template_dir, template.default_templates_dir()) |
| 168 | |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 169 | def prompt(self, *msgs, **msg_details): |
| 170 | 'ask for user interaction. Do not use in tests that should run automatically!' |
| 171 | if msg_details: |
| 172 | msgs = list(msgs) |
| 173 | msgs.append('{%s}' % |
| 174 | (', '.join(['%s=%r' % (k,v) |
| 175 | for k,v in sorted(msg_details.items())]))) |
| 176 | msg = ' '.join(msgs) or 'Hit Enter to continue' |
| 177 | self.log('prompt:', msg) |
| 178 | sys.__stdout__.write('\n\n--- PROMPT ---\n') |
| 179 | sys.__stdout__.write(msg) |
| 180 | sys.__stdout__.write('\n') |
| 181 | sys.__stdout__.flush() |
| 182 | entered = util.input_polling('> ', MainLoop.poll) |
| 183 | self.log('prompt entered:', repr(entered)) |
| 184 | return entered |
| 185 | |
| 186 | def get_reserved_resource(self, resource_class_str, specifics=None): |
| 187 | return self.suite_run.get_reserved_resource(resource_class_str, specifics) |
| 188 | |
| 189 | def ip_address(self, specifics=None): |
| 190 | return self.get_reserved_resource(resource.R_IP_ADDRESS, specifics) |
| 191 | |
| 192 | def nitb(self, ip_address=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 193 | from .obj.nitb_osmo import OsmoNitb |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 194 | if ip_address is None: |
| 195 | ip_address = self.ip_address() |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 196 | return OsmoNitb(self, ip_address) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 197 | |
| 198 | def hlr(self, ip_address=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 199 | from .obj.hlr_osmo import OsmoHlr |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 200 | if ip_address is None: |
| 201 | ip_address = self.ip_address() |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 202 | return OsmoHlr(self, ip_address) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 203 | |
| 204 | def ggsn(self, ip_address=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 205 | from .obj.ggsn_osmo import OsmoGgsn |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 206 | if ip_address is None: |
| 207 | ip_address = self.ip_address() |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 208 | return OsmoGgsn(self, ip_address) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 209 | |
| 210 | def sgsn(self, hlr, ggsn, ip_address=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 211 | from .obj import sgsn_osmo |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 212 | if ip_address is None: |
| 213 | ip_address = self.ip_address() |
| 214 | return sgsn_osmo.OsmoSgsn(self, hlr, ggsn, ip_address) |
| 215 | |
| 216 | def mgcpgw(self, ip_address=None, bts_ip=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 217 | from .obj.mgcpgw_osmo import OsmoMgcpgw |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 218 | if ip_address is None: |
| 219 | ip_address = self.ip_address() |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 220 | return OsmoMgcpgw(self, ip_address, bts_ip) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 221 | |
| 222 | def mgw(self, ip_address=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 223 | from .obj.mgw_osmo import OsmoMgw |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 224 | if ip_address is None: |
| 225 | ip_address = self.ip_address() |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 226 | return OsmoMgw(self, ip_address) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 227 | |
| 228 | def msc(self, hlr, mgcpgw, stp, ip_address=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 229 | from .obj import msc_osmo |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 230 | if ip_address is None: |
| 231 | ip_address = self.ip_address() |
| 232 | return msc_osmo.OsmoMsc(self, hlr, mgcpgw, stp, ip_address) |
| 233 | |
| 234 | def bsc(self, msc, mgw, stp, ip_address=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 235 | from .obj.bsc_osmo import OsmoBsc |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 236 | if ip_address is None: |
| 237 | ip_address = self.ip_address() |
Neels Hofmeyr | af4e231 | 2020-11-27 08:20:56 +0100 | [diff] [blame] | 238 | bsc_obj = OsmoBsc(self, msc, mgw, stp, ip_address) |
| 239 | self.register_for_cleanup(bsc_obj) |
| 240 | return bsc_obj |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 241 | |
| 242 | def stp(self, ip_address=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 243 | from .obj.stp_osmo import OsmoStp |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 244 | if ip_address is None: |
| 245 | ip_address = self.ip_address() |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 246 | return OsmoStp(self, ip_address) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 247 | |
| 248 | def ms_driver(self): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 249 | from .obj.ms_driver import MsDriver |
| 250 | ms = MsDriver(self) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 251 | self.register_for_cleanup(ms) |
| 252 | return ms |
| 253 | |
| 254 | def bts(self, specifics=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 255 | from .obj.bts import Bts |
| 256 | bts_obj = Bts.get_instance_by_type(self, self.get_reserved_resource(resource.R_BTS, specifics=specifics)) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 257 | bts_obj.set_lac(self.lac()) |
| 258 | bts_obj.set_rac(self.rac()) |
| 259 | bts_obj.set_cellid(self.cellid()) |
| 260 | bts_obj.set_bvci(self.bvci()) |
| 261 | self.register_for_cleanup(bts_obj) |
| 262 | return bts_obj |
| 263 | |
| 264 | def modem(self, specifics=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 265 | from .obj.ms import MS |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 266 | conf = self.get_reserved_resource(resource.R_MODEM, specifics=specifics) |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 267 | ms_obj = MS.get_instance_by_type(self, conf) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 268 | self.register_for_cleanup(ms_obj) |
| 269 | return ms_obj |
| 270 | |
| 271 | def modems(self, count): |
| 272 | l = [] |
| 273 | for i in range(count): |
| 274 | l.append(self.modem()) |
| 275 | return l |
| 276 | |
| 277 | def all_resources(self, resource_func): |
| 278 | """Returns all yielded resource.""" |
| 279 | l = [] |
| 280 | while True: |
| 281 | try: |
| 282 | l.append(resource_func()) |
| 283 | except resource.NoResourceExn: |
| 284 | return l |
| 285 | |
| 286 | def esme(self): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 287 | from .obj.esme import Esme |
| 288 | esme_obj = Esme(self.msisdn()) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 289 | self.register_for_cleanup(esme_obj) |
| 290 | return esme_obj |
| 291 | |
| 292 | def run_node(self, specifics=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 293 | from .obj.run_node import RunNode |
| 294 | return RunNode.from_conf(self.get_reserved_resource(resource.R_RUN_NODE, specifics=specifics)) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 295 | |
| 296 | def enb(self, specifics=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 297 | from .obj.enb import eNodeB |
| 298 | enb_obj = eNodeB.get_instance_by_type(self, self.get_reserved_resource(resource.R_ENB, specifics=specifics)) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 299 | self.register_for_cleanup(enb_obj) |
| 300 | return enb_obj |
| 301 | |
| 302 | def epc(self, run_node=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 303 | from .obj.epc import EPC |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 304 | if run_node is None: |
| 305 | run_node = self.run_node() |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 306 | epc_obj = EPC.get_instance_by_type(self, run_node) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 307 | self.register_for_cleanup(epc_obj) |
| 308 | return epc_obj |
| 309 | |
| 310 | def osmocon(self, specifics=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 311 | from .obj.osmocon import Osmocon |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 312 | conf = self.get_reserved_resource(resource.R_OSMOCON, specifics=specifics) |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 313 | osmocon_obj = Osmocon(self, conf=conf) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 314 | self.register_for_cleanup(osmocon_obj) |
| 315 | return osmocon_obj |
| 316 | |
| 317 | def iperf3srv(self, ip_address=None): |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 318 | from .obj.iperf3 import IPerf3Server |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 319 | if ip_address is None: |
| 320 | ip_address = self.ip_address() |
Pau Espin Pedrol | 5b9c7b9 | 2020-05-05 14:35:04 +0200 | [diff] [blame] | 321 | iperf3srv_obj = IPerf3Server(self, ip_address) |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 322 | return iperf3srv_obj |
| 323 | |
Pau Espin Pedrol | 969a4ee | 2020-07-02 13:21:08 +0200 | [diff] [blame] | 324 | def stress(self, run_node=None): |
| 325 | from .obj.stress import StressTool |
| 326 | stress_obj = StressTool(self, run_node) |
| 327 | return stress_obj |
| 328 | |
Pau Espin Pedrol | aa1cbdc | 2020-05-04 20:21:31 +0200 | [diff] [blame] | 329 | def msisdn(self): |
| 330 | msisdn = self.suite_run.resource_pool().next_msisdn(self) |
| 331 | self.log('using MSISDN', msisdn) |
| 332 | return msisdn |
| 333 | |
| 334 | def lac(self): |
| 335 | lac = self.suite_run.resource_pool().next_lac(self) |
| 336 | self.log('using LAC', lac) |
| 337 | return lac |
| 338 | |
| 339 | def rac(self): |
| 340 | rac = self.suite_run.resource_pool().next_rac(self) |
| 341 | self.log('using RAC', rac) |
| 342 | return rac |
| 343 | |
| 344 | def cellid(self): |
| 345 | cellid = self.suite_run.resource_pool().next_cellid(self) |
| 346 | self.log('using CellId', cellid) |
| 347 | return cellid |
| 348 | |
| 349 | def bvci(self): |
| 350 | bvci = self.suite_run.resource_pool().next_bvci(self) |
| 351 | self.log('using BVCI', bvci) |
| 352 | return bvci |
| 353 | |
| 354 | |
Pau Espin Pedrol | ee217b0 | 2020-05-04 19:06:47 +0200 | [diff] [blame] | 355 | def setup(suite_run, _test): |
Pau Espin Pedrol | ee217b0 | 2020-05-04 19:06:47 +0200 | [diff] [blame] | 356 | from .core.event_loop import MainLoop |
| 357 | from .obj.sms import Sms as Sms_class |
Pau Espin Pedrol | ee217b0 | 2020-05-04 19:06:47 +0200 | [diff] [blame] | 358 | |
Pau Espin Pedrol | 315ba57 | 2020-06-04 17:09:16 +0200 | [diff] [blame] | 359 | global test, log, dbg, err, wait, wait_no_raise, sleep, poll, prompt, Sms, process, tenv |
Pau Espin Pedrol | ee217b0 | 2020-05-04 19:06:47 +0200 | [diff] [blame] | 360 | |
Neels Hofmeyr | 3531a19 | 2017-03-28 14:30:28 +0200 | [diff] [blame] | 361 | test = _test |
Neels Hofmeyr | 3531a19 | 2017-03-28 14:30:28 +0200 | [diff] [blame] | 362 | log = test.log |
| 363 | dbg = test.dbg |
| 364 | err = test.err |
Pau Espin Pedrol | 664e383 | 2020-06-10 19:30:33 +0200 | [diff] [blame] | 365 | tenv = TestEnv(suite_run, _test) |
| 366 | wait = MainLoop.wait |
| 367 | wait_no_raise = MainLoop.wait_no_raise |
| 368 | sleep = MainLoop.sleep |
Pau Espin Pedrol | ee217b0 | 2020-05-04 19:06:47 +0200 | [diff] [blame] | 369 | poll = MainLoop.poll |
Pau Espin Pedrol | ee217b0 | 2020-05-04 19:06:47 +0200 | [diff] [blame] | 370 | Sms = Sms_class |
Pau Espin Pedrol | 878b2c6 | 2018-05-18 15:57:06 +0200 | [diff] [blame] | 371 | process = process_module |
Pau Espin Pedrol | 40c7bc7 | 2020-05-05 13:41:42 +0200 | [diff] [blame] | 372 | prompt = tenv.prompt |
| 373 | return tenv |
Neels Hofmeyr | dae3d3c | 2017-03-28 12:16:58 +0200 | [diff] [blame] | 374 | |
Neels Hofmeyr | dae3d3c | 2017-03-28 12:16:58 +0200 | [diff] [blame] | 375 | # vim: expandtab tabstop=4 shiftwidth=4 |