Home
last modified time | relevance | path

Searched refs:decoder (Results 1 - 25 of 29) sorted by relevance

12

/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/decode/
H A Dpart.rs191 let mut decoder = MimePartDecoder::new(); in ut_mime_part_decoder_new_by_crlf() variables
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() variables
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() variables
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 in ut_mime_part_decoder_new_by_lf() variables
254 let mut decoder = MimePartDecoder::new(); ut_mime_part_decoder_new_by_lf() variables
266 let mut decoder = MimePartDecoder::new(); ut_mime_part_decoder_new_by_lf() variables
287 let mut decoder = MimePartDecoder::new(); ut_mime_part_decoder_decode() variables
313 let mut decoder = MimePartDecoder::new(); ut_mime_part_decoder_no_headers_no_body() variables
335 let mut decoder = MimePartDecoder::new(); ut_decode_headers_decode_times() variables
[all...]
H A Dmulti.rs40 /// let mut decoder = MimeMultiDecoder::new();
41 /// let (elem, rest) = decoder.decode(buf).unwrap();
77 /// let mut decoder = MimeMultiDecoder::new();
80 let mut decoder = MimeMultiDecoder { in new() variables
85 decoder.multis.push(multi); in new()
87 decoder.stages.push(MultiStage::Multi(data)); in new()
88 decoder in new()
101 /// let mut decoder = MimeMultiDecoder::new();
102 /// let (elem, rest) = decoder.decode(buf).unwrap();
190 let mut decoder in push_new_part_stage() variables
543 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_new() variables
569 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_one_part() variables
602 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_one_part_no_headers() variables
634 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_one_part_no_body() variables
667 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_several_parts() variables
707 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_several_parts_has_lwsp() variables
748 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_nest() variables
789 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_nest2() variables
837 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_nest3() variables
885 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_nest4() variables
936 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_times() variables
995 let mut decoder = MimeMultiDecoder::new(); ut_mime_multi_decoder_err() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Ddecoder.rs20 use crate::h2::decoder::Stage::{Header, Payload};
160 /// Frame bytes sequence decoder, supporting fragment deserialization of Frames.
167 /// let mut decoder = FrameDecoder::new();
168 /// decoder.set_max_header_list_size(30);
170 /// let decoded_frames = decoder.decode(data_frame_bytes).unwrap();
178 // Current decode Stage of decoder
341 /// let mut decoder = FrameDecoder::new();
342 /// decoder.set_max_header_list_size(30);
344 /// let decoded_frames = decoder.decode(&data_frame_bytes[..9]).unwrap();
346 /// let decoded_frames = decoder
1026 let mut decoder = FrameDecoder::default(); global() variables
1057 let mut decoder = FrameDecoder::default(); global() variables
1083 let mut decoder = FrameDecoder::new(); global() variables
1149 let mut decoder = FrameDecoder::default(); ut_frame_decoder_with_segmented_data_frame() variables
1262 let mut decoder = FrameDecoder::default(); ut_frame_decoder_with_series_request_frames() variables
1354 let mut decoder = FrameDecoder::default(); ut_frame_decoder_with_padded_end_stream_headers_frame() variables
1381 let mut decoder = FrameDecoder::new(); ut_decode_ping_payload() variables
1439 let mut decoder = FrameDecoder::new(); ut_decode_priority_payload() variables
1487 let mut decoder = FrameDecoder::new(); ut_decode_goaway_payload() variables
1532 let mut decoder = FrameDecoder::new(); ut_decode_window_update_payload() variables
1576 let mut decoder = FrameDecoder::new(); ut_decode_reset_payload() variables
1626 let mut decoder = FrameDecoder::new(); ut_decode_settings_payload() variables
1708 let mut decoder = FrameDecoder::new(); ut_decode_push_promise_payload() variables
[all...]
H A Dmod.rs53 mod decoder; modules
61 pub use decoder::{FrameDecoder, FrameKind, Frames, FramesIntoIter};
/commonlibrary/rust/ylong_http/ylong_http/src/response/
H A Dmod.rs121 let mut decoder = ResponseDecoder::new(); in ut_response_version() variables
122 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_response_version()
140 let mut decoder = ResponseDecoder::new(); in ut_response_status_code() variables
141 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_response_status_code()
158 let mut decoder = ResponseDecoder::new(); in ut_response_headers() variables
159 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_response_headers()
184 let mut decoder = ResponseDecoder::new(); in ut_response_body() variables
185 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_response_body()
202 let mut decoder = ResponseDecoder::new(); in ut_response_body_mut() variables
203 let result = decoder in ut_response_body_mut()
219 let mut decoder = ResponseDecoder::new(); ut_response_into_parts() variables
240 let mut decoder = ResponseDecoder::new(); ut_response_from_raw_parts() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http/tests/
H A Dsdv_http_error.rs39 // We need to create a decoder first. in sdv_client_send_request_repeatedly()
40 let mut decoder = ResponseDecoder::new(); in sdv_client_send_request_repeatedly() variables
48 decoder.decode(b"HTTP/1.3 304 OK\r\nCon").err().unwrap() in sdv_client_send_request_repeatedly()
55 decoder.decode(b"HTTP/1.3 304 OK\r\nCon").err().unwrap() in sdv_client_send_request_repeatedly()
H A Dsdv_http_body.rs159 let mut decoder = ChunkBodyDecoder::new(); in sdv_chunk_body_decode_0() variables
171 let (chunks_1, _) = decoder.decode(chunk_body_bytes_1).unwrap(); in sdv_chunk_body_decode_0()
183 let (chunks_2, _) = decoder.decode(chunk_body_bytes_2).unwrap(); in sdv_chunk_body_decode_0()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dnormalizer.rs273 let mut decoder = ResponseDecoder::new(); in ut_body_length_parser() variables
274 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_body_length_parser()
281 let mut decoder = ResponseDecoder::new(); in ut_body_length_parser() variables
282 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_body_length_parser()
289 let mut decoder = ResponseDecoder::new(); in ut_body_length_parser() variables
290 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_body_length_parser()
297 let mut decoder = ResponseDecoder::new(); in ut_body_length_parser() variables
298 let result = decoder.decode(response_str).unwrap().unwrap(); in ut_body_length_parser()
/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/
H A Ddecoder.rs57 let mut decoder = ReprDecoder::new(buf); variables
58 decoder.load(&mut self.holder);
62 match decoder.decode()? {
68 decoder.save(&mut self.holder);
598 let mut decoder = HpackDecoder::with_max_size(1000, 2000); in ut_decode_literal_non_utf8_header_value() variables
607 let res = decoder.decode(&buf); in ut_decode_literal_non_utf8_header_value()
H A Dmod.rs46 mod decoder; modules
52 pub(crate) use decoder::HpackDecoder;
/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dtext.rs229 /// A decoder for decoding plaintext body.
231 /// You need to provide the decoder with a body length and some byte slices
232 /// containing a legal body. The decoder will divide the correct body and
235 /// This decoder supports decoding segmented byte slices.
242 /// // Creates a decoder and set the body length to 20.
243 /// let mut decoder = TextBodyDecoder::new(20);
245 /// // Provides the decoder with the first slice that may contain the body data.
250 /// let (text, left) = decoder.decode(slice1);
251 /// // Since the slice provided before is not enough for the decoder to
258 /// // Provides the decoder wit
623 let mut decoder = TextBodyDecoder::new(22); ut_text_body_decoder_decode() variables
646 let mut decoder = TextBodyDecoder::new(22); ut_text_body_decoder_decode() variables
[all...]
H A Dchunk.rs857 /// Chunk decoder.
858 /// The decoder decode only all chunks and last-chunk in chunk-body and does not
859 /// decode subsequent trailer-section. The decoder maintains a state saving
885 /// Constructor of `ChunkBodyDecoder` bytes decoder.
921 /// Decode interface of the chunk decoder.
931 /// let mut decoder = ChunkBodyDecoder::new();
939 /// let (chunks, rest) = decoder.decode(chunk_body_bytes).unwrap();
1604 let mut decoder = ChunkBodyDecoder::new().contains_trailer(true); in ut_chunk_body_decode_0() variables
1617 let res = decoder.decode(&chunk_body_bytes[..1]); in ut_chunk_body_decode_0()
1629 let res = decoder in ut_chunk_body_decode_0()
1857 let mut decoder = ChunkBodyDecoder::new(); ut_chunk_body_decode_1() variables
1910 let mut decoder = ChunkBodyDecoder::new(); ut_chunk_body_decode_2() variables
1970 let mut decoder = ChunkBodyDecoder::new(); ut_chunk_body_decode_3() variables
1994 let mut decoder = ChunkBodyDecoder::new(); ut_chunk_body_decode_4() variables
2017 let mut decoder = ChunkBodyDecoder::new(); ut_chunk_body_decode_5() variables
2031 let mut decoder = ChunkBodyDecoder::new(); ut_chunk_body_decode_6() variables
2072 let mut decoder = ChunkBodyDecoder::new().contains_trailer(true); ut_chunk_body_decode_7() variables
2135 let mut decoder = ChunkBodyDecoder::new().contains_trailer(true); ut_chunk_body_decode_8() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dhttp_body.rs80 decoder: TextBodyDecoder,
88 decoder: TextBodyDecoder::new(len),
112 Kind::Chunk(ref mut chunk) => chunk.decoder.get_trailer().map_err(|_| { in trailer()
135 let (text, rem) = self.decoder.decode(&buf[..read]); in data()
165 let (text, rem) = self.decoder.decode(&buf[read..read + filled]); in data()
190 decoder: ChunkBodyDecoder,
198 decoder: ChunkBodyDecoder::new().contains_trailer(is_trailer),
280 .decoder in merge_chunks()
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Dmod.rs16 mod decoder; modules
26 pub use decoder::FrameDecoder;
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dhttp_body.rs154 Poll::Ready(Ok(chunk.decoder.get_trailer().map_err(|e| { in poll_trailer()
271 decoder: TextBodyDecoder,
285 decoder: TextBodyDecoder::new(len),
330 let (text, rem) = self.decoder.decode(&buf[..read]); in read_remaining()
369 if io.is_stream_closable() && self.decoder.decode(&buf[..0]).0.is_complete() { in poll_read_io()
375 let (text, rem) = self.decoder.decode(read_buf.filled()); in poll_read_io()
416 decoder: ChunkBodyDecoder,
426 decoder: ChunkBodyDecoder::new().contains_trailer(true),
521 .decoder in merge_chunks()
/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/
H A Ddecoder.rs585 ($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() variables
610 inner_test_case!(decoder, $pat $(, $kind)? => $first $(, $second)?); in ut_repr_decoder()
H A Dmod.rs64 mod decoder; modules
67 pub(crate) use decoder::{ReprDecStateHolder, ReprDecodeState, ReprDecoder};
/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/
H A Dmod.rs13 pub(crate) mod decoder;
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Doutput.rs41 decoder: FrameDecoder,
62 decoder: FrameDecoder,
68 decoder,
99 match self.decoder.decode(&buf[..read]) {
246 self.decoder.set_max_header_list_size(*size as usize); in update_decoder_settings()
249 self.decoder.set_max_frame_size(*size)?; in update_decoder_settings()
/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/
H A Ddecoder.rs20 use crate::h3::qpack::decoder::FieldDecodeState::{Blocked, Decoded};
23 use crate::h3::qpack::format::decoder::{
108 let mut decoder = EncInstDecoder::new(); variables
112 match decoder.decode(&buf[cnt..], &mut self.inst_state)? {
216 let mut decoder = ReprDecoder::new(); in decode_buffered_repr() variables
221 match decoder.decode(&buf[cnt..], &mut message.repr_state)? { in decode_buffered_repr()
310 /// the decoder emits a Section Acknowledgment instruction. The instruction
345 /// abandoned, the decoder emits a Stream Cancellation instruction. The
H A Dmod.rs14 pub mod decoder; modules
20 pub(crate) use decoder::{FieldDecodeState, FiledLines, QpackDecoder};
23 use crate::h3::qpack::format::decoder::Name;
H A Dencoder.rs41 // `RFC`: the number of insertions that the decoder needs to receive before it can decode the
187 let mut decoder = DecInstDecoder::new(buf); in decode_ins() variables
189 match decoder.decode(&mut self.inst_state)? { in decode_ins()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A Dstream_manager.rs46 pub(crate) decoder: FrameDecoder,
60 decoder: FrameDecoder,
74 decoder,
300 self.decoder
479 .decoder in process_recv_data()
696 self.decoder.finish_stream(id)?;
/commonlibrary/rust/ylong_http/ylong_http/src/huffman/
H A Dmod.rs369 let mut decoder = HuffmanDecoder::new(); in ut_huffman_decoder() variables
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/async_impl/downloader/
H A Dmod.rs308 let mut decoder = ResponseDecoder::new(); variables
309 let result = decoder.decode(response_str).unwrap().unwrap();

Completed in 15 milliseconds

12