Home
last modified time | relevance | path

Searched refs:end (Results 1 - 25 of 74) sorted by relevance

123

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dread_buf.rs21 /// filled, and a region at the end that is fully uninitialized. The filled
152 let end = self.filled + n; in initialize_unfilled_to()
154 if self.initialized < end { in initialize_unfilled_to()
158 .write_bytes(0, end - self.initialized); in initialize_unfilled_to()
160 self.initialized = end; in initialize_unfilled_to()
162 unsafe { &mut *(&mut self.buf[self.filled..end] as *mut [MaybeUninit<u8>] as *mut [u8]) } in initialize_unfilled_to()
217 let end = std::cmp::min(self.filled + n, self.capacity()); in assume_init()
218 if end > self.initialized { in assume_init()
219 self.initialized = end; in assume_init()
239 let end in append()
[all...]
/commonlibrary/ets_utils/js_api_module/buffer/
H A Djs_buffer.cpp121 void Buffer::SubBuffer(Buffer *tBuf, uint32_t start, uint32_t end) in SubBuffer() argument
127 this->Init(tBuf->GetRaw(), tBuf->byteOffset_ + start, (end - start)); in SubBuffer()
337 void Buffer::WriteStringLoop(string value, unsigned int offset, unsigned int end, unsigned int length) in WriteStringLoop() argument
339 if (end - offset <= 0 || value.length() == 0) { in WriteStringLoop()
342 unsigned int loop = length > end - offset ? end - offset : length; in WriteStringLoop()
345 while (offset < end) { in WriteStringLoop()
346 if (loop + offset > end) { in WriteStringLoop()
347 WriteBytes(str, end - offset, raw_ + byteOffset_ + offset); in WriteStringLoop()
375 void Buffer::WriteStringLoop(std::u16string value, unsigned int offset, unsigned int end) in WriteStringLoop() argument
405 FillBuffer(Buffer *buffer, unsigned int offset, unsigned int end) FillBuffer() argument
424 FillNumber(vector<uint8_t> numbers, unsigned int offset, unsigned int end) FillNumber() argument
464 FillString(string value, unsigned int offset, unsigned int end, string encoding) FillString() argument
[all...]
H A Djs_buffer.h61 void SubBuffer(Buffer *tBuf, uint32_t start, uint32_t end);
70 void FillBuffer(Buffer *buffer, unsigned int offset, unsigned int end);
71 void FillNumber(std::vector<uint8_t> numbers, unsigned int offset, unsigned int end);
72 void FillString(std::string value, unsigned int offset, unsigned int end, std::string encoding);
83 void WriteStringLoop(std::string value, unsigned int offset, unsigned int end, unsigned int length);
84 void WriteStringLoop(std::u16string value, unsigned int offset, unsigned int end);
H A Djs_blob.cpp55 void Blob::Init(Blob *blob, int start, int end) in Init() argument
57 if (start > end) { in Init()
60 if ((start > 0 && end < 0) || (start < 0 && end > 0)) { in Init()
66 unsigned int length = static_cast<unsigned int>(end - start); in Init()
75 HILOG_FATAL("Blob constructor(start >= 0, end) memcpy_s failed"); in Init()
79 HILOG_FATAL("Blob constructor(start >= 0, end) memcpy_s failed"); in Init()
83 HILOG_FATAL("Blob constructor(start, end) memcpy_s failed"); in Init()
87 HILOG_FATAL("Blob constructor(start, end) memcpy_s failed"); in Init()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_sync_rwlock_perf.rs33 let end = Instant::now(); in main()
34 println!("read : {:?}", end - start); in main()
41 let end = Instant::now(); in main()
42 println!("write : {:?}", end - start); in main()
H A Dylong_sync_mutex_perf.rs30 let end = Instant::now(); in main()
31 println!("{:?}", end - start); in main()
H A Dylong_runtime_tcp_client_perf.rs43 let end = Instant::now(); in main()
44 println!("async_tcp_client CostTime: {:?}", end - start); in main()
H A Dylong_runtime_tcp_server_perf.rs56 let end = Instant::now(); in main()
57 println!("Server CostTime: {:?}", end - start); in main()
/commonlibrary/c_utils/base/include/
H A Dsorted_vector.h185 return *(vec_.end() + index); in MirrorItemAt()
237 return vec_.end(); in Erase()
272 return vec_.end(); in End()
283 return vec_.end(); in End()
349 auto it = std::lower_bound(std::begin(vec_), std::end(vec_), item); in IndexOf()
350 if (it == vec_.end() || !(*it == item)) { in IndexOf()
359 auto it = std::upper_bound(vec_.begin(), vec_.end(), item); in OrderOf()
371 auto it = std::upper_bound(vec_.begin(), vec_.end(), item); in Add()
384 std::sort(newvector.begin(), newvector.end()); in SortedVector()
388 std::unique_copy(newvector.begin(), newvector.end(), st in SortedVector()
[all...]
H A Dsafe_map.h143 if (iter != map_.end()) { in Find()
166 if (iter != map_.end()) { in FindOldAndSetNew()
210 for (auto it = map_.begin(); it != map_.end(); it++) { in Iterate()
/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_datetime_test.cpp148 int64_t end = GetTickCount(); in HWTEST_F() local
150 EXPECT_TRUE(end - begin >= 100); in HWTEST_F()
151 EXPECT_TRUE(end - begin < 120); in HWTEST_F()
162 int64_t end = GetMicroTickCount(); in HWTEST_F() local
164 EXPECT_TRUE(end - begin >= 100000); in HWTEST_F()
165 EXPECT_TRUE(end - begin < 120000); in HWTEST_F()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dinput.rs48 end: usize,
57 end: 0,
64 self.end = 0;
139 .poll_write(cx, &self.buf.buf[self.buf.start..self.buf.end]) in poll_writer_frame()
144 if self.buf.start == self.buf.end { in poll_writer_frame()
179 self.buf.end = size;
/commonlibrary/c_utils/base/src/
H A Dtimer.cpp96 while (timerToEntries_.find(timerId) != timerToEntries_.end()) { in Register()
118 if (timerToEntries_.find(timerId) == timerToEntries_.end()) { in Unregister()
127 for (; itor != intervalToTimers_[entry->interval].end(); ++itor) { in Unregister()
227 if (intervalToTimers_.find(interval) == intervalToTimers_.end()) { in GetTimerFd()
243 for (auto itor = entryList.begin(); itor != entryList.end();) { in EraseUnusedTimerId()
245 if (std::find(unusedIds.begin(), unusedIds.end(), id) == unusedIds.end()) { in EraseUnusedTimerId()
H A Dfile_ex.cpp60 std::vector<char> tmpContent(content.begin(), content.end()); in RustLoadBufferFromFile()
62 std::copy(tmpContent.begin(), tmpContent.end(), std::back_inserter(content)); in RustLoadBufferFromFile()
71 std::vector<char> tmpContent(content.begin(), content.end()); in RustSaveBufferToFile()
118 file.seekg(0, ios::end); in LoadStringFromFile()
303 file.seekg(0, std::ios::end); in LoadBufferFromFile()
376 transform(str.begin(), str.end(), strlower.begin(), ::tolower); in StringExistsInFile()
377 transform(subStr.begin(), subStr.end(), sublower.begin(), ::tolower); in StringExistsInFile()
419 transform(str.begin(), str.end(), strlower.begin(), ::tolower); in CountStrInFile()
420 transform(subStr.begin(), subStr.end(), sublower.begin(), ::tolower); in CountStrInFile()
H A Dstring_ex.cpp34 transform(upperString.begin(), upperString.end(), upperString.begin(), ::toupper); in UpperStr()
41 transform(lowerString.begin(), lowerString.end(), lowerString.begin(), ::tolower); in LowerStr()
124 char* end = nullptr; in StrToInt() local
127 auto result = strtol(addr, &end, 10); /* 10 means decimal */ in StrToInt()
128 if ((end == addr) || (end[0] != '\0') || (errno == ERANGE) || in StrToInt()
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_manager.cpp245 for (auto iter = workers_.begin(); iter != workers_.end(); iter++) { in CheckForBlockedWorkers()
438 auto iter = std::find_if(idleWorkers_.begin(), idleWorkers_.end(), [](Worker *worker) { in TriggerShrink()
443 if (iter != idleWorkers_.end()) { in TriggerShrink()
467 for (auto iter = timeoutWorkers_.begin(); iter != timeoutWorkers_.end();) { in NotifyShrink()
469 if (workers_.find(worker) == workers_.end()) { in NotifyShrink()
692 return std::count_if(workers_.begin(), workers_.end(), [](const auto& worker) { in GetRunningWorkers()
902 idleWorkers_.emplace_hint(idleWorkers_.end(), worker); in RestoreWorker()
919 if (iter == callbackTable_.end() || iter->second == nullptr) { in GetCallbackInfo()
933 if (iter == callbackTable_.end() || iter->second == nullptr) { in IncreaseRefCount()
946 if (iter == callbackTable_.end() || ite in DecreaseRefCount()
[all...]
H A Dtask_queue.cpp26 auto it = std::find(tasks_.begin(), tasks_.end(), taskId); in EraseWaitingTaskId()
27 if (it != tasks_.end()) { in EraseWaitingTaskId()
/commonlibrary/memory_utils/libpurgeablemem/test/
H A Dpurgeable_memory_test.cpp29 char end; member
41 bool InitData(void *data, size_t size, char start, char end);
117 bool InitData(void *data, size_t size, char start, char end) in InitData() argument
121 for (char ch = start; ch <= end && len < size; ch++) { in InitData()
132 bool ret = InitData(data, size, para->start, para->end); in InitAlphabet()
133 std::cout << "quit " << __func__ << ": " << para->start << "-" << para->end << in InitAlphabet()
H A Dpurgeable_c_test.cpp29 char end; member
41 bool InitData(void *data, size_t size, char start, char end);
178 bool InitData(void *data, size_t size, char start, char end) in InitData() argument
182 for (char ch = start; ch <= end && len < size; ch++) { in InitData()
193 bool ret = InitData(data, size, para->start, para->end); in InitAlphabet()
194 std::cout << "quit " << __func__ << ": " << para->start << "-" << para->end << in InitAlphabet()
/commonlibrary/ets_utils/js_sys_module/timer/
H A Dtimer.cpp97 if (iter == timerTable.end()) { in ClearTimer()
159 if (timerTable.find(tId) == timerTable.end()) { in TimerCallback()
209 if (timerTable.find(tId) != timerTable.end()) { in SetTimeoutInnerCore()
255 while (iter != timerTable.end()) { in ClearEnvironmentTimer()
269 auto iter = std::find_if(timerTable.begin(), timerTable.end(), [env](const auto &item) { in HasTimer()
272 return iter != timerTable.end(); in HasTimer()
279 if (timerTable.find(tId) != timerTable.end()) { in DeleteTimer()
/commonlibrary/c_utils/base/test/benchmarktest/datatime_benchmark_test/
H A Ddatatime_benchmark_test.cpp85 BENCHMARK_LOGD("DateTimeTest testTimecover001 end."); in BENCHMARK_F()
120 BENCHMARK_LOGD("DateTimeTest testTime001 end."); in BENCHMARK_F()
138 BENCHMARK_LOGD("DateTimeTest testTime002 end."); in BENCHMARK_F()
159 BENCHMARK_LOGD("DateTimeTest testTime003 end."); in BENCHMARK_F()
174 BENCHMARK_LOGD("DateTimeTest testTime004 end."); in BENCHMARK_F()
187 int64_t end = GetTickCount(); in BENCHMARK_F() local
189 AssertGreaterThanOrEqual(end - begin, 0, "end - begin >= 0 did not equal true as expected.", state); in BENCHMARK_F()
191 BENCHMARK_LOGD("DateTimeTest testGetTickCount001 end."); in BENCHMARK_F()
204 int64_t end in BENCHMARK_F() local
[all...]
/commonlibrary/rust/ylong_json/src/
H A Dserializer_compact.rs162 seq.end() in serialize_bytes()
233 // The start of the sequence, each value, and the end use three separate method calls.
326 // Add another half of the parentheses at the end.
336 // Finally, one call to end the serializing of the compound type.
355 fn end(self) -> Result<(), Error> { in end() functions
374 fn end(self) -> Result<(), Error> { in end() functions
393 fn end(self) -> Result<(), Error> { in end() functions
406 // So the `end` method in this impl is responsible for closing
420 fn end(self) -> Result<(), Error> { in end() functions
450 // the end o
460 fn end(self) -> Result<(), Error> { end() functions
480 fn end(self) -> Result<(), Error> { end() functions
502 fn end(self) -> Result<(), Error> { end() functions
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/
H A Dmod.rs1058 let mut end = bytes.len(); in authority_token() variables
1065 end = i; in authority_token()
1101 authority_parse(bytes, end, colon_num, left_bracket, right_bracket) in authority_token()
1106 end: usize, in authority_parse()
1112 if end == 0 { in authority_parse()
1113 return Ok((None, &bytes[end..])); in authority_parse()
1124 let authority = host_port(&bytes[..end], colon_num)?; in authority_parse()
1125 Ok((Some(authority), &bytes[end..])) in authority_parse()
1129 let mut end = bytes.len(); in path_token() variables
1133 end in path_token()
1156 let mut end = bytes.len(); query_token() variables
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_signal.rs81 let end = Instant::now(); in main()
82 let duration = end - start; in main()
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dworker.cpp111 for (auto item = g_limitedworkers.begin(); item != g_limitedworkers.end(); item++) { in InitPort()
118 for (auto item = g_workers.begin(); item != g_workers.end(); item++) { in InitPort()
1189 for (auto iter = globalCallObjects_.begin(); iter != globalCallObjects_.end(); iter++) { in RemoveGlobalCallObject()
1201 for (auto iter = globalCallObjects_.begin(); iter != globalCallObjects_.end(); iter++) { in ClearGlobalCallObject()
1462 HILOG_WARN("worker:: FinishContainerScopeFunc error when HostOnMessageInner end(only stage model)"); in HostOnMessageInner()
1533 if (iter == globalCallObjects_.end()) { in HostOnGlobalCallInner()
1734 HILOG_WARN("worker:: FinishContainerScopeFunc error when onerror end(only stage model)"); in HostOnErrorInner()
1915 std::list<Worker*>::iterator it = std::find(g_workers.begin(), g_workers.end(), worker); in IsValidWorker()
1916 if (it == g_workers.end()) { in IsValidWorker()
1978 if (iter == eventListeners_.end()) { in HandleEventListeners()
[all...]

Completed in 16 milliseconds

123