| # Copyright 2015 The Chromium OS Authors. All rights reserved. |
| # Use of this source code is governed by a BSD-style license that can be |
| # found in the LICENSE file. |
| import logging |
| import time |
| |
| |
| from autotest_lib.client.common_lib import error |
| from autotest_lib.client.common_lib.cros.network import ping_runner |
| from autotest_lib.client.common_lib.cros.network import xmlrpc_datatypes |
| from autotest_lib.client.cros.chameleon import chameleon_audio_helper |
| from autotest_lib.client.cros.chameleon import chameleon_audio_ids |
| from autotest_lib.server.cros.audio import audio_test |
| from autotest_lib.server.cros.multimedia import remote_facade_factory |
| from autotest_lib.server.cros.network import netperf_runner |
| from autotest_lib.server.cros.network import netperf_session |
| from autotest_lib.server.cros.network import wifi_cell_test_base |
| |
| |
| class network_WiFi_BluetoothStreamPerf(wifi_cell_test_base.WiFiCellTestBase): |
| """Test maximal achievable bandwidth on several channels per band. |
| |
| Conducts a performance test for a set of specified router configurations |
| and reports results as keyval pairs. |
| |
| """ |
| |
| version = 1 |
| |
| NETPERF_CONFIGS = [ |
| netperf_runner.NetperfConfig( |
| netperf_runner.NetperfConfig.TEST_TYPE_TCP_STREAM), |
| netperf_runner.NetperfConfig( |
| netperf_runner.NetperfConfig.TEST_TYPE_TCP_MAERTS), |
| netperf_runner.NetperfConfig( |
| netperf_runner.NetperfConfig.TEST_TYPE_UDP_STREAM), |
| netperf_runner.NetperfConfig( |
| netperf_runner.NetperfConfig.TEST_TYPE_UDP_MAERTS), |
| ] |
| |
| |
| def parse_additional_arguments(self, commandline_args, additional_params): |
| """Hook into super class to take control files parameters. |
| |
| @param commandline_args dict of parsed parameters from the autotest. |
| @param additional_params list of HostapConfig objects. |
| |
| """ |
| self._ap_configs = additional_params |
| |
| |
| def test_one(self, session, config, ap_config_tag, bt_tag): |
| """Run one iteration of wifi testing. |
| |
| @param session NetperfSession session |
| @param config NetperfConfig config |
| @param ap_config_tag string for AP configuration |
| @param bt_tag string for BT operation |
| |
| """ |
| get_ping_config = lambda period: ping_runner.PingConfig( |
| self.context.get_wifi_addr(), interval=1, count=period) |
| |
| logging.info('testing config %s, ap_config %s, BT:%s', |
| config.tag, ap_config_tag, bt_tag) |
| test_str = '_'.join([ap_config_tag, bt_tag]) |
| time.sleep(1) |
| |
| # Record the signal level. |
| signal_level = self.context.client.wifi_signal_level |
| signal_description = '_'.join(['signal', test_str]) |
| self.write_perf_keyval({signal_description: signal_level}) |
| |
| # Run netperf and log the results. |
| results = session.run(config) |
| if not results: |
| logging.error('Failed to take measurement for %s', |
| config.tag) |
| return |
| values = [result.throughput for result in results] |
| self.output_perf_value(config.tag + '_' + bt_tag, values, units='Mbps', |
| higher_is_better=True, |
| graph=ap_config_tag) |
| result = netperf_runner.NetperfResult.from_samples(results) |
| self.write_perf_keyval(result.get_keyval( |
| prefix='_'.join([config.tag, test_str]))) |
| |
| # Log the drop in throughput compared with the 'BT_disconnected' |
| # baseline. Only positive values are valid. Report the drop as a |
| # whole integer percentage of (base_through-through)/base_through. |
| if bt_tag == 'BT_disconnected': |
| self.base_through = result.throughput |
| elif self.base_through > 0: |
| drop = int( (self.base_through - result.throughput) * 100 / |
| self.base_through) |
| self.output_perf_value(config.tag + '_' + bt_tag + '_drop', |
| drop, units='percent_drop', |
| higher_is_better=False, |
| graph=ap_config_tag + '_drop') |
| self.write_perf_keyval({'_'.join([config.tag, test_str, 'drop']): |
| drop}) |
| logging.info('logging drop value as %d%%', drop) |
| |
| # Test latency with ping. |
| result_ping = self.context.client.ping(get_ping_config(3)) |
| self.write_perf_keyval( |
| { '_'.join(['ping', test_str]): result_ping.avg_latency }) |
| logging.info('Ping statistics with %s: %r', bt_tag, result_ping) |
| |
| |
| |
| def run_once(self, host): |
| """Test body.""" |
| start_time = time.time() |
| |
| # Setup Bluetooth widgets and their binder, but do not yet connect. |
| audio_test.audio_test_requirement() |
| factory = remote_facade_factory.RemoteFacadeFactory( |
| host, results_dir=self.resultsdir) |
| chameleon_board = host.chameleon |
| if chameleon_board is None: |
| raise error.TestNAError("No chameleon device is present") |
| |
| chameleon_board.setup_and_reset(self.outputdir) |
| widget_factory = chameleon_audio_helper.AudioWidgetFactory( |
| factory, host) |
| source = widget_factory.create_widget( |
| chameleon_audio_ids.CrosIds.BLUETOOTH_HEADPHONE) |
| bluetooth_widget = widget_factory.create_widget( |
| chameleon_audio_ids.PeripheralIds.BLUETOOTH_DATA_RX) |
| binder = widget_factory.create_binder( |
| source, bluetooth_widget) |
| audio_test_file = 'http://commondatastorage.googleapis.com/' \ |
| 'chromiumos-test-assets-public/audio_test/' \ |
| 'chameleon/Headphone/test_256_16.mp3' |
| |
| |
| for ap_config in self._ap_configs: |
| # Set up the router and associate the client with it. |
| self.context.configure(ap_config) |
| assoc_params = xmlrpc_datatypes.AssociationParameters( |
| ssid=self.context.router.get_ssid(), |
| security_config=ap_config.security_config) |
| self.context.assert_connect_wifi(assoc_params) |
| session = netperf_session.NetperfSession(self.context.client, |
| self.context.router) |
| session.MEASUREMENT_MAX_SAMPLES = 6. |
| |
| |
| # Warmup the wifi path and measure signal. |
| session.warmup_stations() |
| ap_config_tag = ap_config.perf_loggable_description |
| |
| for config in self.NETPERF_CONFIGS: |
| self.base_through = 0 |
| self.test_one(session, config, ap_config_tag, 'BT_disconnected') |
| with chameleon_audio_helper.bind_widgets(binder): |
| self.test_one(session, config, ap_config_tag, |
| 'BT_connected_but_not_streaming') |
| logging.info('Playing an audio test file') |
| browser_facade = factory.create_browser_facade() |
| browser_facade.new_tab(audio_test_file) |
| self.test_one(session, config, ap_config_tag, |
| 'BT_streaming_audiofile') |
| self.test_one(session, config, ap_config_tag, |
| 'BT_disconnected_again') |
| |
| # Clean up router and client state for the next run. |
| self.context.client.shill.disconnect(self.context.router.get_ssid()) |
| self.context.router.deconfig() |
| |
| end_time = time.time() |
| logging.info('Running time %0.1f seconds.', end_time - start_time) |
| |
