/external/libchrome/base/files/ |
D | file_descriptor_watcher_posix_unittest.cc | 174 RunLoop run_loop; in TEST_P() local 176 .WillOnce(testing::Invoke(&run_loop, &RunLoop::Quit)); in TEST_P() 177 run_loop.Run(); in TEST_P() 186 RunLoop run_loop; in TEST_P() local 188 .WillOnce(testing::Invoke([this, &run_loop]() { in TEST_P() 190 run_loop.Quit(); in TEST_P() 192 run_loop.Run(); in TEST_P() 206 RunLoop run_loop; in TEST_P() local 209 .WillOnce(testing::Invoke([this, &run_loop]() { in TEST_P() 211 run_loop.Quit(); in TEST_P() [all …]
|
/external/libchrome/mojo/public/cpp/bindings/tests/ |
D | binding_unittest.cc | 76 base::RunLoop run_loop; in TEST_P() local 78 SetFlagAndRunClosure(&called, run_loop.QuitClosure())); in TEST_P() 84 run_loop.Run(); in TEST_P() 94 base::RunLoop run_loop; in TEST_P() local 96 SetFlagAndRunClosure(&encountered_error, run_loop.QuitClosure())); in TEST_P() 110 run_loop.Run(); in TEST_P() 130 base::RunLoop run_loop; in TEST_P() local 132 SetFlagAndRunClosure(&called, run_loop.QuitClosure())); in TEST_P() 135 run_loop.Run(); in TEST_P() 193 base::RunLoop run_loop; in TEST_P() local [all …]
|
D | interface_ptr_unittest.cc | 237 base::RunLoop run_loop; in RunTest() local 238 done_closure_ = run_loop.QuitClosure(); in RunTest() 243 run_loop.Run(); in RunTest() 336 base::RunLoop run_loop; in TEST_P() local 337 calculator_ui.Add(2.0, run_loop.QuitClosure()); in TEST_P() 338 run_loop.Run(); in TEST_P() 364 base::RunLoop run_loop; in TEST_P() local 367 run_loop.QuitClosure())); in TEST_P() 386 run_loop.Run(); in TEST_P() 404 base::RunLoop run_loop; in TEST_P() local [all …]
|
D | binding_callback_unittest.cc | 150 base::RunLoop run_loop, run_loop2; in TEST_F() local 151 server_impl.set_closure(run_loop.QuitClosure()); in TEST_F() 156 run_loop.Run(); in TEST_F() 199 base::RunLoop run_loop; in TEST_F() local 204 interface_ptr_.set_connection_error_handler(run_loop.QuitClosure()); in TEST_F() 237 run_loop.Run(); in TEST_F() 256 base::RunLoop run_loop; in TEST_F() local 257 server_impl.set_closure(run_loop.QuitClosure()); in TEST_F() 261 run_loop.Run(); in TEST_F() 287 base::RunLoop run_loop; in TEST_F() local [all …]
|
D | connector_unittest.cc | 125 base::RunLoop run_loop; in TEST_F() local 126 MessageAccumulator accumulator(run_loop.QuitClosure()); in TEST_F() 129 run_loop.Run(); in TEST_F() 172 base::RunLoop run_loop; in TEST_F() local 173 MessageAccumulator accumulator(run_loop.QuitClosure()); in TEST_F() 180 run_loop.Run(); in TEST_F() 209 base::RunLoop run_loop; in TEST_F() local 210 accumulator.set_closure(run_loop.QuitClosure()); in TEST_F() 211 run_loop.Run(); in TEST_F() 274 base::RunLoop run_loop; in TEST_F() local [all …]
|
D | request_response_unittest.cc | 98 base::RunLoop run_loop; in TEST_P() local 100 base::Bind(&RecordString, &buf, run_loop.QuitClosure())); in TEST_P() 102 run_loop.Run(); in TEST_P() 112 base::RunLoop run_loop; in TEST_P() local 114 run_loop.QuitClosure())); in TEST_P() 116 run_loop.Run(); in TEST_P() 126 base::RunLoop run_loop; in TEST_P() local 129 base::Bind(&WriteToMessagePipe, "hello", run_loop.QuitClosure())); in TEST_P() 131 run_loop.Run(); in TEST_P() 144 base::RunLoop run_loop; in TEST_P() local [all …]
|
D | associated_interface_unittest.cc | 147 void QuitRunLoop(base::RunLoop* run_loop) { in QuitRunLoop() argument 149 run_loop->Quit(); in QuitRunLoop() 154 base::Unretained(this), base::Unretained(run_loop))); in QuitRunLoop() 214 base::RunLoop run_loop, run_loop2; in TEST_F() local 217 run_loop.QuitClosure())); in TEST_F() 223 run_loop.Run(); in TEST_F() 402 base::RunLoop run_loop; in TEST_F() local 406 base::Unretained(this), base::Unretained(&run_loop))); in TEST_F() 424 run_loop.Run(); in TEST_F() 427 base::RunLoop run_loop; in TEST_F() local [all …]
|
D | e2e_perftest.cc | 87 base::RunLoop run_loop; in RunTest() local 88 quit_closure_ = run_loop.QuitClosure(); in RunTest() 91 run_loop.Run(); in RunTest() 124 base::RunLoop run_loop; in RunTestOnTaskRunner() local 129 run_loop.QuitClosure()); in RunTestOnTaskRunner() 130 run_loop.Run(); in RunTestOnTaskRunner() 175 base::RunLoop run_loop; in DEFINE_TEST_CLIENT_TEST_WITH_PIPE() local 181 run_loop.QuitClosure()))); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE() 182 run_loop.Run(); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
|
D | handle_passing_unittest.cc | 208 base::RunLoop run_loop; in TEST_P() local 210 run_loop.QuitClosure()); in TEST_P() 224 run_loop.Run(); in TEST_P() 241 base::RunLoop run_loop; in TEST_P() local 244 run_loop.QuitClosure())); in TEST_P() 248 run_loop.Run(); in TEST_P() 276 base::RunLoop run_loop; in TEST_P() local 279 run_loop.QuitClosure())); in TEST_P() 283 run_loop.Run(); in TEST_P() 308 base::RunLoop run_loop, run_loop2; in TEST_P() local [all …]
|
D | multiplex_router_unittest.cc | 78 base::RunLoop run_loop; in TEST_F() local 81 run_loop.QuitClosure())); in TEST_F() 83 run_loop.Run(); in TEST_F() 163 base::RunLoop run_loop; in TEST_F() local 164 LazyResponseGenerator generator(run_loop.QuitClosure()); in TEST_F() 178 run_loop.Run(); in TEST_F() 288 base::RunLoop run_loop; in TEST_F() local 289 LazyResponseGenerator generator(run_loop.QuitClosure()); in TEST_F() 306 run_loop.Run(); in TEST_F()
|
D | pickle_unittest.cc | 327 base::RunLoop run_loop; in TEST_F() local 342 run_loop.Quit(); in TEST_F() 344 run_loop.Run(); in TEST_F() 368 base::RunLoop run_loop; in TEST_F() local 389 run_loop.Quit(); in TEST_F() 391 run_loop.Run(); in TEST_F() 406 base::RunLoop run_loop; in TEST_F() local 416 run_loop.Quit(); in TEST_F() 418 run_loop.Run(); in TEST_F()
|
D | sync_method_unittest.cc | 345 base::RunLoop run_loop; in SetUp() local 347 [this, &run_loop](TestSyncAssociatedRequest request) { in SetUp() 349 run_loop.Quit(); in SetUp() 354 run_loop.Run(); in SetUp() 470 base::RunLoop run_loop; in RunTestOnSequencedTaskRunner() local 471 test->Init(run_loop.QuitClosure()); in RunTestOnSequencedTaskRunner() 475 run_loop.Run(); in RunTestOnSequencedTaskRunner() 527 base::RunLoop run_loop; in TYPED_TEST() local 529 run_loop.QuitClosure())); in TYPED_TEST() 530 run_loop.Run(); in TYPED_TEST() [all …]
|
/external/python/cpython3/Lib/test/test_asyncio/ |
D | test_sendfile.py | 125 def run_loop(self, coro): member in SendfileBase 169 server = self.run_loop(self.loop.create_server( 174 self.run_loop(self.loop.sock_connect(sock, ('127.0.0.1', port))) 182 self.run_loop(proto.wait_closed()) 185 self.run_loop(server.wait_closed()) 193 ret = self.run_loop(self.loop.sock_sendfile(sock, self.file)) 195 self.run_loop(proto.wait_closed()) 203 ret = self.run_loop(self.loop.sock_sendfile(sock, self.file, 206 self.run_loop(proto.wait_closed()) 215 ret = self.run_loop(self.loop.sock_sendfile(sock, f, [all …]
|
/external/libchrome/base/message_loop/ |
D | message_pump_glib_unittest.cc | 194 RunLoop run_loop; in TEST_F() local 195 injector()->AddEvent(0, run_loop.QuitClosure()); in TEST_F() 196 run_loop.Run(); in TEST_F() 216 RunLoop run_loop; in TEST_F() local 217 injector()->AddEvent(0, run_loop.QuitClosure()); in TEST_F() 218 run_loop.Run(); in TEST_F() 230 RunLoop run_loop; in TEST_F() local 231 injector()->AddEvent(0, run_loop.QuitClosure()); in TEST_F() 232 run_loop.Run(); in TEST_F() 248 RunLoop run_loop; in TEST_F() local [all …]
|
D | message_loop_io_posix_unittest.cc | 251 RunLoop* run_loop) { in StopWatching() argument 253 run_loop->Quit(); in StopWatching() 259 RunLoop run_loop; in TEST_F() local 261 CallClosureHandler handler(BindOnce(&StopWatching, &watcher, &run_loop), in TEST_F() 270 run_loop.Run(); in TEST_F() 282 RunLoop run_loop; in TEST_F() local 283 CallClosureHandler handler(run_loop.QuitClosure(), OnceClosure()); in TEST_F() 291 run_loop.Run(); in TEST_F() 326 RunLoop* run_loop) { in StopWatchingAndWatchAgain() argument 333 run_loop->Quit(); in StopWatchingAndWatchAgain() [all …]
|
D | message_loop_unittest.cc | 1332 void FuncThatRuns(TaskList* order, int cookie, RunLoop* run_loop) { in FuncThatRuns() argument 1336 run_loop->Run(); in FuncThatRuns() 1353 RunLoop run_loop; in TEST_P() local 1356 FROM_HERE, BindOnce(&FuncThatRuns, &order, 1, Unretained(&run_loop))); in TEST_P() 1583 RunLoop run_loop; in TEST_P() local 1585 run_loop.Quit(); in TEST_P() 1592 run_loop.Run(); in TEST_P() 1603 RunLoop run_loop; in TEST_P() local 1607 ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, run_loop.QuitClosure()); in TEST_P() 1613 run_loop.Run(); in TEST_P() [all …]
|
/external/libchrome/ipc/ |
D | ipc_channel_mojo_unittest.cc | 214 base::RunLoop run_loop; in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT() local 215 ListenerThatQuits listener(run_loop.QuitClosure()); in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT() 218 run_loop.Run(); in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT() 227 base::RunLoop run_loop; in TEST_F() local 228 ListenerExpectingErrors listener(run_loop.QuitClosure()); in TEST_F() 241 run_loop.Run(); in TEST_F() 475 base::RunLoop run_loop; in TEST_F() local 476 ListenerThatExpectsOK listener(run_loop.QuitClosure()); in TEST_F() 483 run_loop.Run(); in TEST_F() 491 base::RunLoop run_loop; in DEFINE_IPC_CHANNEL_MOJO_TEST_CLIENT() local [all …]
|
D | ipc_mojo_bootstrap_unittest.cc | 121 base::RunLoop run_loop; in TEST_F() local 122 PeerPidReceiver impl(std::move(receiver), run_loop.QuitClosure()); in TEST_F() 123 run_loop.Run(); in TEST_F() 146 base::RunLoop run_loop; in MULTIPROCESS_TEST_MAIN_WITH_SETUP() local 147 PeerPidReceiver impl(std::move(receiver), run_loop.QuitClosure()); in MULTIPROCESS_TEST_MAIN_WITH_SETUP() 148 run_loop.Run(); in MULTIPROCESS_TEST_MAIN_WITH_SETUP() 167 base::RunLoop run_loop; in TEST_F() local 168 PeerPidReceiver impl(std::move(receiver), run_loop.QuitClosure(), in TEST_F() 170 run_loop.Run(); in TEST_F() 200 base::RunLoop run_loop; in MULTIPROCESS_TEST_MAIN_WITH_SETUP() local [all …]
|
D | ipc_cpu_perftest.cc | 88 base::RunLoop run_loop; in MULTIPROCESS_TEST_MAIN() local 89 run_loop.RunUntilIdle(); in MULTIPROCESS_TEST_MAIN() 240 base::RunLoop run_loop; in RunPingPongServer() local 243 run_loop.QuitWhenIdleClosure()); in RunPingPongServer() 248 run_loop.Run(); in RunPingPongServer() 288 base::RunLoop run_loop; in RunPingPongServer() local 289 quit_closure_ = run_loop.QuitWhenIdleClosure(); in RunPingPongServer() 290 run_loop.Run(); in RunPingPongServer() 370 base::RunLoop run_loop; in RunPingPongClient() local 371 ReflectorImpl impl(std::move(scoped_mp), run_loop.QuitWhenIdleClosure()); in RunPingPongClient() [all …]
|
D | ipc_security_test_util.cc | 16 base::RunLoop run_loop; in PwnMessageReceived() local 21 FROM_HERE, inject_message, run_loop.QuitClosure()); in PwnMessageReceived() 22 run_loop.Run(); in PwnMessageReceived()
|
/external/libchrome/base/test/ |
D | test_mock_time_task_runner_unittest.cc | 131 RunLoop run_loop; in TEST() local 133 FROM_HERE, run_loop.QuitClosure(), TimeDelta::FromSeconds(1)); in TEST() 142 run_loop.Run(); in TEST() 154 RunLoop run_loop; in TEST() local 156 FROM_HERE, run_loop.QuitWhenIdleClosure(), TimeDelta::FromSeconds(5)); in TEST() 165 run_loop.Run(); in TEST() 175 RunLoop run_loop; in TEST() local 177 FROM_HERE, run_loop.QuitWhenIdleClosure(), TimeDelta::FromDays(50)); in TEST() 179 run_loop.Run(); in TEST() 222 RunLoop run_loop; in TEST() local [all …]
|
/external/libchrome/mojo/public/cpp/system/tests/ |
D | simple_watcher_unittest.cc | 53 base::RunLoop run_loop; in TEST_F() local 61 run_loop.Quit(); in TEST_F() 67 run_loop.Run(); in TEST_F() 137 base::RunLoop run_loop; in TEST_F() local 152 run_loop.QuitClosure()); in TEST_F() 153 run_loop.Run(); in TEST_F() 160 base::RunLoop run_loop; in TEST_F() local 167 run_loop.Quit(); in TEST_F() 174 run_loop.Run(); in TEST_F() 182 base::RunLoop run_loop; in TEST_F() local [all …]
|
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
D | rx-runloop.hpp | 118 class run_loop class 121 typedef run_loop this_type; 124 run_loop(const this_type&); 125 run_loop(this_type&&); 137 run_loop() in run_loop() function in rxcpp::schedulers::run_loop 145 ~run_loop() in ~run_loop() 204 inline scheduler make_run_loop(const run_loop& r) { in make_run_loop()
|
/external/libchrome/mojo/public/java/system/javatests/ |
D | mojo_test_rule.cc | 61 base::RunLoop run_loop; in JNI_MojoTestRule_RunLoop() local 64 FROM_HERE, run_loop.QuitWhenIdleClosure(), in JNI_MojoTestRule_RunLoop() 66 run_loop.Run(); in JNI_MojoTestRule_RunLoop() 68 run_loop.RunUntilIdle(); in JNI_MojoTestRule_RunLoop()
|
/external/libchrome/base/debug/ |
D | task_annotator_unittest.cc | 145 RunLoop run_loop; in TEST_F() local 154 run_loop.QuitClosure()); in TEST_F() 185 run_loop.Run(); in TEST_F() 211 RunLoop run_loop; in TEST_F() local 236 run_loop.QuitClosure()); in TEST_F() 276 run_loop.Run(); in TEST_F() 289 RunLoop run_loop; in TEST_F() local 321 run_loop.QuitClosure()); in TEST_F() 367 run_loop.Run(); in TEST_F()
|