Home
last modified time | relevance | path

Searched refs:len (Results 1 - 25 of 168) sorted by relevance

1234567

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A Dasync_buf_writer.rs165 /// let without_flush = capacity - buf_writer.buffer().len();
175 let len = this.buf.len();
177 while this.written < len {
211 if self.buf.len() + buf.len() > self.buf.capacity() { in poll_write()
216 if buf.len() >= this.buf.capacity() { in poll_write()
220 Poll::Ready(Ok(buf.len())) in poll_write()
230 let mut len: usize = 0; in poll_write_vectored() variables
232 len in poll_write_vectored()
254 let mut len = bufs[0].len(); poll_write_vectored() variables
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/
H A Dslice.rs17 fn len(&self) -> usize { in len() functions
18 <[T]>::len(self) in len()
21 fn reduce(self, len: usize) -> Self { in reduce()
22 self.split_at(len).0 in reduce()
25 let idx = self.len() >> 1; in split()
32 fn len(&self) -> usize { in len() functions
33 <[T]>::len(self) in len()
36 fn reduce(self, len: usize) -> Self { in reduce()
37 self.split_at_mut(len).0 in reduce()
41 let idx = self.len() >> in split()
[all...]
H A Dvec.rs17 fn len(&self) -> usize { in len() functions
18 <Vec<T>>::len(self) in len()
21 fn reduce(mut self, len: usize) -> Self { in reduce()
22 self.truncate(len); in reduce()
27 let idx = self.len() >> 1; in split()
H A Dmod.rs30 fn len(&self) -> usize; in len() functions
33 fn reduce(self, len: usize) -> Self; in reduce()
41 self.len() == 0 in is_empty()
109 fn len(&self) -> usize { in len() functions
110 self.data.len() in len()
113 fn reduce(self, len: usize) -> Self { in reduce()
115 data: self.data.reduce(len), in reduce()
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Doctets.rs25 ($buf: expr, $ty: ty, $len: expr) => {{
26 if $buf.len() < $len {
29 let bytes: [u8; $len] = <[u8; $len]>::try_from($buf[..$len].as_ref()).unwrap();
36 ($this: expr, $ty: ty, $len: expr) => {{
37 let res = peek_bytes!($this.buf[$this.idx..], $ty, $len);
38 $this.idx += $len;
78 let len in get_varint()
[all...]
/commonlibrary/memory_utils/libpurgeablemem/cpp/src/
H A Dux_page_table.cpp28 UxPageTable::UxPageTable(uint64_t addr, size_t len) in UxPageTable() argument
34 PMState err = InitUxPageTable(uxpt_, addr, len); /* dataPtr is aligned */ in UxPageTable()
56 void UxPageTable::GetUxpte(uint64_t addr, size_t len) in GetUxpte() argument
58 UxpteGet(uxpt_, addr, len); in GetUxpte()
61 void UxPageTable::PutUxpte(uint64_t addr, size_t len) in PutUxpte() argument
63 UxptePut(uxpt_, addr, len); in PutUxpte()
67 bool UxPageTable::CheckPresent(uint64_t addr, size_t len) in CheckPresent() argument
69 return UxpteIsPresent(uxpt_, addr, len); in CheckPresent()
/commonlibrary/c_utils/base/test/unittest/rust/
H A Drust_utils_ashmem_test.rs50 assert!(ashmem.WriteToAshmem(c_content_ptr, MEMORY_CONTENT.len().try_into().expect("Invalid content size."), 0)); in test_ashmem_ffi_write_read_002()
51 assert!(ashmem.WriteToAshmem(c_content_ptr, MEMORY_CONTENT.len().try_into().expect("Invalid content size."), in test_ashmem_ffi_write_read_002()
52 MEMORY_CONTENT.len().try_into().expect("Invalid content size."))); in test_ashmem_ffi_write_read_002()
56 readout_ptr = ashmem::ffi::AsCharPtr(ashmem.ReadFromAshmem(MEMORY_CONTENT.len().try_into().expect("Invalid content size."), 0)); in test_ashmem_ffi_write_read_002()
85 assert!(ashmem.WriteToAshmem(c_content_ptr, MEMORY_CONTENT.len().try_into().expect("Invalid content size."), 0)); in test_ashmem_ffi_write_read_003()
92 assert!(!ashmem.WriteToAshmem(c_content_ptr, MEMORY_CONTENT.len().try_into().expect("Invalid content size."), in test_ashmem_ffi_write_read_003()
93 MEMORY_NAME.len().try_into().expect("Invalid content size."))); in test_ashmem_ffi_write_read_003()
98 readout_ptr = ashmem::ffi::AsCharPtr(ashmem.ReadFromAshmem(MEMORY_CONTENT.len().try_into().expect("Invalid content size."), 0)); in test_ashmem_ffi_write_read_003()
123 assert!(ashmem.WriteToAshmem(c_content_ptr, MEMORY_CONTENT.len().try_into().expect("Invalid content size."), 0)); in test_ashmem_ffi_write_read_004()
133 readout_ptr = ashmem::ffi::AsCharPtr(ashmem.ReadFromAshmem(MEMORY_CONTENT.len() in test_ashmem_ffi_write_read_004()
[all...]
/commonlibrary/memory_utils/libpurgeablemem/common/include/
H A Dux_page_table_c.h36 PMState InitUxPageTable(UxPageTableStruct *upt, uint64_t addr, size_t len);
39 void UxpteGet(UxPageTableStruct *upt, uint64_t addr, size_t len);
40 void UxptePut(UxPageTableStruct *upt, uint64_t addr, size_t len);
41 void UxpteClear(UxPageTableStruct *upt, uint64_t addr, size_t len);
42 bool UxpteIsPresent(UxPageTableStruct *upt, uint64_t addr, size_t len);
/commonlibrary/rust/ylong_json/src/
H A Dadapter.rs46 let len = strlen(value);
47 let slice = &*slice_from_raw_parts(value as *mut u8, len);
82 // Here we use `Vec::with_capacity(256)`, which performs better when `12 < string.len() < 256`.
83 // If here we use `Vec::new()`, it performs better when `string.len() < 32 || 256 > string.len()`
84 // In most cases, `12 < the average string.len() < 256`, so we use `Vec::with_capacity()`.
362 let len = strlen(string);
363 let slice = &*slice_from_raw_parts(string as *mut u8, len);
418 let len = strlen(value);
419 let slice = &*slice_from_raw_parts(value as *mut u8, len);
1988 let mut len = 0i32; ut_ylong_json_get_array_size() variables
1998 let mut len = 1i32; ut_ylong_json_get_array_size() variables
2004 let mut len = 1i32; ut_ylong_json_get_array_size() variables
2176 let mut len = 0i32; ut_ylong_json_remove_array_item_by_index() variables
2232 let mut len = 0i32; ut_ylong_json_delete_array_item_by_index() variables
2398 let mut len = 0i32; ut_ylong_json_add_item_to_array_then_get_node() variables
2477 let mut len = 0i32; ut_ylong_json_remove_array_node() variables
2558 let mut len = 0i32; ut_ylong_json_delete_array_node() variables
2644 let mut len = 0i32; ut_ylong_json_get_object_size() variables
2657 let mut len = 1i32; ut_ylong_json_get_object_size() variables
2666 let mut len = 0i32; ut_ylong_json_get_object_size() variables
2804 let mut len = 0i32; ut_ylong_json_add_item_to_object() variables
3009 let mut len = 1i32; ut_ylong_json_get_all_object_items() variables
3022 let mut len = 1i32; ut_ylong_json_get_all_object_items() variables
3035 let mut len = 1i32; ut_ylong_json_get_all_object_items() variables
3065 let mut len = 0i32; ut_ylong_json_get_all_object_items() variables
3099 let mut len = 1i32; ut_ylong_json_get_all_object_items() variables
[all...]
H A Dlinked_list.rs25 len: usize,
35 len: 0,
42 pub(crate) fn len(&self) -> usize {
43 self.len
49 self.len == 0
68 self.len += 1;
87 self.len -= 1;
99 len: self.len,
110 len
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/
H A Dzip.rs23 let len_a = a.len(); in zip()
24 let len_b = b.len(); in zip()
46 fn len(&self) -> usize { in len() functions
47 self.a.len() in len()
50 fn reduce(self, len: usize) -> Self { in reduce()
52 a: self.a.reduce(len), in reduce()
53 b: self.b.reduce(len), in reduce()
H A Dfilter.rs33 fn len(&self) -> usize { in len() functions
34 self.base.len() in len()
37 fn reduce(self, len: usize) -> Self { in reduce()
39 base: self.base.reduce(len), in reduce()
H A Dmap.rs39 fn len(&self) -> usize { in len() functions
40 self.base.len() in len()
43 fn reduce(self, len: usize) -> Self { in reduce()
45 base: self.base.reduce(len), in reduce()
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dudp_socket_test.rs59 assert_eq!(n, "Hello".len()); in sdv_send_recv()
67 let len = loop { in sdv_send_recv()
75 assert_eq!(&recv_buf[..len], b"Hello"); in sdv_send_recv()
106 assert_eq!(n, "Hello".len()); in sdv_send_to_recv_from()
114 let (len, addr) = loop { in sdv_send_to_recv_from()
121 assert_eq!(&recv_buf[..len], b"Hello"); in sdv_send_to_recv_from()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dmod.rs74 /// assert_eq!(rx.len(), 1);
166 /// assert_eq!(tx.len(), 0);
168 /// assert_eq!(tx.len(), 1);
170 pub fn len(&self) -> usize { in len() functions
171 self.channel.len() in len()
186 self.len() == 0 in is_empty()
210 /// assert_eq!(rx.len(), 2);
212 pub fn len(&self) -> usize { in len() functions
213 self.channel.len() in len()
228 self.len() in is_empty()
[all...]
/commonlibrary/utils_lite/hals/file/
H A Dhal_file.c32 int HalFileRead(int fd, char *buf, unsigned int len) in HalFileRead() argument
34 return read(fd, buf, len); in HalFileRead()
37 int HalFileWrite(int fd, const char *buf, unsigned int len) in HalFileWrite() argument
39 return write(fd, buf, len); in HalFileWrite()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dqueue.rs106 pub(crate) fn len(&self) -> u16 {
107 self.inner.len()
151 /// Return queue's len.
152 fn len(&self) -> u16 { in len() functions
334 .fetch_add(tmp_buf.len() as u64 + 1, AcqRel);
427 len: AtomicUsize,
447 len: AtomicUsize::new(0_usize),
454 self.len.load(Acquire) == 0
459 let len = tasks.len()
568 fn len(&self) -> u16 { len() functions
579 pub fn len(&self) -> u16 { len() functions
[all...]
/commonlibrary/rust/ylong_http/ylong_http/tests/
H A Dsdv_http_body.rs65 let mut size = buf.len(); in sdv_chunk_body_encode()
66 while size == buf.len() { in sdv_chunk_body_encode()
88 let mut size = buf.len(); in sdv_async_chunk_body_from_async_reader()
89 while size == buf.len() { in sdv_async_chunk_body_from_async_reader()
115 let mut size = buf.len(); in sdv_async_chunk_body_from_bytes()
116 while size == buf.len() { in sdv_async_chunk_body_from_bytes()
143 let mut size = buf.len(); in sdv_chunk_body_encode_trailer_0()
144 while size == buf.len() { in sdv_chunk_body_encode_trailer_0()
196 assert_eq!(chunks_1.iter().len(), 3);
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/
H A Dsimple.rs106 size += 2 + self.boundary.len() as u64 + 2; in total_bytes()
113 size += 9 + name.len() as u64; in total_bytes()
118 size += 13 + name.len() as u64; in total_bytes()
126 size += 16 + mime.len() as u64; in total_bytes()
133 size += 2 + self.boundary.len() as u64 + 4; in total_bytes()
225 let filled = buf.filled().len(); in poll_read()
228 let new_filled = buf.filled().len(); in poll_read()
238 let new_filled = buf.filled().len(); in poll_read()
381 self.length = Some(body.len() as u64); in body()
452 let filled_len = buf.filled().len(); in poll_read_curr()
[all...]
H A Dmime_test_macro.rs67 let mut len = 1; variables
69 $(len = $size;)?
70 let mut buf = vec![0u8; len];
113 let mut len = 1; variables
115 $(len = $size;)?
116 let mut buf = vec![0u8; len];
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dread_buf.rs43 initialized: buf.len(), in new()
74 self.buf.len() in capacity()
139 self.buf.len() - self.filled in remaining()
233 buf.len() <= remaining, in append()
234 "slice size is larger than the buf's remaining size, buf len: {}, remaining: {}", in append()
235 buf.len(), in append()
239 let end = self.filled + buf.len(); in append()
244 .copy_from_nonoverlapping(buf.as_ptr(), buf.len()); in append()
272 let buf_len = buf.len(); in ut_test_readbuf_new()
275 assert_eq!(read_buf.filled().len(), in ut_test_readbuf_new()
316 let mut len: usize = 0; ut_test_readbuf_new() variables
[all...]
/commonlibrary/memory_utils/libpurgeablemem/cpp/include/
H A Dux_page_table.h34 void GetUxpte(uint64_t addr, size_t len);
35 void PutUxpte(uint64_t addr, size_t len);
36 bool CheckPresent(uint64_t addr, size_t len);
/commonlibrary/memory_utils/libpurgeablemem/common/src/
H A Dux_page_table_c.c142 static PMState UxpteOps(UxPageTableStruct *upt, uint64_t addr, size_t len, enum UxpteOp op);
193 PMState InitUxPageTable(UxPageTableStruct *upt, uint64_t addr, size_t len) in InitUxPageTable() argument
204 upt->dataSize = len; in InitUxPageTable()
209 UxpteClear(upt, addr, len); in InitUxPageTable()
238 void UxpteGet(UxPageTableStruct *upt, uint64_t addr, size_t len) in UxpteGet() argument
243 UxpteOps(upt, addr, len, UPT_GET); in UxpteGet()
246 void UxptePut(UxPageTableStruct *upt, uint64_t addr, size_t len) in UxptePut() argument
251 UxpteOps(upt, addr, len, UPT_PUT); in UxptePut()
254 void UxpteClear(UxPageTableStruct *upt, uint64_t addr, size_t len) in UxpteClear() argument
259 UxpteOps(upt, addr, len, UPT_CLEA in UxpteClear()
262 UxpteIsPresent(UxPageTableStruct *upt, uint64_t addr, size_t len) UxpteIsPresent() argument
373 UxpteOps(UxPageTableStruct *upt, uint64_t addr, size_t len, enum UxpteOp op) UxpteOps() argument
454 InitUxPageTable(UxPageTableStruct *upt, uint64_t addr, size_t len) InitUxPageTable() argument
464 UxpteGet(UxPageTableStruct *upt, uint64_t addr, size_t len) UxpteGet() argument
466 UxptePut(UxPageTableStruct *upt, uint64_t addr, size_t len) UxptePut() argument
468 UxpteIsPresent(UxPageTableStruct *upt, uint64_t addr, size_t len) UxpteIsPresent() argument
[all...]
/commonlibrary/rust/ylong_json/src/value/array/
H A Dvec.rs59 /// assert_eq!(array.len(), 0);
62 /// assert_eq!(array.len(), 1);
64 pub fn len(&self) -> usize { in len() functions
65 self.inner.len() in len()
81 self.inner.len() == 0 in is_empty()
91 /// assert_eq!(array.len(), 0);
94 /// assert_eq!(array.len(), 1);
213 /// assert_eq!(array.len(), 3);
216 /// assert_eq!(array.len(), 2);
219 if index >= self.inner.len() { in remove()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Dmod.rs81 /// assert_eq!(rx.len(), 1);
284 /// assert_eq!(tx.len(), 0);
286 /// assert_eq!(tx.len(), 1);
288 pub fn len(&self) -> usize { in len() functions
289 self.channel.len() in len()
304 self.len() == 0 in is_empty()
328 /// assert_eq!(rx.len(), 2);
330 pub fn len(&self) -> usize { in len() functions
331 self.channel.len() in len()
346 self.len() in is_empty()
[all...]

Completed in 10 milliseconds

1234567