Lines Matching refs:measure
1064 ThreadAssertWait(zx_handle_t object, zx_signals_t trigger, ConcurrencyMeasure* measure) in ThreadAssertWait() argument
1065 : TestWait(object, trigger), measure_(measure) {} in ThreadAssertWait()
1079 ThreadAssertTask(ConcurrencyMeasure* measure) in ThreadAssertTask() argument
1080 : measure_(measure) {} in ThreadAssertTask()
1093 ThreadAssertReceiver(ConcurrencyMeasure* measure) in ThreadAssertReceiver() argument
1094 : measure_(measure) {} in ThreadAssertReceiver()
1116 ConcurrencyMeasure* measure) in ThreadAssertException() argument
1117 : TestException(dispatcher, task, options), measure_(measure) {} in ThreadAssertException()
1203 ConcurrencyMeasure measure(num_items); in threads_waits_run_concurrently_test() local
1211 items[i] = new ThreadAssertWait(event.get(), ZX_USER_SIGNAL_0, &measure); in threads_waits_run_concurrently_test()
1219 EXPECT_EQ(num_items, measure.count(), "item count"); in threads_waits_run_concurrently_test()
1229 EXPECT_NE(1u, measure.max_threads(), "waits handled concurrently"); in threads_waits_run_concurrently_test()
1247 ConcurrencyMeasure measure(num_items); in threads_tasks_run_sequentially_test() local
1253 items[i] = new ThreadAssertTask(&measure); in threads_tasks_run_sequentially_test()
1261 EXPECT_EQ(num_items, measure.count(), "item count"); in threads_tasks_run_sequentially_test()
1270 EXPECT_EQ(1u, measure.max_threads(), "tasks handled sequentially"); in threads_tasks_run_sequentially_test()
1288 ConcurrencyMeasure measure(num_items); in threads_receivers_run_concurrently_test() local
1291 ThreadAssertReceiver receiver(&measure); in threads_receivers_run_concurrently_test()
1300 EXPECT_EQ(num_items, measure.count(), "item count"); in threads_receivers_run_concurrently_test()
1305 EXPECT_NE(1u, measure.max_threads(), "packets handled concurrently"); in threads_receivers_run_concurrently_test()
1321 ConcurrencyMeasure measure(num_items); in threads_exceptions_run_concurrently_test() local
1324 &measure); in threads_exceptions_run_concurrently_test()
1355 EXPECT_EQ(num_items, measure.count()); in threads_exceptions_run_concurrently_test()
1366 EXPECT_NE(1u, measure.max_threads()); in threads_exceptions_run_concurrently_test()