| /external/openscreen/util/ |
| D | alarm.cc | 13 explicit CancelableFunctor(Alarm* alarm) : alarm_(alarm) { in CancelableFunctor()
14 OSP_DCHECK(alarm_); in CancelableFunctor()
15 OSP_DCHECK(!alarm_->queued_fire_); in CancelableFunctor()
16 alarm_->queued_fire_ = this; in CancelableFunctor()
21 CancelableFunctor(CancelableFunctor&& other) : alarm_(other.alarm_) { in CancelableFunctor()
22 other.alarm_ = nullptr; in CancelableFunctor()
23 if (alarm_) { in CancelableFunctor()
24 OSP_DCHECK_EQ(alarm_->queued_fire_, &other); in CancelableFunctor()
25 alarm_->queued_fire_ = this; in CancelableFunctor()
31 alarm_ = other.alarm_; in operator =()
[all …]
|
| D | alarm_unittest.cc | 22 Alarm* alarm() { return &alarm_; } in alarm()
27 Alarm alarm_{&FakeClock::now, &task_runner_}; member in openscreen::__anon6156f3060111::AlarmTest
|
| /external/grpc-grpc/include/grpcpp/ |
| D | alarm.h | 70 Alarm(Alarm&& rhs) : alarm_(rhs.alarm_) { rhs.alarm_ = nullptr; } in Alarm()
72 alarm_ = rhs.alarm_;
73 rhs.alarm_ = nullptr;
86 explicit experimental_type(Alarm* alarm) : alarm_(alarm) {} in experimental_type()
93 alarm_->SetInternal(TimePoint<T>(deadline).raw_time(), std::move(f)); in Set()
97 Alarm* alarm_;
109 internal::CompletionQueueTag* alarm_; variable
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/ |
| D | alarm.h | 69 Alarm(Alarm&& rhs) noexcept : alarm_(rhs.alarm_) { rhs.alarm_ = nullptr; } in Alarm()
71 alarm_ = rhs.alarm_;
72 rhs.alarm_ = nullptr;
95 explicit experimental_type(Alarm* alarm) : alarm_(alarm) {} in experimental_type()
102 alarm_->SetInternal(::grpc::TimePoint<T>(deadline).raw_time(), in Set()
107 Alarm* alarm_;
120 ::grpc::internal::CompletionQueueTag* alarm_;
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/ |
| D | alarm.h | 69 Alarm(Alarm&& rhs) noexcept : alarm_(rhs.alarm_) { rhs.alarm_ = nullptr; } in Alarm()
71 alarm_ = rhs.alarm_;
72 rhs.alarm_ = nullptr;
95 explicit experimental_type(Alarm* alarm) : alarm_(alarm) {} in experimental_type()
102 alarm_->SetInternal(::grpc::TimePoint<T>(deadline).raw_time(), in Set()
107 Alarm* alarm_;
120 ::grpc::internal::CompletionQueueTag* alarm_;
|
| /external/webrtc/test/time_controller/ |
| D | external_time_controller.cc | 175 : alarm_(alarm), in ExternalTimeController()
176 impl_(alarm_->GetClock()->CurrentTime()), in ExternalTimeController()
178 global_clock_.SetTime(alarm_->GetClock()->CurrentTime()); in ExternalTimeController()
179 alarm_->SetCallback([this] { Run(); }); in ExternalTimeController()
183 return alarm_->GetClock(); in GetClock()
197 alarm_->Sleep(duration); in AdvanceTime()
229 Timestamp now = alarm_->GetClock()->CurrentTime(); in UpdateTime()
235 RTC_DCHECK_EQ(impl_.CurrentTime(), alarm_->GetClock()->CurrentTime()); in ScheduleNext()
239 alarm_->ScheduleAlarmAt(alarm_->GetClock()->CurrentTime() + delay); in ScheduleNext()
|
| D | external_time_controller.h | 62 ControlledAlarmClock* alarm_; variable
|
| /external/openscreen/discovery/mdns/ |
| D | mdns_probe.cc | 39 alarm_(now_function_, task_runner_), in MdnsProbeImpl()
50 alarm_.ScheduleFromNow([this]() { ProbeOnce(); }, in MdnsProbeImpl()
73 alarm_.ScheduleFromNow([this]() { ProbeOnce(); }, in ProbeOnce()
85 alarm_.Cancel(); in Stop()
95 alarm_.Cancel(); in Postpone()
96 alarm_.ScheduleFromNow([this]() { ProbeOnce(); }, Clock::to_duration(delay)); in Postpone()
|
| D | mdns_publisher.cc | 258 alarm_(now_function_, task_runner_), in RecordAnnouncer()
268 alarm_.Cancel(); in ~RecordAnnouncer()
291 alarm_.ScheduleFromNow([this]() { QueueAnnouncement(); }, new_delay); in QueueAnnouncement()
|
| D | mdns_responder.cc | 301 alarm_(now_function, task_runner) { in TruncatedQuery()
334 alarm_.Cancel(); in RescheduleSend()
351 alarm_.ScheduleFromNow([this]() { SendResponse(); }, send_delay); in RescheduleSend()
355 alarm_.Cancel(); in SendResponse()
|
| D | mdns_probe.h | 114 Alarm alarm_; variable
|
| D | mdns_publisher.h | 135 Alarm alarm_; variable
|
| D | mdns_responder.h | 127 Alarm alarm_; variable
|
| /external/grpc-grpc/src/cpp/common/ |
| D | alarm.cc | 119 Alarm::Alarm() : alarm_(new internal::AlarmImpl()) { in Alarm()
129 static_cast<internal::AlarmImpl*>(alarm_)->Set(cq, deadline, tag); in SetInternal()
138 static_cast<internal::AlarmImpl*>(alarm_)->Set(deadline, std::move(f)); in SetInternal()
142 if (alarm_ != nullptr) { in ~Alarm()
143 static_cast<internal::AlarmImpl*>(alarm_)->Destroy(); in ~Alarm()
147 void Alarm::Cancel() { static_cast<internal::AlarmImpl*>(alarm_)->Cancel(); } in Cancel()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/common/ |
| D | alarm.cc | 131 Alarm::Alarm() : alarm_(new internal::AlarmImpl()) { in Alarm()
142 static_cast<internal::AlarmImpl*>(alarm_)->Set(cq, deadline, tag); in SetInternal()
151 static_cast<internal::AlarmImpl*>(alarm_)->Set(deadline, std::move(f)); in SetInternal()
155 if (alarm_ != nullptr) { in ~Alarm()
156 static_cast<internal::AlarmImpl*>(alarm_)->Destroy(); in ~Alarm()
160 void Alarm::Cancel() { static_cast<internal::AlarmImpl*>(alarm_)->Cancel(); } in Cancel()
|
| /external/openscreen/cast/standalone_receiver/ |
| D | sdl_glue.cc | 17 : alarm_(&Clock::now, task_runner), in SDLEventLoopProcessor()
19 alarm_.Schedule([this] { ProcessPendingEvents(); }, Alarm::kImmediately); in SDLEventLoopProcessor()
38 alarm_.ScheduleFromNow([this] { ProcessPendingEvents(); }, kEventPollPeriod); in ProcessPendingEvents()
|
| D | sdl_glue.h | 72 Alarm alarm_; variable
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | client_async.cc | 122 std::unique_ptr<Alarm> alarm_; member in grpc::testing::ClientRpcContextUnaryImpl
143 alarm_.reset(new Alarm); in StartInternal()
144 alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this)); in StartInternal()
372 alarm_.reset(new Alarm); in RunNextState()
373 alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this)); in RunNextState()
437 std::unique_ptr<Alarm> alarm_; member in grpc::testing::ClientRpcContextStreamingPingPongImpl
556 alarm_.reset(new Alarm); in RunNextState()
557 alarm_->Set(cq_, next_issue_(), ClientRpcContext::tag(this)); in RunNextState()
592 std::unique_ptr<Alarm> alarm_; member in grpc::testing::ClientRpcContextStreamingFromClientImpl
712 std::unique_ptr<Alarm> alarm_; member in grpc::testing::ClientRpcContextStreamingFromServerImpl
[all …]
|
| /external/openscreen/cast/streaming/ |
| D | sender_packet_router.cc | 43 alarm_(environment_->now_function(), environment_->task_runner()) { in SenderPacketRouter()
148 alarm_.Cancel(); in ScheduleNextBurst()
150 alarm_.Schedule([this] { SendBurstOfPackets(); }, next_burst_time); in ScheduleNextBurst()
|
| D | sender_packet_router.h | 182 Alarm alarm_; variable
|