| /commonlibrary/rust/ylong_runtime/ylong_runtime_macros/src/ |
| H A D | select.rs | 44 fn parse_ident(ident: &Ident, idx: &mut usize, flags: &mut Flags) -> bool { in parse_ident()
49 *idx += 1; in parse_ident()
54 *idx += 1; in parse_ident()
59 *idx += 1; in parse_ident()
69 idx: &mut usize, in parse_group()
78 *idx += 1; in parse_group()
84 *idx += 1; in parse_group()
90 fn parse_token(buf: &[TokenTree], idx: &mut usize, flags: &mut Flags, builder: &mut ParserBuilder) { in parse_token()
91 match &buf[*idx] { in parse_token()
93 if !parse_ident(ident, idx, flag in parse_token()
122 let mut idx = 0; global() variables
[all...] |
| /commonlibrary/c_utils/base/src/ |
| H A D | event_demultiplexer.cpp | 130 for (int idx = 0; idx < nfds; ++idx) { in Polling()
131 int targetFd = epollEvents[idx].data.fd; in Polling()
132 uint32_t events = epollEvents[idx].events; in Polling()
144 for (size_t idx = 0u; idx < taskQue.size() && idx < eventQue.size(); idx++) { in Polling()
145 taskQue[idx] in Polling()
[all...] |
| H A D | io_event_epoll.cpp | 117 for (int idx = 0; idx < nfds; ++idx) { in Polling()
118 res.emplace_back(std::make_pair(epollEvents[idx].data.fd, Epoll2Reactor(epollEvents[idx].events))); in Polling()
|
| H A D | io_event_reactor.cpp | 264 for (size_t idx = 0u; idx < events.size(); idx++) { in HandleAll()
265 int fd = events[idx].first; in HandleAll()
266 EventId event = events[idx].second; in HandleAll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
| H A D | slice.rs | 25 let idx = self.len() >> 1; in split()
26 let (left, right) = self.split_at(idx); in split()
41 let idx = self.len() >> 1; in split()
42 let (left, right) = self.split_at_mut(idx); in split()
|
| H A D | vec.rs | 27 let idx = self.len() >> 1; in split()
28 let right = self.split_off(idx); in split()
|
| /commonlibrary/ets_utils/js_sys_module/timer/ |
| H A D | timer.cpp | 36 for (size_t idx = 0; idx < argc_; idx++) { in ~TimerCallbackInfo()
37 Helper::NapiHelper::DeleteReference(env_, argv_[idx]); in ~TimerCallbackInfo()
136 for (size_t idx = 0; idx < callbackInfo->argc_; idx++) { in TimerCallback()
137 callbackArgv[idx] = Helper::NapiHelper::GetReferenceValue(env, callbackInfo->argv_[idx]); in TimerCallback()
191 for (size_t idx in SetTimeoutInnerCore()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | file_buf.rs | 21 idx: usize,
29 idx: 0,
34 self.buf.len() - self.idx
39 let r_idx = n + self.idx;
40 buf.append(&self.buf[self.idx..r_idx]);
43 self.idx = 0;
46 self.idx = r_idx;
98 self.idx = 0;
|
| H A D | async_file.rs | 45 idx: u64,
115 idx: 0, in fmt()
306 res.map(|u| file.idx = u) in fmt()
489 if let SeekFrom::Current(ref mut idx) = pos { in poll_seek()
490 *idx -= unread in poll_seek()
513 if let Ok(idx) = res { in poll_seek()
514 inner.idx = idx; in poll_seek()
580 if let Ok(idx) = res { in poll_read()
581 inner.idx in poll_read()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | octets.rs | 37 let res = peek_bytes!($this.buf[$this.idx..], $ty, $len);
38 $this.idx += $len;
46 idx: usize,
51 ReadableBytes { buf, idx: 0 } in from()
55 peek_bytes!(self.buf[self.idx..], u8, 1)
99 self.buf.len() - self.idx in cap()
103 self.idx in index()
107 &self.buf[self.idx..] in remaining()
114 let curr = self.idx; in slice()
115 self.idx in slice()
[all...] |
| /commonlibrary/rust/ylong_json/src/reader/ |
| H A D | io_reader.rs | 34 idx: usize, // A counter of all bytes that have been read.
62 idx: 0,
131 self.idx += 1; in next()
166 self.idx += 1; in discard()
178 self.idx in index()
232 idx: usize,
237 Self { vec, idx: 0 } in new()
243 if self.idx == self.vec.len() { in read()
246 let last = cmp::min(self.idx + buf.len(), self.vec.len()); in read()
247 let len = last - self.idx; in read()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| H A D | mod.rs | 88 let mut idx = 0; variables
91 SP | HTAB => idx += 1,
95 &buf[idx..]
100 let mut idx = 0; in trim_back_lwsp() variables
103 SP | HTAB => idx += 1, in trim_back_lwsp()
107 &buf[..buf.len() - idx] in trim_back_lwsp()
|
| /commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
| H A D | async_lock.cpp | 161 uint32_t idx = 0; in FillLockState() local
170 napi_create_int32(env, idx, &index); in FillLockState()
175 ++idx; in FillLockState()
177 idx = 0; in FillLockState()
186 napi_create_int32(env, idx, &index); in FillLockState()
191 ++idx; in FillLockState()
|
| H A D | async_lock_manager.cpp | 374 uint32_t idx = 0; in CreateLockStates() local
384 NAPI_CALL(env, napi_create_uint32(env, idx, &index)); in CreateLockStates()
386 ++idx; in CreateLockStates()
398 NAPI_CALL(env, napi_create_uint32(env, idx, &index)); in CreateLockStates()
400 ++idx; in CreateLockStates()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| H A D | encoder.rs | 527 idx: usize,
535 Self { src: dst, idx: 0 } in new()
537 Self { src, idx: 0 } in new()
548 let input_len = self.src.len() - self.idx; in encode()
557 dst[..input_len].copy_from_slice(&self.src[self.idx..]); in encode()
562 dst[..].copy_from_slice(&self.src[self.idx..self.idx + output_len]); in encode()
563 self.idx += output_len; in encode()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| H A D | multi.rs | 148 for (idx, xpart) in list.into_iter().enumerate() {
156 if idx == len - 1 {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| H A D | slab.rs | 319 let idx = locked.index_for(value); in release()
320 locked.slots[idx].next = locked.head as u32; in release()
321 locked.head = idx; in release()
339 let idx = locked.head; in allocate()
340 let slot = &locked.slots[idx]; in allocate()
349 Some((me.addr(idx), slot.gen_ref(me))) in allocate()
353 let idx = locked.slots.len(); in allocate()
355 if idx == 0 { in allocate()
372 Some((me.addr(idx), locked.slots[idx] in allocate()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | http_body.rs | 310 let mut idx = 0; in merge_chunks() variables
314 buf.copy_within(st..ed, idx); in merge_chunks()
315 idx += len; in merge_chunks()
317 Ok((idx, finished)) in merge_chunks()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| H A D | integer.rs | 172 Ok(idx) => assert_eq!(idx, $fb_res), in ut_integer_decode()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | queue.rs | 277 let idx = (rear & MASK) as usize;
278 let ptr = self.buffer[idx].get();
491 let idx = (curr & MASK) as usize;
492 let ptr = inner_buf.buffer[idx].get();
|
| H A D | async_pool.rs | 112 pub(crate) fn is_waked_by_last_search(&self, idx: usize) -> bool {
114 let is_waked_by_last_search = search_list[idx];
115 search_list[idx] = false;
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | encoder.rs | 750 Ok(idx) => DecResult::Decoded((inst, idx)), in decode()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| H A D | encoder.rs | 213 .map_or(false, |idx| (idx as u64) > self.table.known_recved_count()) in encode()
|
| /commonlibrary/memory_utils/libdmabufheap/test/unittest/libdmabufheap/ |
| H A D | dmabuf_alloc_test.cpp | 65 std::string::size_type idx = fileName.find("system"); in SetUp() local
66 if (idx != std::string::npos) { in SetUp()
|
| /commonlibrary/c_utils/base/test/benchmarktest/parcel_benchmark_test/ |
| H A D | parcel_benchmark_test.cpp | 546 for (unsigned int idx = 0; idx < DEFAULT_CPACITY / sizeof(T1); idx++) { in WriteDataToVector()
1449 for (size_t idx = 0; idx < vec1.size(); idx++) { in LoopReadVectorCmpData()
1450 AssertEqual(vec1[idx], vec2[idx], printInfo, state); in LoopReadVectorCmpData()
1457 for (size_t idx = 0; idx < vec in LoopReadVectorCmpData()
[all...] |