KaneAI - World’s First E2E Software Testing Agent.Book a Demo Join TestMu Conference

How to use restore_busy_poll method in lisa

Best Python code snippet using lisa_python

performance.py

Source:performance.py

...295                )296            finally:297                for lagscope in [server_lagscope, client_lagscope]:298                    lagscope.kill()299                    lagscope.restore_busy_poll()300        else:301            ntttcp_messages = perf_ntttcp(302                test_result=test_result,303                udp_mode=False,304                connections=[1],305                test_case_name=inspect.stack()[2].function,306            )307            return float(308                # The type is always TCP message, because the above line set udp309                # to False. Ignore type error here, because UDP message has no310                # latency metrics.311                sum(x.latency_us for x in ntttcp_messages)  # type: ignore312                / len(ntttcp_messages)313            )...

common.py

Source:common.py

...139            test_result,140        )141    finally:142        for lagscope in [client_lagscope, server_lagscope]:143            lagscope.restore_busy_poll()144    return latency_perf_messages145def perf_tcp_pps(146    test_result: TestResult,147    test_type: str,148    server: Optional[RemoteNode] = None,149    client: Optional[RemoteNode] = None,150) -> None:151    # Either server and client are set explicitly or we use the first two nodes152    # from the environment. We never combine the two options. We need to specify153    # server and client explicitly for nested VM's which are not part of the154    # `environment` and are created during the test.155    if server is not None or client is not None:156        assert server is not None, "server need to be specified, if client is set"157        assert client is not None, "client need to be specified, if server is set"158    else:159        environment = test_result.environment160        assert environment, "fail to get environment from testresult"161        # set server and client from environment, if not set explicitly162        server = cast(RemoteNode, environment.nodes[1])163        client = cast(RemoteNode, environment.nodes[0])164    client_netperf, server_netperf = run_in_parallel(165        [lambda: client.tools[Netperf], lambda: server.tools[Netperf]]  # type: ignore166    )167    cpu = client.tools[Lscpu]168    core_count = cpu.get_core_count()169    if "maxpps" == test_type:170        ssh = client.tools[Ssh]171        ssh.set_max_session()172        client.close()173        ports = range(30000, 30032)174    else:175        ports = range(30000, 30001)176    for port in ports:177        server_netperf.run_as_server(port)178    for port in ports:179        client_netperf.run_as_client_async(server.internal_address, core_count, port)180    client_sar = client.tools[Sar]181    server_sar = server.tools[Sar]182    server_sar.get_statistics_async()183    result = client_sar.get_statistics()184    pps_message = client_sar.create_pps_performance_messages(185        result, inspect.stack()[1][3], test_type, test_result186    )187    notifier.notify(pps_message)188def perf_ntttcp(189    test_result: TestResult,190    server: Optional[RemoteNode] = None,191    client: Optional[RemoteNode] = None,192    udp_mode: bool = False,193    connections: Optional[List[int]] = None,194    test_case_name: str = "",195    server_nic_name: Optional[str] = None,196    client_nic_name: Optional[str] = None,197) -> List[Union[NetworkTCPPerformanceMessage, NetworkUDPPerformanceMessage]]:198    # Either server and client are set explicitly or we use the first two nodes199    # from the environment. We never combine the two options. We need to specify200    # server and client explicitly for nested VM's which are not part of the201    # `environment` and are created during the test.202    if server is not None or client is not None:203        assert server is not None, "server need to be specified, if client is set"204        assert client is not None, "client need to be specified, if server is set"205    else:206        environment = test_result.environment207        assert environment, "fail to get environment from testresult"208        # set server and client from environment, if not set explicitly209        server = cast(RemoteNode, environment.nodes[1])210        client = cast(RemoteNode, environment.nodes[0])211    if not test_case_name:212        # if it's not filled, assume it's called by case directly.213        test_case_name = inspect.stack()[1][3]214    if connections is None:215        if udp_mode:216            connections = NTTTCP_UDP_CONCURRENCY217        else:218            connections = NTTTCP_TCP_CONCURRENCY219    client_ntttcp, server_ntttcp = run_in_parallel(220        [lambda: client.tools[Ntttcp], lambda: server.tools[Ntttcp]]  # type: ignore221    )222    try:223        client_lagscope, server_lagscope = run_in_parallel(224            [225                lambda: client.tools[Lagscope],  # type: ignore226                lambda: server.tools[Lagscope],  # type: ignore227            ]228        )229        for ntttcp in [client_ntttcp, server_ntttcp]:230            ntttcp.setup_system(udp_mode)231        for lagscope in [client_lagscope, server_lagscope]:232            lagscope.set_busy_poll()233        data_path = get_nic_datapath(client)234        if NetworkDataPath.Sriov.value == data_path:235            server_nic_name = (236                server_nic_name if server_nic_name else server.nics.get_lower_nics()[0]237            )238            client_nic_name = (239                client_nic_name if client_nic_name else client.nics.get_lower_nics()[0]240            )241            dev_differentiator = "mlx"242        else:243            server_nic_name = (244                server_nic_name if server_nic_name else server.nics.default_nic245            )246            client_nic_name = (247                client_nic_name if client_nic_name else client.nics.default_nic248            )249            dev_differentiator = "Hypervisor callback interrupts"250        server_lagscope.run_as_server(ip=server.internal_address)251        max_server_threads = 64252        perf_ntttcp_message_list: List[253            Union[NetworkTCPPerformanceMessage, NetworkUDPPerformanceMessage]254        ] = []255        for test_thread in connections:256            if test_thread < max_server_threads:257                num_threads_p = test_thread258                num_threads_n = 1259            else:260                num_threads_p = max_server_threads261                num_threads_n = int(test_thread / num_threads_p)262            if 1 == num_threads_n and 1 == num_threads_p:263                buffer_size = int(1048576 / 1024)264            else:265                buffer_size = int(65536 / 1024)266            if udp_mode:267                buffer_size = int(1024 / 1024)268            server_result = server_ntttcp.run_as_server_async(269                server_nic_name,270                ports_count=num_threads_p,271                buffer_size=buffer_size,272                dev_differentiator=dev_differentiator,273                udp_mode=udp_mode,274            )275            client_lagscope_process = client_lagscope.run_as_client_async(276                server_ip=server.internal_address,277                ping_count=0,278                run_time_seconds=10,279                print_histogram=False,280                print_percentile=False,281                histogram_1st_interval_start_value=0,282                length_of_histogram_intervals=0,283                count_of_histogram_intervals=0,284                dump_csv=False,285            )286            client_ntttcp_result = client_ntttcp.run_as_client(287                client_nic_name,288                server.internal_address,289                buffer_size=buffer_size,290                threads_count=num_threads_n,291                ports_count=num_threads_p,292                dev_differentiator=dev_differentiator,293                udp_mode=udp_mode,294            )295            server_ntttcp_result = server_result.wait_result()296            server_result_temp = server_ntttcp.create_ntttcp_result(297                server_ntttcp_result298            )299            client_result_temp = client_ntttcp.create_ntttcp_result(300                client_ntttcp_result, role="client"301            )302            client_sar_result = client_lagscope_process.wait_result()303            client_average_latency = client_lagscope.get_average(client_sar_result)304            if udp_mode:305                ntttcp_message: Union[306                    NetworkTCPPerformanceMessage, NetworkUDPPerformanceMessage307                ] = client_ntttcp.create_ntttcp_udp_performance_message(308                    server_result_temp,309                    client_result_temp,310                    str(test_thread),311                    buffer_size,312                    test_case_name,313                    test_result,314                )315            else:316                ntttcp_message = client_ntttcp.create_ntttcp_tcp_performance_message(317                    server_result_temp,318                    client_result_temp,319                    client_average_latency,320                    str(test_thread),321                    buffer_size,322                    test_case_name,323                    test_result,324                )325            notifier.notify(ntttcp_message)326            perf_ntttcp_message_list.append(ntttcp_message)327    finally:328        for ntttcp in [client_ntttcp, server_ntttcp]:329            ntttcp.restore_system(udp_mode)330        for lagscope in [client_lagscope, server_lagscope]:331            lagscope.restore_busy_poll()332    return perf_ntttcp_message_list333def perf_iperf(334    test_result: TestResult,335    connections: List[int],336    buffer_length_list: List[int],337    udp_mode: bool = False,338) -> None:339    environment = test_result.environment340    assert environment, "fail to get environment from testresult"341    client = cast(RemoteNode, environment.nodes[0])342    server = cast(RemoteNode, environment.nodes[1])343    client_iperf3 = client.tools[Iperf3]344    server_iperf3 = server.tools[Iperf3]345    test_case_name = inspect.stack()[1][3]...

lagscope.py

Source:lagscope.py

...107        #  sleeping, which can incur additional power consumption.108        sysctl = self.node.tools[Sysctl]109        for key in self._busy_pool_keys:110            sysctl.write(key, "50")111    def restore_busy_poll(self) -> None:112        sysctl = self.node.tools[Sysctl]113        for key in self._busy_pool_keys:114            sysctl.write(key, self._original_settings[key])115    def run_as_server(self, ip: str = "", daemon: bool = True) -> None:116        # -r: run as a receiver117        # -rip: run as server mode with specified ip address118        # -D: run as a daemon119        cmd = ""120        if daemon:121            cmd += " -D"122        if ip:123            cmd += f" -r{ip}"124        else:125            cmd += " -r"...

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.