Lines Matching refs:self
13 def __init__(self, count, seed=None, parallel_subtests=1):
21 super(SeedProc, self).__init__('Seed')
22 self._count = count
23 self._seed = seed
24 self._last_idx = defaultdict(int)
25 self._todo = defaultdict(int)
26 self._parallel_subtests = parallel_subtests
28 self._parallel_subtests = min(self._parallel_subtests, count)
30 def setup(self, requirement=base.DROP_RESULT):
31 super(SeedProc, self).setup(requirement)
36 def _next_test(self, test):
38 for _ in range(0, self._parallel_subtests):
39 is_loaded |= self._try_send_next_test(test)
43 def _result_for(self, test, subtest, result):
44 self._todo[test.procid] -= 1
45 if not self._try_send_next_test(test):
46 if not self._todo.get(test.procid):
47 del self._last_idx[test.procid]
48 del self._todo[test.procid]
49 self._send_result(test, None)
51 def _try_send_next_test(self, test):
53 seed = self._seed or random_utils.random_seed()
54 return self._create_subtest(test, idx, random_seed=seed)
56 num = self._last_idx[test.procid]
57 if not self._count or num < self._count:
59 self._todo[test.procid] += 1
60 self._last_idx[test.procid] = num
61 return self._send_test(create_subtest(num))