| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| H A D | decoder.rs | 110 let mut cnt = 0; variables
111 while cnt < buf.len() {
112 match decoder.decode(&buf[cnt..], &mut self.inst_state)? {
115 cnt += offset;
129 cnt += offset;
140 cnt += offset;
144 cnt += offset;
219 let mut cnt = 0; in decode_buffered_repr() variables
221 match decoder.decode(&buf[cnt..], &mut message.repr_state)? { in decode_buffered_repr()
228 cnt in decode_buffered_repr()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | block_on.rs | 204 let cnt = 100; in sdv_block_on_nest_batch_spawn()
206 for _ in 0..cnt { in sdv_block_on_nest_batch_spawn()
229 let cnt = 100; in sdv_block_on_nest_await_spawn()
231 for _ in 0..cnt { in sdv_block_on_nest_await_spawn()
263 let cnt = 1000; in sdv_block_on_nest_await_spawn_bug_test()
265 for _ in 0..cnt { in sdv_block_on_nest_await_spawn_bug_test()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| H A D | slots.rs | 365 let mut cnt = 149; in ut_slots_push_back() variables
367 assert_eq!(*slots.get(index).unwrap(), cnt); in ut_slots_push_back()
368 cnt -= 1; in ut_slots_push_back()
385 let mut cnt = 149; in ut_slots_push_back() variables
387 assert_eq!(*slots.get(index).unwrap(), Data::new(cnt)); in ut_slots_push_back()
388 cnt -= 1; in ut_slots_push_back()
496 let mut cnt = 14999; in ut_slots_huge_data_remove() variables
498 assert_eq!(slots[key], cnt); in ut_slots_huge_data_remove()
499 cnt -= 1; in ut_slots_huge_data_remove()
584 let mut cnt in ut_slots_huge_data_pop_front() variables
[all...] |
| H A D | slab.rs | 462 cnt: AtomicUsize,
469 cnt: AtomicUsize::new(0), in default()
477 self.cnt.fetch_add(1, SeqCst); in reset()
481 cnt: AtomicUsize,
488 cnt: AtomicUsize::new(0), in default()
496 self.cnt.fetch_add(1, SeqCst); in reset()
624 // The `reset` function has not been called yet, so `cnt` remains unchanged in ut_slab_insert_move()
625 assert_eq!(0, slab.get(addr1).unwrap().cnt.load(SeqCst)); in ut_slab_insert_move()
630 assert_eq!(0, slab.get(addr2).unwrap().cnt.load(SeqCst)); in ut_slab_insert_move()
646 assert_eq!(1, slab.get(addr3).unwrap().cnt in ut_slab_insert_move()
[all...] |
| /commonlibrary/rust/ylong_json/src/reader/ |
| H A D | io_reader.rs | 255 cnt: usize,
260 Self { cnt: 0 } in new()
264 self.cnt == 10 in is_finished()
270 if self.cnt < 10 { in read()
271 self.cnt += 1; in read()
|
| /commonlibrary/ets_utils/platform/ |
| H A D | util_helper.h | 57 OutBufferInfo(size_t length, std::string inputStr, size_t bufferLength, size_t cnt, std::string bufferRst) in OutBufferInfo()
61 cntSize(cnt), in OutBufferInfo()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | decoder.rs | 109 if let DecResult::Decoded((cnt, repr)) = $res {
110 return DecResult::Decoded((cnt + $buf_index, repr));
439 if let DecResult::Decoded((cnt, prefix, mid_bit, int)) = res { in decode()
440 return DecResult::Decoded((cnt + buf_index, prefix, mid_bit, int)); in decode()
539 if let DecResult::Decoded((cnt, vec)) = res { in decode()
540 return DecResult::Decoded((cnt + buf_index, vec)); in decode()
547 if let DecResult::Decoded((cnt, vec)) = res { in decode()
548 return DecResult::Decoded((cnt + buf_index, vec)); in decode()
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_safe_map_test.cpp | 240 auto lamfuncIterate = [](SafeMap<string, int>& data, const int& cnt, in HWTEST_F()
242 auto callback_it = [cnt](const string data, int& value) { in HWTEST_F()
243 value = cnt; in HWTEST_F()
|
| H A D | utils_timer_test.cpp | 317 int cnt = 0, cnt1 = 0; in HWTEST_F() local
318 DoFunc(timer, cnt); in HWTEST_F()
|
| H A D | utils_mapped_file_test.cpp | 226 for (unsigned int cnt = 2; cnt < (MappedFile::PageSize() / orig); cnt++) { // 2: start from 2 to take the first in TestFileRegion()
831 for (off_t cnt = 1; cnt < (MappedFile::PageSize() / 100LL / curSize); cnt++) { in HWTEST_F()
|
| H A D | utils_event_test.cpp | 1137 int cnt = 0; in HWTEST_F() local
1139 DoFunc(timer, cnt); in HWTEST_F()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | simple.rs | 565 let mut cnt = 1; in xor_shift() variables
569 hasher.write_usize(cnt); in xor_shift()
574 cnt += 1; in xor_shift()
|
| /commonlibrary/c_utils/base/test/benchmarktest/timer_benchmark_test/ |
| H A D | timer_benchmark_test.cpp | 298 int cnt = 0, cnt1 = 0; in BENCHMARK_F() local
299 DoFunc(timer, cnt); in BENCHMARK_F()
|
| /commonlibrary/c_utils/base/test/benchmarktest/safe_map_benchmark_test/ |
| H A D | safe_map_benchmark_test.cpp | 423 auto lamfuncIterate = [](SafeMap<string, int>& data, const int& cnt, in BENCHMARK_F()
425 auto callback_it = [cnt](const string data, int& value) { in BENCHMARK_F()
426 value = cnt; in BENCHMARK_F()
|
| /commonlibrary/c_utils/base/test/benchmarktest/mapped_benchmark_test/ |
| H A D | mapped_benchmark_test.cpp | 770 for (unsigned int cnt = 2; cnt < (MappedFile::PageSize() / orig); cnt++) { in KeepAPageAndReachBottom()
860 for (off_t cnt = 1; cnt < (MappedFile::PageSize() / 100LL / curSize); cnt++) { in BENCHMARK_F()
|
| /commonlibrary/rust/ylong_json/src/ |
| H A D | adapter.rs | 3078 let mut cnt = 0; in ut_ylong_json_get_all_object_items() variables
3081 while cnt != len { in ut_ylong_json_get_all_object_items()
3082 let key = *(keys.offset(cnt as isize)); in ut_ylong_json_get_all_object_items()
3084 assert_eq!(key_str, key_result[cnt as usize]); in ut_ylong_json_get_all_object_items()
3087 let item = *(values.offset(cnt as isize)); in ut_ylong_json_get_all_object_items()
3090 assert_eq!(value_str, value_result[cnt as usize]); in ut_ylong_json_get_all_object_items()
3091 cnt += 1; in ut_ylong_json_get_all_object_items()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | chunk.rs | 86 cnt: usize,
136 self.chunk_data.chunk_count = v.cnt; in chunk_encode()
377 self.chunk_data.chunk_count = v.cnt; in chunk_encode_reader()
515 cnt: 0, in finish_encode()
532 cnt: 1, in data_encode()
548 cnt: 0, in tail_encode()
|
| /commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/ |
| H A D | event_benchmark_test.cpp | 1325 int cnt = 0, cnt1 = 0; in BENCHMARK_F() local
1326 DoFunc(timer, cnt); in BENCHMARK_F()
|