Searched refs:shard (Results 1 – 12 of 12) sorted by relevance
163 uptr shard; // started from 1. member170 uptr shard = (uptr)arg; in OnJoined() local171 num_joined[shard]++; in OnJoined()174 uptr shard = (uptr)arg; in OnStarted() local175 num_started[shard]++; in OnStarted()178 uptr shard = (uptr)arg; in OnCreated() local179 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 …]
822 size_t shard; member828 for (size_t i = p->shard; i < p->m->size(); i += p->num_shards) { in TwoLevelByteMapUserThread()846 p[i].shard = i; in TEST()
51 shard = int(options["--shard"])58 my_configs = filter(lambda x: x[1] % shards == shard, my_configs)
174 for (Shard shard : IsValidUtf8TestUtil.FOUR_BYTE_SHARDS) { in testShardsHaveExpectedRoundTrippables()175 actual += shard.expected; in testShardsHaveExpectedRoundTrippables()
188 for (int shard = 2; shard <= MAX_SHARDS; shard++) { in testConsistentHash_probabilities()190 assertTrue(map.get(shard) <= 1.2 * ITERS / shard + 20); in testConsistentHash_probabilities()
279 shard = []282 shard.append(test)284 return shard
383 shard = []386 shard.append(test)388 return shard
50 DEFINE_int32(shard, 0, "Which shard do I run?");
594 Note: This is test shard 1 of 2.
685 Note: This is test shard 1 of 2.
700 Note: This is test shard 2 of 2.
712 Note: This is test shard 2 of 2.