| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | timer.rs | 17 use std::time::{Duration, Instant};
22 const TEN_YEARS: Duration = Duration::from_secs(86400 * 365 * 10);
47 pub fn timer(period: Duration) -> Timer { in timer()
77 pub fn timer_at(start: Instant, period: Duration) -> Timer { in timer_at()
133 period: Duration,
164 pub fn period(&self) -> Duration { in period() argument
172 use std::time::{Duration, Instant};
187 assert_eq!(Duration::new(1, 0), timer.period()); in ut_new_timer()
204 Duration::new(0, 20_000_000), in ut_new_timer_base()
229 Duration::from_millis(100), in ut_new_timer_timeout()
[all …]
|
| H A D | sleep.rs | 19 use std::time::{Duration, Instant};
21 const TEN_YEARS: Duration = Duration::from_secs(86400 * 365 * 10);
43 pub fn sleep(duration: Duration) -> Sleep { in sleep()
282 use std::time::{Duration, Instant};
297 sleep(Duration::new(0, 20_000_000)).await; in ut_new_timer_sleep()
298 sleep(Duration::new(0, 20_000_000)).await; in ut_new_timer_sleep()
299 sleep(Duration::new(0, 20_000_000)).await; in ut_new_timer_sleep()
308 sleep(Duration::new(0, 20_000_000)).await; in ut_new_timer_sleep()
312 sleep(Duration::new(0, 20_000_000)).await; in ut_new_timer_sleep()
316 sleep(Duration::new(0, 20_000_000)).await; in ut_new_timer_sleep()
[all …]
|
| H A D | timeout.rs | 17 use std::time::Duration;
44 pub fn timeout<F>(duration: Duration, future: F) -> Timeout<F> in timeout() argument
90 use std::time::Duration;
110 timeout(Duration::from_millis(10), rx).await.is_ok() in ut_timeout_test()
117 timeout(Duration::from_millis(10), rx).await.is_ok() in ut_timeout_test()
137 let result = timeout(Duration::from_millis(100), async { 1 }).await; in ut_timeout_test_002()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/ |
| H A D | task_executor.h | 25 using Duration = std::chrono::steady_clock::duration; variable
26 static constexpr Duration INVALID_DURATION = std::chrono::milliseconds(0);
43 TaskId Schedule(Duration delay, Task task) in Schedule()
48 TaskId Schedule(Task task, Duration interval) in Schedule()
53 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule()
58 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule()
68 TaskId Reset(TaskId taskId, Duration interval) in Reset()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | ithread_pool.h | 25 using Duration = std::chrono::steady_clock::duration; variable
33 virtual TaskId Execute(const Task &task, Duration delay) = 0;
35 virtual TaskId Schedule(const Task &task, Duration interval) = 0;
37 virtual TaskId Schedule(const Task &task, Duration delay, Duration interval) = 0;
39 … virtual TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) = 0;
43 virtual TaskId Reset(const TaskId &taskId, Duration interval) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/ |
| H A D | task_executor_adapter.h | 25 using Duration = std::chrono::steady_clock::duration; variable
29 TaskId Execute(const Task &task, Duration delay) override;
30 TaskId Schedule(const Task &task, Duration interval) override;
31 TaskId Schedule(const Task &task, Duration delay, Duration interval) override;
32 TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) override;
34 TaskId Reset(const TaskId &taskId, Duration interval) override;
|
| H A D | task_executor.h | 23 using Duration = std::chrono::steady_clock::duration; variable
24 static constexpr Duration INVALID_DURATION = std::chrono::milliseconds(0);
30 TaskId Schedule(Duration delay, const Task &task, Duration interval = INVALID_DURATION,
33 TaskId Reset(TaskId taskId, Duration interval);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | mock_thread_pool.h | 24 MOCK_METHOD2(Execute, TaskId(const Task &, Duration));
25 MOCK_METHOD2(Schedule, TaskId(const Task &, Duration));
26 MOCK_METHOD3(Schedule, TaskId(const Task &, Duration, Duration));
27 MOCK_METHOD4(Schedule, TaskId(const Task &, Duration, Duration, uint64_t));
29 MOCK_METHOD2(Reset, TaskId(const TaskId &, Duration));
|
| H A D | thread_pool_test_stub.h | 32 TaskId Execute(const Task &task, Duration delay) override;
34 TaskId Schedule(const Task &task, Duration interval) override;
36 TaskId Schedule(const Task &task, Duration delay, Duration interval) override;
38 TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) override;
42 TaskId Reset(const TaskId &taskId, Duration interval) override;
|
| H A D | thread_pool_test_stub.cpp | 68 TaskId ThreadPoolTestStub::Execute(const Task &task, Duration delay) in Execute()
76 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration interval) in Schedule()
81 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval) in Schedule()
86 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval, uint64_t t… in Schedule()
96 TaskId ThreadPoolTestStub::Reset(const TaskId &taskId, Duration interval) in Reset()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | task_manager.h | 25 using Duration = std::chrono::steady_clock::duration; variable
30 TaskId Execute(const Task &task, Duration delay) override;
31 TaskId Schedule(const Task &task, Duration interval) override;
32 TaskId Schedule(const Task &task, Duration delay, Duration interval) override;
33 TaskId Schedule(const Task &task, Duration delay, Duration interval, uint64_t times) override;
35 TaskId Reset(const TaskId &taskId, Duration interval) override;
|
| H A D | task_manager.cpp | 30 TaskManager::TaskId TaskManager::Execute(const Task &task, Duration delay) in Execute()
34 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration interval) in Schedule()
38 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval) in Schedule()
42 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval, uint… in Schedule()
50 TaskManager::TaskId TaskManager::Reset(const TaskId &taskId, Duration interval) in Reset()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | task_executor_adapter.cpp | 23 TaskExecutorAdapter::Duration delay) in Execute()
28 TaskExecutorAdapter::Duration interval) in Schedule()
33 TaskExecutorAdapter::Duration delay, TaskExecutorAdapter::Duration interval) in Schedule()
38 TaskExecutorAdapter::Duration delay, TaskExecutorAdapter::Duration interval, uint64_t times) in Schedule()
48 TaskExecutorAdapter::Duration interval) in Reset()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_timer_memory.rs | 14 use std::time::Duration;
23 ylong_runtime::time::sleep(Duration::from_secs_f32(0.5)).await; in read_big_data()
24 ylong_runtime::time::sleep(Duration::from_secs_f32(30.0)).await; in read_big_data()
32 ylong_runtime::time::timeout(Duration::from_secs(1), read_big_data()).await in run_forever()
39 ylong_runtime::time::sleep(Duration::from_secs_f32(0.1)).await; in run_forever()
53 std::thread::sleep(Duration::from_secs(3600)); in main()
|
| H A D | ylong_runtime_timer_sleep.rs | 16 use std::time::{Duration, Instant};
28 sleep(Duration::new(1, 0)).await; in main()
33 sleep(Duration::new(2, 0)).await; in main()
38 sleep(Duration::new(3, 0)).await; in main()
51 sleep(Duration::new(0, 200_000_000)).await; in main()
|
| /ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | executor_pool.h | 35 using Duration = Executor::Duration; variable
41 static constexpr Duration INVALID_INTERVAL = std::chrono::milliseconds(0);
43 static constexpr Duration INVALID_DELAY = std::chrono::seconds(0);
91 TaskId Schedule(Duration delay, Task task) in Schedule()
96 TaskId Schedule(Task task, Duration interval) in Schedule()
101 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule()
106 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule()
130 TaskId Reset(TaskId taskId, Duration interval) in Reset()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | executor_pool.h | 32 using Duration = Executor::Duration; variable
38 static constexpr Duration INVALID_INTERVAL = std::chrono::milliseconds(0);
40 static constexpr Duration INVALID_DELAY = std::chrono::seconds(0);
87 TaskId Schedule(Duration delay, Task task) in Schedule()
92 TaskId Schedule(Task task, Duration interval) in Schedule()
97 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule()
102 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule()
126 TaskId Reset(TaskId taskId, Duration interval) in Reset()
|
| /ohos5.0/foundation/systemabilitymgr/safwk/interfaces/innerkits/safwk/rust/tests/ |
| H A D | basic.rs | 27 std::thread::sleep(std::time::Duration::from_secs(20)); in init()
29 std::thread::sleep(std::time::Duration::from_secs(20)); in init()
49 std::thread::sleep(std::time::Duration::from_secs(5)); in reason()
54 std::thread::sleep(std::time::Duration::from_secs(5)); in reason()
59 std::thread::sleep(std::time::Duration::from_secs(5)); in reason()
64 std::thread::sleep(std::time::Duration::from_secs(5)); in reason()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/ |
| H A D | settings.rs | 15 use core::time::Duration;
182 pub struct Timeout(Option<Duration>);
208 Self(Some(Duration::from_secs(secs))) in from_secs()
211 pub(crate) fn inner(&self) -> Option<Duration> { in inner() argument
232 min: (u64, Duration),
269 self.min = (cmp::min(self.max, min), Duration::from_secs(secs)); in min_speed()
304 min: (0, Duration::MAX), in none()
467 use std::time::Duration;
583 assert_eq!(speed.min, (1024, Duration::from_secs(12))) in ut_speed_limit_min_speed()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | happy_eyeballs.rs | 16 use core::time::Duration;
36 timeout: Option<Duration>,
46 timeout: Option<Duration>,
48 delay: Option<Duration>,
100 pub(crate) fn new(timeout: Option<Duration>, delay: Option<Duration>) -> Self { in new() argument
106 fn new(addrs: Vec<SocketAddr>, timeout: Option<Duration>) -> Self { in new()
153 Duration::from_millis(HAPPY_EYEBALLS_PREFERRED_TIMEOUT_MS) in new()
236 timeout: Option<Duration>, in connect() argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/common/ |
| H A D | task_scheduler.h | 35 using Duration = std::chrono::steady_clock::duration; variable
39 inline static constexpr Duration INVALID_INTERVAL = std::chrono::milliseconds(0);
63 …TaskId At(const Time &begin, Task task, Duration interval = INVALID_INTERVAL, uint64_t times = UNL…
81 TaskId Reset(TaskId taskId, const Duration &interval) in Reset()
111 TaskId Every(Duration interval, Task task) in Every()
131 TaskId Every(Duration delay, Duration interval, Task task) in Every()
136 TaskId Every(int32_t times, Duration delay, Duration interval, Task task) in Every()
147 Duration interval = INVALID_INTERVAL;
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/ |
| H A D | config.rs | 20 use std::time::Duration;
31 pub struct Timeout(Option<Duration>);
57 Self(Some(Duration::from_secs(secs))) in from_secs()
60 pub(crate) fn inner(&self) -> Option<Duration> { in inner() argument
75 min: (u64, Duration),
111 self.min = (cmp::min(self.max, min), Duration::from_secs(duration)); in min_speed()
146 min: (0, Duration::MAX), in none()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | task_cancel.rs | 19 use std::time::Duration;
36 sleep(Duration::from_secs(100)).await; in sdv_task_cancel_simple()
38 sleep(Duration::from_millis(100)).await; in sdv_task_cancel_simple()
58 sleep(Duration::from_millis(100)).await; in sdv_task_cancel_failed()
97 sleep(Duration::from_secs(1000000)); in sdv_task_cancel_multiple()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/docs/ |
| H A D | user_guide.md | 24 .keep_alive_time(std::time::Duration::from_secs(10))
80 use std::time::Duration;
87 sleep(Duration::from_secs(100)).await;
136 use std::time::Duration;
142 let result = timeout(Duration::from_millis(100), async { 1 }).await;
146 let result = timeout(Duration::from_millis(100), sleep(Duration::from_secs(1)));
|
| /ohos5.0/base/msdp/device_status/rust/modules/scheduler/test/src/ |
| H A D | lib.rs | 23 use std::time::Duration;
129 fn wait(&self, dur: Duration) -> bool in wait()
168 assert!(epoll.wait(Duration::from_millis(100))); in test_add_epoll_handler()
218 }, None, Duration::from_millis(100), Some(10)); in test_post_perioric_task()
220 std::thread::sleep(Duration::from_secs(1)); in test_post_perioric_task()
237 }, Duration::from_millis(10)); in test_post_delayed_task()
239 assert!(epoll.wait(Duration::from_millis(100))); in test_post_delayed_task()
252 std::thread::sleep(Duration::from_millis(100)); in test_post_blocking_task()
|