Searched refs:shard (Results 1 - 25 of 69) sorted by relevance

123

/external/autotest/client/site_tests/graphics_dEQP/
H A Dgenerate_controlfiles.py8 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...]
/external/tensorflow/tensorflow/python/data/kernel_tests/
H A Dshard_dataset_op_test.py28 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(
[all...]
/external/autotest/cli/
H A Dshard.py5 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 action
[all...]
/external/compiler-rt/lib/sanitizer_common/tests/
H A Dsanitizer_thread_registry_test.cc163 uptr shard; // started from 1. member in struct:__sanitizer::__anon3838::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/
H A Drecord_yielder.cc73 std::vector<string> filenames; // File names given to this shard.
74 Notification done; // Notified when this shard is done.
132 // Shards files and use one thread to go through each shard.
136 Shard* shard = &shards[i]; local
137 shard->index = i;
139 shard->filenames.push_back(filenames[j]);
141 thread_->Schedule([this, shard]() { ShardLoop(shard); });
198 void RecordYielder::ShardLoop(Shard* shard) { argument
201 for (const string& filename : shard
[all...]
H A Dcandidate_sampler_ops.cc173 int64 shard; local
174 OP_REQUIRES_OK(context, context->GetAttr("shard", &shard));
179 num_shards, shard));
182 num_reserved_ids, num_shards, shard));
H A Dpopulation_count_op.cc102 auto shard = [input_ptr, output_ptr](int64 start, int64 limit) { local
119 shard_cost, shard);
/external/skia/infra/bots/recipe_modules/swarming/
H A Dapi.py83 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
[all...]
/external/skqp/infra/bots/recipe_modules/swarming/
H A Dapi.py83 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
[all...]
/external/tensorflow/tensorflow/core/util/
H A Dtensor_slice_reader.cc129 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...]
/external/tensorflow/tensorflow/python/ops/
H A Dcandidate_sampling_ops.py211 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,
/external/tensorflow/tensorflow/contrib/factorization/python/ops/
H A Dgmm_ops.py129 # 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/
H A Dwals_solver_ops.cc189 // 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]);
224 for (int64 p = shard.first; p < shard.second; ++p) {
226 // Check that all entries in the shard hav
[all...]
/external/autotest/frontend/afe/
H A Drpc_interface.py224 # 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 desyn
[all...]
H A Drpc_interface_unittest.py67 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',
233 self.assertIsNone(job1.shard)
420 host2.shard = shard1
441 host2.shard
[all...]
H A Drpc_utils.py734 @return: A map of shard hostname: list of hosts on the shard.
738 if host.shard:
739 shard_host_map[host.shard.hostname].append(host.hostname)
840 'The following hosts are on shard(s), please create '
841 'seperate jobs for hosts on each shard: %s ' %
849 # num_shards == 1 but number of hosts on shard is less
851 # one shard and the master.
938 Retrieves the shard with the given hostname from the database.
940 @param shard_hostname: Hostname of the shard t
[all...]
H A Dmodels.py454 # shard, just delete any existing user records that don't match
495 'shard'])
500 assert link == 'shard', 'Link %s should not be deserialized' % link
501 self.shard = Shard.deserialize(data)
517 shard = dbmodels.ForeignKey(Shard, blank=True, null=True) variable in class:Host
635 def assign_to_shard(cls, shard, known_ids):
636 """Assigns hosts to a shard.
638 For all labels that have been assigned to a shard, all hosts that
639 have at least one of the shard's labels are assigned to the shard
1541 shard = dbmodels.ForeignKey(Shard, blank=True, null=True) variable in class:Job
[all...]
/external/boringssl/src/util/
H A Dall_tests.go52 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...]
/external/tensorflow/tensorflow/contrib/tpu/python/tpu/
H A Dtpu_feed.py214 """Gets the shard dimension of each tuple element.
218 is the shard dimension of that tuple element or None if the
219 shard dimension has not been set.
263 number_of_shards: number of ways to shard the InfeedQueue.
301 determine the types and shapes of the corresponding shard. This method
302 depends on the shard dimension, and calling it freezes the shard policy.
307 and shape of the desired configuration of the corresponding shard.
327 # Transpose the inputs to make a list of shard shapes for each tuple
379 A list of Outputs corresponding to a shard o
[all...]
/external/autotest/contrib/
H A Dtask_runner.sh8 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' $operation
122 printf '\n\n%s shard \
[all...]
/external/autotest/scheduler/shard/
H A Dshard_client.py40 Autotest shard client
42 The shard client can be run as standalone service. It periodically polls the
46 A shard is set up (by a human) and pointed to the global AFE (cautotest).
47 On the shard, this script periodically makes so called heartbeat requests to the
50 1. Find the previously created (with atest) record for the shard. Shards are
58 3. Find labels that have been assigned to this shard.
81 2. monitor_db on the shard will pick up these jobs and schedule them on the
87 - the shard_id will be set back to the shard's id, so the record won't be
193 job_models.update(shard=None)
214 def shard(sel member in class:ShardClient
[all...]
H A Dshard_client_integration_tests.py17 from autotest_lib.scheduler.shard import shard_client
26 """Mock out global_config for shard client creation."""
84 # freshness, then make sure it has shard=None and an unset complete bit.
88 modified_hqe.job.shard == None)
90 # Make sure the job with a shard but without complete is still
95 # Make sure the job with a shard but without complete is not
H A Dsimple_heartbeat_client.py33 from autotest_lib.scheduler.shard import simple_heartbeat_server
/external/autotest/tko/
H A Dretrieve_logs.cgi59 shard = args['shard']
60 if shard:
69 # On Vms the shard name is set to the default gateway but the
102 arg = {'host': host, 'job_path': job_path, 'shard': is_shard}
/external/protobuf/java/core/src/test/java/com/google/protobuf/
H A DIsValidUtf8Test.java181 for (Shard shard : IsValidUtf8TestUtil.FOUR_BYTE_SHARDS) {
182 actual += shard.expected;

Completed in 2335 milliseconds

123