Lines Matching refs:measure
921 ThreadAssertWait(zx_handle_t object, zx_signals_t trigger, ConcurrencyMeasure* measure)
922 : TestWait(object, trigger), measure_(measure) {}
936 ThreadAssertTask(ConcurrencyMeasure* measure)
937 : measure_(measure) {}
950 ThreadAssertReceiver(ConcurrencyMeasure* measure)
951 : measure_(measure) {}
973 ConcurrencyMeasure* measure)
974 : TestException(task, options), measure_(measure) {}
1060 ConcurrencyMeasure measure(num_items);
1068 items[i] = new ThreadAssertWait(event.get(), ZX_USER_SIGNAL_0, &measure);
1076 EXPECT_EQ(num_items, measure.count(), "item count");
1086 EXPECT_NE(1u, measure.max_threads(), "waits handled concurrently");
1104 ConcurrencyMeasure measure(num_items);
1110 items[i] = new ThreadAssertTask(&measure);
1118 EXPECT_EQ(num_items, measure.count(), "item count");
1127 EXPECT_EQ(1u, measure.max_threads(), "tasks handled sequentially");
1145 ConcurrencyMeasure measure(num_items);
1148 ThreadAssertReceiver receiver(&measure);
1157 EXPECT_EQ(num_items, measure.count(), "item count");
1162 EXPECT_NE(1u, measure.max_threads(), "packets handled concurrently");
1177 ConcurrencyMeasure measure(num_items);
1181 ThreadAssertException receiver(zx_process_self(), 0, &measure);
1197 // will continue until |measure| receives |num_items|.
1213 EXPECT_EQ(num_items, measure.count());
1222 EXPECT_NE(1u, measure.max_threads());