viser-ffmpeg 0.6.1

FFmpeg/FFprobe wrapper for viser
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

use crate::{Codec, ffmpeg_path};
use std::collections::HashSet;
use std::sync::OnceLock;
use tokio::process::Command;

static HW_ENCODERS_CACHE: OnceLock<HashSet<Codec>> = OnceLock::new();

static HW_ENCODERS_SEARCH: &[(Codec, &str)] = &[
    (Codec::NvencH264, "h264_nvenc"),
    (Codec::NvencH265, "hevc_nvenc"),
    (Codec::QsvH264, "h264_qsv"),
    (Codec::QsvH265, "hevc_qsv"),
    (Codec::VideoToolboxH264, "h264_videotoolbox"),
    (Codec::VideoToolboxH265, "hevc_videotoolbox"),
    (Codec::VaapiH264, "h264_vaapi"),
    (Codec::VaapiH265, "hevc_vaapi"),
    (Codec::AmfH264, "h264_amf"),
    (Codec::AmfH265, "hevc_amf"),
];

async fn probe_available_encoders() -> HashSet<String> {
    let result = Command::new(ffmpeg_path()).args(["-encoders"]).output().await;

    let Ok(output) = result else {
        return HashSet::new();
    };
    if !output.status.success() {
        return HashSet::new();
    }

    let stdout = String::from_utf8_lossy(&output.stdout);
    let mut encoders = HashSet::new();
    for line in stdout.lines() {
        let trimmed = line.trim();
        if (trimmed.starts_with("V") || trimmed.starts_with("VE"))
            && let Some(name) = trimmed.split_whitespace().nth(1)
        {
            encoders.insert(name.to_string());
        }
    }
    encoders
}

async fn detect_hw_encoders_inner() -> HashSet<Codec> {
    let available = probe_available_encoders().await;
    HW_ENCODERS_SEARCH
        .iter()
        .filter_map(|(codec, name)| if available.contains(*name) { Some(*codec) } else { None })
        .collect()
}

pub async fn init_hw_encoders() {
    if HW_ENCODERS_CACHE.get().is_some() {
        return;
    }
    let codecs = detect_hw_encoders_inner().await;
    let _ = HW_ENCODERS_CACHE.set(codecs);
}

pub fn is_hw_encoder_available(codec: Codec) -> bool {
    assert!(codec.is_hardware(), "is_hw_encoder_available called on non-HW codec");
    HW_ENCODERS_CACHE.get().map(|set| set.contains(&codec)).unwrap_or(false)
}

pub fn hw_encoders_available() -> Vec<Codec> {
    HW_ENCODERS_CACHE
        .get()
        .map(|set| {
            let mut v: Vec<_> = set.iter().copied().collect();
            v.sort_by_key(|c| c.as_str());
            v
        })
        .unwrap_or_default()
}

pub fn list_hw_encoder_names() -> Vec<&'static str> {
    HW_ENCODERS_SEARCH.iter().map(|(_, name)| *name).collect()
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_hw_encoders_cache_empty_before_init() {
        assert!(HW_ENCODERS_CACHE.get().is_none());
    }

    #[test]
    fn test_hw_encoder_search_has_expected_count() {
        assert_eq!(HW_ENCODERS_SEARCH.len(), 10);
    }

    #[test]
    fn test_search_all_have_matching_as_str() {
        for (codec, name) in HW_ENCODERS_SEARCH {
            assert_eq!(codec.as_str(), *name);
        }
    }
}