Home
last modified time | relevance | path

Searched refs:num_done (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc/test/core/gpr/
Dmpscq_test.cc91 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/
Dfunction_threadpool_test.cc228 std::atomic<int32> num_done(0); in TEST_F() local
231 tp1->Schedule([&h, &x1, &opts, &num_done, this]() { in TEST_F()
234 num_done.fetch_add(1); in TEST_F()
238 EXPECT_EQ(0, num_done.load()); in TEST_F()
248 EXPECT_EQ(4, num_done.load()); in TEST_F()
Ddirect_session_test.cc1985 std::atomic<int32> num_done(0); in TestSessionInterOpThreadsImpl() local
1988 [use_global_pools, &def, &options, &sessions, &sessions_mu, &num_done]( in TestSessionInterOpThreadsImpl()
1991 inter_op_pool, node, &num_done]() { in TestSessionInterOpThreadsImpl()
2015 num_done.fetch_add(1); in TestSessionInterOpThreadsImpl()
2038 num_done = 0; in TestSessionInterOpThreadsImpl()
2062 EXPECT_EQ(kUnblockedThreads, num_done.load()); in TestSessionInterOpThreadsImpl()
2072 EXPECT_EQ(kUnblockedThreads + kBlockedThreads + 1 + 1, num_done.load()); in TestSessionInterOpThreadsImpl()
/external/llvm-project/openmp/runtime/src/
Dkmp_dispatch.cpp2062 UT num_done; in __kmp_dispatch_next() local
2064 num_done = test_then_inc<ST>((volatile ST *)&sh->u.s.num_done); in __kmp_dispatch_next()
2072 KD_TRACE(10, (buff, gtid, sh->u.s.num_done)); in __kmp_dispatch_next()
2080 if ((ST)num_done == th->th.th_team_nproc - 1) { in __kmp_dispatch_next()
2105 sh->u.s.num_done = 0; in __kmp_dispatch_next()
Dkmp_dispatch.h159 volatile UT num_done; member
Dkmp_csupport.cpp4173 kmp_int32 num_done; in __kmpc_doacross_fini() local
4183 num_done = KMP_TEST_THEN_INC32((kmp_int32 *)pr_buf->th_doacross_info[1]) + 1; in __kmpc_doacross_fini()
4184 if (num_done == th->th.th_team_nproc) { in __kmpc_doacross_fini()
4191 KMP_DEBUG_ASSERT(num_done == sh_buf->doacross_num_done); in __kmpc_doacross_fini()
Dkmp.h1769 volatile kmp_uint32 num_done; member
1779 volatile kmp_uint64 num_done; member
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_locks.py965 num_done = sum(t.done() for t in [t3, t4])
966 self.assertEqual(num_done, 1)