| /external/autotest/client/site_tests/graphics_dEQP/ |
| generate_controlfiles.py | 8 each shard will run less than 1 minute. It mostly makes sense in
94 {% endif %}'shard_number={{shard}}',
104 def get_controlfilename(test, shard=0):
105 return 'control.%s' % get_name(test, shard)
122 def get_name(test, shard):
127 name = '%s.%d' % (name, shard)
131 def get_testname(test, shard=0):
132 return 'graphics_dEQP.%s' % get_name(test, shard)
145 for shard in xrange(0, test.shards):
146 testname = get_testname(test, shard)
[all...] |
| /tools/tradefederation/core/src/com/android/tradefed/invoker/shard/ |
| IShardHelper.java | 16 package com.android.tradefed.invoker.shard;
26 * Shard and reschedule the shard if possible.
|
| ShardBuildCloner.java | 16 package com.android.tradefed.invoker.shard;
26 * Helper class that handles cloning a build info from the command line. Shard will get the build
|
| /external/compiler-rt/lib/sanitizer_common/tests/ |
| sanitizer_thread_registry_test.cc | 163 uptr shard; // started from 1. member in struct:__sanitizer::__anon17203::RunThreadArgs
170 uptr shard = (uptr)arg; local
171 num_joined[shard]++;
174 uptr shard = (uptr)arg; local
175 num_started[shard]++;
178 uptr shard = (uptr)arg; local
179 num_created[shard]++;
190 args->registry->CreateThread(0, false, 0, (void*)args->shard));
192 args->registry->StartThread(tids[i], 0, (void*)args->shard);
196 args->registry->JoinThread(tids[i], (void*)args->shard);
[all...] |
| /external/tensorflow/tensorflow/core/kernels/ |
| record_yielder.cc | 71 struct RecordYielder::Shard {
72 int index; // Shard index.
73 std::vector<string> filenames; // File names given to this shard.
74 Notification done; // Notified when this shard is done.
75 Status status; // Shard status.
132 // Shards files and use one thread to go through each shard.
134 std::vector<Shard> shards(N);
136 Shard* shard = &shards[i]; local
137 shard->index = i
[all...] |
| record_yielder.h | 152 struct Shard;
153 void ShardLoop(Shard* shard);
|
| /external/tensorflow/tensorflow/python/data/kernel_tests/ |
| shard_dataset_op_test.py | 28 dataset = dataset_ops.Dataset.range(10).shard(5, 2)
40 dataset = dataset_ops.Dataset.zip((dataset_a, dataset_b)).shard(5, 2)
50 dataset = dataset_ops.Dataset.range(10).shard(5, 0)
61 dataset_ops.Dataset.range(10).shard(5, 7)
65 dataset_ops.Dataset.range(10).shard(5, -3)
69 dataset_ops.Dataset.range(10).shard(-3, 1)
73 dataset_ops.Dataset.range(10).shard(0, 1)
76 dataset = dataset_ops.Dataset.range(1).shard(5, 2)
84 dataset = dataset_ops.Dataset.range(10).shard(7, 5)
92 dataset = dataset_ops.Dataset.range(10).shard(5, 4
[all...] |
| /external/autotest/cli/ |
| shard.py | 5 The shard module contains the objects and methods used to
9 create: creates shard
10 remove: deletes shard(s)
12 add_boards: add boards to a given shard
13 remove_board: remove board from a given shard
22 class shard(topic_common.atest): class in inherits:topic_common.atest
23 """shard class
24 atest shard [create|delete|list|add_boards|remove_board] <options>"""
26 topic = msg_topic = 'shard'
31 shard actions""
[all...] |
| /external/tensorflow/tensorflow/core/util/ |
| tensor_slice_reader.cc | 129 for (size_t shard = 0; shard < fnames_.size(); ++shard) {
130 fname_to_index_.insert(std::make_pair(fnames_[shard], shard));
136 VLOG(1) << "Loading shard " << preferred_shard << " for " << filepattern_;
141 void TensorSliceReader::LoadShard(int shard) const {
142 CHECK_LT(shard, sss_.size());
143 if (sss_[shard] || !status_.ok()) {
148 const string fname = fnames_[shard];
[all...] |
| /tools/tradefederation/core/src/com/android/tradefed/testtype/ |
| AndroidJUnitTest.java | 117 name = "ajur-max-shard",
118 description = "The maximum number of shard we want to allow the AJUR test to shard into"
259 // If not shardable, only first shard can run.
439 AndroidJUnitTest shard; local
442 shard = this.getClass().newInstance();
447 OptionCopier.copyOptions(this, shard);
451 shard.mShardIndex = shardIndex;
452 shard.mTotalShards = shardCount;
453 shard.mIsSharded = true
[all...] |
| VersionedTfLauncher.java | 94 mCmdArgs.add("--shard-count");
96 mCmdArgs.add("--shard-index");
119 IRemoteTest shard = new VersionedTfLauncher(shardCount, shardIndex); local
121 OptionCopier.copyOptions(this, shard);
126 return shard;
|
| InstalledInstrumentationsTest.java | 227 * Sets the shard index number of this test.
275 // shard these instrumentations by APKs, rather than by test methods.
405 InstalledInstrumentationsTest shard = new InstalledInstrumentationsTest(); local
407 OptionCopier.copyOptions(this, shard);
411 shard.mShards = 0;
412 shard.mShardIndex = shardIndex;
413 shard.mTotalShards = shardCount;
414 return shard;
|
| /external/tensorflow/tensorflow/contrib/factorization/python/ops/ |
| gmm_ops.py | 129 # lists are indexed by shard.
247 """Returns a list of Tensors with the matrix of assignments per shard."""
271 for shard_id, shard in enumerate(data):
272 self._num_examples = array_ops.shape(shard)[0]
273 shard = array_ops.expand_dims(shard, 0)
274 self._define_log_prob_operation(shard_id, shard)
277 self._define_partial_maximization_operation(shard_id, shard)
282 def _define_full_covariance_probs(self, shard_id, shard):
288 shard_id: id of the current shard
[all...] |
| /external/tensorflow/tensorflow/contrib/factorization/kernels/ |
| wals_solver_ops.cc | 144 typedef std::pair<int64, int64> Shard;
145 std::vector<Shard> shards;
189 // Lambda encapsulating the per-shard computation.
190 auto work = [&](const Shard& shard) {
212 CHECK_GE(shard.first, 0);
213 CHECK_LE(shard.second, perm.size());
214 CHECK_LE(shard.first, shard.second);
215 const int64 input_index = get_input_index(perm[shard.first])
[all...] |
| /external/skia/infra/bots/recipe_modules/swarming/ |
| api.py | 83 def _is_expired(self, shard):
87 shard.get('state') == self.State.EXPIRED or
88 shard.get('state') == 'EXPIRED')
90 def _is_timed_out(self, shard):
94 shard.get('state') == self.State.TIMED_OUT or
95 shard.get('state') == 'TIMED_OUT')
97 def _get_exit_code(self, shard):
98 if shard.get('exit_code'):
99 return shard.get('exit_code') # pragma: no cover
100 lst = shard.get('exit_codes', []
[all...] |
| /external/skqp/infra/bots/recipe_modules/swarming/ |
| api.py | 83 def _is_expired(self, shard):
87 shard.get('state') == self.State.EXPIRED or
88 shard.get('state') == 'EXPIRED')
90 def _is_timed_out(self, shard):
94 shard.get('state') == self.State.TIMED_OUT or
95 shard.get('state') == 'TIMED_OUT')
97 def _get_exit_code(self, shard):
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/ |
| rpc_interface_unittest.py | 67 returned_jobs = [(job['id'], job['name'], job['shard']['hostname'])
97 """Create a hostless job and ensure it's not assigned to a shard."""
107 """Ensure that hosts that don't belong to shard are determined."""
120 self.assertEqual(host2.shard, None)
134 self.assertEqual(host2.shard, None)
213 job2.shard = None
221 models.Test.objects.create(name='platform_BootPerfServer:shard',
228 models.Shard.DoesNotExist, models.Shard.objects.get, pk=shard1.id)
233 self.assertIsNone(job1.shard)
[all...] |
| rpc_interface.py | 200 DO NOT RUN THIS ON A SHARD!!! Deputies will hate you if you do!!!
224 # Make sure the label exists on the shard with the same id
226 # It is possible that the label is already in a shard because
229 # For example, we add a label L1 to a host in shard S1.
352 If this is called on the master, but the host is assigned to a shard, this
353 will call `modify_host_local` RPC to the responsible shard. This means if
356 When this is called on a shard, the shard just routes the RPC to the master
373 # between the master and a shard.
386 # In case the shard update fails mid-flight and the master-shard desync, w
[all...] |
| /external/tensorflow/tensorflow/python/ops/ |
| candidate_sampling_ops.py | 211 shard=0,
262 parameter (together with `shard`) indicates the number of partitions that
264 shard: A sampler can be used to sample from a subset of the original range
289 num_reserved_ids=num_reserved_ids, num_shards=num_shards, shard=shard,
|
| /tools/tradefederation/core/src/com/android/tradefed/invoker/ |
| ShardMasterResultForwarder.java | 77 // Track serials used in each shard.
105 // TODO: consider logging all shard final times.
107 "There was %s between the first and last shard ended.",
172 // Shard master does not need log saver.
176 * Copy the build info from the shard builds to the main build in the original invocation
180 * @param shardContexts the list of {@link IInvocationContext}s, one for each shard invocation.
184 for (IInvocationContext shard : shardContexts) {
185 for (String deviceName : shard.getDeviceConfigNames()) {
186 IBuildInfo shardBuild = shard.getBuildInfo(deviceName);
195 "Found a device '%s' in shard configuration but not in parent configuration."
[all...] |
| IInvocationExecution.java | 21 import com.android.tradefed.invoker.shard.IShardHelper;
99 * Attempt to shard the configuration into sub-configurations, to be re-scheduled to run on
102 * <p>If a shard count is greater than 1, it will simply create configs for each shard by
103 * setting shard indices and reschedule them. If a shard count is not set,it would fallback to
|
| /tools/tradefederation/core/src/com/android/tradefed/testtype/testdefs/ |
| XmlDefsTest.java | 116 description = "Shard this test into given number of separately runnable chunks.")
396 Log.w(LOG_TAG, "no tests to shard!");
404 XmlDefsTest shard = new XmlDefsTest(); local
405 shard.mTests = new LinkedList<InstrumentationTest>();
406 shardQueue.add(shard);
410 XmlDefsTest shard = (XmlDefsTest)shardQueue.poll(); local
411 shard.mTests.add(test);
412 shardQueue.add(shard);
|
| /external/autotest/contrib/ |
| task_runner.sh | 8 HELP="This is a script to bootstrap a localhost shard cluster for testing.\n\
10 SHARD_NAME: Name of the shard to register with master\n\
11 NUM_HOSTS_MASTER/SHARD: Number of hosts to add to the master/shard.\n\
12 MASTER/SHARD_BOARD: Boards to add to the master/shard\n\
16 # Invalidate (delete) the hosts/labels/shard instead of adding them.
25 # Number of hosts on master and shard. They will
32 # to the shard based on the board.
110 printf '\n\n%s following hosts to shard \n' $operation
116 printf '\n\n%s following hosts to shard \n' $operatio
[all...] |
| /art/compiler/utils/ |
| dedupe_set-inl.h | 55 class DedupeSet<InKey, StoreKey, Alloc, HashType, HashFunc, kShard>::Shard {
57 Shard(const Alloc& alloc, const std::string& lock_name)
64 ~Shard() {
217 shards_[i].reset(new Shard(alloc, oss.str()));
240 for (HashType shard = 0; shard < kShard; ++shard) {
241 shards_[shard]->UpdateStats(self, &stats);
|
| /external/boringssl/src/util/ |
| all_tests.go | 52 shard, numShards int
317 return fmt.Sprintf(" [shard %d/%d]", t.shard+1, t.numShards)
333 // Only shard the three GTest-based tests.
394 shard := t
395 shard.args = []string{shard.args[0], "--gtest_filter=" + strings.Join(shuffled[i:i+n], ":")}
396 shard.shard = len(shards)
397 shards = append(shards, shard)
[all...] |
