| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/decode/ |
| D | part.rs | 191 let mut decoder = MimePartDecoder::new(); in ut_mime_part_decoder_new_by_crlf() localVariable
192 decoder.set_boundary(b"abc".to_vec()); in ut_mime_part_decoder_new_by_crlf()
193 let (elem, rest) = decoder.decode(buf).unwrap(); in ut_mime_part_decoder_new_by_crlf()
203 let mut decoder = MimePartDecoder::new(); in ut_mime_part_decoder_new_by_crlf() localVariable
204 decoder.set_boundary(b"abc".to_vec()); in ut_mime_part_decoder_new_by_crlf()
205 let (elem, rest) = decoder.decode(buf).unwrap(); in ut_mime_part_decoder_new_by_crlf()
215 let mut decoder = MimePartDecoder::new(); in ut_mime_part_decoder_new_by_crlf() localVariable
216 decoder.set_boundary(b"abc".to_vec()); in ut_mime_part_decoder_new_by_crlf()
217 let (elem, rest) = decoder.decode(buf).unwrap(); in ut_mime_part_decoder_new_by_crlf()
242 let mut decoder = MimePartDecoder::new(); in ut_mime_part_decoder_new_by_lf() localVariable
[all …]
|
| D | multi.rs | 80 let mut decoder = MimeMultiDecoder { in new() localVariable
85 decoder.multis.push(multi); in new()
87 decoder.stages.push(MultiStage::Multi(data)); in new()
88 decoder in new()
190 let mut decoder = MimePartDecoder::new(); in push_new_part_stage() localVariable
192 decoder.init_from_multi(headers, self.last_multi()?.boundary.clone()); in push_new_part_stage()
193 self.stages.push(MultiStage::Part(decoder)); in push_new_part_stage()
543 let mut decoder = MimeMultiDecoder::new(); in ut_mime_multi_decoder_new() localVariable
544 let (elem, rest) = decoder.decode(buf).unwrap(); in ut_mime_multi_decoder_new()
569 let mut decoder = MimeMultiDecoder::new(); in ut_mime_multi_decoder_one_part() localVariable
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/response/ |
| D | mod.rs | 121 let mut decoder = ResponseDecoder::new(); in ut_response_version() localVariable
122 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_response_version()
140 let mut decoder = ResponseDecoder::new(); in ut_response_status_code() localVariable
141 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_response_status_code()
158 let mut decoder = ResponseDecoder::new(); in ut_response_headers() localVariable
159 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_response_headers()
184 let mut decoder = ResponseDecoder::new(); in ut_response_body() localVariable
185 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_response_body()
202 let mut decoder = ResponseDecoder::new(); in ut_response_body_mut() localVariable
203 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_response_body_mut()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| D | decoder.rs | 19 use crate::h2::decoder::Stage::{Header, Payload};
883 use crate::h2::decoder::{get_setting, FrameDecoder, FrameHeader, FrameKind};
1020 let mut decoder = FrameDecoder::default(); localVariable
1022 … let decoded_frames = decoder.decode(frame_bytes.as_slice()).expect("decode frame bytes failed !");
1051 let mut decoder = FrameDecoder::default(); localVariable
1053 … let decoded_frames = decoder.decode(frame_bytes.as_slice()).expect("decode frame bytes failed !");
1077 let mut decoder = FrameDecoder::new(); localVariable
1078 decoder.set_max_header_list_size($header_list_size);
1079 … decoder.set_max_frame_size($max_frame_size).expect("Illegal size of SETTINGS_MAX_FRAME_SIZE !");
1081 let decoded_frames = decoder.decode(frame_bytes.as_slice());
[all …]
|
| D | mod.rs | 53 mod decoder; module
61 pub use decoder::{FrameDecoder, FrameKind, Frames, FramesIntoIter};
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| D | headers.rs | 23 use crate::h1::response::decoder::{HEADER_NAME_BYTES, HEADER_VALUE_BYTES};
332 let mut decoder = DecodeHeaders::new(); in ut_decode_headers_new() localVariable
333 let (headers, rest) = decoder.decode(buf).unwrap(); in ut_decode_headers_new()
339 let mut decoder = DecodeHeaders::new(); in ut_decode_headers_new() localVariable
340 let (headers, rest) = decoder.decode(buf).unwrap(); in ut_decode_headers_new()
355 let mut decoder = DecodeHeaders::new(); in ut_decode_headers_new2() localVariable
356 let (headers, rest) = decoder.decode(buf).unwrap(); in ut_decode_headers_new2()
362 let mut decoder = DecodeHeaders::new(); in ut_decode_headers_new2() localVariable
363 let (headers, rest) = decoder.decode(buf).unwrap(); in ut_decode_headers_new2()
379 let mut decoder = DecodeHeaders::new(); in ut_decode_headers_decode() localVariable
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h1/response/ |
| D | mod.rs | 18 pub(crate) mod decoder; module
20 pub use decoder::ResponseDecoder;
|
| D | decoder.rs | 721 let mut decoder = ResponseDecoder::new(); localVariable
722 let result = decoder.decode($res1).unwrap().unwrap();
735 let mut decoder = ResponseDecoder::new(); localVariable
736 let result = decoder.decode($res1.0).unwrap();
738 let result = decoder.decode($res1.1).unwrap().unwrap();
751 let mut decoder = ResponseDecoder::new(); localVariable
752 let result = decoder.decode($res1);
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| D | mod.rs | 46 mod decoder; module
52 pub(crate) use decoder::HpackDecoder;
|
| D | decoder.rs | 57 let mut decoder = ReprDecoder::new(buf); in decode() localVariable
58 decoder.load(&mut self.holder); in decode()
62 match decoder.decode()? { in decode()
68 decoder.save(&mut self.holder); in decode()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | http_body.rs | 81 decoder: TextBodyDecoder, field
89 decoder: TextBodyDecoder::new(len), in new()
134 let (text, rem) = self.decoder.decode(&buf[..read]); in data()
167 let (text, rem) = self.decoder.decode(&buf[read..read + filled]); in data()
197 decoder: ChunkBodyDecoder, field
206 decoder: ChunkBodyDecoder::new().contains_trailer(is_trailer), in new()
294 .decoder in merge_chunks()
423 decoder: ChunkBodyDecoder::new().contains_trailer(true), in ut_http_body_chunk()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| D | chunk.rs | 1630 let mut decoder = ChunkBodyDecoder::new().contains_trailer(true); in ut_chunk_body_decode_0() localVariable
1643 let res = decoder.decode(&chunk_body_bytes[..1]); in ut_chunk_body_decode_0()
1655 let res = decoder.decode(&chunk_body_bytes[1..2]); in ut_chunk_body_decode_0()
1667 let res = decoder.decode(&chunk_body_bytes[2..2]); in ut_chunk_body_decode_0()
1679 let res = decoder.decode(&chunk_body_bytes[2..3]); in ut_chunk_body_decode_0()
1692 let res = decoder.decode(&chunk_body_bytes[3..5]); in ut_chunk_body_decode_0()
1705 let res = decoder.decode(&chunk_body_bytes[5..9]); in ut_chunk_body_decode_0()
1718 let res = decoder.decode(&chunk_body_bytes[9..9]); in ut_chunk_body_decode_0()
1731 let res = decoder.decode(&chunk_body_bytes[9..10]); in ut_chunk_body_decode_0()
1744 let res = decoder.decode(&chunk_body_bytes[10..13]); in ut_chunk_body_decode_0()
[all …]
|
| D | text.rs | 648 let mut decoder = TextBodyDecoder::new(22); in ut_text_body_decoder_decode() localVariable
649 let (text, left) = decoder.decode(&bytes[..4]); in ut_text_body_decoder_decode()
654 let (text, left) = decoder.decode(&bytes[4..11]); in ut_text_body_decoder_decode()
659 let (text, left) = decoder.decode(&bytes[11..26]); in ut_text_body_decoder_decode()
664 let (text, left) = decoder.decode(&bytes[26..]); in ut_text_body_decoder_decode()
671 let mut decoder = TextBodyDecoder::new(22); in ut_text_body_decoder_decode() localVariable
672 let (text, left) = decoder.decode(bytes); in ut_text_body_decoder_decode()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| D | mod.rs | 64 mod decoder; module
67 pub(crate) use decoder::{ReprDecStateHolder, ReprDecodeState, ReprDecoder};
|
| D | decoder.rs | 585 ($decoder: expr, $pat: ident => $name: expr) => { in ut_repr_decoder()
586 match $decoder.decode() { in ut_repr_decoder()
591 ($decoder: expr, $pat: ident, $kind: ident => $name: expr, $value: expr) => { in ut_repr_decoder()
592 match $decoder.decode() { in ut_repr_decoder()
608 let mut decoder = ReprDecoder::new(&slice); in ut_repr_decoder() localVariable
610 inner_test_case!(decoder, $pat $(, $kind)? => $first $(, $second)?); in ut_repr_decoder()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | http_body.rs | 249 decoder: TextBodyDecoder, field
257 decoder: TextBodyDecoder::new(len), in new()
283 let (text, rem) = self.decoder.decode(&buf[..read]); in data()
320 let (text, rem) = self.decoder.decode(read_buf.filled()); in data()
360 decoder: ChunkBodyDecoder, field
370 decoder: ChunkBodyDecoder::new().contains_trailer(false), in new()
471 .decoder in merge_chunks()
584 decoder: ChunkBodyDecoder::new().contains_trailer(true), in ut_http_body_chunk()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/huffman/ |
| D | mod.rs | 369 let mut decoder = HuffmanDecoder::new(); in ut_huffman_decoder() localVariable
372 assert!(decoder.decode(&bytes).is_ok()); in ut_huffman_decoder()
374 match decoder.finish() { in ut_huffman_decoder()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | redirect.rs | 292 let mut decoder = ResponseDecoder::new(); in ut_get_trigger_kind() localVariable
293 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_get_trigger_kind()
319 let mut decoder = ResponseDecoder::new(); in ut_get_trigger_kind_err() localVariable
320 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_get_trigger_kind_err()
|
| D | dispatcher.rs | 255 pub(crate) decoder: FrameDecoder, field
548 decoder: FrameDecoder::new(), in new()
1066 let frames = io_manager.inner.decoder.decode(&buf[..read])?; in poll_read_frame()
1257 guard.inner.decoder.set_max_header_list_size(*size as usize); in recv_settings_frame()
1260 guard.inner.decoder.set_max_frame_size(*size)?; in recv_settings_frame()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| D | http1.rs | 90 let mut decoder = ResponseDecoder::new(); in request() localVariable
107 match decoder.decode(&buf[..size]) { in request()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/conn/ |
| D | http1.rs | 84 let mut decoder = ResponseDecoder::new(); in request() localVariable
90 match decoder.decode(&buf[..size]) { in request()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/ |
| D | settings.rs | 555 let mut decoder = ResponseDecoder::new(); in ut_setting_get_redirect_kind_err() localVariable
556 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_setting_get_redirect_kind_err()
|