diff --git a/tines-core/src/consts.rs b/tines-core/src/consts.rs index 120a7a1b..6c1a730a 100644 --- a/tines-core/src/consts.rs +++ b/tines-core/src/consts.rs @@ -29,3 +29,6 @@ pub const SEND_QUEUE_CAP: usize = 256; /// Maximum UDP frame size in bytes. pub const MAX_FRAME: usize = 1500; + +/// Maximum number of content-IDs an `Ack` receipt may carry. +pub const ACK_IDS_CAP: usize = 90; diff --git a/tines-core/src/exchange.rs b/tines-core/src/exchange.rs index 39604dbd..3d92c249 100644 --- a/tines-core/src/exchange.rs +++ b/tines-core/src/exchange.rs @@ -492,6 +492,10 @@ impl Exchange { let obs = peer.reassembler.feed(id, index, count, &data, now)?; self.accept(obs, addr, store, now) } + // Ack carries a handoff receipt of content-IDs; it produces no + // Observation here (ack handling in the exchange layer is out of + // scope for this wire-frame task). + Frame::Ack { .. } => None, } } diff --git a/tines-core/src/wire.rs b/tines-core/src/wire.rs index 92389d92..9b532bfe 100644 --- a/tines-core/src/wire.rs +++ b/tines-core/src/wire.rs @@ -32,6 +32,10 @@ pub enum Frame { count: u8, data: Vec, }, + Ack { + from: NodeId, + ids: Vec, + }, } impl Frame { @@ -41,6 +45,7 @@ impl Frame { Frame::Summary { from, .. } => *from, Frame::Obs { from, .. } => *from, Frame::Frag { from, .. } => *from, + Frame::Ack { from, .. } => *from, } } @@ -148,6 +153,82 @@ mod tests { assert_eq!(f, decoded); } + #[test] + fn ack_frame_roundtrip() { + // Ack carrying 3 content-IDs must roundtrip through encode/decode. + let ids = Vec::::from_slice(&[ + [1u8; 16], [2u8; 16], [3u8; 16], + ]) + .unwrap(); + let f = Frame::Ack { from: [5; 16], ids }; + // sender() must return `from` for an Ack. + assert_eq!(f.sender(), [5; 16]); + let mut buf = [0u8; consts::MAX_FRAME]; + let n = f.encode(&mut buf).unwrap(); + let decoded = Frame::decode(&buf[..n]).unwrap(); + assert_eq!(f, decoded); + } + + #[test] + fn summary_golden_vector() { + // Pinned wire bytes for the exact Summary frame below. postcard tags are + // positional, so any future reorder of the existing Frame variants changes + // what these bytes decode to and fails this assertion. + const GOLDEN: [u8; 536] = [ + 0u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, 3u8, + 239u8, 253u8, 182u8, 245u8, 13u8, 128u8, 4u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, 170u8, + 170u8, 170u8, + ]; + let expected = Frame::Summary { + from: [3; 16], + salt: 0xdeadbeef, + bits: Vec::from_slice(&[0xAAu8; consts::SUMMARY_BYTES]).unwrap(), + }; + assert_eq!(Frame::decode(&GOLDEN).unwrap(), expected); + } + #[test] fn decode_garbage_is_error_not_panic() { for len in [0usize, 1, 7, 64, 1500] {