| /commonlibrary/rust/ylong_runtime/ylong_runtime_macros/src/ |
| D | select.rs | 29 let mut idx = 0; in tuple_parser() localVariable
30 while idx < buf.len() { in tuple_parser()
31 match &buf[idx] { in tuple_parser()
37 idx += 1; in tuple_parser()
42 idx += 1; in tuple_parser()
47 idx += 1; in tuple_parser()
59 idx += 1; in tuple_parser()
65 idx += 1; in tuple_parser()
74 let default_or_except = TokenStream::from((buf[idx]).to_owned()); in tuple_parser()
82 idx += 1; in tuple_parser()
|
| /commonlibrary/ets_utils/js_api_module/convertxml/src/ |
| D | js_convertxml.ts | 78 let idx: number = 0;
83 while ((idx = strXml.indexOf(']]><![CDATA')) !== -1) {
84 …strXml = strXml.substring(0, idx + LESS_SIGN_INDEX) + ' ' + strXml.substring(idx + LESS_SIGN_INDEX…
86 while ((idx = strXml.indexOf('>', idxSec)) !== -1) {
87 idxThir = strXml.indexOf('<', idx);
88 strXml = dealPriorReplace(strXml, idx, idxThir);
89 idxSec = strXml.indexOf('<', idx);
104 function dealPriorReplace(strXml: string, idx: number, idxThir: number): string {
105 let i: number = idx + 1;
112 let j: number = idx + 1;
[all …]
|
| /commonlibrary/c_utils/base/src/ |
| D | event_demultiplexer.cpp | 120 for (int idx = 0; idx < nfds; ++idx) { in Polling() local
121 int targetFd = epollEvents[idx].data.fd; in Polling()
122 uint32_t events = epollEvents[idx].events; in Polling()
132 for (size_t idx = 0u; idx < taskQue.size() && idx < eventQue.size(); idx++) { in Polling() local
133 taskQue[idx]->HandleEvents(eventQue[idx]); in Polling()
|
| D | io_event_epoll.cpp | 117 for (int idx = 0; idx < nfds; ++idx) { in Polling() local
118 …res.emplace_back(std::make_pair(epollEvents[idx].data.fd, Epoll2Reactor(epollEvents[idx].events))); in Polling()
|
| D | io_event_reactor.cpp | 264 for (size_t idx = 0u; idx < events.size(); idx++) { in HandleAll() local
265 int fd = events[idx].first; in HandleAll()
266 EventId event = events[idx].second; in HandleAll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | file_buf.rs | 21 idx: usize, field
31 idx: 0, in with_capacity()
36 self.buf.len() - self.idx in remaining()
41 let r_idx = n + self.idx; in append_to()
42 buf.append(&self.buf[self.idx..r_idx]); in append_to()
45 self.idx = 0; in append_to()
48 self.idx = r_idx; in append_to()
100 self.idx = 0; in clear()
|
| D | async_file.rs | 41 idx: u64, field
103 idx: 0, in new()
298 res.map(|u| file.idx = u) in set_len()
357 if let SeekFrom::Current(ref mut idx) = pos { in poll_seek()
358 *idx -= unread in poll_seek()
381 if let Ok(idx) = res { in poll_seek()
382 inner.idx = idx; in poll_seek()
447 if let Ok(idx) = res { in poll_read()
448 inner.idx = idx; in poll_read()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
| D | slice.rs | 25 let idx = self.len() >> 1; in split() localVariable
26 let (left, right) = self.split_at(idx); in split()
41 let idx = self.len() >> 1; in split() localVariable
42 let (left, right) = self.split_at_mut(idx); in split()
|
| D | vec.rs | 27 let idx = self.len() >> 1; in split() localVariable
28 let right = self.split_off(idx); in split()
|
| /commonlibrary/ets_utils/js_sys_module/timer/ |
| D | timer.cpp | 31 for (size_t idx = 0; idx < argc_; idx++) { in ~TimerCallbackInfo() local
32 Helper::NapiHelper::DeleteReference(env_, argv_[idx]); in ~TimerCallbackInfo()
123 for (size_t idx = 0; idx < callbackInfo->argc_; idx++) { in TimerCallback() local
124 callbackArgv[idx] = Helper::NapiHelper::GetReferenceValue(env, callbackInfo->argv_[idx]); in TimerCallback()
195 for (size_t idx = 0; idx < callbackArgc; idx++) { in SetTimeoutInner() local
196 callbackArgv[idx] = in SetTimeoutInner()
197 … Helper::NapiHelper::CreateReference(env, argv[idx + 2], 1); // 2 include callback and timeout in SetTimeoutInner()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| D | mod.rs | 88 let mut idx = 0; in trim_front_lwsp() localVariable
91 SP | HTAB => idx += 1, in trim_front_lwsp()
95 &buf[idx..] in trim_front_lwsp()
100 let mut idx = 0; in trim_back_lwsp() localVariable
103 SP | HTAB => idx += 1, in trim_back_lwsp()
107 &buf[..buf.len() - idx] in trim_back_lwsp()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| D | slab.rs | 318 let idx = locked.index_for(value); in release() localVariable
319 locked.slots[idx].next = locked.head as u32; in release()
320 locked.head = idx; in release()
338 let idx = locked.head; in allocate() localVariable
339 let slot = &locked.slots[idx]; in allocate()
348 Some((me.addr(idx), slot.gen_ref(me))) in allocate()
352 let idx = locked.slots.len(); in allocate() localVariable
354 if idx == 0 { in allocate()
371 Some((me.addr(idx), locked.slots[idx].gen_ref(me))) in allocate()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ffi/ |
| D | stack.rs | 23 pub(crate) fn OPENSSL_sk_value(stack: *const OPENSSL_STACK, idx: c_int) -> *mut c_void; in OPENSSL_sk_value()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| D | encoder.rs | 519 idx: usize, field
524 Self { src, idx: 0 } in new()
530 let input_len = self.src.len() - self.idx; in encode()
539 dst[..input_len].copy_from_slice(&self.src[self.idx..]); in encode()
544 dst[..].copy_from_slice(&self.src[self.idx..self.idx + output_len]); in encode()
545 self.idx += output_len; in encode()
|
| D | decoder.rs | 292 Ok(idx) => DecResult::Decoded((repr, idx)), in decode()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| D | integer.rs | 172 Ok(idx) => assert_eq!(idx, $fb_res), in ut_integer_decode()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | http_body.rs | 332 let mut idx = 0; in merge_chunks() localVariable
336 buf.copy_within(st..ed, idx); in merge_chunks()
337 idx += len; in merge_chunks()
339 Ok((idx, finished)) in merge_chunks()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | http_body.rs | 509 let mut idx = 0; in merge_chunks() localVariable
513 buf.copy_within(st..ed, idx); in merge_chunks()
514 idx += len; in merge_chunks()
516 Ok((idx, finished)) in merge_chunks()
|
| /commonlibrary/memory_utils/libdmabufheap/test/unittest/libdmabufheap/ |
| 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/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | queue.rs | 270 let idx = (rear & MASK) as usize; in push_back() localVariable
271 let ptr = self.buffer[idx].get(); in push_back()
470 let idx = (curr & MASK) as usize; in pop_batch() localVariable
471 let ptr = inner_buf.buffer[idx].get(); in pop_batch()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| D | multi.rs | 148 for (idx, xpart) in list.into_iter().enumerate() { in push_list_to_stages()
156 if idx == len - 1 { in push_list_to_stages()
|