| /third_party/nghttp2/src/ |
| D | shrpx_accept_handler.cc | 53 ev_io_start(conn_hnr_->get_loop(), &wev_); in AcceptHandler()
57 ev_io_stop(conn_hnr_->get_loop(), &wev_); in ~AcceptHandler()
105 void AcceptHandler::enable() { ev_io_start(conn_hnr_->get_loop(), &wev_); } in enable()
107 void AcceptHandler::disable() { ev_io_stop(conn_hnr_->get_loop(), &wev_); } in disable()
|
| D | HttpServer.cc | 129 ev_timer_stop(hd->get_loop(), &stream->rtimer); in stream_timeout_cb()
130 ev_timer_stop(hd->get_loop(), &stream->wtimer); in stream_timeout_cb()
150 ev_timer_again(hd->get_loop(), &stream->rtimer); in add_stream_read_timeout()
158 ev_timer_again(hd->get_loop(), &stream->rtimer); in add_stream_read_timeout_if_pending()
166 ev_timer_again(hd->get_loop(), &stream->wtimer); in add_stream_write_timeout()
173 ev_timer_stop(hd->get_loop(), &stream->rtimer); in remove_stream_read_timeout()
180 ev_timer_stop(hd->get_loop(), &stream->wtimer); in remove_stream_write_timeout()
290 struct ev_loop *get_loop() const { in get_loop() function in nghttp2::Sessions
482 auto loop = handler->get_loop(); in ~Stream()
550 auto loop = sessions_->get_loop(); in Http2Handler()
[all …]
|
| D | shrpx_downstream.cc | 180 auto loop = upstream_->get_client_handler()->get_loop(); in ~Downstream()
987 auto loop = upstream_->get_client_handler()->get_loop(); in reset_upstream_rtimer()
992 auto loop = upstream_->get_client_handler()->get_loop(); in reset_upstream_wtimer()
1007 auto loop = upstream_->get_client_handler()->get_loop(); in ensure_upstream_wtimer()
1015 auto loop = upstream_->get_client_handler()->get_loop(); in disable_upstream_rtimer()
1023 auto loop = upstream_->get_client_handler()->get_loop(); in disable_upstream_wtimer()
1031 auto loop = upstream_->get_client_handler()->get_loop(); in reset_downstream_rtimer()
1036 auto loop = upstream_->get_client_handler()->get_loop(); in reset_downstream_wtimer()
1051 auto loop = upstream_->get_client_handler()->get_loop(); in ensure_downstream_wtimer()
1059 auto loop = upstream_->get_client_handler()->get_loop(); in disable_downstream_rtimer()
[all …]
|
| D | shrpx_quic_listener.cc | 43 ev_io_start(worker_->get_loop(), &rev_);
47 ev_io_stop(worker_->get_loop(), &rev_); in ~QUICListener()
|
| D | shrpx_quic_connection_handler.cc | 58 ev_timer_stop(worker_->get_loop(), &stateless_reset_bucket_regen_timer_); in ~QUICConnectionHandler()
595 ev_timer_again(worker_->get_loop(), &stateless_reset_bucket_regen_timer_); in send_stateless_reset()
696 ev_timer_stop(worker_->get_loop(), &stateless_reset_bucket_regen_timer_); in on_stateless_reset_bucket_regen()
728 ev_timer_start(worker->get_loop(), &timer);
732 auto loop = worker->get_loop(); in ~CloseWait()
|
| D | shrpx_http2_upstream.cc | 154 ev_timer_start(handler_->get_loop(), &settings_timer_); in start_settings_timer()
158 ev_timer_stop(handler_->get_loop(), &settings_timer_); in stop_settings_timer()
935 ev_prepare_stop(handler_->get_loop(), &prep_); in check_shutdown()
955 ev_timer_start(handler_->get_loop(), &shutdown_timer_); in start_graceful_shutdown()
1113 ev_prepare_start(handler_->get_loop(), &prep_); in Http2Upstream()
1142 ev_prepare_stop(handler_->get_loop(), &prep_); in ~Http2Upstream()
1143 ev_timer_stop(handler_->get_loop(), &shutdown_timer_); in ~Http2Upstream()
1144 ev_timer_stop(handler_->get_loop(), &settings_timer_); in ~Http2Upstream()
|
| D | shrpx_client_handler.h | 97 struct ev_loop *get_loop() const;
|
| D | shrpx_http2_session.h | 159 struct ev_loop *get_loop() const;
|
| D | HttpServer.h | 206 struct ev_loop *get_loop() const;
|
| D | shrpx_connection_handler.h | 151 struct ev_loop *get_loop() const;
|
| D | shrpx_http3_upstream.cc | 137 ev_prepare_start(handler_->get_loop(), &prep_);
141 auto loop = handler_->get_loop(); in ~Http3Upstream()
1897 ev_io_stop(handler_->get_loop(), &conn->wev); in signal_write_upstream_addr()
1966 auto loop = handler_->get_loop(); in reset_timer()
2774 ev_prepare_stop(handler_->get_loop(), &prep_); in check_shutdown()
2799 ev_timer_start(handler_->get_loop(), &shutdown_timer_); in start_graceful_shutdown()
|
| D | shrpx_worker.h | 340 struct ev_loop *get_loop() const;
|
| D | shrpx_connection_handler.cc | 467 ev_async_send(get_loop(), &thread_join_asyncev_); in graceful_shutdown_worker()
546 struct ev_loop *ConnectionHandler::get_loop() const { in get_loop() function in shrpx::ConnectionHandler
|
| D | shrpx_worker_process.cc | 129 ev_break(conn_handler->get_loop()); in graceful_shutdown()
|
| D | shrpx_client_handler.cc | 445 conn_(worker->get_loop(), fd, ssl, worker->get_mcpool(), in ClientHandler()
590 struct ev_loop *ClientHandler::get_loop() const { in get_loop() function in shrpx::ClientHandler
|
| D | shrpx_worker.cc | 604 struct ev_loop *Worker::get_loop() const { in get_loop() function in shrpx::Worker
|
| /third_party/python/Lib/asyncio/ |
| D | futures.py | 122 def get_loop(self): member in Future
300 get_loop = fut.get_loop
304 return get_loop()
|
| D | events.py | 169 def get_loop(self): member in AbstractServer
|
| D | base_events.py | 318 def get_loop(self): member in Server
|
| /third_party/python/Misc/NEWS.d/ |
| D | 3.7.0a4.rst | 313 asyncio: Add Task.get_loop() and Future.get_loop()
766 Add get_loop() method to Server and AbstractServer classes.
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_futures.py | 153 self.assertIs(f.get_loop(), self.loop)
163 self.assertIs(f.get_loop(), self.loop)
912 fut.get_loop()
|
| D | test_tasks.py | 193 self.assertIs(t.get_loop(), self.loop)
3059 def get_loop(self): member in CTask_Future_Tests.test_foobar.Fut
3103 def get_loop(self): member in BaseTaskIntrospectionTests.test__register_task_2.TaskLike
3119 def get_loop(self): member in BaseTaskIntrospectionTests.test__register_task_3.TaskLike
3178 task.get_loop = lambda: loop
|
| D | test_events.py | 2848 self.assertEqual(server.get_loop(), loop)
2868 events.AbstractServer().get_loop()
|
| /third_party/python/Doc/library/ |
| D | asyncio-future.rst | 212 .. method:: get_loop()
|
| /third_party/python/Doc/whatsnew/ |
| D | 3.7.rst | 696 * The new :meth:`Future.get_loop() <asyncio.Future.get_loop>` and
697 ``Task.get_loop()`` methods return the instance of the loop on which a task or
699 :meth:`Server.get_loop() <asyncio.Server.get_loop>` allows doing the same for
|