| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_timer_latency.rs | 22 let duration = Duration::from_millis(100); in main()
24 ylong_runtime::time::sleep(duration).await; in main()
26 let latency = since.saturating_sub(duration).as_millis(); in main()
44 let duration = Duration::from_millis(100); in main()
46 tokio::time::sleep(duration).await; in main()
48 let latency = since.saturating_sub(duration).as_millis(); in main()
|
| H A D | ylong_runtime_signal.rs | 29 fn print_time(duration: Duration) { in print_time()
30 let hours = duration.as_secs() / 3600; in print_time()
31 let minutes = duration.as_secs() % 3600 / 60; in print_time()
32 let seconds = duration.as_secs() % 60; in print_time()
34 println!("duration : {:?}", formatted_time); in print_time()
82 let duration = end - start; in main()
83 print_time(duration); in main()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | parker.rs | 95 ParkFlag::ParkTimeout(duration) => self.park_on_condvar_timeout(Some(duration)), in park()
122 // if duration is none, than park permanently
123 fn park_on_condvar_timeout(&self, duration: Option<Duration>) { in park_on_condvar_timeout()
140 if let Some(duration) = duration { in park_on_condvar_timeout()
141 let (lock, timeout_result) = self.condvar.wait_timeout(l, duration).unwrap(); in park_on_condvar_timeout()
|
| H A D | driver.rs | 92 Some(duration) if duration.is_zero() => ParkFlag::NotPark,
93 Some(duration) => ParkFlag::ParkTimeout(duration),
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | wheel.rs | 31 // Maximum sleep duration.
42 // Elapsed time duration.
43 duration: u64,
63 duration: 0,
90 pub(crate) fn duration(&self) -> u64 {
91 self.duration
94 pub(crate) fn set_duration(&mut self, duration: u64) {
95 self.duration = duration;
340 // This duration represent
[all...] |
| H A D | timeout.rs | 44 pub fn timeout<F>(duration: Duration, future: F) -> Timeout<F> in timeout()
48 let sleep = sleep(duration); in timeout()
|
| H A D | driver.rs | 112 TimeOut::Duration(duration) => {
113 timeout = Some(duration);
|
| H A D | sleep.rs | 35 /// Waits until 'duration' has elapsed.
43 pub fn sleep(duration: Duration) -> Sleep { in sleep()
46 match Instant::now().checked_add(duration) { in sleep()
140 if let Some(duration) = this.deadline.checked_duration_since(Instant::now()) {
141 let ms = duration.as_millis()
291 /// 2. Uses block_on to test different sleep duration.
328 /// 1. Call sleep with a duration of zero, check if the val is successfully
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | happy_eyeballs.rs | 242 Some(duration) => match crate::runtime::timeout(duration, stream_fut).await { in connect()
330 let duration = start.elapsed(); in ut_happy_eyeballs_connect()
340 assert!(duration >= min_duration); in ut_happy_eyeballs_connect()
341 assert!(duration <= max_duration); in ut_happy_eyeballs_connect()
353 let duration = start.elapsed(); in ut_happy_eyeballs_connect()
354 (reachable, duration) in ut_happy_eyeballs_connect()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | socket.rs | 119 pub(crate) fn set_sock_linger(fd: Fd, duration: Option<Duration>) -> io::Result<()> {
120 let payload = into_linger(duration);
139 fn into_linger(duration: Option<Duration>) -> linger { in into_linger()
140 match duration { in into_linger()
|
| /commonlibrary/c_utils/base/src/ |
| H A D | datetime_ex.cpp | 28 using secondtype = duration<int64_t>; in GetSecondsSince1970ToNow()
40 using secondtype = duration<int64_t>; in GetSecondsSince1970ToPointTime()
57 typedef duration<int64_t, std::ratio<SECONDS_PER_DAY>> dayType; in GetDaysSince1970ToNow()
|
| /commonlibrary/rust/ylong_runtime/ylong_ffrt/src/ |
| H A D | sys_event.rs | 47 duration: c_ulonglong, in ffrt_timer_start()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | worker.cpp | 584 uint64_t duration = ConcurrentHelper::GetMilliseconds() - startTime_;
in UpdateExecutedInfo() local
585 TaskManager::GetInstance().UpdateExecutedInfo(duration);
in UpdateExecutedInfo()
|
| H A D | task_manager.cpp | 194 uint64_t duration = 0; in GetTaskInfos() local
196 duration = ConcurrentHelper::GetMilliseconds() - task->startTime_; in GetTaskInfos()
201 napi_value durationValue = NapiHelper::CreateUint32(env, duration); in GetTaskInfos()
202 napi_set_named_property(env, taskInfoValue, "duration", durationValue); in GetTaskInfos()
210 void TaskManager::UpdateExecutedInfo(uint64_t duration) in UpdateExecutedInfo() argument
212 totalExecTime_ += duration; in UpdateExecutedInfo()
|
| H A D | task_manager.h | 80 void UpdateExecutedInfo(uint64_t duration);
126 // for duration
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test_taskpool.cpp | 313 uint64_t duration = 10; in HWTEST_F() local
314 taskManager.UpdateExecutedInfo(duration); in HWTEST_F()
|