| /external/autotest/client/site_tests/graphics_dEQP/ |
| D | generate_controlfiles.py | 103 def get_controlfilename(test, shard=0): argument
104 return 'control.%s' % get_name(test, shard)
121 def get_name(test, shard): argument
126 name = '%s.%d' % (name, shard)
130 def get_testname(test, shard=0): argument
131 return 'graphics_dEQP.%s' % get_name(test, shard)
144 for shard in xrange(0, test.shards):
145 testname = get_testname(test, shard)
146 filename = get_controlfilename(test, shard)
154 shard=shard,
|
| /external/compiler-rt/lib/sanitizer_common/tests/ |
| D | sanitizer_thread_registry_test.cc | 163 uptr shard; // started from 1. member
170 uptr shard = (uptr)arg; in OnJoined() local
171 num_joined[shard]++; in OnJoined()
174 uptr shard = (uptr)arg; in OnStarted() local
175 num_started[shard]++; in OnStarted()
178 uptr shard = (uptr)arg; in OnCreated() local
179 num_created[shard]++; in OnCreated()
190 args->registry->CreateThread(0, false, 0, (void*)args->shard)); in RunThread()
192 args->registry->StartThread(tids[i], 0, (void*)args->shard); in RunThread()
196 args->registry->JoinThread(tids[i], (void*)args->shard); in RunThread()
[all …]
|
| /external/autotest/cli/ |
| D | shard.py | 22 class shard(topic_common.atest): class
32 super(shard, self).__init__()
43 class shard_help(shard):
49 class shard_list(action_common.atest_list, shard):
84 class shard_create(action_common.atest_create, shard):
126 class shard_delete(action_common.atest_delete, shard):
142 class shard_remove_board(shard):
|
| /external/skia/infra/bots/recipe_modules/swarming/ |
| D | api.py | 83 def _is_expired(self, shard): argument
87 shard.get('state') == self.State.EXPIRED or
88 shard.get('state') == 'EXPIRED')
90 def _is_timed_out(self, shard): argument
94 shard.get('state') == self.State.TIMED_OUT or
95 shard.get('state') == 'TIMED_OUT')
97 def _get_exit_code(self, shard): argument
98 if shard.get('exit_code'):
99 return shard.get('exit_code') # pragma: no cover
100 lst = shard.get('exit_codes', [])
[all …]
|
| /external/autotest/frontend/afe/ |
| D | rpc_interface.py | 367 if host.shard:
368 affected_shard_hostnames.add(host.shard.rpc_hostname())
977 hosts = [h for h in hosts if h.shard is None]
978 for shard, hostnames in shard_host_map.iteritems():
990 rpc, [shard], **shard_filter)
1306 if not host.shard:
1313 shard_afe = frontend.AFE(server=host.shard.rpc_hostname())
1345 if not host_model.shard:
1348 shard_afe = frontend.AFE(server=host_model.shard.rpc_hostname())
1395 if not host.shard:
[all …]
|
| D | rpc_interface_unittest.py | 331 shard = models.Shard.objects.create(hostname='shard')
332 job = self._create_job(shard=shard, control_file='foo')
471 shard = models.Shard.objects.create(hostname=shard_hostname)
472 host.shard = shard
534 host1.shard = shard1
538 host2.shard = shard2
588 host1.shard = shard1
614 host2.shard = shard1
637 host2.shard = shard1
1074 shard = models.Shard.objects.create(hostname='host1')
[all …]
|
| D | rpc_utils.py | 727 if host.shard:
728 shard_name = (host.shard.rpc_hostname() if rpc_hostnames
729 else host.shard.hostname)
930 def find_records_for_shard(shard, known_job_ids, known_host_ids): argument
941 shard, known_host_ids)
942 jobs = models.Job.assign_to_shard(shard, known_job_ids)
950 shard, records, record_type, *args, **kwargs):
978 shard, serialized_record, *args, **kwargs)
990 def persist_records_sent_from_shard(shard, jobs, hqes): argument
1010 shard, jobs, models.Job)
[all …]
|
| D | models.py | 457 self.shard = Shard.deserialize(data)
471 shard = dbmodels.ForeignKey(Shard, blank=True, null=True) variable in Host
513 def assign_to_shard(cls, shard, known_ids): argument
559 labels__in=shard.labels.all(),
571 labels__in=shard.labels.all(),
573 ).update(shard=shard)
576 shard=shard
582 shard=shard
1247 self.shard = Shard.deserialize(data)
1250 def sanity_check_update_from_shard(self, shard, updated_serialized): argument
[all …]
|
| D | frontend_test_utils.py | 72 shard=None): argument
115 shard=shard)
|
| /external/autotest/server/site_tests/platform_BootPerfServer/ |
| D | control.shard | 5 NAME = "platform_BootPerfServer.shard"
12 DOC = """This test reboots the client on a shard. When a shard is deleted,
|
| /external/boringssl/src/util/ |
| D | all_tests.go | 380 shard := t
381 shard.args = []string{shard.args[0], "--gtest_filter=" + strings.Join(shuffled[i:i+n], ":")}
382 shards = append(shards, shard)
423 for _, shard := range shards {
424 tests <- shard
|
| /external/autotest/scheduler/shard/ |
| D | shard_client.py | 192 job_models.update(shard=None)
213 def shard(self): member in ShardClient
239 shard=None,
251 models.Job.objects.filter(pk__in=job_ids).update(shard=self.shard)
|
| D | shard_client_integration_tests.py | 17 from autotest_lib.scheduler.shard import shard_client
88 modified_hqe.job.shard == None)
|
| D | shard_client_unittest.py | 17 from autotest_lib.scheduler.shard import shard_client
208 job.shard = None
|
| /external/libvpx/libvpx/tools/ |
| D | all_builds.py | 51 shard = int(options["--shard"])
58 my_configs = filter(lambda x: x[1] % shards == shard, my_configs)
|
| /external/autotest/contrib/ |
| D | task_runner.sh | 126 $AT_DIR/cli/atest shard delete $SHARD_NAME --web $AFE
128 $AT_DIR/cli/atest shard create $SHARD_NAME -l $SHARD_BOARD --web $AFE
|
| /external/autotest/tko/ |
| D | retrieve_logs.cgi | 59 shard = args['shard']
60 if shard:
|
| /external/protobuf/java/core/src/test/java/com/google/protobuf/ |
| D | IsValidUtf8Test.java | 181 for (Shard shard : IsValidUtf8TestUtil.FOUR_BYTE_SHARDS) { in testShardsHaveExpectedRoundTrippables()
182 actual += shard.expected; in testShardsHaveExpectedRoundTrippables()
|
| /external/autotest/scheduler/ |
| D | rdb_testing_utils.py | 143 shard = cls.get_shard(hostname=shard_hostname)
145 if not shard else shard[0])
184 job_filter.update(shard=cls.create_shard(shard_hostname))
|
| /external/autotest/puppylab/ |
| D | ClusterTemplate | 42 "server_type" => "testing-shard-master",
64 "server_type" => "testing-shard",
|
| /external/guava/guava-tests/test/com/google/common/hash/ |
| D | HashingTest.java | 181 for (int shard = 2; shard <= MAX_SHARDS; shard++) { in testConsistentHash_probabilities()
183 assertTrue(map.get(shard) <= 1.2 * ITERS / shard + 20); in testConsistentHash_probabilities()
|
| /external/autotest/server/lib/ |
| D | suite_report.py | 117 if job.shard:
118 entry['shard'] = job.shard
|
| /external/toolchain-utils/go/patch/ |
| D | go2.patch | 14 shard = flag.Int("shard", 0, "shard index to run. Only applicable if -shards is non-zero.")
|
| /external/skia/infra/bots/recipe_modules/skia_swarming/ |
| D | api.py | 211 for shard in shards:
212 ids.append(shard['id'])
|
| /external/v8/tools/ |
| D | run-deopt-fuzzer.py | 284 shard = []
287 shard.append(test)
289 return shard
|