Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use __discover_jmeter_udp_port method in yandex-tank

Best Python code snippet using yandex-tank

plugin.py

Source:plugin.py

...114            raise RuntimeError(115                "Unable to access to JMeter executable file or it does not exist: %s"116                % self.jmeter_path)117        self.start_time = time.time()118        self.jmeter_udp_port = self.__discover_jmeter_udp_port()119    def is_test_finished(self):120        retcode = self.process.poll()121        aggregator = self.core.job.aggregator122        if not aggregator.reader.jmeter_finished and retcode is not None:123            logger.info(124                "JMeter process finished with exit code: %s, waiting for aggregator",125                retcode)126            self.retries = 0127            aggregator.reader.jmeter_finished = True128            return -1129        elif aggregator.reader.jmeter_finished is True:130            if aggregator.reader.agg_finished:131                self.reader.close()132                return retcode133            else:134                logger.info("Waiting for aggregator to finish")135                return -1136        else:137            return -1138    def end_test(self, retcode):139        if self.process:140            gracefully_shutdown = self.__graceful_shutdown()141            if not gracefully_shutdown:142                self.__kill_jmeter()143        if self.process_stderr:144            self.process_stderr.close()145        self.core.add_artifact_file(self.jmeter_log)146        self.reader.close()147        return retcode148    def __discover_jmeter_udp_port(self):149        """Searching for line in jmeter.log such as150        Waiting for possible shutdown message on port 4445151        """152        r = re.compile(self.DISCOVER_PORT_PATTERN)153        with open(self.process_stderr.name, 'r') as f:154            cnt = 0155            while self.process.pid and cnt < 10:156                line = f.readline()157                m = r.match(line)158                if m is None:159                    cnt += 1160                    time.sleep(1)161                else:162                    port = int(m.group('port'))...

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.