| /tools/tradefederation/core/prod-tests/src/com/android/ota/tests/ |
| OtaStabilityTestTest.java | 32 * shards.
38 Collection<IRemoteTest> shards = test.split(); local
39 assertEquals(5, shards.size());
40 for (IRemoteTest shardTest : shards) {
47 * Test {@link OtaStabilityTest#split()}, where there are more iterations than shards.
53 Collection<IRemoteTest> shards = test.split(); local
54 assertEquals(5, shards.size());
55 for (IRemoteTest shardTest : shards) {
68 Collection<IRemoteTest> shards = test.split(); local
69 assertEquals(3, shards.size())
[all...] |
| /external/autotest/client/site_tests/graphics_dEQP/ |
| generate_controlfiles.py | 7 3) Decomposing a test into shards. Ideally shard_count is chosen such that
18 Test = namedtuple('Test', 'filter, suite, shards, time, hasty, tag, test_file, perf_failure_description')
46 Test('bvt', Suite.bvtcq, shards=1, hasty=False, time='FAST', tag='bvt', test_file=BVT_MASTER_FILE, perf_failure_description='Failures_BVT'),
47 Test('dEQP-GLES2-master', Suite.daily, shards=1, hasty=False, time='LENGTHY', tag='gles2-master', test_file=GLES2_MASTER_FILE, perf_failure_description='Failures_GLES2'),
48 Test('dEQP-GLES2-master', Suite.bvtpb, shards=10, hasty=True, time='FAST', tag='gles2-master', test_file=GLES2_MASTER_FILE, perf_failure_description=None),
52 Test('dEQP-GLES2.stress', Suite.daily, shards=1, hasty=False, time='LONG', tag='stress', test_file=None, perf_failure_description=None),
53 Test('dEQP-GLES3.accuracy', Suite.none, shards=1, hasty=False, time='FAST', tag=None, test_file=None, perf_failure_description=None),
54 Test('dEQP-GLES3-master', Suite.daily, shards=1, hasty=False, time='LENGTHY', tag='gles3-master', test_file=GLES3_MASTER_FILE, perf_failure_description='Failures_GLES3'),
55 Test('dEQP-GLES3-master', Suite.bvtpb, shards=10, hasty=True, time='FAST', tag='gles3-master', test_file=GLES3_MASTER_FILE, perf_failure_description=None),
56 Test('dEQP-GLES3.performance', Suite.none, shards=1, hasty=False, time='LONG', tag=None, test_file=None, perf_failure_ (…)
[all...] |
| /external/skia/infra/bots/recipe_modules/swarming/ |
| test_api.py | 22 self, shards=1, failure=False, internal_failure=False):
24 'shards': [
54 } for i in xrange(shards)
|
| /external/skqp/infra/bots/recipe_modules/swarming/ |
| test_api.py | 22 self, shards=1, failure=False, internal_failure=False):
24 'shards': [
54 } for i in xrange(shards)
|
| /test/framework/harnesses/host_controller/campaigns/ |
| vts.py | 23 "shards",
109 shards = int(kwargs["shards"])
116 if shards > 1:
118 test_command = "test --keep-result -- %s --shards %d %s" % (
119 test_name, shards, param)
120 if shards <= len(serials):
121 for shard_index in range(shards):
132 result.append("test --keep-result -- %s --serial %s --shards %s %s" %
133 (test_name, ",".join(serials), shards, param)
[all...] |
| /system/timezone/tzlookup_generator/src/test/java/com/android/libcore/timezone/tzlookup/zonetree/ |
| ZoneOffsetPeriodTest.java | 163 ZoneOffsetPeriod[] shards = ZoneOffsetPeriod.splitAtTime( local
167 assertEquals(startInstant, shards[0].getStartInstant());
168 assertEquals(partitionInstant, shards[0].getEndInstant());
169 assertEquals(honoluluRawOffset, shards[0].getRawOffsetMillis());
170 assertEquals(honoluluDstOffset, shards[0].getDstOffsetMillis());
171 assertEquals(honoluluOldName, shards[0].getName());
173 assertEquals(partitionInstant, shards[1].getStartInstant());
174 assertEquals(endInstant, shards[1].getEndInstant());
175 assertEquals(honoluluRawOffset, shards[1].getRawOffsetMillis());
176 assertEquals(honoluluDstOffset, shards[1].getDstOffsetMillis())
[all...] |
| /tools/tradefederation/core/src/com/android/tradefed/testtype/ |
| StubTest.java | 39 name = "num-shards",
102 List<IRemoteTest> shards = new ArrayList<IRemoteTest>(mNumShards); local
104 shards.add(new StubTest());
107 LogLevel.INFO, "splitting into %d shards", mNumShards);
108 return shards;
|
| /external/skia/tools/lua/ |
| ngrams_aggregate.lua | 3 -- Get the data from all shards.
|
| /external/skqp/tools/lua/ |
| ngrams_aggregate.lua | 3 -- Get the data from all shards.
|
| /external/autotest/cli/ |
| shard.py | 6 manage shards in Autotest.
11 list: lists shards with label
27 msg_items = '<shards>'
35 attribute_name='shards',
40 return self.shards
54 if self.shards:
55 filters['hostname__in'] = self.shards
61 """Prints a warning if one label is assigned to multiple shards.
72 'multiple shards.\n'
99 req_items='shards')
[all...] |
| /tools/tradefederation/core/src/com/android/tradefed/invoker/shard/ |
| StrictShardHelper.java | 40 /** Sharding strategy to create strict shards that do not report together, */
151 * implementation attempts to balance the number of IRemoteTest per shards as much as possible
162 List<List<IRemoteTest>> shards = new ArrayList<>(); local
176 // Based of the parameters, distribute the tests accross shards.
177 shards = balancedDistrib(fullList, shardCount, numPerShard, needsCorrection);
179 topBottom(shards, shardCount);
180 return shards;
185 List<List<IRemoteTest>> shards = new ArrayList<>(); local
189 // Generate all the shards
193 // Return empty list when we don't have enough tests for all the shards
[all...] |
| ShardHelper.java | 49 /** Helper class that handles creating the shards and scheduling them for an invocation. */
92 // create the TestInvocationListener that will collect results from all the shards,
94 // once all shards complete
227 Collection<IRemoteTest> shards = null; local
230 shards = shardableTest.split(shardCount);
232 shards = shardableTest.split();
234 if (shards != null) {
235 shardableTests.addAll(shards);
247 * shards. Currently excludes {@link IShardableListener}s.
|
| /prebuilts/tools/linux-x86_64/kythe/proto/ |
| storage.proto | 48 // results when the store is being written to. Shards are indexed from 0.
200 int64 shards = 2;
212 int64 shards = 2;
|
| /test/vti/test_serving/gae/webapp/src/endpoint/ |
| schedule_info.py | 71 schedule.shards = request.shards
127 schedule.shards = request.shards
|
| /external/autotest/server/ |
| system_utils.py | 32 """Get a list of shards from server database or global config.
38 shards = config.get_config_value(
39 'SERVER', 'shards', default='')
40 return [hostname.strip() for hostname in shards.split(',')]
|
| /external/tensorflow/tensorflow/contrib/factorization/kernels/ |
| wals_solver_ops.cc | 145 std::vector<Shard> shards; variable
156 // These are the shards of work that can be processed in parallel
166 shards.emplace_back(start, end);
170 CHECK_LE(shards.size(), num_nonzero_elements);
171 CHECK_GT(shards.size(), 0);
188 BlockingCounter counter(shards.size());
254 for (size_t i = 1; i < shards.size(); ++i) {
255 worker_threads.workers->Schedule(std::bind(work, shards[i]));
258 work(shards[0]); variable
|
| /tools/tradefederation/core/prod-tests/src/com/android/stability/tests/ |
| RebootStressTest.java | 58 @Option(name = "shards", description = "Optional number of shards to split test into. " +
59 "Iterations will be split evenly among shards.", importance = Importance.IF_UNSET)
114 * Set the number of shards
116 void setShards(int shards) {
117 mShards = shards;
161 Collection<IRemoteTest> shards = new ArrayList<IRemoteTest>(mShards); local
171 // attempt to divide iterations evenly among shards with no remainder
176 shards.add(testShard);
179 return shards;
[all...] |
| /external/turbine/javatests/com/google/turbine/lower/ |
| LowerIntegrationTest.java | 319 int shards = Integer.parseInt(testTotalShards); local
320 return Lists.partition(tests, (tests.size() + shards - 1) / shards).get(index);
|
| /external/autotest/site_utils/ |
| rpc_flight_recorder.py | 48 def update_shards(shards, shards_lock, period=600, stop_event=None):
49 """Updates dict of shards
51 @param shards: list of shards to be updated
52 @param shards_lock: shared lock for accessing shards
59 logging.debug('Updating Shards')
63 current_shards = set(shards)
69 shards.remove(s)
72 shards.extend(add_shards)
86 def poll_rpc_servers(servers, servers_lock, shards=None, period=60
[all...] |
| /test/suite_harness/common/host-side/tradefed/src/com/android/compatibility/common/tradefed/command/ |
| CompatibilityConsole.java | 126 int shards = Integer.parseInt(arg);
127 if (shards <= 1) {
128 printLine("number of shards should be more than 1");
131 splitModules(shards);
198 "\t\t\t--shard-count <shards>: Shards a run into the given number of independent " +
254 private void splitModules(int shards) {
303 for (int i = 0; i < shards; i++) {
308 long[] shardTimes = new long[shards];
309 // go through the sorted list, distribute modules into shards in zig-zag pattern to ge
[all...] |
| /external/tensorflow/tensorflow/core/kernels/ |
| record_yielder.cc | 132 // Shards files and use one thread to go through each shard.
134 std::vector<Shard> shards(N);
136 Shard* shard = &shards[i];
144 shards[i].done.WaitForNotification();
145 s.Update(shards[i].status);
|
| /test/suite_harness/common/host-side/tradefed/src/com/android/compatibility/common/tradefed/testtype/ |
| IModuleRepo.java | 40 void initialize(int shards, Integer shardIndex, File testsDir, Set<IAbi> abis,
54 * @return the number of shards this repo is initialized for.
|
| /test/vti/test_serving/gae/webapp/src/scheduler/ |
| periodic.py | 136 new_job.shards = schedule.shards
191 model.JobModel.shards == schedule.shards,
297 self.logger.Println("- len(devices) %s >= shards %s ?" %
299 schedule.shards))
300 if len(available_devices[host]) >= schedule.shards:
303 available_devices[host])[:schedule.shards]
|
| /external/boringssl/src/util/ |
| all_tests.go | 388 var shards []test
396 shard.shard = len(shards)
397 shards = append(shards, shard)
400 for i := range shards {
401 shards[i].numShards = len(shards)
404 return shards, nil
437 shards, err := test.getGTestShards()
442 for _, shard := range shards {
[all...] |
| /external/guava/guava-tests/test/com/google/common/hash/ |
| HashingTest.java | 166 for (int shards = 1; shards <= 100000; shards++) {
167 int b = Hashing.consistentHash(hashCode, shards);
169 assertEquals(shards - 1, b);
189 for (int shards = 2; shards <= MAX_SHARDS; shards++) {
190 int chosen = Hashing.consistentHash(h, shards);
192 map.incrementAndGet(shards);
[all...] |
