use super::descriptor_body;
use crate::error::{Error, Result};
use dvb_common::{Parse, Serialize};
pub const TAG: u8 = 0x0B;
const HEADER_LEN: usize = 2;
const BODY_LEN: u8 = 2;
#[derive(Debug, Clone, PartialEq, Eq)]
#[cfg_attr(feature = "serde", derive(serde::Serialize))]
#[cfg_attr(feature = "yoke", derive(yoke::Yokeable))]
pub struct SystemClockDescriptor {
pub external_clock_reference_indicator: bool,
pub clock_accuracy_integer: u8,
pub clock_accuracy_exponent: u8,
}
impl<'a> Parse<'a> for SystemClockDescriptor {
type Error = crate::error::Error;
fn parse(bytes: &'a [u8]) -> Result<Self> {
let body = descriptor_body(
bytes,
TAG,
"SystemClockDescriptor",
"unexpected tag for system_clock_descriptor",
)?;
if body.len() != BODY_LEN as usize {
return Err(Error::InvalidDescriptor {
tag: TAG,
reason: "system_clock_descriptor length must equal 2",
});
}
let b0 = body[0];
let external_clock_reference_indicator = (b0 & 0x80) != 0;
let clock_accuracy_integer = b0 & 0x3F;
let b1 = body[1];
let clock_accuracy_exponent = b1 >> 5;
Ok(Self {
external_clock_reference_indicator,
clock_accuracy_integer,
clock_accuracy_exponent,
})
}
}
impl Serialize for SystemClockDescriptor {
type Error = crate::error::Error;
fn serialized_len(&self) -> usize {
HEADER_LEN + (BODY_LEN as usize)
}
fn serialize_into(&self, buf: &mut [u8]) -> Result<usize> {
let len = self.serialized_len();
if buf.len() < len {
return Err(Error::OutputBufferTooSmall {
need: len,
have: buf.len(),
});
}
buf[0] = TAG;
buf[1] = BODY_LEN;
buf[HEADER_LEN] = ((self.external_clock_reference_indicator as u8) << 7)
| (self.clock_accuracy_integer & 0x3F);
buf[HEADER_LEN + 1] = (self.clock_accuracy_exponent & 0x07) << 5;
Ok(len)
}
}
impl<'a> crate::traits::DescriptorDef<'a> for SystemClockDescriptor {
const TAG: u8 = TAG;
const NAME: &'static str = "SYSTEM_CLOCK";
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn parse() {
let bytes = [
TAG,
2,
0b1011_1111, 0b101_00000, ];
let d = SystemClockDescriptor::parse(&bytes).unwrap();
assert!(d.external_clock_reference_indicator);
assert_eq!(d.clock_accuracy_integer, 63);
assert_eq!(d.clock_accuracy_exponent, 5);
}
#[test]
fn serialize_round_trip() {
let d = SystemClockDescriptor {
external_clock_reference_indicator: false,
clock_accuracy_integer: 42,
clock_accuracy_exponent: 2,
};
let mut buf = vec![0u8; d.serialized_len()];
d.serialize_into(&mut buf).unwrap();
let reparsed = SystemClockDescriptor::parse(&buf).unwrap();
assert_eq!(d, reparsed);
}
#[test]
fn parse_rejects_wrong_tag() {
let err = SystemClockDescriptor::parse(&[0x0C, 2, 0, 0]).unwrap_err();
assert!(matches!(err, Error::InvalidDescriptor { tag: 0x0C, .. }));
}
#[test]
fn parse_rejects_wrong_length() {
let err = SystemClockDescriptor::parse(&[TAG, 3, 0, 0, 0]).unwrap_err();
assert!(matches!(err, Error::InvalidDescriptor { tag: TAG, .. }));
}
#[test]
fn serialize_rejects_small_buffer() {
let d = SystemClockDescriptor {
external_clock_reference_indicator: false,
clock_accuracy_integer: 0,
clock_accuracy_exponent: 0,
};
let mut tiny = vec![0u8; 2];
let err = d.serialize_into(&mut tiny).unwrap_err();
assert!(matches!(err, Error::OutputBufferTooSmall { .. }));
}
}