Lines Matching full:frame
58 pub enum Frame { enum
182 impl Frame { implementation
185 ) -> Result<Frame> { in from_bytes() argument
188 let frame = match frame_type { in from_bytes() localVariable
198 Frame::Padding { len } in from_bytes()
201 0x01 => Frame::Ping, in from_bytes()
205 0x04 => Frame::ResetStream { in from_bytes()
211 0x05 => Frame::StopSending { in from_bytes()
221 Frame::Crypto { data } in from_bytes()
224 0x07 => Frame::NewToken { in from_bytes()
230 0x10 => Frame::MaxData { in from_bytes()
234 0x11 => Frame::MaxStreamData { in from_bytes()
239 0x12 => Frame::MaxStreamsBidi { in from_bytes()
243 0x13 => Frame::MaxStreamsUni { in from_bytes()
247 0x14 => Frame::DataBlocked { in from_bytes()
251 0x15 => Frame::StreamDataBlocked { in from_bytes()
256 0x16 => Frame::StreamsBlockedBidi { in from_bytes()
260 0x17 => Frame::StreamsBlockedUni { in from_bytes()
264 0x18 => Frame::NewConnectionId { in from_bytes()
275 0x19 => Frame::RetireConnectionId { in from_bytes()
279 0x1a => Frame::PathChallenge { in from_bytes()
287 0x1b => Frame::PathResponse { in from_bytes()
295 0x1c => Frame::ConnectionClose { in from_bytes()
301 0x1d => Frame::ApplicationClose { in from_bytes()
306 0x1e => Frame::HandshakeDone, in from_bytes()
313 let allowed = match (pkt, &frame) { in from_bytes()
315 (_, Frame::Padding { .. }) | (_, Frame::Ping { .. }) => true, in from_bytes()
319 (packet::Type::ZeroRTT, Frame::ACK { .. }) => false, in from_bytes()
320 (packet::Type::ZeroRTT, Frame::Crypto { .. }) => false, in from_bytes()
321 (packet::Type::ZeroRTT, Frame::HandshakeDone) => false, in from_bytes()
322 (packet::Type::ZeroRTT, Frame::NewToken { .. }) => false, in from_bytes()
323 (packet::Type::ZeroRTT, Frame::PathResponse { .. }) => false, in from_bytes()
324 (packet::Type::ZeroRTT, Frame::RetireConnectionId { .. }) => false, in from_bytes()
325 (packet::Type::ZeroRTT, Frame::ConnectionClose { .. }) => false, in from_bytes()
329 (_, Frame::ACK { .. }) => true, in from_bytes()
330 (_, Frame::Crypto { .. }) => true, in from_bytes()
331 (_, Frame::ConnectionClose { .. }) => true, in from_bytes()
345 Ok(frame) in from_bytes()
352 Frame::Padding { len } => { in to_bytes()
362 Frame::Ping => { in to_bytes()
366 Frame::ACK { in to_bytes()
406 Frame::ResetStream { in to_bytes()
418 Frame::StopSending { in to_bytes()
428 Frame::Crypto { data } => { in to_bytes()
434 Frame::CryptoHeader { .. } => (), in to_bytes()
436 Frame::NewToken { token } => { in to_bytes()
443 Frame::Stream { stream_id, data } => { in to_bytes()
455 Frame::StreamHeader { .. } => (), in to_bytes()
457 Frame::MaxData { max } => { in to_bytes()
463 Frame::MaxStreamData { stream_id, max } => { in to_bytes()
470 Frame::MaxStreamsBidi { max } => { in to_bytes()
476 Frame::MaxStreamsUni { max } => { in to_bytes()
482 Frame::DataBlocked { limit } => { in to_bytes()
488 Frame::StreamDataBlocked { stream_id, limit } => { in to_bytes()
495 Frame::StreamsBlockedBidi { limit } => { in to_bytes()
501 Frame::StreamsBlockedUni { limit } => { in to_bytes()
507 Frame::NewConnectionId { in to_bytes()
522 Frame::RetireConnectionId { seq_num } => { in to_bytes()
528 Frame::PathChallenge { data } => { in to_bytes()
534 Frame::PathResponse { data } => { in to_bytes()
540 Frame::ConnectionClose { in to_bytes()
553 Frame::ApplicationClose { error_code, reason } => { in to_bytes()
561 Frame::HandshakeDone => { in to_bytes()
565 Frame::Datagram { data } => { in to_bytes()
571 Frame::DatagramHeader { .. } => (), in to_bytes()
579 Frame::Padding { len } => *len, in wire_len()
581 Frame::Ping => 1, in wire_len()
583 Frame::ACK { in wire_len()
593 let mut len = 1 + // frame type in wire_len()
620 Frame::ResetStream { in wire_len()
625 1 + // frame type in wire_len()
631 Frame::StopSending { in wire_len()
635 1 + // frame type in wire_len()
640 Frame::Crypto { data } => { in wire_len()
641 1 + // frame type in wire_len()
647 Frame::CryptoHeader { offset, length, .. } => { in wire_len()
648 1 + // frame type in wire_len()
654 Frame::NewToken { token } => { in wire_len()
655 1 + // frame type in wire_len()
660 Frame::Stream { stream_id, data } => { in wire_len()
661 1 + // frame type in wire_len()
668 Frame::StreamHeader { in wire_len()
674 1 + // frame type in wire_len()
681 Frame::MaxData { max } => { in wire_len()
682 1 + // frame type in wire_len()
686 Frame::MaxStreamData { stream_id, max } => { in wire_len()
687 1 + // frame type in wire_len()
692 Frame::MaxStreamsBidi { max } => { in wire_len()
693 1 + // frame type in wire_len()
697 Frame::MaxStreamsUni { max } => { in wire_len()
698 1 + // frame type in wire_len()
702 Frame::DataBlocked { limit } => { in wire_len()
703 1 + // frame type in wire_len()
707 Frame::StreamDataBlocked { stream_id, limit } => { in wire_len()
708 1 + // frame type in wire_len()
713 Frame::StreamsBlockedBidi { limit } => { in wire_len()
714 1 + // frame type in wire_len()
718 Frame::StreamsBlockedUni { limit } => { in wire_len()
719 1 + // frame type in wire_len()
723 Frame::NewConnectionId { in wire_len()
729 1 + // frame type in wire_len()
737 Frame::RetireConnectionId { seq_num } => { in wire_len()
738 1 + // frame type in wire_len()
742 Frame::PathChallenge { .. } => { in wire_len()
743 1 + // frame type in wire_len()
747 Frame::PathResponse { .. } => { in wire_len()
748 1 + // frame type in wire_len()
752 Frame::ConnectionClose { in wire_len()
758 1 + // frame type in wire_len()
765 Frame::ApplicationClose { reason, error_code } => { in wire_len()
766 1 + // frame type in wire_len()
772 Frame::HandshakeDone => { in wire_len()
773 1 // frame type in wire_len()
776 Frame::Datagram { data } => { in wire_len()
777 1 + // frame type in wire_len()
782 Frame::DatagramHeader { length } => { in wire_len()
783 1 + // frame type in wire_len()
791 // Any other frame is ack-eliciting (note the `!`). in ack_eliciting()
794 Frame::Padding { .. } | in ack_eliciting()
795 Frame::ACK { .. } | in ack_eliciting()
796 Frame::ApplicationClose { .. } | in ack_eliciting()
797 Frame::ConnectionClose { .. } in ack_eliciting()
804 Frame::Padding { .. } | in probing()
805 Frame::NewConnectionId { .. } | in probing()
806 Frame::PathChallenge { .. } | in probing()
807 Frame::PathResponse { .. } in probing()
814 Frame::Padding { .. } => QuicFrame::Padding, in to_qlog()
816 Frame::Ping { .. } => QuicFrame::Ping, in to_qlog()
818 Frame::ACK { in to_qlog()
846 Frame::ResetStream { in to_qlog()
856 Frame::StopSending { in to_qlog()
864 Frame::Crypto { data } => QuicFrame::Crypto { in to_qlog()
869 Frame::CryptoHeader { offset, length } => QuicFrame::Crypto { in to_qlog()
874 Frame::NewToken { token } => QuicFrame::NewToken { in to_qlog()
887 Frame::Stream { stream_id, data } => QuicFrame::Stream { in to_qlog()
895 Frame::StreamHeader { in to_qlog()
908 Frame::MaxData { max } => QuicFrame::MaxData { maximum: *max }, in to_qlog()
910 Frame::MaxStreamData { stream_id, max } => QuicFrame::MaxStreamData { in to_qlog()
915 Frame::MaxStreamsBidi { max } => QuicFrame::MaxStreams { in to_qlog()
920 Frame::MaxStreamsUni { max } => QuicFrame::MaxStreams { in to_qlog()
925 Frame::DataBlocked { limit } => in to_qlog()
928 Frame::StreamDataBlocked { stream_id, limit } => in to_qlog()
934 Frame::StreamsBlockedBidi { limit } => QuicFrame::StreamsBlocked { in to_qlog()
939 Frame::StreamsBlockedUni { limit } => QuicFrame::StreamsBlocked { in to_qlog()
944 Frame::NewConnectionId { in to_qlog()
959 Frame::RetireConnectionId { seq_num } => in to_qlog()
964 Frame::PathChallenge { .. } => in to_qlog()
967 Frame::PathResponse { .. } => QuicFrame::PathResponse { data: None }, in to_qlog()
969 Frame::ConnectionClose { in to_qlog()
979 Frame::ApplicationClose { error_code, reason } => in to_qlog()
988 Frame::HandshakeDone => QuicFrame::HandshakeDone, in to_qlog()
990 Frame::Datagram { data } => QuicFrame::Datagram { in to_qlog()
995 Frame::DatagramHeader { length } => QuicFrame::Datagram { in to_qlog()
1003 impl std::fmt::Debug for Frame { implementation
1006 Frame::Padding { len } => { in fmt()
1010 Frame::Ping => { in fmt()
1014 Frame::ACK { in fmt()
1025 Frame::ResetStream { in fmt()
1036 Frame::StopSending { in fmt()
1043 Frame::Crypto { data } => { in fmt()
1047 Frame::CryptoHeader { offset, length } => { in fmt()
1051 Frame::NewToken { .. } => { in fmt()
1055 Frame::Stream { stream_id, data } => { in fmt()
1066 Frame::StreamHeader { in fmt()
1078 Frame::MaxData { max } => { in fmt()
1082 Frame::MaxStreamData { stream_id, max } => { in fmt()
1086 Frame::MaxStreamsBidi { max } => { in fmt()
1090 Frame::MaxStreamsUni { max } => { in fmt()
1094 Frame::DataBlocked { limit } => { in fmt()
1098 Frame::StreamDataBlocked { stream_id, limit } => { in fmt()
1105 Frame::StreamsBlockedBidi { limit } => { in fmt()
1109 Frame::StreamsBlockedUni { limit } => { in fmt()
1113 Frame::NewConnectionId { in fmt()
1125 Frame::RetireConnectionId { seq_num } => { in fmt()
1129 Frame::PathChallenge { data } => { in fmt()
1133 Frame::PathResponse { data } => { in fmt()
1137 Frame::ConnectionClose { in fmt()
1144 "CONNECTION_CLOSE err={error_code:x} frame={frame_type:x} reason={reason:x?}" in fmt()
1148 Frame::ApplicationClose { error_code, reason } => { in fmt()
1155 Frame::HandshakeDone => { in fmt()
1159 Frame::Datagram { data } => { in fmt()
1163 Frame::DatagramHeader { length } => { in fmt()
1172 fn parse_ack_frame(ty: u64, b: &mut octets::Octets) -> Result<Frame> { in parse_ack_frame() argument
1221 Ok(Frame::ACK { in parse_ack_frame()
1282 fn parse_stream_frame(ty: u64, b: &mut octets::Octets) -> Result<Frame> { in parse_stream_frame() argument
1308 Ok(Frame::Stream { stream_id, data }) in parse_stream_frame()
1311 fn parse_datagram_frame(ty: u64, b: &mut octets::Octets) -> Result<Frame> { in parse_datagram_frame() argument
1322 Ok(Frame::Datagram { in parse_datagram_frame()
1335 let frame = Frame::Padding { len: 128 }; in padding() localVariable
1339 frame.to_bytes(&mut b).unwrap() in padding()
1345 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in padding()
1348 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_ok()); in padding()
1351 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in padding()
1354 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_ok()); in padding()
1361 let frame = Frame::Ping; in ping() localVariable
1365 frame.to_bytes(&mut b).unwrap() in ping()
1372 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in ping()
1375 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in ping()
1378 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_ok()); in ping()
1381 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_ok()); in ping()
1394 let frame = Frame::ACK { in ack() localVariable
1402 frame.to_bytes(&mut b).unwrap() in ack()
1408 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in ack()
1411 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_ok()); in ack()
1414 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_err()); in ack()
1417 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_ok()); in ack()
1436 let frame = Frame::ACK { in ack_ecn() localVariable
1444 frame.to_bytes(&mut b).unwrap() in ack_ecn()
1450 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in ack_ecn()
1453 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_ok()); in ack_ecn()
1456 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_err()); in ack_ecn()
1459 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_ok()); in ack_ecn()
1466 let frame = Frame::ResetStream { in reset_stream() localVariable
1474 frame.to_bytes(&mut b).unwrap() in reset_stream()
1480 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in reset_stream()
1483 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in reset_stream()
1486 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in reset_stream()
1489 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in reset_stream()
1496 let frame = Frame::StopSending { in stop_sending() localVariable
1503 frame.to_bytes(&mut b).unwrap() in stop_sending()
1509 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in stop_sending()
1512 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in stop_sending()
1515 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in stop_sending()
1518 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in stop_sending()
1527 let frame = Frame::Crypto { in crypto() localVariable
1533 frame.to_bytes(&mut b).unwrap() in crypto()
1539 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in crypto()
1542 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_ok()); in crypto()
1545 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_err()); in crypto()
1548 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_ok()); in crypto()
1555 let frame = Frame::NewToken { in new_token() localVariable
1561 frame.to_bytes(&mut b).unwrap() in new_token()
1567 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in new_token()
1570 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in new_token()
1573 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_err()); in new_token()
1576 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in new_token()
1585 let frame = Frame::Stream { in stream() localVariable
1592 frame.to_bytes(&mut b).unwrap() in stream()
1598 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in stream()
1601 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in stream()
1604 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in stream()
1607 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in stream()
1616 let frame = Frame::Stream { in stream_too_big() localVariable
1623 frame.to_bytes(&mut b).unwrap() in stream_too_big()
1630 Frame::from_bytes(&mut b, packet::Type::Short), in stream_too_big()
1639 let frame = Frame::MaxData { max: 128_318_273 }; in max_data() localVariable
1643 frame.to_bytes(&mut b).unwrap() in max_data()
1649 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in max_data()
1652 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in max_data()
1655 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in max_data()
1658 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in max_data()
1665 let frame = Frame::MaxStreamData { in max_stream_data() localVariable
1672 frame.to_bytes(&mut b).unwrap() in max_stream_data()
1678 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in max_stream_data()
1681 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in max_stream_data()
1684 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in max_stream_data()
1687 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in max_stream_data()
1694 let frame = Frame::MaxStreamsBidi { max: 128_318_273 }; in max_streams_bidi() localVariable
1698 frame.to_bytes(&mut b).unwrap() in max_streams_bidi()
1704 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in max_streams_bidi()
1707 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in max_streams_bidi()
1710 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in max_streams_bidi()
1713 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in max_streams_bidi()
1720 let frame = Frame::MaxStreamsUni { max: 128_318_273 }; in max_streams_uni() localVariable
1724 frame.to_bytes(&mut b).unwrap() in max_streams_uni()
1730 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in max_streams_uni()
1733 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in max_streams_uni()
1736 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in max_streams_uni()
1739 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in max_streams_uni()
1746 let frame = Frame::DataBlocked { limit: 128_318_273 }; in data_blocked() localVariable
1750 frame.to_bytes(&mut b).unwrap() in data_blocked()
1756 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in data_blocked()
1759 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in data_blocked()
1762 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in data_blocked()
1765 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in data_blocked()
1772 let frame = Frame::StreamDataBlocked { in stream_data_blocked() localVariable
1779 frame.to_bytes(&mut b).unwrap() in stream_data_blocked()
1785 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in stream_data_blocked()
1788 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in stream_data_blocked()
1791 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in stream_data_blocked()
1794 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in stream_data_blocked()
1801 let frame = Frame::StreamsBlockedBidi { limit: 128_318_273 }; in streams_blocked_bidi() localVariable
1805 frame.to_bytes(&mut b).unwrap() in streams_blocked_bidi()
1811 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in streams_blocked_bidi()
1814 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in streams_blocked_bidi()
1817 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in streams_blocked_bidi()
1820 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in streams_blocked_bidi()
1827 let frame = Frame::StreamsBlockedUni { limit: 128_318_273 }; in streams_blocked_uni() localVariable
1831 frame.to_bytes(&mut b).unwrap() in streams_blocked_uni()
1837 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in streams_blocked_uni()
1840 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in streams_blocked_uni()
1843 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in streams_blocked_uni()
1846 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in streams_blocked_uni()
1853 let frame = Frame::NewConnectionId { in new_connection_id() localVariable
1862 frame.to_bytes(&mut b).unwrap() in new_connection_id()
1868 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in new_connection_id()
1871 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in new_connection_id()
1874 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in new_connection_id()
1877 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in new_connection_id()
1884 let frame = Frame::RetireConnectionId { seq_num: 123_213 }; in retire_connection_id() localVariable
1888 frame.to_bytes(&mut b).unwrap() in retire_connection_id()
1894 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in retire_connection_id()
1897 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in retire_connection_id()
1900 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_err()); in retire_connection_id()
1903 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in retire_connection_id()
1910 let frame = Frame::PathChallenge { in path_challenge() localVariable
1916 frame.to_bytes(&mut b).unwrap() in path_challenge()
1922 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in path_challenge()
1925 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in path_challenge()
1928 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in path_challenge()
1931 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in path_challenge()
1938 let frame = Frame::PathResponse { in path_response() localVariable
1944 frame.to_bytes(&mut b).unwrap() in path_response()
1950 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in path_response()
1953 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in path_response()
1956 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_err()); in path_response()
1959 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in path_response()
1966 let frame = Frame::ConnectionClose { in connection_close() localVariable
1974 frame.to_bytes(&mut b).unwrap() in connection_close()
1980 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in connection_close()
1983 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_ok()); in connection_close()
1986 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_err()); in connection_close()
1989 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_ok()); in connection_close()
1996 let frame = Frame::ApplicationClose { in application_close() localVariable
2003 frame.to_bytes(&mut b).unwrap() in application_close()
2009 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in application_close()
2012 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in application_close()
2015 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in application_close()
2018 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in application_close()
2025 let frame = Frame::HandshakeDone; in handshake_done() localVariable
2029 frame.to_bytes(&mut b).unwrap() in handshake_done()
2035 assert_eq!(Frame::from_bytes(&mut b, packet::Type::Short), Ok(frame)); in handshake_done()
2038 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in handshake_done()
2041 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_err()); in handshake_done()
2044 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in handshake_done()
2053 let frame = Frame::Datagram { data: data.clone() }; in datagram() localVariable
2057 frame.to_bytes(&mut b).unwrap() in datagram()
2064 Frame::from_bytes(&mut b, packet::Type::Short), in datagram()
2065 Ok(frame.clone()) in datagram()
2069 assert!(Frame::from_bytes(&mut b, packet::Type::Initial).is_err()); in datagram()
2072 assert!(Frame::from_bytes(&mut b, packet::Type::ZeroRTT).is_ok()); in datagram()
2075 assert!(Frame::from_bytes(&mut b, packet::Type::Handshake).is_err()); in datagram()
2077 let frame_data = match &frame { in datagram()
2078 Frame::Datagram { data } => data.clone(), in datagram()