pq/libfreemkv
1
Fork 0
mirror of https://github.com/freemkv/libfreemkv.git synced 2026-10-07 18:13:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

pipeline: one run context, KeyRing, Source, Read stage, block and tree sinks

Browse Source 
One run context (halt, events, loss counters) serves every stage; keys
come from KeyEvidence into a KeyRing. open_source opens every input,
disc:// included, replacing MuxSource; PesSource/PesSink replace
pes::Stream; one Read stage replaces DiscStream and the byte
prefetcher. iso://, null:// and dir:// are sinks. Dead error variants
(E9009, E9063, E9082) and scaffolding removed.
This commit is contained in:
Matthew Jackson
2026-10-01 08:34:14 -07:00
parent 81ecc8acce
commit 46ffac8690
103 changed files with 6935 additions and 14641 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/streams.rs
+35 -27
View File
@@ -1,7 +1,7 @@
//! Integration tests for the PES stream pipeline.
use libfreemkv::mux::meta::M2tsMeta;
use libfreemkv::pes::Stream as PesStream;
use libfreemkv::pes::PesSink;
use libfreemkv::*;
use std::io::{Cursor, Write};
@@ -120,7 +120,11 @@ fn parse_url_m2ts_relative() {
#[test]
fn open_input_bare_path_errors() {
let result = libfreemkv::input("Movie.mkv", &libfreemkv::InputOptions::default());
let result = libfreemkv::input(
"Movie.mkv",
&libfreemkv::InputOptions::default(),
&libfreemkv::Ctx::default(),
);
assert!(result.is_err());
let msg = match result {
Err(e) => e.to_string(),
@@ -143,7 +147,11 @@ fn open_output_bare_path_errors() {
#[test]
fn open_input_m2ts_empty_path_errors() {
let result = libfreemkv::input("m2ts://", &libfreemkv::InputOptions::default());
let result = libfreemkv::input(
"m2ts://",
&libfreemkv::InputOptions::default(),
&libfreemkv::Ctx::default(),
);
assert!(result.is_err());
let msg = match result {
Err(e) => e.to_string(),
@@ -154,7 +162,11 @@ fn open_input_m2ts_empty_path_errors() {
#[test]
fn open_output_null_input_errors() {
let result = libfreemkv::input("null://", &libfreemkv::InputOptions::default());
let result = libfreemkv::input(
"null://",
&libfreemkv::InputOptions::default(),
&libfreemkv::Ctx::default(),
);
assert!(result.is_err());
let msg = match result {
Err(e) => e.to_string(),
@@ -177,7 +189,11 @@ fn open_output_disc_errors() {
#[test]
fn open_input_network_no_port_errors() {
let result = libfreemkv::input("network://192.0.2.1", &libfreemkv::InputOptions::default());
let result = libfreemkv::input(
"network://192.0.2.1",
&libfreemkv::InputOptions::default(),
&libfreemkv::Ctx::default(),
);
assert!(result.is_err());
let msg = match result {
Err(e) => e.to_string(),
@@ -284,12 +300,12 @@ fn m2ts_stream_write_read() {
data: vec![i; 100],
duration_ns: None,
};
PesStream::write(&mut stream, &frame).unwrap();
PesSink::write(&mut stream, &frame).unwrap();
}
PesStream::finish(&mut stream).unwrap();
PesSink::finish(&mut stream).unwrap();
// Verify the info is correct
let info = PesStream::info(&stream);
let info = PesSink::info(&stream);
assert_eq!(info.streams.len(), 4);
assert_eq!(info.duration_secs, 7200.0);
}
@@ -332,19 +348,11 @@ fn m2ts_implements_pes_stream() {
let output = Cursor::new(Vec::new());
let stream = M2tsStream::create(output, &dt).unwrap();
let boxed: Box<dyn PesStream> = Box::new(stream);
let boxed: Box<dyn PesSink> = Box::new(stream);
let meta = boxed.info();
assert_eq!(meta.streams.len(), 4);
}
#[test]
fn m2ts_read_returns_error_on_write_stream() {
let dt = sample_disc_title();
let output = Cursor::new(Vec::new());
let mut stream = M2tsStream::create(output, &dt).unwrap();
assert!(PesStream::read(&mut stream).is_err());
}
// ── DiscTitle::empty ──────────────────────────────────────────
#[test]
@@ -598,11 +606,11 @@ fn mkvstream_write_finish() {
data: vec![i; 100],
duration_ns: None,
};
PesStream::write(&mut stream, &frame).unwrap();
PesSink::write(&mut stream, &frame).unwrap();
}
// finish should not panic even without valid codec data
PesStream::finish(&mut stream).unwrap();
PesSink::finish(&mut stream).unwrap();
}
#[test]
@@ -611,7 +619,7 @@ fn mkvstream_meta_sets_title() {
let writer: Box<dyn libfreemkv::mux::WriteSeek + Send> = Box::new(Cursor::new(Vec::new()));
let stream = MkvStream::create(writer, &dt, None).unwrap();
let info = PesStream::info(&stream);
let info = PesSink::info(&stream);
assert_eq!(info.playlist, "Test Movie");
assert_eq!(info.duration_secs, 7200.0);
assert_eq!(info.streams.len(), 4);
@@ -662,13 +670,13 @@ fn mkvstream_roundtrip_bdts() {
data: vec![i; 100],
duration_ns: None,
};
PesStream::write(&mut stream, &frame).unwrap();
PesSink::write(&mut stream, &frame).unwrap();
}
PesStream::finish(&mut stream).unwrap();
PesSink::finish(&mut stream).unwrap();
// Verify the info is correct
let info = PesStream::info(&stream);
let info = PesSink::info(&stream);
assert_eq!(info.streams.len(), 1);
assert_eq!(info.playlist, "Audio Only");
}
@@ -740,7 +748,7 @@ fn mkvstream_meta_preserves_all_streams() {
let writer: Box<dyn libfreemkv::mux::WriteSeek + Send> = Box::new(Cursor::new(Vec::new()));
let stream = MkvStream::create(writer, &dt, None).unwrap();
let info = PesStream::info(&stream);
let info = PesSink::info(&stream);
assert_eq!(info.streams.len(), 5, "all 5 streams should be preserved");
assert_eq!(info.playlist, "Stream Test");
assert_eq!(info.duration_secs, 3600.0);
@@ -862,7 +870,7 @@ fn mkvstream_e2e_h264_produces_valid_mkv() {
data: es_data,
duration_ns: None,
};
PesStream::write(&mut stream2, &frame1).unwrap();
PesSink::write(&mut stream2, &frame1).unwrap();
// Write a second non-IDR frame
let frame2 = libfreemkv::pes::PesFrame {
@@ -875,8 +883,8 @@ fn mkvstream_e2e_h264_produces_valid_mkv() {
data: es_data2,
duration_ns: None,
};
PesStream::write(&mut stream2, &frame2).unwrap();
PesStream::finish(&mut stream2).unwrap();
PesSink::write(&mut stream2, &frame2).unwrap();
PesSink::finish(&mut stream2).unwrap();
let data = output2.lock().unwrap().clone().into_inner();