Searched refs:num_done (Results 1 – 5 of 5) sorted by relevance
| /external/grpc-grpc/test/core/gpr/ |
| D | mpscq_test.cc | 91 size_t num_done = 0; in test_mt() local
94 while (num_done != GPR_ARRAY_SIZE(thds)) { in test_mt()
102 if (tn->i == THREAD_ITERATIONS) num_done++; in test_mt()
116 size_t num_done; member
128 if (pa->num_done == pa->num_thds) { in pull_thread()
139 if (tn->i == THREAD_ITERATIONS) pa->num_done++; in pull_thread()
165 pa.num_done = 0; in test_mt_multipop()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | function_threadpool_test.cc | 224 std::atomic<int32> num_done(0); in TEST_F() local
227 tp1->Schedule([&h, &x1, &opts, &num_done, this]() { in TEST_F()
230 num_done.fetch_add(1); in TEST_F()
234 EXPECT_EQ(0, num_done.load()); in TEST_F()
244 EXPECT_EQ(4, num_done.load()); in TEST_F()
|
| D | direct_session_test.cc | 1562 std::atomic<int32> num_done(0); in TestSessionInterOpThreadsImpl() local
1565 [use_global_pools, &def, &options, &sessions, &sessions_mu, &num_done]( in TestSessionInterOpThreadsImpl()
1568 inter_op_pool, node, &num_done]() { in TestSessionInterOpThreadsImpl()
1592 num_done.fetch_add(1); in TestSessionInterOpThreadsImpl()
1615 num_done = 0; in TestSessionInterOpThreadsImpl()
1639 EXPECT_EQ(kUnblockedThreads, num_done.load()); in TestSessionInterOpThreadsImpl()
1649 EXPECT_EQ(kUnblockedThreads + kBlockedThreads + 1 + 1, num_done.load()); in TestSessionInterOpThreadsImpl()
|
| /external/toolchain-utils/crb/ |
| D | crb_driver.py | 130 def GetProgressBar(num_done, num_total): argument
131 ret = 'Done: %s%%' % int(100.0 * num_done / num_total)
135 num_done_chars = bar_length * num_done / num_total
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_locks.py | 975 num_done = sum(t.done() for t in [t3, t4])
976 self.assertEqual(num_done, 1)
|