statime_wire/messages/
delay_req.rs

1use crate::{Error, common::Timestamp};
2
3/// Delay request message body
4#[derive(Debug, Clone, Copy, PartialEq, Eq)]
5pub struct DelayReqMessage {
6    /// Time this delay request was sent.
7    pub origin_timestamp: Timestamp,
8}
9
10impl DelayReqMessage {
11    pub(crate) fn content_size(&self) -> usize {
12        10
13    }
14
15    pub(crate) fn serialize_content(&self, buffer: &mut [u8]) -> Result<(), Error> {
16        self.origin_timestamp
17            .serialize(buffer.get_mut(0..10).ok_or(Error::BufferTooShort)?)?;
18
19        Ok(())
20    }
21
22    pub(crate) fn deserialize_content(buffer: &[u8]) -> Result<Self, Error> {
23        let slice = buffer.get(0..10).ok_or(Error::BufferTooShort)?;
24        let origin_timestamp = Timestamp::deserialize(slice)?;
25
26        Ok(Self { origin_timestamp })
27    }
28}
29
30#[cfg(test)]
31mod tests {
32    use super::*;
33
34    #[test]
35    fn timestamp_wireformat() {
36        let representations = [(
37            [0x00, 0x00, 0x45, 0xb1, 0x11, 0x5a, 0x0a, 0x64, 0xfa, 0xb0],
38            DelayReqMessage {
39                origin_timestamp: Timestamp::new(1_169_232_218, 174_389_936).unwrap(),
40            },
41        )];
42
43        for (byte_representation, object_representation) in representations {
44            // Test the serialization output
45            let mut serialization_buffer = [0; 10];
46            object_representation
47                .serialize_content(&mut serialization_buffer)
48                .unwrap();
49            assert_eq!(serialization_buffer, byte_representation);
50
51            // Test the deserialization output
52            let deserialized_data =
53                DelayReqMessage::deserialize_content(&byte_representation).unwrap();
54            assert_eq!(deserialized_data, object_representation);
55        }
56    }
57}
statime_wire/messages/delay_req.rs

statime_wire/messages/
delay_req.rs
