Home
last modified time | relevance | path

Searched refs:slice (Results 1 - 25 of 27) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dasync_read.rs25 /// 2. construct a buf and a slice, buf's length is greater than the slice.
27 /// 4. construct another buf and slice, buf's length is smaller than the slice.
34 let slice = vec![1u8, 2, 3]; in sdv_async_read_slice()
35 let res = AsyncReadExt::read(&mut slice.as_slice(), &mut buf) in sdv_async_read_slice()
40 assert_eq!(slice, vec![1, 2, 3]); in sdv_async_read_slice()
43 let slice = vec![1u8, 2, 3, 4, 5]; in sdv_async_read_slice()
44 let res = AsyncReadExt::read(&mut slice.as_slice(), &mut buf) in sdv_async_read_slice()
49 assert_eq!(slice, ve in sdv_async_read_slice()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Drequest.rs207 BodyKind::Slice(ref slice) => { in body()
210 format!("{}", slice.get_ref().len()).as_str(), in body()
241 /// - Slice: a body whose content comes from a memory slice.
277 /// Creates an HTTP body that based on memory slice.
286 /// let body = Body::slice("HelloWorld");
288 pub fn slice<T>(slice: T) -> Self in slice() functions
292 Body::new(BodyKind::Slice(Cursor::new(slice.into()))) in slice()
347 BodyKind::Slice(ref mut slice) => {
348 slice
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dalt_svc.rs116 let slice = value.as_slice();
117 if slice == "clear".as_bytes() {
122 for slice in slice.split(|c| *c == b',') {
123 if let Some(alt_svc) = Self::parse_alt_svc(host, slice) {
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/
H A Dc_ssl_stream.rs16 use core::{future, ptr, slice};
100 let slice = unsafe { in poll_read()
102 slice::from_raw_parts_mut(buf.as_mut_ptr().cast::<u8>(), buf.len()) in poll_read()
104 match check_io_to_poll(s.read(slice))? { in poll_read()
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dtcp_test.rs112 let slice = IoSlice::new(vec); in sdv_tcp_server_vectored()
113 let mut ret = stream.write_vectored(&[slice]); in sdv_tcp_server_vectored()
132 let slice = IoSliceMut::new(&mut buf); in sdv_tcp_server_vectored()
133 let ret = read_stream.read_vectored(&mut [slice]); in sdv_tcp_server_vectored()
H A Duds_test.rs48 let slice = IoSliceMut::new(&mut buffer); in sdv_uds_stream_test()
50 match stream.read_vectored(&mut [slice]) { in sdv_uds_stream_test()
60 let slice = IoSlice::new(buf); in sdv_uds_stream_test()
61 let n = stream.write_vectored(&[slice]).unwrap(); in sdv_uds_stream_test()
/commonlibrary/rust/ylong_json/src/reader/
H A Dslice_reader.rs20 /// let slice = "Hello World";
21 /// let mut reader = SliceReader::new(slice.as_bytes());
26 slice: &'a [u8],
36 /// Create a new `SliceReader` from the given slice.
38 /// let slice = "Hello World";
39 /// let reader = SliceReader::new(slice.as_bytes());
41 pub(crate) fn new(slice: &'a [u8]) -> Self {
43 slice,
55 if self.index >= self.slice.len() { in next()
58 let ch = self.slice[sel in next()
[all...]
/commonlibrary/rust/ylong_json/src/
H A Dadapter.rs47 let slice = &*slice_from_raw_parts(value as *mut u8, len);
49 let value = match JsonValue::from_text(slice) {
363 let slice = &*slice_from_raw_parts(string as *mut u8, len);
364 let string = CString::from_vec_unchecked(slice.to_vec());
419 let slice = &*slice_from_raw_parts(value as *mut u8, len);
420 *string = CString::from_vec_unchecked(slice.to_vec());
748 let slice = &*slice_from_raw_parts(string as *mut u8, len);
749 let str = from_utf8_unchecked(slice);
778 let slice = &*slice_from_raw_parts(string as *mut u8, len);
779 let index = from_utf8_unchecked(slice);
[all...]
H A Ddeserializer.rs75 /// Creates an instance of Deserializer from slice.
77 pub fn new_from_slice(slice: &'a [u8]) -> Self { in new_from_slice()
78 Deserializer::new(SliceReader::new(slice)) in new_from_slice()
130 /// let slice = r#"{"int":1,"seq":["abcd","efgh"],"tup":[1,2,3]}"#.as_bytes();
136 /// assert_eq!(expected, from_slice(slice).unwrap())
138 pub fn from_slice<'a, T>(slice: &'a [u8]) -> Result<T, Error> in from_slice()
142 let mut deserializer = Deserializer::new_from_slice(slice); in from_slice()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
H A Dbio.rs17 use core::{ptr, slice};
260 let buf = slice::from_raw_parts(buf as *const _, len as usize);
268 let buf = slice::from_raw_parts_mut(buf as *mut _, len as usize);
/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_http2.rs179 .body(Body::slice(body_date)) in sdv_async_h2_client_send_request()
259 .body(Body::slice(body_date)) in sdv_async_h2_client_send_request_concurrently()
H A Dsdv_async_https_pinning.rs276 .body(ylong_http_client::async_impl::Body::slice("hello")) in sdv_client_public_key_pinning_error()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Dasync_source.rs184 let slice = &mut *(buf.unfilled_mut() as *mut [MaybeUninit<u8>] as *mut [u8]);
186 self.io.as_ref().unwrap().read(slice)
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Dstream.rs34 iter: core::slice::Iter<'a, FrameKind>,
81 type Target = core::slice::Iter<'a, FrameKind>;
H A Ddecoder.rs524 Payload::Data(Data::new(Vec::from(reader.slice(payload_len)?))), in decode_data_payload()
603 .decode_repr(reader.slice(payload_len)?, id) in decode_headers_payload()
743 reader.slice(payload_len)?; in decode_unknown_payload()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/
H A Dmod.rs21 /// Parallel iterator implementation for slice
22 pub mod slice; modules
/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/
H A Ddecoder.rs607 let slice = decode($octets).unwrap(); in ut_repr_decoder()
608 let mut decoder = ReprDecoder::new(&slice); in ut_repr_decoder()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/
H A Dssl_base.rs19 use std::slice::from_raw_parts;
/commonlibrary/rust/ylong_json/src/value/array/
H A Dvec.rs16 use core::slice::{Iter, IterMut};
/commonlibrary/rust/ylong_json/src/value/object/
H A Dvec.rs16 use core::slice::{Iter, IterMut};
/commonlibrary/rust/ylong_http/ylong_http/src/
H A Dheaders.rs48 use core::{fmt, slice, str};
198 /// Converts a slice of bytes to a `HeaderName`.
310 /// Attempts to convert a byte slice to a non-sensitive `HeaderValue`.
532 pub type HeaderValueIter<'a> = slice::Iter<'a, Vec<u8>>;
552 pub type HeaderValueIterMut<'a> = slice::IterMut<'a, Vec<u8>>;
/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/
H A Dasync_utils.rs341 .body(ylong_http_client::async_impl::Body::slice($req_body))
H A Dmod.rs260 .body(ylong_http_client::async_impl::Body::slice($req_body.as_bytes()))
/commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/
H A Dmod.rs297 .body(ylong_http_client::async_impl::Body::slice($req_body.as_bytes()))
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dread_task.rs17 use std::slice::from_raw_parts_mut;

Completed in 14 milliseconds

12