use super::descriptor_body;
use crate::error::{Error, Result};
use broadcast_common::{Parse, Serialize};
pub const TAG: u8 = 0x31;
const HEADER_LEN: usize = 2;
pub const RESERVED_DEFAULT: u8 = 0b11;
const RESERVED_MASK: u8 = 0x03;
const BODY_LEN: u8 = 8;
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
#[cfg_attr(feature = "serde", derive(serde::Serialize))]
#[non_exhaustive]
pub struct MvcExtensionDescriptor {
pub average_bit_rate: u16,
pub maximum_bitrate: u16,
pub view_association_not_present: bool,
pub base_view_is_left_eyeview: bool,
pub view_order_index_min: u16,
pub view_order_index_max: u16,
pub temporal_id_start: u8,
pub temporal_id_end: u8,
pub no_sei_nal_unit_present: bool,
pub no_prefix_nal_unit_present: bool,
pub reserved: u8,
}
impl MvcExtensionDescriptor {
#[must_use]
pub const fn new(average_bit_rate: u16, maximum_bitrate: u16) -> Self {
Self {
average_bit_rate,
maximum_bitrate,
view_association_not_present: false,
base_view_is_left_eyeview: false,
view_order_index_min: 0,
view_order_index_max: 0,
temporal_id_start: 0,
temporal_id_end: 0,
no_sei_nal_unit_present: false,
no_prefix_nal_unit_present: false,
reserved: RESERVED_DEFAULT,
}
}
}
impl Default for MvcExtensionDescriptor {
fn default() -> Self {
Self::new(0, 0)
}
}
impl<'a> Parse<'a> for MvcExtensionDescriptor {
type Error = crate::error::Error;
fn parse(bytes: &'a [u8]) -> Result<Self> {
let body = descriptor_body(
bytes,
TAG,
"MvcExtensionDescriptor",
"unexpected tag for MVC_extension_descriptor",
)?;
if body.len() != BODY_LEN as usize {
return Err(Error::InvalidDescriptor {
tag: TAG,
reason: "MVC_extension_descriptor length must equal 8",
});
}
let average_bit_rate = u16::from_be_bytes([body[0], body[1]]);
let maximum_bitrate = u16::from_be_bytes([body[2], body[3]]);
let b4 = body[4];
let b5 = body[5];
let b6 = body[6];
let b7 = body[7];
let view_association_not_present = (b4 & 0x80) != 0;
let base_view_is_left_eyeview = (b4 & 0x40) != 0;
let view_order_index_min = ((b4 as u16 & 0x0F) << 6) | ((b5 as u16 >> 2) & 0x3F);
let view_order_index_max = ((b5 as u16 & 0x03) << 8) | (b6 as u16);
let temporal_id_start = (b7 >> 5) & 0x07;
let temporal_id_end = (b7 >> 2) & 0x07;
let no_sei_nal_unit_present = (b7 & 0x02) != 0;
let no_prefix_nal_unit_present = (b7 & 0x01) != 0;
Ok(Self {
average_bit_rate,
maximum_bitrate,
view_association_not_present,
base_view_is_left_eyeview,
view_order_index_min,
view_order_index_max,
temporal_id_start,
temporal_id_end,
no_sei_nal_unit_present,
no_prefix_nal_unit_present,
reserved: (b4 >> 4) & RESERVED_MASK,
})
}
}
impl Serialize for MvcExtensionDescriptor {
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..HEADER_LEN + 2].copy_from_slice(&self.average_bit_rate.to_be_bytes());
buf[HEADER_LEN + 2..HEADER_LEN + 4].copy_from_slice(&self.maximum_bitrate.to_be_bytes());
let vmin = broadcast_common::len::fit_bits(
u64::from(self.view_order_index_min),
10,
"view_order_index_min",
)? as u16;
let vmax = broadcast_common::len::fit_bits(
u64::from(self.view_order_index_max),
10,
"view_order_index_max",
)? as u16;
broadcast_common::len::fit_bits(u64::from(self.temporal_id_start), 3, "temporal_id_start")?;
broadcast_common::len::fit_bits(u64::from(self.temporal_id_end), 3, "temporal_id_end")?;
buf[HEADER_LEN + 4] = ((self.view_association_not_present as u8) << 7)
| ((self.base_view_is_left_eyeview as u8) << 6)
| (broadcast_common::len::fit_mask(self.reserved, RESERVED_MASK, "reserved")? << 4)
| ((vmin >> 6) as u8 & 0x0F);
buf[HEADER_LEN + 5] = (((vmin & 0x3F) << 2) as u8) | ((vmax >> 8) as u8 & 0x03);
buf[HEADER_LEN + 6] = (vmax & 0xFF) as u8;
buf[HEADER_LEN + 7] =
(broadcast_common::len::fit_mask(self.temporal_id_start, 0x07, "temporal_id_start")?
<< 5)
| (broadcast_common::len::fit_mask(self.temporal_id_end, 0x07, "temporal_id_end")?
<< 2)
| ((self.no_sei_nal_unit_present as u8) << 1)
| (self.no_prefix_nal_unit_present as u8);
Ok(len)
}
}
impl crate::traits::DescriptorDef<'_> for MvcExtensionDescriptor {
const TAG: u8 = TAG;
const NAME: &'static str = "MVC_EXTENSION";
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn parse_extracts_fields() {
let bytes = [
TAG, 8, 0x00, 0x64, 0x00, 0xC8, 0x0F, 0xFC, 0xE8, 0x4A, ];
let d = MvcExtensionDescriptor::parse(&bytes).unwrap();
assert_eq!(d.average_bit_rate, 100);
assert_eq!(d.maximum_bitrate, 200);
assert!(!d.view_association_not_present);
assert!(!d.base_view_is_left_eyeview);
assert_eq!(d.view_order_index_min, (15 << 6) | 63);
assert_eq!(d.view_order_index_max, 232);
assert_eq!(d.temporal_id_start, 2);
assert_eq!(d.temporal_id_end, 2);
assert!(d.no_sei_nal_unit_present);
assert!(!d.no_prefix_nal_unit_present);
}
#[test]
fn parse_flags() {
let bytes = [
TAG, 8, 0, 0, 0, 0, 0xC0, 0, 0, 0x03, ];
let d = MvcExtensionDescriptor::parse(&bytes).unwrap();
assert!(d.view_association_not_present);
assert!(d.base_view_is_left_eyeview);
assert!(d.no_sei_nal_unit_present);
assert!(d.no_prefix_nal_unit_present);
}
#[test]
fn parse_max_10bit_fields() {
let bytes = [
TAG, 8, 0, 0, 0, 0, 0x0F, 0xFF, 0xFF, 0x00, ];
let d = MvcExtensionDescriptor::parse(&bytes).unwrap();
assert_eq!(d.view_order_index_min, 1023);
assert_eq!(d.view_order_index_max, 1023);
}
#[test]
fn parse_rejects_wrong_tag() {
let err = MvcExtensionDescriptor::parse(&[0x02, 8, 0, 0, 0, 0, 0, 0, 0, 0]).unwrap_err();
assert!(matches!(err, Error::InvalidDescriptor { tag: 0x02, .. }));
}
#[test]
fn parse_rejects_wrong_length() {
let err = MvcExtensionDescriptor::parse(&[TAG, 7, 0, 0, 0, 0, 0, 0, 0]).unwrap_err();
assert!(matches!(err, Error::InvalidDescriptor { .. }));
}
#[test]
fn serialize_round_trip() {
let mut d = MvcExtensionDescriptor::new(5000, 10000);
d.base_view_is_left_eyeview = true;
d.view_order_index_min = 512;
d.view_order_index_max = 256;
d.temporal_id_start = 3;
d.temporal_id_end = 5;
d.no_sei_nal_unit_present = true;
let mut buf = vec![0u8; d.serialized_len()];
d.serialize_into(&mut buf).unwrap();
let reparsed = MvcExtensionDescriptor::parse(&buf).unwrap();
assert_eq!(d, reparsed);
}
#[test]
fn serialize_rejects_small_buffer() {
let d = MvcExtensionDescriptor::default();
let mut tiny = vec![0u8; 5];
let err = d.serialize_into(&mut tiny).unwrap_err();
assert!(matches!(err, Error::OutputBufferTooSmall { .. }));
}
#[test]
fn mvc_extension_reserved_preserved() {
for r in 0u8..=3 {
let bytes = [
TAG,
8,
0x00,
0x64,
0x00,
0xC8,
(r << 4) | 0x0F,
0xFC,
0xE8,
0x4A,
];
let d = MvcExtensionDescriptor::parse(&bytes).unwrap();
assert_eq!(d.reserved, r);
let mut out = vec![0u8; d.serialized_len()];
d.serialize_into(&mut out).unwrap();
assert_eq!(out, bytes);
}
}
#[test]
fn mvc_extension_default_is_spec_value() {
let mut d = MvcExtensionDescriptor::new(0x64, 0xC8);
d.view_order_index_min = (15 << 6) | 63;
d.view_order_index_max = 232;
d.temporal_id_start = 2;
d.temporal_id_end = 2;
d.no_sei_nal_unit_present = true;
let mut out = vec![0u8; d.serialized_len()];
d.serialize_into(&mut out).unwrap();
assert_eq!(
out,
[TAG, 8, 0x00, 0x64, 0x00, 0xC8, 0x3F, 0xFC, 0xE8, 0x4A]
);
}
}