Home
last modified time | relevance | path

Searched refs:run_loop (Results 1 – 22 of 22) sorted by relevance

/third_party/python/Lib/test/test_asyncio/
Dtest_sendfile.py131 def run_loop(self, coro): member in SendfileBase
175 server = self.run_loop(self.loop.create_server(
180 self.run_loop(self.loop.sock_connect(sock, ('127.0.0.1', port)))
188 self.run_loop(proto.wait_closed())
191 self.run_loop(server.wait_closed())
199 ret = self.run_loop(self.loop.sock_sendfile(sock, self.file))
201 self.run_loop(proto.wait_closed())
209 ret = self.run_loop(self.loop.sock_sendfile(sock, self.file,
212 self.run_loop(proto.wait_closed())
221 ret = self.run_loop(self.loop.sock_sendfile(sock, f,
[all …]
Dtest_base_events.py616 def run_loop(): function
628 handle = run_loop()
640 run_loop()
649 def run_loop(): function
663 run_loop()
687 def run_loop(): function
694 run_loop()
705 run_loop()
2020 def run_loop(self, coro): member in BaseLoopSockSendfileTests
2026 server = self.run_loop(self.loop.create_server(
[all …]
Dtest_proactor_events.py965 def run_loop(self, coro): member in ProactorEventLoopUnixSockSendfileTests
974 server = self.run_loop(self.loop.create_server(
976 self.run_loop(self.loop.sock_connect(sock, srv_sock.getsockname()))
983 self.run_loop(proto.wait_closed())
986 self.run_loop(server.wait_closed())
997 self.run_loop(self.loop._sock_sendfile_native(sock, f,
1006 self.run_loop(self.loop._sock_sendfile_native(sock, f,
1016 self.run_loop(self.loop._sock_sendfile_native(sock, f,
Dtest_unix_events.py504 def run_loop(self, coro): member in SelectorEventLoopUnixSockSendfileTests
513 server = self.run_loop(self.loop.create_server(
515 self.run_loop(self.loop.sock_connect(sock, (socket_helper.HOST, port)))
516 self.run_loop(proto._ready)
520 self.run_loop(proto.wait_closed())
523 self.run_loop(server.wait_closed())
534 self.run_loop(self.loop._sock_sendfile_native(sock, self.file,
543 self.run_loop(self.loop._sock_sendfile_native(sock, f,
552 self.run_loop(self.loop._sock_sendfile_native(sock, f,
562 self.run_loop(self.loop._sock_sendfile_native(sock, f,
[all …]
/third_party/gstreamer/gstplugins_bad/gst-libs/gst/winrt/
Dgstwinrtdevicewatcher.cpp418 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
426 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
432 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
438 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
444 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
452 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
458 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
468 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
477 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
486 goto run_loop; in gst_winrt_device_watcher_thread_func_inner()
[all …]
/third_party/grpc/src/core/lib/iomgr/
Dev_apple.cc65 CFRunLoopRef run_loop; member
124 CFReadStreamScheduleWithRunLoop(read_stream, gGlobalRunLoopContext->run_loop, in grpc_apple_register_read_stream_run_loop()
138 write_stream, gGlobalRunLoopContext->run_loop, kCFRunLoopDefaultMode); in grpc_apple_register_write_stream_run_loop()
168 gGlobalRunLoopContext->run_loop = CFRunLoopGetCurrent(); in GlobalRunLoopFunc()
200 while (gGlobalRunLoopContext->run_loop == NULL) in pollset_global_init()
208 CFRunLoopStop(gGlobalRunLoopContext->run_loop); in pollset_global_shutdown()
Dpollset_uv.cc57 static void run_loop(size_t timeout) { in run_loop() function
91 grpc_custom_poller_vtable uv_pollset_vtable = {init, run_loop, kick, shutdown};
Dpollset_uv.h26 void (*run_loop)(int blocking); member
/third_party/cef/libcef/common/chrome/
Dchrome_main_runner_delegate.cc46 base::RunLoop* run_loop) { in BeforeMainMessageLoopRun() argument
58 ->SetQuitClosure(run_loop->QuitWhenIdleClosure()); in BeforeMainMessageLoopRun()
Dchrome_main_runner_delegate.h36 void BeforeMainMessageLoopRun(base::RunLoop* run_loop) override;
/third_party/cef/libcef/browser/
Dmain_runner.cc280 base::RunLoop run_loop; in RunMessageLoop() local
283 quit_when_idle_callback_ = run_loop.QuitWhenIdleClosure(); in RunMessageLoop()
285 main_delegate_->BeforeMainMessageLoopRun(&run_loop); in RunMessageLoop()
288 run_loop.Run(); in RunMessageLoop()
Dcontext.cc253 base::RunLoop run_loop; in CefDoMessageLoopWork() local
254 run_loop.RunUntilIdle(); in CefDoMessageLoopWork()
/third_party/gstreamer/gstplugins_bad/sys/asio/
Dgstasioobject.cpp609 goto run_loop; in gst_asio_object_thread_func()
616 goto run_loop; in gst_asio_object_thread_func()
623 goto run_loop; in gst_asio_object_thread_func()
634 goto run_loop; in gst_asio_object_thread_func()
647 goto run_loop; in gst_asio_object_thread_func()
672 goto run_loop; in gst_asio_object_thread_func()
683 goto run_loop; in gst_asio_object_thread_func()
700 goto run_loop; in gst_asio_object_thread_func()
727 goto run_loop; in gst_asio_object_thread_func()
746 goto run_loop; in gst_asio_object_thread_func()
[all …]
/third_party/cef/libcef/common/
Dmain_runner_delegate.h25 virtual void BeforeMainMessageLoopRun(base::RunLoop* run_loop) {} in BeforeMainMessageLoopRun() argument
/third_party/gstreamer/gstplugins_bad/sys/mediafoundation/
Dgstwin32devicewatcher.cpp237 goto run_loop; in gst_win32_device_watcher_thread_func()
247 run_loop: in gst_win32_device_watcher_thread_func()
Dgstmftransform.cpp482 goto run_loop; in gst_mf_transform_thread_func()
496 goto run_loop; in gst_mf_transform_thread_func()
512 goto run_loop; in gst_mf_transform_thread_func()
522 goto run_loop; in gst_mf_transform_thread_func()
547 run_loop: in gst_mf_transform_thread_func()
Dgstmfcapturewinrt.cpp301 goto run_loop; in gst_mf_capture_winrt_thread_func()
306 goto run_loop; in gst_mf_capture_winrt_thread_func()
334 run_loop: in gst_mf_capture_winrt_thread_func()
Dgstmfsourcereader.cpp802 goto run_loop; in gst_mf_source_reader_thread_func()
856 run_loop: in gst_mf_source_reader_thread_func()
/third_party/gstreamer/gstplugins_bad/sys/wasapi/
Dgstmmdeviceenumerator.cpp328 goto run_loop; in gst_mm_device_enumerator_thread_func()
333 run_loop: in gst_mm_device_enumerator_thread_func()
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dgrpc_gevent.pyx.pxi351 cdef void run_loop(size_t timeout_ms) with gil: function
411 gevent_pollset_vtable.poll = run_loop
/third_party/gstreamer/gstplugins_bad/sys/wasapi2/
Dgstwasapi2client.cpp830 goto run_loop; in gst_wasapi2_client_thread_func()
843 run_loop: in gst_wasapi2_client_thread_func()
/third_party/chromium/patch/
D0003-3.2-Beta3-1115.patch1735 +#include "base/run_loop.h"
2589 diff --git a/src/base/run_loop.h b/src/base/run_loop.h
2591 --- a/src/base/run_loop.h
2592 +++ b/src/base/run_loop.h
36764 base::RunLoop run_loop;
36779 base::RunLoop run_loop;
41722 + base::RunLoop run_loop;
41738 + run_loop.Quit();
41740 + run_loop.Run();
42395 #include "base/run_loop.h"
[all …]