mpeg2ts 0.6.0

MPEG2-TS decoding/encoding library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119

use crate::crc::Crc32;
use crate::ts::TsPacket;
use crate::{Error, Result};
use std::io::{self, Read, Write};

#[track_caller]
pub fn consume_stuffing_bytes<R: Read>(mut reader: R) -> Result<()> {
    let mut buf = [0];
    while 1 == reader.read(&mut buf)? {
        if buf[0] != 0xFF {
            return Err(Error::invalid_input("Expected stuffing byte 0xFF"));
        }
    }
    Ok(())
}

#[track_caller]
pub fn write_stuffing_bytes<W: Write>(mut writer: W, size: usize) -> Result<()> {
    let buf = [0xFF; TsPacket::SIZE];
    writer.write_all(&buf[..size])?;
    Ok(())
}

#[derive(Debug)]
pub struct WithCrc32<T> {
    stream: T,
    crc32: Crc32,
}
impl<T> WithCrc32<T> {
    pub fn new(stream: T) -> Self {
        WithCrc32 {
            stream,
            crc32: Crc32::new(),
        }
    }
    pub fn crc32(&self) -> u32 {
        self.crc32.value()
    }
}
impl<T: Read> Read for WithCrc32<T> {
    fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
        let size = self.stream.read(buf)?;
        self.crc32.update(&buf[..size]);
        Ok(size)
    }
}
impl<T: Write> Write for WithCrc32<T> {
    fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
        let size = self.stream.write(buf)?;
        self.crc32.update(&buf[..size]);
        Ok(size)
    }
    fn flush(&mut self) -> io::Result<()> {
        self.stream.flush()
    }
}

pub trait WriteBytesExt {
    fn write_u8(&mut self, n: u8) -> std::io::Result<()>;
    fn write_u16(&mut self, n: u16) -> std::io::Result<()>;
    fn write_u32(&mut self, n: u32) -> std::io::Result<()>;
    fn write_uint<const SIZE: usize>(&mut self, n: u64) -> std::io::Result<()>;
    fn write_i8(&mut self, n: i8) -> std::io::Result<()>;
}

impl<W: Write> WriteBytesExt for W {
    fn write_u8(&mut self, n: u8) -> std::io::Result<()> {
        self.write_all(&[n])
    }
    fn write_u16(&mut self, n: u16) -> std::io::Result<()> {
        self.write_all(&n.to_be_bytes())
    }
    fn write_u32(&mut self, n: u32) -> std::io::Result<()> {
        self.write_all(&n.to_be_bytes())
    }
    fn write_uint<const SIZE: usize>(&mut self, n: u64) -> std::io::Result<()> {
        let bytes = n.to_be_bytes();
        self.write_all(&bytes[8 - SIZE..])
    }
    fn write_i8(&mut self, n: i8) -> std::io::Result<()> {
        self.write_all(&[n as u8])
    }
}

pub trait ReadBytesExt {
    fn read_u8(&mut self) -> std::io::Result<u8>;
    fn read_u16(&mut self) -> std::io::Result<u16>;
    fn read_u32(&mut self) -> std::io::Result<u32>;
    fn read_uint<const SIZE: usize>(&mut self) -> std::io::Result<u64>;
    fn read_i8(&mut self) -> std::io::Result<i8>;
}

impl<R: Read> ReadBytesExt for R {
    fn read_u8(&mut self) -> std::io::Result<u8> {
        let mut buf = [0; 1];
        Read::read_exact(self, &mut buf)?;
        Ok(buf[0])
    }
    fn read_u16(&mut self) -> std::io::Result<u16> {
        let mut buf = [0; 2];
        Read::read_exact(self, &mut buf)?;
        Ok(u16::from_be_bytes(buf))
    }
    fn read_u32(&mut self) -> std::io::Result<u32> {
        let mut buf = [0; 4];
        Read::read_exact(self, &mut buf)?;
        Ok(u32::from_be_bytes(buf))
    }
    fn read_uint<const SIZE: usize>(&mut self) -> std::io::Result<u64> {
        let mut buf = [0; 8];
        Read::read_exact(self, &mut buf[8 - SIZE..])?;
        Ok(u64::from_be_bytes(buf))
    }
    fn read_i8(&mut self) -> std::io::Result<i8> {
        let mut buf = [0; 1];
        Read::read_exact(self, &mut buf)?;
        Ok(buf[0] as i8)
    }
}