ffcine 0.4.0

GPU video finishing: decode, grade (LUTs, tone mapping, scaling) and encode with frames kept in VRAM (facade over the ffcine-* crates)
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

//! Temporal denoise across a cut (`cargo test -p ffcine --test denoise_context_gpu -- --ignored`;
//! needs a Vulkan GPU and `ffmpeg` on PATH): a clip rendered in two pieces, each given its
//! neighbouring frames as context, matches the clip rendered whole, frame for frame.

use std::path::{Path, PathBuf};
use std::process::Command;
use std::time::Duration;

use ffcine::filters::Motion;
use ffcine::{Denoise, EncoderSettings, Grade, Pipeline, RateControl, Temporal, backend};

const N: u64 = 48;
const CUT: u64 = 24;

fn dir() -> PathBuf {
    let d = std::env::temp_dir().join(format!("ffcine-denoise-ctx-{}", std::process::id()));
    std::fs::create_dir_all(&d).expect("temp dir");
    d
}

fn ffmpeg(args: &[&str]) -> Vec<u8> {
    let out = Command::new("ffmpeg")
        .args(["-v", "error", "-y"])
        .args(args)
        .output()
        .expect("ffmpeg on PATH");
    assert!(
        out.status.success(),
        "{}",
        String::from_utf8_lossy(&out.stderr)
    );
    out.stdout
}

/// Per-frame hashes of a video.
fn frames(path: &Path) -> Vec<String> {
    let out = ffmpeg(&["-i", path.to_str().expect("utf-8"), "-f", "framemd5", "-"]);
    String::from_utf8_lossy(&out)
        .lines()
        .filter(|l| !l.starts_with('#'))
        .map(|l| l.rsplit(',').next().unwrap_or("").trim().to_owned())
        .collect()
}

#[test]
#[ignore = "needs a Vulkan GPU and ffmpeg"]
#[allow(clippy::cast_precision_loss, clippy::cast_possible_truncation)]
fn pieces_with_context_match_the_whole_clip() {
    let d = dir();
    let src = d.join("src.mkv");
    ffmpeg(&[
        "-f",
        "lavfi",
        "-i",
        "testsrc2=size=320x180:rate=24,noise=alls=24:allf=t,format=yuv420p",
        "-frames:v",
        &N.to_string(),
        "-g",
        "12",
        "-c:v",
        "libx264",
        "-qp",
        "0",
        "-colorspace",
        "bt709",
        "-color_primaries",
        "bt709",
        "-color_trc",
        "bt709",
        "-color_range",
        "tv",
        src.to_str().expect("utf-8"),
    ]);
    let ff = backend::Ffmpeg::new().expect("backend");
    let render = |name: &str, start: u64, n: u64, before: u64, after: u64| {
        let out = d.join(format!("{name}.mkv"));
        Pipeline::new(&src, &out)
            .range(Duration::from_secs_f64(start as f64 / 24.0), Some(n))
            .context(before, after)
            .grade(Grade {
                dither: None,
                peak_detect: false,
                denoise: Some(Denoise {
                    temporal: Some(Temporal {
                        radius: 2,
                        motion: Motion::Blocks,
                        strength: 8.0,
                        chroma: None,
                        protect: 0.0,
                    }),
                    spatial: None,
                }),
                ..Grade::default()
            })
            .encoder(EncoderSettings {
                rate: RateControl::Crf(0.0),
                pixel_format: ffcine::PixelFormat::Yuv420p,
                ..EncoderSettings::x264_preview()
            })
            .run(&ff)
            .expect("render");
        frames(&out)
    };
    let whole = render("whole", 0, N, 0, 0);
    assert_eq!(whole.len(), N as usize);
    // At the source's start there's no history to read: fewer frames, no error.
    let a = render("a", 0, CUT, 2, 2);
    let b = render("b", CUT, N - CUT, 2, 2);
    let cut = CUT as usize;
    assert_eq!(a, whole[..cut]);
    assert_eq!(b, whole[cut..]);
    // Without context the piece's first frame has no history: it differs.
    let bare = render("bare", CUT, N - CUT, 0, 0);
    assert_ne!(bare[0], whole[cut]);
    let _ = std::fs::remove_dir_all(&d);
}