| /commonlibrary/rust/ylong_http/ylong_http/src/h1/response/ |
| D | decoder.rs | 213 buf: &'a [u8], in decode()
214 ) -> Result<Option<(ResponsePart, &'a [u8])>, HttpError> { in decode()
228 buffer: &'a [u8], in version_phase()
229 ) -> Result<Option<(ResponsePart, &'a [u8])>, HttpError> { in version_phase()
252 buffer: &'a [u8], in status_code_phase()
253 ) -> Result<Option<(ResponsePart, &'a [u8])>, HttpError> { in status_code_phase()
273 buffer: &'a [u8], in reason_phase()
274 ) -> Result<Option<(ResponsePart, &'a [u8])>, HttpError> { in reason_phase()
284 buffer: &'a [u8], in status_crlf_phase()
285 ) -> Result<Option<(ResponsePart, &'a [u8])>, HttpError> { in status_crlf_phase()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| D | mod.rs | 74 pub(crate) fn data_copy(src: &[u8], src_idx: &mut usize, buf: &mut [u8]) -> TokenResult<usize> { in data_copy()
87 pub(crate) fn trim_front_lwsp(buf: &[u8]) -> &[u8] { in trim_front_lwsp()
99 fn trim_back_lwsp(buf: &[u8]) -> &[u8] { in trim_back_lwsp()
112 pub(crate) fn trim_back_lwsp_if_end_with_lf(buf: &[u8]) -> &[u8] { in trim_back_lwsp_if_end_with_lf()
122 buf: &[u8], in consume_crlf()
125 ) -> Result<TokenStatus<&[u8], usize>, HttpError> { in consume_crlf()
147 pub(crate) fn get_crlf_contain(buf: &[u8]) -> TokenStatus<(&[u8], &[u8]), &[u8]> { in get_crlf_contain()
157 fn trim_ascii_start(mut bytes: &[u8]) -> &[u8] { in trim_ascii_start()
171 fn trim_ascii_end(mut bytes: &[u8]) -> &[u8] { in trim_ascii_end()
185 fn trim_ascii(bytes: &[u8]) -> &[u8] { in trim_ascii()
[all …]
|
| D | multi.rs | 181 pub(crate) fn set_boundary(&mut self, boundary: Vec<u8>) { in set_boundary()
187 content_type: &[u8], in set_content_type()
188 boundary: Vec<u8>, in set_content_type()
243 pub fn boundary(&self) -> &[u8] { in boundary()
248 pub fn boundary_mut(&mut self) -> &mut [u8] { in boundary_mut()
253 pub fn boundary_once(&mut self) -> Vec<u8> { in boundary_once()
462 pub fn set_content_type(mut self, content_type: &'a [u8], boundary: Vec<u8>) -> Self { in set_content_type()
|
| D | headers.rs | 160 buf: &'a [u8], in decode()
161 ) -> Result<(TokenStatus<Headers, ()>, &'a [u8]), HttpError> { in decode()
189 fn start_decode<'a>(&mut self, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in start_decode()
231 fn crlf_decode<'a>(&mut self, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in crlf_decode()
242 fn name_decode<'a>(&mut self, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in name_decode()
264 fn value_decode<'a>(&mut self, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in value_decode()
|
| D | part.rs | 105 pub(crate) fn body_from_owned(&mut self, data: Vec<u8>) { in body_from_owned()
109 pub(crate) fn body_from_bytes(&mut self, data: &'a [u8]) { in body_from_bytes()
127 pub(crate) fn body_extend_from_slice(&mut self, src: &[u8]) { in body_extend_from_slice()
183 pub fn body(&self) -> Option<&Vec<u8>> { in body()
191 pub fn body_mut(&mut self) -> Option<&mut Vec<u8>> { in body_mut()
199 pub fn body_once(&mut self) -> Option<Vec<u8>> { in body_once()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/huffman/ |
| D | mod.rs | 44 pub(crate) fn huffman_encode(src: &[u8], dst: &mut Vec<u8>) { in huffman_encode()
127 pub(crate) fn huffman_decode(src: &[u8], dst: &mut Vec<u8>) -> Result<(), HuffmanDecodeError> { in huffman_decode()
171 src: &[u8], in huffman_decode_inner()
172 dst: &mut Vec<u8>, in huffman_decode_inner()
173 state: u8, in huffman_decode_inner()
174 flags: u8, in huffman_decode_inner()
175 ) -> Result<(u8, u8), HuffmanDecodeError> { in huffman_decode_inner() argument
232 pub(crate) fn finish(self) -> Result<Vec<u8>, HuffmanDecodeError> { in finish()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | read_buf.rs | 50 buf: &'a mut [MaybeUninit<u8>], in create()
99 pub fn filled(&self) -> &[u8] { in filled()
105 pub fn filled_mut(&mut self) -> &mut [u8] { in filled_mut()
111 pub fn unfilled_mut(&mut self) -> &mut [MaybeUninit<u8>] { in unfilled_mut()
117 pub fn initialized(&self) -> &[u8] { in initialized()
123 pub fn initialized_mut(&mut self) -> &mut [u8] { in initialized_mut()
132 pub fn inner_mut(&mut self) -> &mut [MaybeUninit<u8>] { in inner_mut()
149 pub fn initialize_unfilled_to(&mut self, n: usize) -> &mut [u8] { in initialize_unfilled_to()
169 pub fn initialize_unfilled(&mut self) -> &mut [u8] { in initialize_unfilled()
227 pub fn append(&mut self, buf: &[u8]) { in append()
|
| D | async_buf_read.rs | 37 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>>; in poll_fill_buf()
52 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
63 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
78 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
106 fn read_until<'a>(&'a mut self, byte: u8, buf: &'a mut Vec<u8>) -> ReadUtilTask<'a, Self> in read_until()
|
| D | read_task.rs | 96 fn poll_read_to_end<R: AsyncRead + Unpin>( in poll_read_to_end()
280 pub(crate) fn new(reader: &'a mut R, delim: u8, buf: &'a mut Vec<u8>) -> ReadUtilTask<'a, R> { in new()
290 fn poll_read_until<R: AsyncBufRead + Unpin>( in poll_read_until()
293 delim: u8, in poll_read_until()
399 fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<Option<Vec<u8>>>> { in poll_next()
414 pub async fn next(&mut self) -> io::Result<Option<Vec<u8>>> { in next()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/decode/ |
| D | multi.rs | 117 buf: &'a [u8], in decode()
118 ) -> Result<(TokenStatus<MimeMulti, ()>, &'a [u8]), HttpError> { in decode()
155 buf: &'a [u8], in unknown_decode()
156 ) -> Result<&'a [u8], HttpError> { in unknown_decode()
177 fn push_new_multi_stage(&mut self, headers: Headers, boundary: Vec<u8>) { in push_new_multi_stage()
200 buf: &'a [u8], in part_decode()
201 ) -> Result<&'a [u8], HttpError> { in part_decode()
222 fn multi_decode<'a>(&mut self, data: DecodeData, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in multi_decode()
233 buf: &'a [u8], in middle_or_end_boundary_decode()
234 ) -> Result<&'a [u8], HttpError> { in middle_or_end_boundary_decode()
[all …]
|
| D | part.rs | 59 pub(crate) fn init_from_multi(&mut self, headers: Headers, boundary: Vec<u8>) { in init_from_multi()
66 pub(crate) fn set_boundary(&mut self, boundary: Vec<u8>) { in set_boundary()
72 buf: &'a [u8], in decode()
73 ) -> Result<(TokenStatus<MimePart<'static>, ()>, &'a [u8]), HttpError> { in decode()
101 fn start_decode<'a>(&mut self, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in start_decode()
108 fn headers_decode<'a>(&mut self, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in headers_decode()
119 fn body_decode<'a>(&mut self, buf: &'a [u8]) -> Result<&'a [u8], HttpError> { in body_decode()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/tls/alpn/ |
| D | mod.rs | 93 pub fn as_use_bytes(&self) -> &[u8] { in as_use_bytes()
108 pub fn id_sequence(&self) -> &[u8] { in id_sequence()
134 fn extend_from_slice(&mut self, other: &[u8]) { in extend_from_slice()
146 pub fn into_bytes(self) -> Vec<u8> { in into_bytes()
152 pub fn as_slice(&self) -> &[u8] { in as_slice()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| D | multi.rs | 133 fn push_list_to_stages(&mut self, boundary: Vec<u8>, list: Vec<XPart<'a>>) { in push_list_to_stages()
172 fn push_first_boundary(&mut self, boundary: Vec<u8>) { in push_first_boundary()
181 fn push_middle_boundary(&mut self, boundary: Vec<u8>) { in push_middle_boundary()
188 fn push_end_boundary(&mut self, boundary: Vec<u8>) { in push_end_boundary()
239 fn boundary_encode(&mut self, dst: &mut [u8], boundary: Vec<u8>) -> SizeResult { in boundary_encode()
252 fn headers_encode(&mut self, dst: &mut [u8], mut headers_encoder: EncodeHeaders) -> SizeResult { in headers_encode()
267 dst: &mut [u8], in sync_mimepart_encode()
314 buf: &mut [u8], in poll_data()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | http_body.rs | 70 pre: &[u8], in new()
102 pub(crate) fn text(len: usize, pre: &[u8], io: BoxStreamData) -> Self { in text()
120 buf: &mut [u8], in poll_data()
183 pub(crate) fn new(pre: &[u8], io: BoxStreamData) -> Self { in new()
193 buf: &mut [u8], in data()
255 pub(crate) fn new(len: usize, pre: &[u8], io: BoxStreamData) -> Self { in new()
268 buf: &mut [u8], in data()
368 pub(crate) fn new(pre: &[u8], io: BoxStreamData) -> Self { in new()
383 buf: &mut [u8], in data()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| D | encoder.rs | 260 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
283 fn new(name: Vec<u8>, value: Vec<u8>, is_huffman: bool) -> Self { in new()
306 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
329 fn new(name: Vec<u8>, value: Vec<u8>, is_huffman: bool) -> Self { in new()
352 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
375 fn new(name: Vec<u8>, value: Vec<u8>, is_huffman: bool) -> Self { in new()
423 fn set_index(mut self, index: usize, mask: u8, pre: u8) -> Self { in set_index()
428 fn set_value(mut self, value: Vec<u8>, is_huffman: bool) -> Self { in set_value()
462 fn set_index(mut self, mask: u8, pre: u8) -> Self { in set_index()
467 fn set_name_and_value(mut self, name: Vec<u8>, value: Vec<u8>, is_huffman: bool) -> Self { in set_name_and_value()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| D | chunk.rs | 131 fn chunk_encode(&mut self, src: &[u8], dst: &mut [u8]) -> usize { in chunk_encode()
271 buf: &mut [u8], in poll_data()
297 buf: &mut [u8], in poll_data()
352 buf: &mut [u8], in poll_data()
522 fn encode(&mut self, src: &[u8], dst: &mut [u8]) -> (usize, Option<StatusVar>) { in encode()
598 fn data_encode(&mut self, src: &[u8], dst: &mut [u8]) -> (usize, Option<StatusVar>) { in data_encode()
615 fn tail_encode(&mut self, src: &[u8], dst: &mut [u8]) -> (usize, Option<StatusVar>) { in tail_encode()
689 fn encode(&mut self, src: &[u8], buf: &mut [u8]) -> Token<usize> { in encode()
702 fn new(src: &'a [u8], src_idx: &'a mut usize, dst: &'a mut [u8]) -> Self { in new()
922 pub fn data(&self) -> &[u8] { in data()
[all …]
|
| D | mod.rs | 229 buf: &mut [u8], in poll_data()
333 buf: &mut [u8], in poll_read()
348 impl Body for &'static [u8] { implementation
354 buf: &mut [u8], in poll_data()
367 buf: &mut [u8], in poll_data()
380 buf: &mut [u8], in poll_data()
|
| D | text.rs | 216 buf: &mut [u8], in poll_data()
236 buf: &mut [u8], in poll_data()
253 buf: &mut [u8], in poll_data()
376 pub fn decode<'a>(&mut self, buf: &'a [u8]) -> (Text<'a>, &'a [u8]) { in decode()
455 pub fn data(&self) -> &[u8] { in data()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| D | integer.rs | 55 pub(crate) fn first_byte(byte: u8, mask: u8) -> Result<usize, Self> { in first_byte()
113 pub(crate) fn new(i: usize, mask: u8, pre: u8) -> Self { in new()
124 pub(crate) fn next_byte(&mut self) -> Option<u8> { in next_byte()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/ |
| D | test_util.rs | 14 pub(crate) fn decode(str: &str) -> Option<Vec<u8>> { in decode()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | base64.rs | 16 pub(crate) fn encode(input: &[u8]) -> Vec<u8> { in encode()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | http_body.rs | 60 pub(crate) fn text(len: usize, pre: &[u8], io: BoxStreamData) -> Self { in text()
66 pub(crate) fn chunk(pre: &[u8], io: BoxStreamData, is_trailer: bool) -> Self { in chunk()
87 pub(crate) fn new(len: usize, pre: &[u8], io: BoxStreamData) -> Self { in new()
204 pub(crate) fn new(pre: &[u8], io: BoxStreamData, is_trailer: bool) -> Self { in new()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| D | operator.rs | 30 data: &[u8], in poll_download()
83 data: &[u8], in poll_download()
140 data: &[u8], in poll_download()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| D | async_buf_writer.rs | 144 pub fn buffer(&self) -> &[u8] { in buffer()
209 buf: &[u8], in poll_write()
319 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
|
| D | async_buf_reader.rs | 141 pub fn buffer(&self) -> &[u8] { in buffer()
201 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<&[u8]>> { in poll_fill_buf()
255 buf: &[u8], in poll_write()
|