| /third_party/node/src/ |
| D | timer_wrap.cc | 11 uv_timer_init(env->event_loop(), &timer_); in TimerWrap()
12 timer_.data = this; in TimerWrap()
16 if (timer_.data == nullptr) return; in Stop()
17 uv_timer_stop(&timer_); in Stop()
21 timer_.data = nullptr; in Close()
22 env_->CloseHandle(reinterpret_cast<uv_handle_t*>(&timer_), TimerClosedCb); in Close()
27 ContainerOf(&TimerWrap::timer_, in TimerClosedCb()
32 if (timer_.data == nullptr) return; in Update()
33 uv_timer_start(&timer_, OnTimeout, interval, repeat); in Update()
37 if (timer_.data == nullptr) return; in Ref()
[all …]
|
| /third_party/nghttp2/src/ |
| D | shrpx_connect_blocker.cc | 51 ev_timer_init(&timer_, connect_blocker_cb, 0., 0.); in ConnectBlocker()
52 timer_.data = this; in ConnectBlocker()
55 ConnectBlocker::~ConnectBlocker() { ev_timer_stop(loop_, &timer_); } in ~ConnectBlocker()
57 bool ConnectBlocker::blocked() const { return ev_is_active(&timer_); } in blocked()
60 if (ev_is_active(&timer_)) { in on_success()
76 if (ev_is_active(&timer_)) { in on_failure()
97 ev_timer_set(&timer_, backoff, 0.); in on_failure()
98 ev_timer_start(loop_, &timer_); in on_failure()
108 if (!ev_is_active(&timer_)) { in offline()
114 ev_timer_stop(loop_, &timer_); in offline()
[all …]
|
| D | shrpx_dns_resolver.cc | 123 ev_timer_init(&timer_, timeoutcb, 0., 0.);
124 timer_.data = this;
135 ev_timer_stop(loop_, &timer_); in ~DNSResolver()
223 timer_.repeat = tv->tv_sec + tv->tv_usec / 1000000. + 1e-9; in reset_timeout()
224 ev_timer_again(loop_, &timer_); in reset_timeout()
291 ev_timer_stop(loop_, &timer_); in on_result()
|
| /third_party/boost/libs/asio/example/cpp03/tutorial/timer4/ |
| D | timer.cpp | 19 : timer_(io, boost::asio::chrono::seconds(1)), in printer()
22 timer_.async_wait(boost::bind(&printer::print, this)); in printer()
37 timer_.expires_at(timer_.expiry() + boost::asio::chrono::seconds(1)); in print()
38 timer_.async_wait(boost::bind(&printer::print, this)); in print()
43 boost::asio::steady_timer timer_; member in printer
|
| /third_party/cef/tests/shared/browser/ |
| D | main_message_loop_external_pump_mac.mm | 39 bool IsTimerPending() override { return timer_ != nil; }
46 NSTimer* timer_;
87 : owner_thread_([NSThread currentThread]), timer_(nil) {
149 DCHECK(!timer_);
152 timer_ = [NSTimer timerWithTimeInterval:delay_s
158 [timer_ retain];
163 [owner_runloop addTimer:timer_ forMode:NSRunLoopCommonModes];
164 [owner_runloop addTimer:timer_ forMode:NSEventTrackingRunLoopMode];
168 if (timer_ != nil) {
169 [timer_ invalidate];
[all …]
|
| /third_party/boost/libs/asio/example/cpp11/spawn/ |
| D | echo_server.cpp | 26 timer_(io_context), in session()
42 timer_.expires_from_now(std::chrono::seconds(10)); in go()
50 timer_.cancel(); in go()
60 timer_.async_wait(yield[ignored_ec]); in go()
61 if (timer_.expires_from_now() <= std::chrono::seconds(0)) in go()
69 boost::asio::steady_timer timer_; member in session
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/spawn/ |
| D | echo_server.cpp | 26 timer_(io_context), in session()
42 timer_.expires_from_now(std::chrono::seconds(10)); in go()
50 timer_.cancel(); in go()
60 timer_.async_wait(yield[ignored_ec]); in go()
61 if (timer_.expires_from_now() <= std::chrono::seconds(0)) in go()
69 boost::asio::steady_timer timer_; member in session
|
| /third_party/boost/libs/asio/example/cpp03/icmp/ |
| D | ping.cpp | 29 timer_(io_context), sequence_number_(0), num_replies_(0) in pinger()
61 timer_.expires_at(time_sent_ + chrono::seconds(5)); in start_send()
62 timer_.async_wait(boost::bind(&pinger::handle_timeout, this)); in start_send()
71 timer_.expires_at(time_sent_ + chrono::seconds(1)); in handle_timeout()
72 timer_.async_wait(boost::bind(&pinger::start_send, this)); in handle_timeout()
106 timer_.cancel(); in handle_receive()
135 steady_timer timer_; member in pinger
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/icmp/ |
| D | ping.cpp | 29 timer_(io_context), sequence_number_(0), num_replies_(0) in pinger()
61 timer_.expires_at(time_sent_ + chrono::seconds(5)); in start_send()
62 timer_.async_wait(boost::bind(&pinger::handle_timeout, this)); in start_send()
71 timer_.expires_at(time_sent_ + chrono::seconds(1)); in handle_timeout()
72 timer_.async_wait(boost::bind(&pinger::start_send, this)); in handle_timeout()
106 timer_.cancel(); in handle_receive()
135 steady_timer timer_; member in pinger
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/spawn/ |
| D | echo_server.cpp | 29 timer_(io_context) in session()
56 timer_.expires_after(boost::asio::chrono::seconds(10)); in echo()
64 timer_.cancel(); in echo()
73 timer_.async_wait(yield[ignored_ec]); in timeout()
74 if (timer_.expiry() <= boost::asio::steady_timer::clock_type::now()) in timeout()
81 boost::asio::steady_timer timer_; member in session
|
| /third_party/boost/libs/asio/example/cpp03/spawn/ |
| D | echo_server.cpp | 29 timer_(io_context) in session()
56 timer_.expires_after(boost::asio::chrono::seconds(10)); in echo()
64 timer_.cancel(); in echo()
73 timer_.async_wait(yield[ignored_ec]); in timeout()
74 if (timer_.expiry() <= boost::asio::steady_timer::clock_type::now()) in timeout()
81 boost::asio::steady_timer timer_; member in session
|
| /third_party/flutter/engine/flutter/fml/platform/win/ |
| D | message_loop_win.cc | 12 : timer_(CreateWaitableTimer(NULL, FALSE, NULL)) { in MessageLoopWin()
13 FML_CHECK(timer_.is_valid()); in MessageLoopWin()
22 FML_CHECK(WaitForSingleObject(timer_.get(), INFINITE) == 0); in Run()
38 FML_CHECK(SetWaitableTimer(timer_.get(), &due_time, 0, NULL, NULL, FALSE)); in WakeUp()
|
| /third_party/boost/doc/html/boost_asio/example/cpp17/coroutines_ts/ |
| D | chat_server.cpp | 91 timer_(socket_.get_executor()), in chat_session()
94 timer_.expires_at(std::chrono::steady_clock::time_point::max()); in chat_session()
113 timer_.cancel_one(); in deliver()
145 co_await timer_.async_wait(redirect_error(use_awaitable, ec)); in writer()
165 timer_.cancel(); in stop()
169 boost::asio::steady_timer timer_; member in chat_session
|
| /third_party/boost/libs/asio/example/cpp17/coroutines_ts/ |
| D | chat_server.cpp | 91 timer_(socket_.get_executor()), in chat_session()
94 timer_.expires_at(std::chrono::steady_clock::time_point::max()); in chat_session()
113 timer_.cancel_one(); in deliver()
145 co_await timer_.async_wait(redirect_error(use_awaitable, ec)); in writer()
165 timer_.cancel(); in stop()
169 boost::asio::steady_timer timer_; member in chat_session
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/multicast/ |
| D | sender.cpp | 26 timer_(io_context), in sender()
50 timer_.expires_after(std::chrono::seconds(1)); in do_timeout()
51 timer_.async_wait( in do_timeout()
62 boost::asio::steady_timer timer_; member in sender
|
| /third_party/boost/libs/asio/example/cpp11/multicast/ |
| D | sender.cpp | 26 timer_(io_context), in sender()
50 timer_.expires_after(std::chrono::seconds(1)); in do_timeout()
51 timer_.async_wait( in do_timeout()
62 boost::asio::steady_timer timer_; member in sender
|
| /third_party/grpc/src/cpp/common/ |
| D | alarm.cc | 42 grpc_timer_init_unset(&timer_); in AlarmImpl()
74 grpc_timer_init(&timer_, grpc_timespec_to_millis_round_up(deadline), in Set()
97 grpc_timer_init(&timer_, grpc_timespec_to_millis_round_up(deadline), in Set()
103 grpc_timer_cancel(&timer_); in Cancel()
118 grpc_timer timer_; member in grpc::internal::AlarmImpl
|
| /third_party/boost/libs/asio/example/cpp03/porthopper/ |
| D | server.cpp | 34 timer_(io_context), in server()
45 timer_.expires_after(boost::asio::chrono::milliseconds(100)); in server()
46 timer_.async_wait(boost::bind(&server::handle_timer, this)); in server()
143 timer_.expires_after(boost::asio::chrono::milliseconds(100)); in handle_timer()
144 timer_.async_wait(boost::bind(&server::handle_timer, this)); in handle_timer()
152 boost::asio::steady_timer timer_; member in server
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/porthopper/ |
| D | server.cpp | 34 timer_(io_context), in server()
45 timer_.expires_after(boost::asio::chrono::milliseconds(100)); in server()
46 timer_.async_wait(boost::bind(&server::handle_timer, this)); in server()
143 timer_.expires_after(boost::asio::chrono::milliseconds(100)); in handle_timer()
144 timer_.async_wait(boost::bind(&server::handle_timer, this)); in handle_timer()
152 boost::asio::steady_timer timer_; member in server
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/multicast/ |
| D | sender.cpp | 27 timer_(io_context), in sender()
44 timer_.expires_after(boost::asio::chrono::seconds(1)); in handle_send_to()
45 timer_.async_wait( in handle_send_to()
69 boost::asio::steady_timer timer_; member in sender
|
| /third_party/boost/libs/asio/example/cpp03/multicast/ |
| D | sender.cpp | 27 timer_(io_context), in sender()
44 timer_.expires_after(boost::asio::chrono::seconds(1)); in handle_send_to()
45 timer_.async_wait( in handle_send_to()
69 boost::asio::steady_timer timer_; member in sender
|
| /third_party/grpc/test/cpp/qps/ |
| D | server.h | 44 : timer_(new UsageTimer), last_reset_poll_count_(0) { in Server()
60 timer.swap(timer_); in Mark()
64 timer_result = timer_->Mark(); in Mark()
149 std::unique_ptr<UsageTimer> timer_; variable
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | timer_queue.hpp | 153 per_timer_data* timer = heap_[0].timer_; in get_ready_timers()
205 heap_[target.heap_index_].timer_ = ⌖ in move_timer()
257 heap_[index1].timer_->heap_index_ = index1; in swap_heap()
258 heap_[index2].timer_->heap_index_ = index2; in swap_heap()
349 per_timer_data* timer_; member
|
| /third_party/boost/boost/asio/detail/ |
| D | timer_queue.hpp | 153 per_timer_data* timer = heap_[0].timer_; in get_ready_timers()
205 heap_[target.heap_index_].timer_ = ⌖ in move_timer()
257 heap_[index1].timer_->heap_index_ = index1; in swap_heap()
258 heap_[index2].timer_->heap_index_ = index2; in swap_heap()
349 per_timer_data* timer_; member
|
| /third_party/node/test/cctest/ |
| D | test_inspector_socket_server.cc | 44 uv_timer_init(loop, &timer_); in Timeout()
45 uv_timer_start(&timer_, Timeout::set_flag, 5000, 0); in Timeout()
46 uv_unref(reinterpret_cast<uv_handle_t*>(&timer_)); in Timeout()
50 uv_timer_stop(&timer_); in ~Timeout()
51 uv_close(reinterpret_cast<uv_handle_t*>(&timer_), mark_done); in ~Timeout()
60 Timeout* t = node::ContainerOf(&Timeout::timer_, timer); in set_flag()
65 Timeout* t = node::ContainerOf(&Timeout::timer_, in mark_done()
71 uv_timer_t timer_; member in __anon74c9fee50111::Timeout
|