Home
last modified time | relevance | path

Searched refs:entry (Results 1 - 16 of 16) sorted by relevance

/commonlibrary/c_utils/base/src/
H A Dtimer.cpp101 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 Dasync_dir.rs32 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 Dasync_pool.rs53 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 Dslots.rs48 /// 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 Djoin_set.rs87 // `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 Dasync_dir.rs531 /// 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 Dasync_source.rs39 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 Dstream.rs155 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 Dasync_lock_manager.cpp375 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 Dpool.rs41 match (*inner).entry(key) {
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Dstream.rs169 let event = self.source.entry.readiness(interest).await?;
H A Ddatagram.rs99 let event = self.source.entry.readiness(interest).await?;
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Dselector.rs162 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 Devent_benchmark_test.cpp894 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 Dutils_event_test.cpp756 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 Dencoder.rs119 .entry(stream_id) in set_frame()

Completed in 14 milliseconds