Searched refs:worker (Results 1 – 6 of 6) sorted by relevance
63 worker.stop(); in TearDown()68 StreamWorkerInvalidTest(TestStream* stream) : testing::TestWithParam<bool>(), worker(stream) {} in StreamWorkerInvalidTest()69 TestWorker worker; member in StreamWorkerInvalidTest73 EXPECT_FALSE(worker.hasWorkerCycleCalled()); in TEST_P()74 EXPECT_FALSE(worker.hasError()); in TEST_P()78 EXPECT_FALSE(worker.hasError()); in TEST_P()79 worker.pause(); in TEST_P()80 EXPECT_FALSE(worker.hasError()); in TEST_P()84 EXPECT_FALSE(worker.hasError()); in TEST_P()85 worker.resume(); in TEST_P()[all …]
33 WorkerThread worker(1 /*maxQueueSize*/); in TEST() local38 ASSERT_TRUE(worker.schedule(Callable::from([promise = std::move(promise)]() mutable { in TEST()48 WorkerThread worker(2 /*maxQueueSize*/); in TEST() local54 ASSERT_TRUE(worker.schedule(Callable::from([promise = std::move(promise)]() mutable { in TEST()66 ASSERT_TRUE(worker.schedule(Callable::from([] {}))); in TEST()67 ASSERT_TRUE(worker.schedule(Callable::from([] {}))); in TEST()69 EXPECT_FALSE(worker.schedule(Callable::from([] {}))); in TEST()74 WorkerThread worker(NUM_TASKS); in TEST() local82 worker.schedule(Callable::from([&mut, &results, i] { in TEST()91 worker.schedule(Callable::from([&mut, &cv, &finished] { in TEST()[all …]
26 FakeFingerprintEngine* engine, WorkerThread* worker) in Session() argument31 mWorker(worker), in Session()
48 FakeFingerprintEngine* engine, WorkerThread* worker);
32 libdrmresource/utils/worker.cpp \
755 * Changes the priority of the cpu worker threads for this context.