| /commonlibrary/c_utils/base/src/ |
| H A D | timer.cpp | 101 TimerEntryPtr entry(new TimerEntry()); in Register()
102 entry->timerId = timerId++; in Register()
103 entry->interval = interval; in Register()
104 entry->callback = callback; in Register()
105 entry->once = once; in Register()
106 entry->timerFd = timerFd; in Register()
108 intervalToTimers_[interval].push_back(entry); in Register()
109 timerToEntries_[entry->timerId] = entry; in Register()
111 UTILS_LOGD("register timer %{public}u with %{public}u ms interval.", entry in Register()
123 auto entry = timerToEntries_[timerId]; Unregister() local
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | async_dir.rs | 32 let entry = dir.next().await.unwrap().unwrap(); in sdv_async_dir()
33 assert!(!entry.file_type().await.unwrap().is_dir()); in sdv_async_dir()
34 assert!(entry.file_type().await.unwrap().is_file()); in sdv_async_dir()
35 assert!(entry.file_name().into_string().unwrap().contains("test")); in sdv_async_dir()
36 let entry = dir.next().await.unwrap().unwrap(); in sdv_async_dir()
37 assert!(!entry.metadata().await.unwrap().is_dir()); in sdv_async_dir()
38 assert!(entry.metadata().await.unwrap().is_file()); in sdv_async_dir()
39 assert!(!entry.metadata().await.unwrap().permissions().readonly()); in sdv_async_dir()
40 assert!(entry.file_name().into_string().unwrap().contains("test")); in sdv_async_dir()
|
| H A D | async_pool.rs | 53 for entry in fs::read_dir(dir.as_str()).expect("read failed") { in dump_dir()
54 result.push(entry.unwrap().file_name()); in dump_dir()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| H A D | slots.rs | 48 /// An entry for the slots.
108 Some(entry) => { in push_back()
109 entry.next = key; in push_back()
131 if let Some(entry) = self.entries.get_mut(curr) { in pop_front()
132 self.head = entry.next; in pop_front()
134 entry.prev = NULL; in pop_front()
135 entry.next = self.next; in pop_front()
136 let val = entry.data.take(); in pop_front()
167 let entry = self.entries.get_mut(key).ok_or(SlotsError)?; in remove()
168 let val = entry in remove()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | join_set.rs | 87 // `true` means the entry is in the done list.
116 // When waking a JoinEntry, the entry will get popped out of the wait list and
118 // changed. Safety: it will take the list's lock before moving the entry, so
120 fn wake_by_ref(entry: &Arc<JoinEntry<R>>) { in wake_by_ref()
121 let mut list = entry.list.lock().unwrap(); in wake_by_ref()
122 if !entry.in_done.replace(true) { in wake_by_ref()
123 // We couldn't find the entry, meaning that the JoinSet has been dropped in wake_by_ref()
124 // already. In this case, there is no need to push the entry back to in wake_by_ref()
126 if !list.wait_list.remove(entry) { in wake_by_ref()
129 list.done_list.push_back(entry in wake_by_ref()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | async_dir.rs | 531 /// contains information like the entry's path and possibly other metadata.
549 Ok(entry) => block.push_back(Ok(DirEntry(Arc::new(entry)))), in fill_block()
562 Some(Ok(entry)) => { in poll_next()
564 return Ready(Ok(Some(entry))); in poll_next()
581 Some(Ok(entry)) => Ok(Some(entry)), in poll_next()
592 /// Returns the next entry in the directory.
596 /// * `Ok(Some(entry))` entry i
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | async_source.rs | 39 pub(crate) entry: Ref<ScheduleIO>,
67 let entry = inner.io_register(&mut io, interest)?; in new()
70 entry, in new()
83 let ready = self.entry.readiness(interest).await?;
86 self.entry.clear_readiness(ready);
110 let ready = self.entry.poll_readiness(cx, interest);
130 self.entry.clear_readiness(ready);
142 let event = self.entry.get_readiness(interest);
150 self.entry.clear_readiness(event);
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 155 self.source.entry.readiness(Interest::READABLE).await?; in fmt()
222 self.source.entry.readiness(Interest::WRITABLE).await?; in fmt()
|
| /commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
| H A D | async_lock_manager.cpp | 375 for (auto &entry : anonymousLockMap) { in CreateLockStates()
376 AsyncLockIdentity identity = {true, entry.first, ""}; in CreateLockStates()
378 napi_value v = CreateLockState(env, entry.second); in CreateLockStates()
389 for (auto &entry : lockMap) { in CreateLockStates()
390 AsyncLockIdentity identity = {false, 0, entry.first}; in CreateLockStates()
392 napi_value v = CreateLockState(env, entry.second); in CreateLockStates()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | pool.rs | 41 match (*inner).entry(key) {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | stream.rs | 169 let event = self.source.entry.readiness(interest).await?;
|
| H A D | datagram.rs | 99 let event = self.source.entry.readiness(interest).await?;
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | selector.rs | 162 callback(iocp_event.entry(), Some(events)); in feed_events()
298 callback(iocp_event.entry(), None); in release_events()
|
| /commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/ |
| H A D | event_benchmark_test.cpp | 894 auto entry = timerHandlers_[timerId]; in Unregister() local
896 gettid(), timerId, entry->interval_); in Unregister()
898 if (CancelTimer(entry) != TIMER_ERR_OK) { in Unregister()
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_event_test.cpp | 756 auto entry = timerHandlers_[timerId]; in Unregister() local
758 ", interval:" << entry->interval_ << std::endl; in Unregister()
760 if (CancelTimer(entry) != TIMER_ERR_OK) { in Unregister()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | encoder.rs | 119 .entry(stream_id) in set_frame()
|