| pulkit |
| hg-reviewers |
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | tests/run-tests.py (30 lines) |
| else: | else: | ||||
| tests.append({'path': t}) | tests.append({'path': t}) | ||||
| else: | else: | ||||
| tests.append({'path': t}) | tests.append({'path': t}) | ||||
| if self.options.retest: | if self.options.retest: | ||||
| retest_args = [] | retest_args = [] | ||||
| for test in tests: | for test in tests: | ||||
| if 'case' in test: | errpath = self._geterrpath(test) | ||||
| # for multiple dimensions test cases | |||||
| casestr = b'#'.join(test['case']) | |||||
| errpath = b'%s#%s.err' % (test['path'], casestr) | |||||
| else: | |||||
| errpath = b'%s.err' % test['path'] | |||||
| if self.options.outputdir: | |||||
| errpath = os.path.join(self.options.outputdir, errpath) | |||||
| if os.path.exists(errpath): | if os.path.exists(errpath): | ||||
| retest_args.append(test) | retest_args.append(test) | ||||
| tests = retest_args | tests = retest_args | ||||
| return tests | return tests | ||||
| def _runtests(self, testdescs): | def _runtests(self, testdescs): | ||||
| def _reloadtest(test, i): | def _reloadtest(test, i): | ||||
| # convert a test back to its description dict | # convert a test back to its description dict | ||||
| desc = {'path': test.path} | desc = {'path': test.path} | ||||
| case = getattr(test, '_case', []) | case = getattr(test, '_case', []) | ||||
| if case: | if case: | ||||
| desc['case'] = case | desc['case'] = case | ||||
| return self._gettest(desc, i) | return self._gettest(desc, i) | ||||
| try: | try: | ||||
| if self.options.restart: | if self.options.restart: | ||||
| orig = list(testdescs) | orig = list(testdescs) | ||||
| while testdescs: | while testdescs: | ||||
| desc = testdescs[0] | desc = testdescs[0] | ||||
| # desc['path'] is a relative path | errpath = self._geterrpath(desc) | ||||
| if 'case' in desc: | |||||
| casestr = b'#'.join(desc['case']) | |||||
| errpath = b'%s#%s.err' % (desc['path'], casestr) | |||||
| else: | |||||
| errpath = b'%s.err' % desc['path'] | |||||
| errpath = os.path.join(self._outputdir, errpath) | |||||
| if os.path.exists(errpath): | if os.path.exists(errpath): | ||||
| break | break | ||||
| testdescs.pop(0) | testdescs.pop(0) | ||||
| if not testdescs: | if not testdescs: | ||||
| print("running all tests") | print("running all tests") | ||||
| testdescs = orig | testdescs = orig | ||||
| tests = [self._gettest(d, i) for i, d in enumerate(testdescs)] | tests = [self._gettest(d, i) for i, d in enumerate(testdescs)] | ||||
| self._outputcoverage() | self._outputcoverage() | ||||
| except KeyboardInterrupt: | except KeyboardInterrupt: | ||||
| failed = True | failed = True | ||||
| print("\ninterrupted!") | print("\ninterrupted!") | ||||
| if failed: | if failed: | ||||
| return 1 | return 1 | ||||
| def _geterrpath(self, test): | |||||
| # test['path'] is a relative path | |||||
| if 'case' in test: | |||||
| # for multiple dimensions test cases | |||||
| casestr = b'#'.join(test['case']) | |||||
| errpath = b'%s#%s.err' % (test['path'], casestr) | |||||
| else: | |||||
| errpath = b'%s.err' % test['path'] | |||||
| if self.options.outputdir: | |||||
| errpath = os.path.join(self.options.outputdir, errpath) | |||||
| return errpath | |||||
| def _getport(self, count): | def _getport(self, count): | ||||
| port = self._ports.get(count) # do we have a cached entry? | port = self._ports.get(count) # do we have a cached entry? | ||||
| if port is None: | if port is None: | ||||
| portneeded = 3 | portneeded = 3 | ||||
| # above 100 tries we just give up and let test reports failure | # above 100 tries we just give up and let test reports failure | ||||
| for tries in xrange(100): | for tries in xrange(100): | ||||
| allfree = True | allfree = True | ||||
| port = self.options.port + self._portoffset | port = self.options.port + self._portoffset | ||||