Searched refs:cap (Results 1 - 7 of 7) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | events.rs | 65 pub fn with_capacity(cap: usize) -> Events { in with_capacity()
67 status: vec![CompletionStatus::zero(); cap].into_boxed_slice(), in with_capacity()
68 events: Vec::with_capacity(cap), in with_capacity()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | decoder.rs | 511 if reader.cap() < payload_len { in decode_data_payload()
516 self.subtract_payload_len(reader.cap())?; in decode_data_payload()
528 let remaining = reader.cap(); in decode_data_payload()
589 if reader.cap() < payload_len { in decode_headers_payload()
598 self.subtract_payload_len(reader.cap())?; in decode_headers_payload()
614 self.get_qpack_decoded_header(frames, qpack_decoder, id, reader.cap()) in decode_headers_payload()
647 let remaining = reader.cap(); in decode_variable_payload()
667 if (reader.cap() as u64) < payload_len { in decode_settings_payload()
705 let remaining = reader.cap(); in decode_settings_payload()
736 if reader.cap() < payload_le in decode_unknown_payload()
[all...] |
| H A D | encoder.rs | 436 let cap = frame_buf.len(); in encode_headers_repr()
437 if cap >= repr_size { in encode_headers_repr()
447 [enc_headers.repr_offset()..enc_headers.repr_offset() + cap], in encode_headers_repr()
449 written += cap; in encode_headers_repr()
450 enc_headers.repr_offset_inc(cap); in encode_headers_repr()
462 let cap = inst_buf.len(); in encode_qpack_inst()
463 if cap >= inst_size { in encode_qpack_inst()
473 [enc_headers.inst_offset()..enc_headers.inst_offset() + cap], in encode_qpack_inst()
475 written += cap; in encode_qpack_inst()
476 enc_headers.inst_offset_inc(cap); in encode_qpack_inst()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | queue.rs | 130 cap: u16,
177 fn new(cap: u16) -> Self { in new()
178 let mut buffer = Vec::with_capacity(cap as usize); in new()
180 for _ in 0..cap { in new()
186 cap, in new()
244 self.cap - (rear.wrapping_sub(steal_pos))
276 if rear.wrapping_sub(steal_pos) < self.cap {
636 assert_eq!(inner_buffer.cap, LOCAL_QUEUE_CAP as u16); in ut_inner_buffer_new()
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_parcel_test.cpp | 623 static void WritevecTestOneFunc01(const size_t cap) in WritevecTestOneFunc01() argument
628 for (int i = 0; i < cap / sizeof(bool); i++) { in WritevecTestOneFunc01()
637 for (int i = 0; i < cap / sizeof(int8_t); i++) { in WritevecTestOneFunc01()
646 for (int i = 0; i < cap / sizeof(int16_t); i++) { in WritevecTestOneFunc01()
655 for (int i = 0; i < cap / sizeof(int32_t); i++) { in WritevecTestOneFunc01()
662 static void WritevecTestOneFunc02(const size_t cap) in WritevecTestOneFunc02() argument
667 for (int i = 0; i < cap / sizeof(int64_t); i++) { in WritevecTestOneFunc02()
676 for (int i = 0; i < cap / sizeof(uint8_t); i++) { in WritevecTestOneFunc02()
685 for (int i = 0; i < cap / sizeof(uint16_t); i++) { in WritevecTestOneFunc02()
694 for (int i = 0; i < cap / sizeo in WritevecTestOneFunc02()
701 WritevecTestOneFunc03(const size_t cap) WritevecTestOneFunc03() argument
753 size_t cap = DEFAULT_CPACITY; HWTEST_F() local
767 size_t cap = DEFAULT_CPACITY; HWTEST_F() local
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| H A D | async_buf_writer.rs | 72 pub fn with_capacity(cap: usize, inner: W) -> AsyncBufWriter<W> { in with_capacity()
75 buf: Vec::with_capacity(cap), in with_capacity()
|
| /commonlibrary/c_utils/base/test/benchmarktest/parcel_benchmark_test/ |
| H A D | parcel_benchmark_test.cpp | 644 size_t cap = DEFAULT_CPACITY; in BENCHMARK_F() local
646 AssertTrue(parcel.SetMaxCapacity(cap + setMaxCapacityValue), in BENCHMARK_F()
647 "parcel.SetMaxCapacity(cap + 1) did not equal true as expected.", state); in BENCHMARK_F()
648 AssertFalse(parcel.SetMaxCapacity(cap - setMaxCapacityValue), in BENCHMARK_F()
649 "parcel.SetMaxCapacity(cap - 1) did not equal false as expected.", state); in BENCHMARK_F()
|
Completed in 10 milliseconds