| /external/openscreen/platform/impl/ |
| D | socket_handle_waiter.cc | 16 : now_function_(now_function) {} in SocketHandleWaiter()
78 Clock::time_point start_time = now_function_(); in ProcessReadyHandles()
102 oldest_handle.subscription->last_updated = now_function_(); in ProcessReadyHandles()
105 } while (now_function_() - start_time <= timeout); in ProcessReadyHandles()
109 Clock::time_point start_time = now_function_(); in ProcessHandles()
121 Clock::time_point current_time = now_function_(); in ProcessHandles()
147 current_time = now_function_(); in ProcessHandles()
|
| D | task_runner.cc | 36 : now_function_(now_function), in TaskRunnerImpl()
63 std::make_pair(now_function_() + delay, std::move(task))); in PostPackagedTaskWithDelay()
146 const auto current_time = now_function_(); in ScheduleDelayedTasks()
171 delayed_tasks_.begin()->first - now_function_(); in GrabMoreRunnableTasks()
185 delayed_tasks_.begin()->first - now_function_()); in GrabMoreRunnableTasks()
|
| D | task_runner_unittest.cc | 36 : now_function_(now_function) {} in FakeTaskWaiter()
40 Clock::time_point start = now_function_(); in WaitForTaskToBePosted()
42 while (!has_event_.load() && (now_function_() - start) < timeout) { in WaitForTaskToBePosted()
64 const ClockNowFunctionPtr now_function_; member in openscreen::__anon8a63f90d0111::FakeTaskWaiter
|
| D | tls_data_router_posix.cc | 19 : waiter_(waiter), now_function_(now_function) {} in TlsDataRouterPosix()
120 return now_function_() - start_time > timeout; in HasTimedOut()
|
| D | socket_handle_waiter.h | 117 const ClockNowFunctionPtr now_function_; variable
|
| D | tls_data_router_posix.h | 98 std::function<Clock::time_point()> now_function_; variable
|
| D | task_runner.h | 117 const ClockNowFunctionPtr now_function_; variable
|
| /external/openscreen/cast/streaming/ |
| D | environment.h | 76 ClockNowFunctionPtr now_function() const { return now_function_; } in now_function()
77 Clock::time_point now() const { return now_function_(); } in now()
125 Environment() : now_function_(nullptr), task_runner_(nullptr) {} in Environment()
128 ClockNowFunctionPtr now_function_; variable
|
| D | environment.cc | 20 : now_function_(now_function), task_runner_(task_runner) { in Environment()
21 OSP_DCHECK(now_function_); in Environment()
133 const Clock::time_point arrival_time = now_function_(); in OnRead()
|
| D | mock_environment.cc | 13 now_function_ = now_function; in MockEnvironment()
|
| /external/openscreen/util/ |
| D | alarm.cc | 62 : now_function_(now_function), task_runner_(task_runner) { in Alarm()
63 OSP_DCHECK(now_function_); in Alarm()
84 const Clock::time_point now = now_function_(); in ScheduleWithTask()
112 const Clock::time_point now = now_function_(); in TryInvoke()
|
| D | alarm.h | 60 now_function_() + delay); in ScheduleFromNow()
87 const ClockNowFunctionPtr now_function_; variable
|
| /external/openscreen/discovery/mdns/ |
| D | mdns_trackers.cc | 71 now_function_(now_function), in MdnsTracker()
76 OSP_DCHECK(now_function_); in MdnsTracker()
146 start_time_(now_function_()), in MdnsRecordTracker()
211 start_time_ = now_function_(); in Update()
237 start_time_ = now_function_(); in ExpireSoon()
246 return (now_function_() - start_time_) > record_.ttl() / 2; in IsNearingExpiry()
251 bool is_expired = (now_function_() >= expiration_time); in SendQuery()
367 TrivialClockTraits::time_point now = now_function_(); in SendQuery()
|
| D | mdns_service_impl.cc | 34 now_function_(now_function), in MdnsServiceImpl()
76 sender_.get(), &receiver_, task_runner_, now_function_, &random_delay_, in MdnsServiceImpl()
81 sender_.get(), &receiver_, &random_delay_, task_runner_, now_function_); in MdnsServiceImpl()
84 task_runner_, now_function_, config); in MdnsServiceImpl()
87 task_runner_, now_function_, &random_delay_, config); in MdnsServiceImpl()
|
| D | mdns_publisher.h | 126 const ClockNowFunctionPtr now_function_; variable
151 task_runner_, now_function_, in CreateAnnouncer()
183 ClockNowFunctionPtr now_function_; variable
|
| D | mdns_probe.cc | 38 now_function_(now_function), in MdnsProbeImpl()
39 alarm_(now_function_, task_runner_), in MdnsProbeImpl()
|
| D | mdns_probe_manager.h | 100 task_runner_, now_function_, this, in CreateProbe()
136 ClockNowFunctionPtr now_function_; variable
|
| D | mdns_publisher.cc | 55 now_function_(now_function), in MdnsPublisher()
256 now_function_(now_function), in RecordAnnouncer()
258 alarm_(now_function_, task_runner_), in RecordAnnouncer()
297 batch_records_alarm_.emplace(now_function_, task_runner_); in QueueRecord()
|
| D | mdns_querier.h | 138 ClockNowFunctionPtr now_function_; variable
212 const ClockNowFunctionPtr now_function_; variable
|
| D | mdns_querier.cc | 231 now_function_(now_function), in RecordTrackerLruCache()
352 now_function_, random_delay_, in StartTracking()
381 now_function_(now_function), in MdnsQuerier()
389 now_function_, in MdnsQuerier()
395 OSP_DCHECK(now_function_); in MdnsQuerier()
824 question, sender_, task_runner_, now_function_, random_delay_, config_); in AddQuestion()
|
| D | mdns_probe.h | 112 ClockNowFunctionPtr now_function_; variable
|
| D | mdns_service_impl.h | 73 ClockNowFunctionPtr now_function_; variable
|
| D | mdns_responder.cc | 379 now_function_(now_function), in MdnsResponder()
458 this, task_runner_, now_function_, src, message, config_); in ProcessMultiPacketTruncatedMessage()
495 this, task_runner_, now_function_, src, message, config_); in ProcessMultiPacketTruncatedMessage()
|
| /external/openscreen/osp/impl/ |
| D | message_demuxer.cc | 122 : now_function_(now_function), buffer_limit_(buffer_limit) { in MessageDemuxer()
123 OSP_DCHECK(now_function_); in MessageDemuxer()
267 buffer->size() - msg_type_byte_length, now_function_()); in HandleStreamBuffer()
|
| /external/openscreen/osp/impl/presentation/ |
| D | url_availability_requester.cc | 54 : now_function_(now_function) { in UrlAvailabilityRequester()
55 OSP_DCHECK(now_function_); in UrlAvailabilityRequester()
152 const Clock::time_point now = now_function_(); in RefreshWatches()
237 watch_id, Watch{listener->now_function_() + kWatchDuration, urls}); in SendRequest()
|