/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
H A D | seek_task.rs | 26 pos: Option<io::SeekFrom>, 30 pub(crate) fn new(seek: &'a mut T, pos: io::SeekFrom) -> SeekTask<'a, T> { 33 pos: Some(pos), 45 // before each take, the pos is set with some in poll() 46 let pos = self.pos.take().unwrap(); in poll() 47 let ret = Pin::new(&mut self.seek).poll_seek(cx, pos); 48 self.pos = Some(pos); [all...] |
H A D | async_seek.rs | 41 pos: SeekFrom, in poll_seek() 52 pos: SeekFrom, in poll_seek() 54 self.get_mut().as_mut().poll_seek(cx, pos) in poll_seek() 62 pos: SeekFrom, in poll_seek() 64 Pin::new(&mut **self).poll_seek(cx, pos) in poll_seek() 72 pos: SeekFrom, in poll_seek() 74 Pin::new(&mut **self).poll_seek(cx, pos) in poll_seek() 100 fn seek(&mut self, pos: SeekFrom) -> SeekTask<Self> in seek() 104 SeekTask::new(self, pos) in seek()
|
H A D | stdio.rs | 35 pos: usize, 42 pos: 0, in new() 51 self.inner.len() - self.pos 55 &self.inner[self.pos..] in bytes() 77 self.pos += n; 79 if self.pos == self.inner.len() { 81 self.pos = 0; 209 assert_eq!(buf_inner.pos, 0); in ut_test_stdio_basic()
|
/commonlibrary/ets_utils/js_api_module/uri/ |
H A D | js_uri.cpp | 89 size_t pos = data_.find('#'); // Fragment
in AnalysisUri() local 90 if (pos != std::string::npos) {
in AnalysisUri() 91 AnalysisFragment(pos);
in AnalysisUri() 96 pos = data_.find('?'); // Query
in AnalysisUri() 97 if (pos != std::string::npos) {
in AnalysisUri() 98 AnalysisQuery(pos);
in AnalysisUri() 103 pos = data_.find(':'); // Scheme
in AnalysisUri() 104 if (pos != std::string::npos) {
in AnalysisUri() 105 AnalysisScheme(pos);
in AnalysisUri() 117 pos in AnalysisUri() 162 AnalysisFragment(size_t pos) AnalysisFragment() argument 177 AnalysisQuery(size_t pos) AnalysisQuery() argument 188 AnalysisScheme(size_t pos) AnalysisScheme() argument 249 size_t pos = data_.find('/'); AnalysisHostAndPath() local 280 AnalysisPath(size_t pos) AnalysisPath() argument 291 AnalysisUserInfo(size_t pos) AnalysisUserInfo() argument 302 AnalysisPort(size_t pos) AnalysisPort() argument 510 size_t pos = 0; Normalize() local [all...] |
H A D | js_uri.h | 166 void AnalysisFragment(size_t pos);
167 void AnalysisQuery(size_t pos);
168 void AnalysisScheme(size_t pos);
171 void AnalysisPath(size_t pos);
172 void AnalysisUserInfo(size_t pos);
177 bool AnalysisPort(size_t pos);
|
/commonlibrary/ets_utils/js_api_module/url/ |
H A D | js_url.cpp | 79 size_t pos = 0;
in ReplaceSpecialSymbols() local 80 if ((pos = input.find(oldstr)) != std::string::npos) {
in ReplaceSpecialSymbols() 81 input.replace(pos, oldlen, newstr);
in ReplaceSpecialSymbols() 109 size_t pos = temp.find("%");
in DecodeSpecialChars() local 110 while (pos != std::string::npos && pos < len - 2) { // 2:end subscript backspace
in DecodeSpecialChars() 111 if (IsHexDigit(temp[pos + 1]) && IsHexDigit(temp[pos + 2])) { // 2:Determine the second character after %
in DecodeSpecialChars() 112 std::string subStr = temp.substr(pos + 1, 2); // 2:Truncate the last two digits of the %
in DecodeSpecialChars() 119 temp.replace(pos, in DecodeSpecialChars() 218 int pos = static_cast<int>(input.size()) - 1; AnalysisUsernameAndPasswd() local 261 size_t pos = 0; AnalysisPath() local 351 size_t pos = str.rfind(":"); DealIpv4() local 379 size_t pos = str.find("::"); FormatIpv6() local 474 size_t pos = 0; Compress() local 504 size_t pos = 0; IPv6Host() local 580 size_t pos = 0; RemovalIpv4() local 771 size_t pos = 0; AnalysisFilePath() local 812 AnalysisSpecialFile(std::string& temp, size_t pos, UrlData& urlinfo, std::bitset<static_cast<size_t>(BitsetStatusFlag::BIT_STATUS_11)>& flags) AnalysisSpecialFile() argument 835 size_t pos = 0; AnalysisFile() local 883 size_t pos = 0; AnalyHostPath() local 931 size_t pos = 0; AnalysisNoDefaultProtocol() local 957 AnalysisOnlyHost(const std::string& input, UrlData& urlinfo, std::bitset<static_cast<size_t>(BitsetStatusFlag::BIT_STATUS_11)>& flags, size_t pos) AnalysisOnlyHost() argument 982 JudgePos(size_t &pos, const size_t &length, const std::string& input) JudgePos() argument 991 SkipSlashSymbol(std::string& input, size_t& pos) SkipSlashSymbol() argument 1004 ParsingHostAndPath(std::string& input, UrlData& urlinfo, size_t& pos, std::bitset<static_cast<size_t>(BitsetStatusFlag::BIT_STATUS_11)>& flags) ParsingHostAndPath() argument 1039 size_t pos = 0; AnalysisHostAndPath() local 1062 size_t pos = 0; AnalysisInput() local 1139 size_t pos = input.find(':'); InitOnlyInput() local [all...] |
H A D | js_url.h | 93 std::bitset<static_cast<size_t>(BitsetStatusFlag::BIT_STATUS_11)>& flags, size_t pos);
96 void AnalysisSpecialFile(std::string& temp, size_t pos, UrlData& urlinfo,
100 void ParsingHostAndPath(std::string& input, UrlData& urlinfo, size_t& pos,
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
H A D | async_buf_reader.rs | 36 pos: usize, 78 pos: 0, in with_capacity() 142 &self.buf[self.pos..self.filled] in buffer() 175 self.pos = 0; in discard_buffer() 186 if self.filled == self.pos && buf.remaining() >= self.buf.len() { in poll_read() 203 if this.pos >= this.filled { 208 this.pos = 0; 211 Poll::Ready(Ok(&this.buf[this.pos..this.filled])) 216 this.pos = cmp::min(this.pos in consume() [all...] |
/commonlibrary/c_utils/base/src/ |
H A D | string_ex.cpp | 51 string::size_type pos = 0; in ReplaceStr() local 53 while ((pos = strTmp.find(src, pos)) != string::npos) { in ReplaceStr() 54 strTmp.replace(pos, src.length(), dst); in ReplaceStr() 55 pos += dst.length(); in ReplaceStr() 101 string::size_type pos = strTmp.find(sep); in SplitStr() local 102 if (string::npos == pos || sep.empty()) { in SplitStr() 109 strPart = needTrim ? TrimStr(strTmp.substr(0, pos)) : strTmp.substr(0, pos); in SplitStr() 113 strTmp = strTmp.substr(sep.size() + pos, strTm in SplitStr() 226 string::size_type pos = GetFirstSubStrBetween(strTmp, left, right, subString); GetSubStrBetween() local [all...] |
H A D | directory_ex.cpp | 120 string::size_type pos = fileName.rfind("."); in ExtractFileExt() local 121 if (pos == string::npos) { in ExtractFileExt() 125 return string(fileName).substr(pos + 1, fileName.size()); in ExtractFileExt() 170 auto pos = currentPath.find_last_of("/"); in GetDirFiles() local 171 if (pos != string::npos) { in GetDirFiles() 172 currentPath.erase(pos); in GetDirFiles() 445 string::size_type pos = fileName.find("."); in TransformFileName() local 447 if (pos == string::npos) { in TransformFileName() 458 transformfileName = string(fileName).substr(0, pos + 1); in TransformFileName()
|
/commonlibrary/ets_utils/js_api_module/buffer/ |
H A D | converter.cpp | 159 unsigned char *pos = nullptr; in Base64Encode() local 174 pos = out; in Base64Encode() 183 *pos = table[pStart[0] >> 2]; in Base64Encode() 185 *(pos + 1) = table[((pStart[0] & LOWER_2_BITS_MASK) << 4) | (pStart[1] >> 4)]; in Base64Encode() 187 *(pos + 2) = table[((pStart[1] & LOWER_4_BITS_MASK) << 2) | (pStart[2] >> 6)]; in Base64Encode() 189 *(pos + 3) = table[pStart[2] & LOWER_6_BITS_MASK]; in Base64Encode() 190 // 4 : the pointer of pos scrolls off 4 bytes to point the next 4 bytes of encoded chars in Base64Encode() 191 pos += 4; in Base64Encode() 199 *pos = table[pStart[0] >> 2]; in Base64Encode() 202 *(pos in Base64Encode() [all...] |
/commonlibrary/rust/ylong_json/src/reader/ |
H A D | io_reader.rs | 35 pos: Position, 63 pos: Position::new(1, 1), 134 self.pos.line += 1; in next() 135 self.pos.column = 1; in next() 137 self.pos.column += 1; in next() 169 self.pos.line += 1; in discard() 170 self.pos.column = 1; in discard() 172 self.pos.column += 1; in discard() 183 self.pos.clone() in position() 307 assert_eq!(io_reader.pos in ut_io_reader_new() [all...] |
/commonlibrary/ets_utils/js_concurrent_module/common/helper/ |
H A D | path_helper.h | 123 size_t pos = moduleName.rfind(SLASH_TAG); in ConcatFileNameForWorker() local 124 if (pos != std::string::npos) { in ConcatFileNameForWorker() 125 moduleName = moduleName.substr(0, pos + 1); // from spcific file to dir in ConcatFileNameForWorker() 171 size_t pos = res.rfind(POINT_TAG); in NormalizePath() local 172 if (pos != std::string::npos) { in NormalizePath() 173 std::string suffix = res.substr(pos); in NormalizePath() 175 res.erase(pos, suffix.length()); in NormalizePath()
|
H A D | error_helper.h | 177 auto pos = rawErrorInfo.rfind(delimiter); in SplitErrorFileInfo() local 178 while (pos != std::string::npos && count > 0) { in SplitErrorFileInfo() 179 result.push_back(rawErrorInfo.substr(pos + 1)); in SplitErrorFileInfo() 180 rawErrorInfo = rawErrorInfo.substr(0, pos); in SplitErrorFileInfo() 181 pos = rawErrorInfo.rfind(delimiter); in SplitErrorFileInfo()
|
/commonlibrary/ets_utils/js_sys_module/console/ |
H A D | console.cpp | 80 size_t pos = 0; in ParseLogContent() local 82 for (; pos < len; ++pos) { in ParseLogContent() 86 if (formatStr[pos] == '%') { in ParseLogContent() 87 if (pos + 1 >= len) { in ParseLogContent() 90 switch (formatStr[pos + 1]) { in ParseLogContent() 100 ++pos; in ParseLogContent() 103 ret += formatStr[pos]; in ParseLogContent() 104 ++pos; in ParseLogContent() 107 ret += formatStr[pos]; in ParseLogContent() [all...] |
/commonlibrary/rust/ylong_json/src/value/object/ |
H A D | vec.rs | 137 let pos = self.inner.iter().position(|(k, _)| k == key)?; in remove() 138 Some(self.inner.remove(pos).1) in remove()
|
/commonlibrary/c_utils/base/test/benchmarktest/string_benchmark_test/ |
H A D | string_benchmark_test.cpp | 671 string::size_type pos = GetFirstSubStrBetween(strBase, left, right, strValue); in BENCHMARK_F() local 672 AssertEqual(GETSUBSTR01_POS_VALUE1, (int)pos, "17 did not equal (int)pos as expected.", state); in BENCHMARK_F() 677 pos = GetFirstSubStrBetween(strBase, left, right, strValue); in BENCHMARK_F() 678 AssertEqual(GETSUBSTR01_POS_VALUE2, (int)pos, "27 did not equal (int)pos as expected.", state); in BENCHMARK_F() 692 string::size_type pos = GetFirstSubStrBetween(strBase, left, right, strValue); in BENCHMARK_F() local 693 AssertEqual(pos, string::npos, "pos did not equal string::npos as expected.", state); in BENCHMARK_F()
|
/commonlibrary/c_utils/base/test/unittest/common/ |
H A D | utils_string_test.cpp | 600 string::size_type pos = GetFirstSubStrBetween(strBase, left, right, strValue); in HWTEST_F() local 601 EXPECT_EQ(17, (int)pos); in HWTEST_F() 606 pos = GetFirstSubStrBetween(strBase, left, right, strValue); in HWTEST_F() 607 EXPECT_EQ(27, (int)pos); in HWTEST_F() 617 string::size_type pos = GetFirstSubStrBetween(strBase, left, right, strValue); in HWTEST_F() local 618 EXPECT_EQ(pos, string::npos); in HWTEST_F()
|
H A D | utils_directory_test.cpp | 197 auto pos = find(files.begin(), files.end(), filepath); in HWTEST_F() local 198 EXPECT_NE(pos, files.end()); in HWTEST_F()
|
/commonlibrary/c_utils/base/test/benchmarktest/directory_benchmark_test/ |
H A D | directory_benchmark_test.cpp | 189 auto pos = find(filenames.begin(), filenames.end(), resultfile[0]); in BENCHMARK_F() local 190 AssertUnequal(pos, filenames.end(), "pos was not different from filenames.end() as expected.", state); in BENCHMARK_F() 192 pos = find(filenames.begin(), filenames.end(), resultfile[1]); in BENCHMARK_F() 193 AssertUnequal(pos, filenames.end(), "pos was not different from filenames.end() as expected.", state); in BENCHMARK_F()
|
/commonlibrary/rust/ylong_json/src/value/ |
H A D | index.rs | 224 if let Some(pos) = object.iter().position(|(k, _)| k == self) { in index_into_mut() 225 return object.get_mut_by_position(pos).unwrap(); in index_into_mut()
|
/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
H A D | decoder.rs | 575 let pos = self.length - self.octets.len(); in decode() 576 self.octets.extend_from_slice(&buf[..pos]); in decode() 577 DecResult::Decoded((pos, self.octets)) in decode() 695 let pos = self.length - self.read; in decode() 696 if self.huffman.decode(&buf[..pos]).is_err() { in decode() 699 // let (_, mut remain_buf) = buf.split_at_mut(pos); in decode() 701 Ok(vec) => DecResult::Decoded((pos, vec)), in decode()
|
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
H A D | mod.rs | 435 let mut pos = 0; variables 438 let n = conn.read(&mut buf[pos..]).await?; 444 pos += n; 445 let resp = &buf[..pos]; 450 if pos == buf.len() {
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
H A D | queue.rs | 207 let pos = loop { 232 let task = self.buffer[(pos & MASK) as usize].get(); 257 "steal pos: {}, real_pos: {}, they should not be the same", in sync_steal_pos()
|
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
H A D | async_fs.rs | 354 let pos = file.stream_position().await.unwrap(); in sdv_async_fs_open_options() 360 let res = file.seek(SeekFrom::Start(pos)).await.unwrap(); in sdv_async_fs_open_options()
|