• Home
  • Raw
  • Download

Lines Matching refs:task_runner

36   UnixTaskRunner task_runner;  member in perfetto::base::__anonc7328b3f0111::TaskRunnerTest
40 auto& task_runner = this->task_runner; in TEST_F() local
42 task_runner.PostTask([&counter] { counter = (counter << 4) | 1; }); in TEST_F()
43 task_runner.PostTask([&counter] { counter = (counter << 4) | 2; }); in TEST_F()
44 task_runner.PostTask([&counter] { counter = (counter << 4) | 3; }); in TEST_F()
45 task_runner.PostTask([&counter] { counter = (counter << 4) | 4; }); in TEST_F()
46 task_runner.PostTask([&task_runner] { task_runner.Quit(); }); in TEST_F()
47 task_runner.Run(); in TEST_F()
52 auto& task_runner = this->task_runner; in TEST_F() local
54 task_runner.PostDelayedTask([&counter] { counter = (counter << 4) | 1; }, 5); in TEST_F()
55 task_runner.PostDelayedTask([&counter] { counter = (counter << 4) | 2; }, 10); in TEST_F()
56 task_runner.PostDelayedTask([&counter] { counter = (counter << 4) | 3; }, 15); in TEST_F()
57 task_runner.PostDelayedTask([&counter] { counter = (counter << 4) | 4; }, 15); in TEST_F()
58 task_runner.PostDelayedTask([&task_runner] { task_runner.Quit(); }, 20); in TEST_F()
59 task_runner.Run(); in TEST_F()
64 auto& task_runner = this->task_runner; in TEST_F() local
65 task_runner.PostTask([&task_runner] { in TEST_F()
66 task_runner.PostTask([&task_runner] { task_runner.Quit(); }); in TEST_F()
68 task_runner.Run(); in TEST_F()
72 auto& task_runner = this->task_runner; in TEST_F() local
73 task_runner.PostTask([&task_runner] { in TEST_F()
74 task_runner.PostDelayedTask([&task_runner] { task_runner.Quit(); }, 10); in TEST_F()
76 task_runner.Run(); in TEST_F()
80 auto& task_runner = this->task_runner; in TEST_F() local
83 std::thread thread([&task_runner, &counter, &thread_checker] { in TEST_F()
84 task_runner.PostTask([&thread_checker] { in TEST_F()
87 task_runner.PostTask([&counter] { counter = (counter << 4) | 1; }); in TEST_F()
88 task_runner.PostTask([&counter] { counter = (counter << 4) | 2; }); in TEST_F()
89 task_runner.PostTask([&counter] { counter = (counter << 4) | 3; }); in TEST_F()
90 task_runner.PostTask([&counter] { counter = (counter << 4) | 4; }); in TEST_F()
91 task_runner.PostTask([&task_runner] { task_runner.Quit(); }); in TEST_F()
93 task_runner.Run(); in TEST_F()
99 auto& task_runner = this->task_runner; in TEST_F() local
100 std::thread thread([&task_runner] { in TEST_F()
101 task_runner.PostDelayedTask([&task_runner] { task_runner.Quit(); }, 10); in TEST_F()
103 task_runner.Run(); in TEST_F()
108 auto& task_runner = this->task_runner; in TEST_F() local
110 task_runner.AddFileDescriptorWatch(evt.fd(), in TEST_F()
111 [&task_runner] { task_runner.Quit(); }); in TEST_F()
113 task_runner.Run(); in TEST_F()
117 auto& task_runner = this->task_runner; in TEST_F() local
122 task_runner.AddFileDescriptorWatch(evt.fd(), in TEST_F()
124 task_runner.RemoveFileDescriptorWatch(evt.fd()); in TEST_F()
125 task_runner.PostDelayedTask([&task_runner] { task_runner.Quit(); }, 10); in TEST_F()
126 task_runner.Run(); in TEST_F()
132 auto& task_runner = this->task_runner; in TEST_F() local
137 task_runner.PostTask([&task_runner, &evt] { in TEST_F()
138 task_runner.RemoveFileDescriptorWatch(evt.fd()); in TEST_F()
140 task_runner.AddFileDescriptorWatch(evt.fd(), in TEST_F()
142 task_runner.PostDelayedTask([&task_runner] { task_runner.Quit(); }, 10); in TEST_F()
143 task_runner.Run(); in TEST_F()
149 auto& task_runner = this->task_runner; in TEST_F() local
154 task_runner.AddFileDescriptorWatch(evt.fd(), [&task_runner, &evt, &evt2] { in TEST_F()
156 task_runner.AddFileDescriptorWatch(evt2.fd(), in TEST_F()
157 [&task_runner] { task_runner.Quit(); }); in TEST_F()
159 task_runner.Run(); in TEST_F()
163 auto& task_runner = this->task_runner; in TEST_F() local
169 task_runner.AddFileDescriptorWatch(evt.fd(), [&task_runner, &evt, &evt2] { in TEST_F()
172 task_runner.RemoveFileDescriptorWatch(evt2.fd()); in TEST_F()
174 task_runner.AddFileDescriptorWatch(evt2.fd(), in TEST_F()
176 task_runner.PostDelayedTask([&task_runner] { task_runner.Quit(); }, 10); in TEST_F()
177 task_runner.Run(); in TEST_F()
183 auto& task_runner = this->task_runner; in TEST_F() local
189 task_runner.AddFileDescriptorWatch(evt.fd(), [&task_runner, &evt, &evt2] { in TEST_F()
192 task_runner.RemoveFileDescriptorWatch(evt2.fd()); in TEST_F()
193 task_runner.AddFileDescriptorWatch(evt2.fd(), in TEST_F()
194 [&task_runner] { task_runner.Quit(); }); in TEST_F()
196 task_runner.AddFileDescriptorWatch(evt2.fd(), in TEST_F()
198 task_runner.Run(); in TEST_F()
204 auto& task_runner = this->task_runner; in TEST_F() local
208 std::thread thread([&task_runner, &evt] { in TEST_F()
209 task_runner.AddFileDescriptorWatch(evt.fd(), in TEST_F()
210 [&task_runner] { task_runner.Quit(); }); in TEST_F()
212 task_runner.Run(); in TEST_F()
217 auto& task_runner = this->task_runner; in TEST_F() local
222 task_runner.AddFileDescriptorWatch( in TEST_F()
223 evt.fd(), [&task_runner, &evt, &event_count] { in TEST_F()
226 task_runner.Quit(); in TEST_F()
230 task_runner.PostTask([&evt] { evt.Notify(); }); in TEST_F()
232 task_runner.Run(); in TEST_F()
238 auto& task_runner = this->task_runner; in TEST_F() local
240 task_runner.PostDelayedTask([] {}, 0); in TEST_F()
241 task_runner.PostDelayedTask([&task_runner] { task_runner.Quit(); }, 10); in TEST_F()
242 task_runner.Run(); in TEST_F()
246 auto& task_runner = this->task_runner; in TEST_F() local
248 task_runner.PostTask([&task_runner, &counter] { in TEST_F()
250 task_runner.Quit(); in TEST_F()
252 task_runner.Run(); in TEST_F()
253 task_runner.PostTask([&task_runner, &counter] { in TEST_F()
255 task_runner.Quit(); in TEST_F()
257 task_runner.Run(); in TEST_F()
261 void RepeatingTask(UnixTaskRunner* task_runner) { in RepeatingTask() argument
262 task_runner->PostTask(std::bind(&RepeatingTask, task_runner)); in RepeatingTask()
266 auto& task_runner = this->task_runner; in TEST_F() local
270 task_runner.PostTask(std::bind(&RepeatingTask, &task_runner)); in TEST_F()
271 task_runner.AddFileDescriptorWatch(evt.fd(), in TEST_F()
272 [&task_runner] { task_runner.Quit(); }); in TEST_F()
273 task_runner.Run(); in TEST_F()
276 void CountdownTask(UnixTaskRunner* task_runner, int* counter) { in CountdownTask() argument
278 task_runner->Quit(); in CountdownTask()
281 task_runner->PostDelayedTask(std::bind(&CountdownTask, task_runner, counter), in CountdownTask()
286 auto& task_runner = this->task_runner; in TEST_F() local
292 task_runner.AddFileDescriptorWatch(evt.fd(), [&evt, &watch_called] { in TEST_F()
297 task_runner.PostTask(std::bind(&CountdownTask, &task_runner, &counter)); in TEST_F()
298 task_runner.Run(); in TEST_F()
302 auto& task_runner = this->task_runner; in TEST_F() local
308 task_runner.AddFileDescriptorWatch(evt.fd(), in TEST_F()
309 [&task_runner] { task_runner.Quit(); }); in TEST_F()
311 std::thread thread([&task_runner, &evt] { in TEST_F()
312 task_runner.RemoveFileDescriptorWatch(evt.fd()); in TEST_F()
313 task_runner.AddFileDescriptorWatch(evt.fd(), in TEST_F()
314 [&task_runner] { task_runner.Quit(); }); in TEST_F()
317 task_runner.Run(); in TEST_F()
322 auto& task_runner = this->task_runner; in TEST_F() local
323 task_runner.PostTask( in TEST_F()
324 [&task_runner] { EXPECT_FALSE(task_runner.IsIdleForTesting()); }); in TEST_F()
325 task_runner.PostTask([&task_runner] { in TEST_F()
326 EXPECT_TRUE(task_runner.IsIdleForTesting()); in TEST_F()
327 task_runner.Quit(); in TEST_F()
329 task_runner.Run(); in TEST_F()
333 auto& main_tr = this->task_runner; in TEST_F()
351 auto& task_runner = this->task_runner; in TEST_F() local
357 task_runner.AddFileDescriptorWatch(e.fd(), [&] { in TEST_F()
360 task_runner.Quit(); in TEST_F()
365 task_runner.Run(); in TEST_F()
380 auto& task_runner = this->task_runner; in TEST_F() local
383 task_runner.AddFileDescriptorWatch(pipe.rd.get(), in TEST_F()
384 [&task_runner] { task_runner.Quit(); }); in TEST_F()
385 task_runner.Run(); in TEST_F()