/external/autotest/client/site_tests/graphics_dEQP/ |
H A D | 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...] |
/external/tensorflow/tensorflow/python/data/kernel_tests/ |
H A D | 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( [all...] |
/external/autotest/cli/ |
H A D | 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 action [all...] |
/external/compiler-rt/lib/sanitizer_common/tests/ |
H A D | sanitizer_thread_registry_test.cc | 163 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 D | record_yielder.cc | 73 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 D | candidate_sampler_ops.cc | 173 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 D | population_count_op.cc | 102 auto shard = [input_ptr, output_ptr](int64 start, int64 limit) { local 119 shard_cost, shard);
|
/external/skia/infra/bots/recipe_modules/swarming/ |
H A D | 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 [all...] |
/external/skqp/infra/bots/recipe_modules/swarming/ |
H A D | 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 [all...] |
/external/tensorflow/tensorflow/core/util/ |
H A D | 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...] |
/external/tensorflow/tensorflow/python/ops/ |
H A D | 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,
|
/external/tensorflow/tensorflow/contrib/factorization/python/ops/ |
H A D | 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/ |
H A D | wals_solver_ops.cc | 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]); 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 D | rpc_interface.py | 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 desyn [all...] |
H A D | 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', 233 self.assertIsNone(job1.shard) 420 host2.shard = shard1 441 host2.shard [all...] |
H A D | rpc_utils.py | 734 @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 D | models.py | 454 # 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 D | 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...] |
/external/tensorflow/tensorflow/contrib/tpu/python/tpu/ |
H A D | tpu_feed.py | 214 """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 D | 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' $operation 122 printf '\n\n%s shard \ [all...] |
/external/autotest/scheduler/shard/ |
H A D | shard_client.py | 40 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 D | shard_client_integration_tests.py | 17 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 D | simple_heartbeat_client.py | 33 from autotest_lib.scheduler.shard import simple_heartbeat_server
|
/external/autotest/tko/ |
H A D | retrieve_logs.cgi | 59 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 D | IsValidUtf8Test.java | 181 for (Shard shard : IsValidUtf8TestUtil.FOUR_BYTE_SHARDS) { 182 actual += shard.expected;
|