Lines Matching refs:id
2378 int id; member
2384 int id = t->id; in MTThreadBody() local
2387 fprintf(stderr, "... starting thread %d\n", id); in MTThreadBody()
2388 Random rnd(1000 + id); in MTThreadBody()
2391 t->state->counter[id].store(counter, std::memory_order_release); in MTThreadBody()
2408 snprintf(valbuf, sizeof(valbuf), "%d.%d.%d.%d.%-1000d", key, id, in MTThreadBody()
2416 snprintf(valbuf, sizeof(valbuf), "%d.%d.%d.%d.%-1000d", key, id, in MTThreadBody()
2485 t->state->thread_done[id].store(true, std::memory_order_release); in MTThreadBody()
2486 fprintf(stderr, "... stopping thread %d after %d ops\n", id, int(counter)); in MTThreadBody()
2525 for (int id = 0; id < kNumThreads; id++) { in TEST_P() local
2526 mt.counter[id].store(0, std::memory_order_release); in TEST_P()
2527 mt.thread_done[id].store(false, std::memory_order_release); in TEST_P()
2532 for (int id = 0; id < kNumThreads; id++) { in TEST_P() local
2533 thread[id].state = &mt; in TEST_P()
2534 thread[id].id = id; in TEST_P()
2535 thread[id].multiget_batched = multiget_batched_; in TEST_P()
2536 env_->StartThread(MTThreadBody, &thread[id]); in TEST_P()
2544 for (int id = 0; id < kNumThreads; id++) { in TEST_P() local
2545 while (mt.thread_done[id].load(std::memory_order_acquire) == false) { in TEST_P()
2569 int id; member
2575 int id = t->id; in GCThreadBody() local
2580 std::string kv(ToString(i + id * kGCNumKeys)); in GCThreadBody()
2604 for (int id = 0; id < kGCNumThreads; id++) { in TEST_F() local
2605 thread[id].id = id; in TEST_F()
2606 thread[id].db = db_; in TEST_F()
2607 thread[id].done = false; in TEST_F()
2608 env_->StartThread(GCThreadBody, &thread[id]); in TEST_F()