/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()
|