Home
last modified time | relevance | path

Searched refs:iter (Results 1 - 25 of 101) sorted by relevance

12345

/commonlibrary/rust/ylong_json/benches/
H A Dserialize_json_cmp.rs33 b.iter(|| { in null_serialize_perf_ylong_json()
43 b.iter(|| { in boolean_serialize_perf_ylong_json()
53 b.iter(|| { in number_serialize_perf_ylong_json()
63 b.iter(|| { in string_serialize_perf_ylong_json()
73 b.iter(|| { in array_serialize_perf_ylong_json()
83 b.iter(|| { in object_serialize_perf_ylong_json()
93 b.iter(|| { in exp1_serialize_perf_ylong_json()
103 b.iter(|| { in exp2_serialize_perf_ylong_json()
113 b.iter(|| { in exp3_serialize_perf_ylong_json()
123 b.iter(|| { in exp4_serialize_perf_ylong_json()
[all...]
H A Ddeserialize_json_cmp.rs32 b.iter(|| { in null_deserialize_perf_ylong_json()
41 b.iter(|| { in boolean_deserialize_perf_ylong_json()
50 b.iter(|| { in number_deserialize_perf_ylong_json()
59 b.iter(|| { in string_deserialize_perf_ylong_json()
68 b.iter(|| { in array_deserialize_perf_ylong_json()
77 b.iter(|| { in object_deserialize_perf_ylong_json()
86 b.iter(|| { in exp1_deserialize_perf_ylong_json()
95 b.iter(|| { in exp2_deserialize_perf_ylong_json()
104 b.iter(|| { in exp3_deserialize_perf_ylong_json()
113 b.iter(|| { in exp4_deserialize_perf_ylong_json()
[all...]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_manager.cpp245 for (auto iter = workers_.begin(); iter != workers_.end(); iter++) { in CheckForBlockedWorkers()
246 auto worker = *iter; in CheckForBlockedWorkers()
438 auto iter = std::find_if(idleWorkers_.begin(), idleWorkers_.end(), [](Worker *worker) { in TriggerShrink() local
443 if (iter != idleWorkers_.end()) { in TriggerShrink()
444 auto worker = *iter; in TriggerShrink()
467 for (auto iter = timeoutWorkers_.begin(); iter != timeoutWorkers_.end();) { in NotifyShrink()
468 auto worker = *iter; in NotifyShrink()
918 auto iter = callbackTable_.find(taskId); GetCallbackInfo() local
932 auto iter = callbackTable_.find(taskId); IncreaseRefCount() local
945 auto iter = callbackTable_.find(taskId); DecreaseRefCount() local
966 auto iter = callbackTable_.find(task->taskId_); NotifyCallbackExecute() local
1031 auto iter = dependentTaskInfos_.find(taskId); NotifyDependencyTaskInfo() local
1063 auto iter = dependTaskInfos_.find(taskId); IsDependendByTaskId() local
1073 auto iter = dependentTaskInfos_.find(dependentTaskId); IsDependentByTaskId() local
1085 auto iter = dependTaskInfos_.find(taskId); StoreTaskDependency() local
1119 auto iter = dependentIdSet.find(id); CheckCircularDependency() local
1139 auto iter = dependTaskInfos_.find(taskId); RemoveTaskDependency() local
1189 auto iter = dependentTaskInfos_.find(id); StoreDependentTaskInfo() local
1203 auto iter = dependentTaskInfos_.find(dependentTaskId); RemoveDependentTaskInfo() local
1218 auto iter = dependTaskInfos_.find(taskId); GetTaskDependInfoToString() local
1231 auto iter = taskDurationInfos_.find(taskId); StoreTaskDuration() local
1248 auto iter = taskDurationInfos_.find(taskId); GetTaskDuration() local
1266 auto iter = taskDurationInfos_.find(taskId); RemoveTaskDuration() local
1287 auto iter = longTasksMap_.find(taskId); GetLongTaskInfo() local
1409 auto iter = tasks_.find(taskId); GetTask() local
1580 auto iter = seqRunners_.find(seqRunnerId); GetSeqRunner() local
1591 auto iter = seqRunners_.find(seqRunnerId); AddTaskToSeqRunner() local
1710 auto iter = globalSeqRunner_.find(name); CreateOrGetGlobalRunner() local
1742 auto iter = seqRunner->globalSeqRunnerRef_.find(env); TriggerGlobalSeqRunner() local
1762 auto iter = seqRunner->globalSeqRunnerRef_.find(env); RemoveGlobalSeqRunnerRef() local
1772 auto iter = globalSeqRunner_.find(name.c_str()); RemoveSequenceRunner() local
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_multi_threaded.rs58 b.iter(black_box(|| {
94 fn iter(runtime: Arc<Runtime>, sender: mpsc::SyncSender<()>, n: usize) { in chained_spawn() functions
99 runtime.spawn(async move { iter(runtime_clone, sender, n - 1) }); in chained_spawn()
107 b.iter(black_box(move || { in chained_spawn()
111 runtime_clone.spawn(async move { iter(runtime_iter_clone, sender, TASK_NUM) }); in chained_spawn()
138 fn iter(sender: mpsc::SyncSender<()>, n: usize) { in chained_spawn() functions
142 tokio::spawn(async move { iter(sender, n - 1) }); in chained_spawn()
149 b.iter(black_box(move || { in chained_spawn()
152 tokio::spawn(async move { iter(sender, TASK_NUM) }); in chained_spawn()
H A Dsync_benchmarks.rs36 b.iter(black_box(|| { in single_thread_run_1000_fibbo()
48 b.iter(black_box(|| { in single_thread_run_task()
57 b.iter(|| { in std_read_file()
71 b.iter(|| { in std_read_file_by_chars()
89 b.iter(black_box(|| { in std_write_file()
103 b.iter(black_box(|| { in std_multi_threaded_ping()
121 b.iter(black_box(|| { in std_multi_threaded_ping_pong()
H A Dylong_tokio_rwlock.rs53 b.iter(black_box(|| { in tokio_rwlock_read()
78 b.iter(black_box(move || { in ylong_rwlock_read()
102 b.iter(black_box(|| { in tokio_rwlock_write()
127 b.iter(black_box(move || { in ylong_rwlock_write()
152 b.iter(black_box(|| { in tokio_rwlock_write_read()
184 b.iter(black_box(|| { in ylong_rwlock_write_read()
H A Dylong_tokio_runtime_init.rs31 b.iter(black_box(|| { in tokio_init()
39 b.iter(black_box(|| { in ylong_init()
H A Dylong_tokio_udp.rs44 b.iter(|| { in ylong_udp_connect()
64 b.iter(|| { in tokio_udp_connect()
87 b.iter(|| { in ylong_udp_send_recv()
134 b.iter(|| { in tokio_udp_send_recv()
174 b.iter(|| { in ylong_udp_send_to_recv_from()
217 b.iter(|| { in tokio_udp_send_to_recv_from()
H A Dylong_tokio_task_creation.rs28 b.iter(black_box(|| {
44 b.iter(black_box(|| {
60 b.iter(black_box(|| {
79 b.iter(black_box(|| {
H A Dylong_tokio_async_file.rs36 b.iter(black_box(|| { in async_read()
60 b.iter(black_box(|| { in async_read_by_chars()
87 b.iter(black_box(|| { in async_write()
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Dstream.rs34 iter: core::slice::Iter<'a, FrameKind>,
54 pub fn iter(&self) -> FramesIter { in iter() functions
56 iter: self.list.iter(), in iter()
84 &self.iter in deref()
90 &mut self.iter in deref_mut()
98 self.iter.next() in next()
110 impl core::iter::IntoIterator for Frames {
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/
H A Dzip.rs14 use std::iter;
44 type Iter = iter::Zip<A::Iter, B::Iter>;
71 fn iter(self) -> Self::Iter { in iter() functions
72 self.a.iter().zip(self.b.iter()) in iter()
H A Dfilter.rs14 use std::iter;
31 type Iter = iter::Filter<P::Iter, F>;
59 fn iter(self) -> Self::Iter { in iter() functions
60 self.base.iter().filter(self.predicate) in iter()
H A Dmap.rs14 use std::iter;
37 type Iter = iter::Map<P::Iter, F>;
62 fn iter(self) -> Self::Iter { in iter() functions
63 self.base.iter().map(self.map_op) in iter()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dpar_iter.rs21 use ylong_runtime::iter::prelude::*;
39 let s = a.iter().copied().collect::<HashSet<i32>>(); in sdv_par_iter_test()
44 .iter() in sdv_par_iter_test()
45 .zip(b.iter()) in sdv_par_iter_test()
/commonlibrary/rust/ylong_json/src/value/array/
H A Dvec.rs123 /// let iter = array.iter();
125 pub fn iter(&self) -> Iter<'_, JsonValue> { in iter() functions
126 self.inner.iter() in iter()
247 for (a, b) in self.iter().zip(other.iter()) { in eq()
259 for (n, item) in self.inner.iter().enumerate() {
322 let mut iter = array.iter_mut(); in fmt() variables
323 assert_eq!(iter.next(), Some(&mut JsonValue::new_number(1.into()))); in fmt()
324 assert_eq!(iter in fmt()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Devents.rs82 pub fn iter(&self) -> IterEvent { in iter() functions
84 iter: &self.events, in iter()
111 self.iter() in fmt()
116 iter: &'a Vec<Event>,
123 if self.index < self.iter.len() { in next()
125 Some(&self.iter[self.index - 1]) in next()
132 self.iter.len() in count()
/commonlibrary/c_utils/base/include/
H A Dsafe_map.h142 auto iter = map_.find(key); in Find() local
143 if (iter != map_.end()) { in Find()
144 value = iter->second; in Find()
165 auto iter = map_.find(key); in FindOldAndSetNew() local
166 if (iter != map_.end()) { in FindOldAndSetNew()
167 oldValue = iter->second; in FindOldAndSetNew()
168 map_.erase(iter); in FindOldAndSetNew()
H A Dsafe_queue.h54 for (auto iter = deque_.begin(); iter != deque_.end(); iter++) { in Erase()
55 if (*iter == object) { in Erase()
56 deque_.erase(iter); in Erase()
/commonlibrary/ets_utils/js_sys_module/timer/
H A Dtimer.cpp96 auto iter = timerTable.find(tId); in ClearTimer() local
97 if (iter == timerTable.end()) { in ClearTimer()
101 TimerCallbackInfo* callbackInfo = iter->second; in ClearTimer()
254 auto iter = timerTable.begin(); in ClearEnvironmentTimer() local
255 while (iter != timerTable.end()) { in ClearEnvironmentTimer()
256 TimerCallbackInfo* callbackInfo = iter->second; in ClearEnvironmentTimer()
258 iter = timerTable.erase(iter); in ClearEnvironmentTimer()
261 iter++; in ClearEnvironmentTimer()
269 auto iter in HasTimer() local
[all...]
/commonlibrary/rust/ylong_json/src/value/object/
H A Dbtree.rs141 /// let iter = object.iter();
143 pub fn iter(&self) -> Iter<'_, String, JsonValue> { in iter() functions
144 self.inner.iter() in iter()
196 for (n, (key, value)) in self.inner.iter().enumerate() {
228 let mut iter = object.iter_mut(); in fmt() variables
230 iter.next(), in fmt()
233 assert_eq!(iter.next(), None); in fmt()
H A Dvec.rs105 self.inner.iter().any(|(k, _)| k == key) in contains_key()
137 let pos = self.inner.iter().position(|(k, _)| k == key)?; in remove()
148 /// let iter = object.iter();
150 pub fn iter(&self) -> Iter<'_, (String, JsonValue)> { in iter() functions
151 self.inner.iter() in iter()
181 self.inner.iter().find(|(k, _)| k == key).map(|(_, v)| v) in iter()
236 for (k, v) in self.iter() { in eq()
248 for (n, (key, value)) in self.inner.iter().enumerate() {
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/collections/
H A Dmod.rs23 ($t: ty, $iter: ty, $f: ident, impl $($args: tt)*) => {
25 type Data = $iter;
/commonlibrary/rust/ylong_http/ylong_http/src/
H A Dheaders.rs239 for b in input.iter() { in normalize()
328 if !bytes.iter().all(|b| Self::is_valid(*b)) { in from_bytes()
369 if !bytes.iter().all(|b| Self::is_valid(*b)) { in append_bytes()
394 for (n, i) in self.inner.iter().enumerate() { in to_string()
406 for (n, i) in self.inner.iter().enumerate() {
425 /// for sub_value in value.iter() {
429 pub fn iter(&self) -> HeaderValueIter<'_> { in iter() functions
430 self.inner.iter() in iter()
516 /// This struct is created by [`HeaderValue::iter`].
518 /// [`HeaderValue::iter`]
829 pub fn iter(&self) -> HeadersIter<'_> { iter() functions
1282 let mut iter = headers.iter(); ut_headers_iter() variables
[all...]
/commonlibrary/ets_utils/js_sys_module/process/
H A Djs_process.cpp105 for (auto iter = pgrous.begin(); iter != pgrous.end(); iter++) { in GetGroups()
106 auto receive = static_cast<uint32_t>(*iter); in GetGroups()
273 auto iter = eventMap.equal_range(temp); in Off() local
274 while (iter.first != iter.second) { in Off()
275 NAPI_CALL(env, napi_delete_reference(env, iter.first->second)); in Off()
277 iter.first = eventMap.erase(iter in Off()
453 auto iter = eventMap.begin(); ClearReference() local
[all...]

Completed in 11 milliseconds

12345