| /external/rust/crates/tokio/src/time/ |
| D | sleep.rs | 265 let time_source = handle.time_source(); in new_timeout() localVariable
266 let deadline_tick = time_source.deadline_to_tick(deadline); in new_timeout()
267 let duration = deadline_tick.saturating_sub(time_source.now()); in new_timeout()
373 let time_source = me.entry.driver().time_source(); in reset_inner() localVariable
374 let now = time_source.now(); in reset_inner()
375 let deadline_tick = time_source.deadline_to_tick(deadline); in reset_inner()
|
| /external/rust/crates/tokio/src/runtime/time/ |
| D | handle.rs | 6 pub(super) time_source: TimeSource, field
12 pub(crate) fn time_source(&self) -> &TimeSource { in time_source() method
13 &self.time_source in time_source()
|
| D | mod.rs | 129 let time_source = TimeSource::new(clock); in new() localVariable
132 time_source, in new()
189 let now = handle.time_source.now(); in park_internal()
194 .time_source in park_internal()
223 let clock = &handle.time_source.clock;
252 let now = self.time_source().now(); in process()
|
| D | entry.rs | 550 let tick = self.driver().time_source().deadline_to_tick(new_time); in reset()
|
| /external/rust/crates/tokio/src/runtime/time/tests/ |
| D | mod.rs | 70 handle.process_at_time(handle.time_source().now() + 2_000_000_000); in single_timer()
103 handle.process_at_time(handle.time_source().now() + 2_000_000_000); in drop_timer()
138 handle.process_at_time(handle.time_source().now() + 2_000_000_000); in change_waker()
182 .time_source() in reset_future()
190 .time_source() in reset_future()
|
| /external/libchrome/base/task/sequence_manager/ |
| D | thread_controller_impl.cc | 22 const TickClock* time_source) in ThreadControllerImpl() argument
27 time_source_(time_source), in ThreadControllerImpl()
49 const TickClock* time_source) { in Create() argument
51 message_loop, message_loop->task_runner(), time_source)); in Create()
|
| D | thread_controller_impl.h | 34 const TickClock* time_source);
56 const TickClock* time_source);
|
| D | thread_controller_with_message_pump_impl.cc | 17 TickClock* time_source) in ThreadControllerWithMessagePumpImpl() argument
20 time_source_(time_source) { in ThreadControllerWithMessagePumpImpl()
|
| D | thread_controller_with_message_pump_impl.h | 27 explicit ThreadControllerWithMessagePumpImpl(TickClock* time_source);
|
| /external/cronet/net/test/ |
| D | test_with_task_environment.h | 31 base::test::TaskEnvironment::TimeSource time_source =
34 time_source) {} in task_environment_() argument
|
| /external/libchrome/base/task/sequence_manager/test/ |
| D | sequence_manager_for_test.cc | 18 const TickClock* time_source) in ThreadControllerForTest() argument
21 time_source) {} in ThreadControllerForTest()
|
| /external/cronet/base/task/sequence_manager/ |
| D | thread_controller_impl.cc | 29 const TickClock* time_source) in ThreadControllerImpl() argument
30 : ThreadController(time_source), in ThreadControllerImpl()
65 const TickClock* time_source) { in Create() argument
70 time_source)); in Create()
|
| D | thread_controller_impl.h | 44 const TickClock* time_source);
80 const TickClock* time_source);
|
| D | thread_controller.cc | 19 ThreadController::ThreadController(const TickClock* time_source) in ThreadController() argument
21 time_source_(time_source) {} in ThreadController()
|
| D | thread_controller_with_message_pump_impl.cc | 546 OnIdle(const TickClock* time_source, RunLevelTracker& run_level_tracker_ref) in DoIdleWork()
547 : lazy_now(time_source), run_level_tracker(run_level_tracker_ref) {} in DoIdleWork()
|
| D | thread_controller.h | 74 explicit ThreadController(const TickClock* time_source);
|
| /external/cronet/base/task/sequence_manager/test/ |
| D | sequence_manager_for_test.cc | 19 const TickClock* time_source) in ThreadControllerForTest() argument
22 time_source) {} in ThreadControllerForTest()
|
| /external/cronet/base/test/ |
| D | task_environment.cc | 376 TimeSource time_source, in TaskEnvironment() argument
392 time_source != TimeSource::SYSTEM_TIME in TaskEnvironment()
398 time_overrides_(time_source == TimeSource::MOCK_TIME in TaskEnvironment()
|
| D | task_environment_unittest.cc | 182 void DelayedTasksTest(TaskEnvironment::TimeSource time_source) { in DelayedTasksTest() argument
186 time_source, TaskEnvironment::ThreadPoolExecutionMode::QUEUED); in DelayedTasksTest()
277 if (time_source == TaskEnvironment::TimeSource::MOCK_TIME) { in DelayedTasksTest()
317 TaskEnvironment::TimeSource time_source) { in SupportsSequenceLocalStorageOnMainThreadTest() argument
319 time_source, TaskEnvironment::ThreadPoolExecutionMode::ASYNC); in SupportsSequenceLocalStorageOnMainThreadTest()
|
| D | task_environment.h | 454 TimeSource time_source,
|
| /external/cronet/components/metrics/ |
| D | metrics_log_unittest.cc | 406 EXPECT_EQ(parsed.time_log_created().time_source(), in TEST_F()
412 EXPECT_EQ(parsed.time_log_closed().time_source(), in TEST_F()
|
| /external/cronet/base/threading/ |
| D | scoped_blocking_call_unittest.cc | 172 test::TaskEnvironment::TimeSource time_source = in ScopedBlockingCallIOJankMonitoringTest() argument
174 : task_environment_(absl::in_place, time_source) {} in ScopedBlockingCallIOJankMonitoringTest()
|
| /external/cronet/third_party/metrics_proto/ |
| D | chrome_user_metrics_extension.proto | 112 optional TimeSource time_source = 1; field
|
| /external/cronet/net/spdy/ |
| D | spdy_stream_unittest.cc | 76 explicit SpdyStreamTest(base::test::TaskEnvironment::TimeSource time_source = in SpdyStreamTest() argument
78 : WithTaskEnvironment(time_source), in SpdyStreamTest()
|
| /external/cronet/net/socket/ |
| D | transport_client_socket_pool_unittest.cc | 112 base::test::TaskEnvironment::TimeSource time_source = in TransportClientSocketPoolTest() argument
114 : WithTaskEnvironment(time_source), in TransportClientSocketPoolTest()
|