Home
last modified time | relevance | path

Searched refs:next (Results 1 - 25 of 42) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dslots.rs28 next: usize,
32 fn new(val: T, prev: usize, next: usize) -> Entry<T> { in new()
36 next, in new()
55 next: usize,
85 let key = self.next; in push_back()
91 // The next slot is exactly the next position of the array. in push_back()
93 self.next = key + 1; in push_back()
96 // The next slot is the recycled slot. in push_back()
97 // Update the index of `next` an in push_back()
289 fn next(&mut self) -> Option<(usize, &'a T)> { fmt() functions
[all...]
H A Dlinked_list.rs29 next: Option<NonNull<T>>,
36 next: None,
44 let next = T::node(node).as_ref().next; in remove_node()
47 Some(prev) => T::node(prev).as_mut().next = next, in remove_node()
49 match next { in remove_node()
51 Some(next) => T::node(next).as_mut().prev = prev, in remove_node()
54 T::node(node).as_mut().next in remove_node()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dstate.rs132 let mut next = cur; variables
133 next &= !SCHEDULING;
134 next |= RUNNING;
135 if is_canceled(next) {
136 action = StateAction::Canceled(next);
139 let res = self.0.compare_exchange(cur, next, AcqRel, Acquire);
161 let mut next = cur; variables
162 next &= !RUNNING;
163 next |= FINISHED;
165 let res = self.0.compare_exchange(cur, next, AcqRe
190 let mut next = cur; global() variables
226 let mut next = cur; global() variables
251 let mut next = cur; global() variables
270 let mut next = cur; global() variables
305 let mut next = cur; global() variables
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Daddr.rs221 assert_eq!(Some(expected_addr), addrs_iter.next()); in ut_to_socket_addrs_str()
222 assert!(addrs_iter.next().is_none()); in ut_to_socket_addrs_str()
262 assert_eq!(Some(expected_addr), addrs_iter.next()); in ut_to_socket_addrs_str_u16()
263 assert!(addrs_iter.next().is_none()); in ut_to_socket_addrs_str_u16()
284 assert_eq!(Some(expected_addr), addrs_iter.next()); in ut_to_socket_addrs_str_u16()
285 assert!(addrs_iter.next().is_none()); in ut_to_socket_addrs_str_u16()
302 assert_eq!(Some(expected_addr), addrs_iter.next()); in ut_to_socket_addrs_ipaddr_u16()
303 assert!(addrs_iter.next().is_none()); in ut_to_socket_addrs_ipaddr_u16()
311 assert_eq!(Some(expected_addr), addrs_iter.next()); in ut_to_socket_addrs_ipaddr_u16()
312 assert!(addrs_iter.next() in ut_to_socket_addrs_ipaddr_u16()
[all...]
/commonlibrary/utils_lite/include/
H A Dutils_list.h39 struct UTILS_DL_LIST *pstNext; /* < Current node's pointer to the next node */
67 * @brief Point to the next node pointed to by the current node.
71 * <li>This API is used to point to the next node pointed to by the current node.</li>
419 * @param item [IN] Current node's pointer to the next node.
469 * @param next [IN] Save the next node.
479 #define UTILS_DL_LIST_FOR_EACH_ENTRY_SAFE(item, next, list, type, member) \
481 next = UTILS_DL_LIST_ENTRY((item)->member.pstNext, type, member); \
483 item = next, next
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dqueue.rs41 next: AtomicPtr<Block<T>>,
48 next: AtomicPtr::new(ptr::null_mut()), in new()
53 self.next.store(ptr::null_mut(), Release); in reclaim()
58 .next in try_insert()
75 Err(next) => { in insert()
77 // therefore this next ptr is guaranteed to be non-null in insert()
78 curr = unsafe { next.as_ref().unwrap() }; in insert()
137 let next_block = block.next.load(Acquire); in send_inner()
198 // next is initialized during block creation
199 head.block = NonNull::new(block.next
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Dstream.rs97 fn next(&mut self) -> Option<Self::Item> { in next() functions
98 self.iter.next() in next()
105 fn next(&mut self) -> Option<Self::Item> { in next() functions
106 self.into_iter.next() in next()
/commonlibrary/rust/ylong_json/src/reader/
H A Dio_reader.rs27 /// let char = io_reader.next();
120 fn next(&mut self) -> Result<Option<u8>> { in next() functions
314 /// UT test case for `IoReader::next`.
321 /// 2. Call `IoReader::next`.
331 assert_eq!(io_reader.next().unwrap(), Some(1)); in ut_io_reader_next()
333 let _ = io_reader.next().unwrap(); in ut_io_reader_next()
335 assert_eq!(io_reader.next().unwrap(), Some(1)); in ut_io_reader_next()
336 assert_eq!(io_reader.next().unwrap(), None); in ut_io_reader_next()
341 assert_eq!(io_reader.next().unwrap(), None); in ut_io_reader_next()
347 assert!(io_reader.next() in ut_io_reader_next()
[all...]
/commonlibrary/rust/ylong_json/src/
H A Dlinked_list.rs64 (*(self.tail as *mut Node<T>)).next = node;
84 (*(self.tail as *mut Node<T>)).next = null();
210 self.head = node.next;
212 (*(node.prev as *mut Node<T>)).next = node.next;
215 if node.next.is_null() {
218 (*(node.next as *mut Node<T>)).prev = node.prev;
282 next: *const Node<T>,
292 next: null(),
334 fn next( functions
383 fn next(&mut self) -> Option<&'a mut T> { next() functions
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/
H A Dpercent_encoding.rs71 while let Some(char) = origin.next() { in parse_scheme()
91 if matches!(tmp_chars.next(), Some(c) if matches!(c, '/')) {
111 while let Some(ch) = chars.next() {
127 if matches!(remaining.clone().next(), Some(c) if matches!(c, '/' | '?' | '#')) {
154 let c = if let Some(ch) = origin.next() { in parse_authority()
300 self.remaining.next().map(|c| (c, &url_str[..c.len_utf8()]))
313 fn next(&mut self) -> Option<Self::Item> { in next() functions
314 self.remaining.next() in next()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dalt_svc.rs56 let alternative = value_it.next()?; in parse_alt_svc()
59 let http_version = words.next()?.try_into().ok()?; in parse_alt_svc()
60 let mut host_port = words.next()?; in parse_alt_svc()
82 if para_it.next()? == b"ma" { in parse_alt_svc()
83 let para = str::from_utf8(para_it.next()?).ok()?; in parse_alt_svc()
/commonlibrary/memory_utils/libpurgeablemem/c/src/
H A Dpurgeable_mem_builder_c.c61 struct PurgMemBuilder *next = NULL; in PurgMemBuilderDestroy() local
63 next = curr->nextBuilder; in PurgMemBuilderDestroy()
65 curr = next; in PurgMemBuilderDestroy()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dasync_dir.rs32 let entry = dir.next().await.unwrap().unwrap(); in sdv_async_dir()
36 let entry = dir.next().await.unwrap().unwrap(); in sdv_async_dir()
41 assert!(dir.next().await.unwrap().is_none()); in sdv_async_dir()
H A Dasync_buf_read.rs112 /// 4. The server calls `split` to get segments and calls `next` with a
123 assert_eq!(segments.next().await.unwrap(), Some(b"lorem".to_vec())); in sdv_buf_reader_split()
124 assert_eq!(segments.next().await.unwrap(), Some(b"ipsum".to_vec())); in sdv_buf_reader_split()
125 assert_eq!(segments.next().await.unwrap(), Some(b"dolor".to_vec())); in sdv_buf_reader_split()
126 assert_eq!(segments.next().await.unwrap(), None); in sdv_buf_reader_split()
/commonlibrary/ets_utils/js_api_module/convertxml/
H A Djs_convertxml.cpp151 attr = attr->next; in SetAttributes()
275 pNode = pNode->next; in GetXMLInfo()
585 curNode->next && curNode->next->type == xmlElementType::XML_TEXT_NODE && in DealCDataInfo()
586 curNode->next->next && curNode->next->next->type == xmlElementType::XML_CDATA_SECTION_NODE) { in DealCDataInfo()
587 char *curContent = reinterpret_cast<char*>(xmlNodeGetContent(curNode->next)); in DealCDataInfo()
595 curNode = curNode->next in DealCDataInfo()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Dtimer.rs137 /// Waits until the next Instant reached.
148 let next = match deadline.checked_add(self.period) {
153 self.start.as_mut().reset(next);
155 Poll::Ready(next)
197 /// 2. Uses tick() to wait until next Instant.
222 /// 2. Uses tick() to wait until next Instant.
/commonlibrary/rust/ylong_json/src/value/object/
H A Dbtree.rs230 iter.next(), in fmt()
233 assert_eq!(iter.next(), None); in fmt()
H A Dvec.rs298 iter_mut.next(), in fmt()
301 assert_eq!(iter_mut.next(), None); in fmt()
H A Dlinked_list.rs350 iter_mut.next(), in fmt()
353 assert_eq!(iter_mut.next(), None); in fmt()
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Ddecoder.rs49 /// let next_frame = iter.next();
62 /// let next_frame = iter.next();
89 /// let next_frame = iter.next();
127 fn next(&mut self) -> Option<Self::Item> { in next() functions
128 self.iter.next() in next()
135 fn next(&mut self) -> Option<Self::Item> { in next() functions
136 self.into_iter.next() in next()
171 /// let frame_kind = decoded_frames.iter().next().unwrap();
1034 FrameKind: frames_iter.next().expect("take next fram
[all...]
H A Dframe.rs634 assert_eq!(setting_iter.next(), Some(&Setting::HeaderTableSize(4096))); in ut_settings_builder()
636 assert_eq!(setting_iter.next(), Some(&Setting::EnablePush(true))); in ut_settings_builder()
638 assert_eq!(setting_iter.next(), Some(&Setting::MaxFrameSize(16384))); in ut_settings_builder()
640 assert_eq!(setting_iter.next(), Some(&Setting::MaxHeaderListSize(8192))); in ut_settings_builder()
642 assert_eq!(setting_iter.next(), None); in ut_settings_builder()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dqueue.rs219 let next = if steal_pos == real_pos {
225 let res = self.front.compare_exchange(head, next, AcqRel, Acquire);
250 let next = wrap(front_real, front_real); in sync_steal_pos()
251 let res = self.front.compare_exchange(prev, next, AcqRel, Acquire); in sync_steal_pos()
305 let next = wrap(front, front.wrapping_add(count as u16));
307 match self.front.compare_exchange(prev, next, Release, Acquire) {
329 self.sync_steal_pos(next);
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Dschedule_io.rs116 let mut next = Bit::from_usize(0); in reset() variables
117 next.set_by_mask(GENERATION, new_generation); in reset()
118 self.status.store(next.as_usize(), Release); in reset()
/commonlibrary/rust/ylong_json/src/value/array/
H A Dvec.rs323 assert_eq!(iter.next(), Some(&mut JsonValue::new_number(1.into()))); in fmt()
324 assert_eq!(iter.next(), None); in fmt()
/commonlibrary/rust/ylong_http/ylong_http/tests/
H A Dsdv_http_body.rs197 let chunk_1 = chunks_1.iter().next().unwrap();
199 let chunk_2 = chunks_1.iter().next().unwrap();

Completed in 14 milliseconds

12