Searched refs:curr (Results 1 - 11 of 11) sorted by relevance
| /commonlibrary/memory_utils/libpurgeablemem/c/src/ |
| H A D | purgeable_mem_builder_c.c | 60 struct PurgMemBuilder *curr = builder; in PurgMemBuilderDestroy() local
62 while (curr) { in PurgMemBuilderDestroy()
63 next = curr->nextBuilder; in PurgMemBuilderDestroy()
64 free(curr); in PurgMemBuilderDestroy()
65 curr = next; in PurgMemBuilderDestroy()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | semaphore_inner.rs | 118 let mut curr = self.permits.load(Acquire); variables
120 if curr & CLOSED == CLOSED {
124 if curr == 0 {
130 .compare_exchange(curr, curr - (1 << PERMIT_SHIFT), AcqRel, Acquire)
136 curr = actual;
160 curr: &mut usize, in update_permit()
165 .compare_exchange(*curr, *curr - permit_num, AcqRel, Acquire) in update_permit()
174 Err(actual) => *curr in update_permit()
185 let mut curr = self.permits.load(Acquire); poll_acquire() variables
[all...] |
| H A D | rwlock.rs | 147 Err(curr) => read_count = curr,
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/buffer/ |
| H A D | window.rs | 43 let (curr, overflow) = self.size.overflowing_add(size as i32);
47 if curr > crate::util::h2::MAX_FLOW_CONTROL_WINDOW as i32 {
50 self.size = curr;
|
| /commonlibrary/ets_utils/js_concurrent_module/common/helper/ |
| H A D | path_helper.h | 144 size_t curr = entryPoint.find(SLASH_TAG); in NormalizePath() local
147 while (curr != std::string::npos) { in NormalizePath()
148 if (curr > prev) { in NormalizePath()
149 std::string elem = entryPoint.substr(prev, curr - prev); in NormalizePath()
150 if (elem == DOUBLE_POINT_TAG && entryPoint.at(curr) == SLASH_TAG in NormalizePath()
157 prev = curr + 1; in NormalizePath()
158 curr = entryPoint.find(SLASH_TAG, prev); in NormalizePath()
|
| /commonlibrary/rust/ylong_json/tests/ |
| H A D | sdv_adapter_test.rs | 187 let curr = json.take().unwrap(); in sdv_adapter_parse_and_print()
189 let curr_str = ylong_json_print_unformatted(curr); in sdv_adapter_parse_and_print()
199 ylong_json_delete(curr); in sdv_adapter_parse_and_print()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
| H A D | queue.rs | 67 let mut curr = self; in insert() variables
73 match curr.try_insert(ptr) { in insert()
78 curr = unsafe { next.as_ref().unwrap() }; in insert()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | queue.rs | 482 let mut curr = rear; variables
491 let idx = (curr & MASK) as usize;
496 curr = curr.wrapping_add(1);
504 inner_buf.rear.store(curr, Release);
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| H A D | slots.rs | 130 let curr = self.head; in pop_front()
131 if let Some(entry) = self.entries.get_mut(curr) { in pop_front()
147 self.next = curr; in pop_front()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | driver.rs | 183 .set_readiness(Some(token.0), Tick::Set(self.tick), |curr| curr | ready) in dispatch()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | decoder.rs | 339 Some(curr) => { in subtract_payload_len()
340 let (remain, overflow) = curr.overflowing_sub(off as u64); in subtract_payload_len()
|
Completed in 9 milliseconds