// This file was generated by gir (https://github.com/gtk-rs/gir) // from gir-files (https://github.com/gtk-rs/gir-files) // from gst-gir-files (https://gitlab.freedesktop.org/gstreamer/gir-files-rs.git) // DO NOT EDIT #![cfg(unix)] use gstreamer_rtsp_server_sys::*; use std::env; use std::error::Error; use std::ffi::OsString; use std::mem::{align_of, size_of}; use std::path::Path; use std::process::{Command, Stdio}; use std::str; use tempfile::Builder; static PACKAGES: &[&str] = &["gstreamer-rtsp-server-1.0"]; #[derive(Clone, Debug)] struct Compiler { pub args: Vec, } impl Compiler { pub fn new() -> Result> { let mut args = get_var("CC", "cc")?; args.push("-Wno-deprecated-declarations".to_owned()); // For _Generic args.push("-std=c11".to_owned()); // For %z support in printf when using MinGW. args.push("-D__USE_MINGW_ANSI_STDIO".to_owned()); args.extend(get_var("CFLAGS", "")?); args.extend(get_var("CPPFLAGS", "")?); args.extend(pkg_config_cflags(PACKAGES)?); Ok(Self { args }) } pub fn compile(&self, src: &Path, out: &Path) -> Result<(), Box> { let mut cmd = self.to_command(); cmd.arg(src); cmd.arg("-o"); cmd.arg(out); let status = cmd.spawn()?.wait()?; if !status.success() { return Err(format!("compilation command {cmd:?} failed, {status}").into()); } Ok(()) } fn to_command(&self) -> Command { let mut cmd = Command::new(&self.args[0]); cmd.args(&self.args[1..]); cmd } } fn get_var(name: &str, default: &str) -> Result, Box> { match env::var(name) { Ok(value) => Ok(shell_words::split(&value)?), Err(env::VarError::NotPresent) => Ok(shell_words::split(default)?), Err(err) => Err(format!("{name} {err}").into()), } } fn pkg_config_cflags(packages: &[&str]) -> Result, Box> { if packages.is_empty() { return Ok(Vec::new()); } let pkg_config = env::var_os("PKG_CONFIG").unwrap_or_else(|| OsString::from("pkg-config")); let mut cmd = Command::new(pkg_config); cmd.arg("--cflags"); cmd.args(packages); cmd.stderr(Stdio::inherit()); let out = cmd.output()?; if !out.status.success() { let (status, stdout) = (out.status, String::from_utf8_lossy(&out.stdout)); return Err(format!("command {cmd:?} failed, {status:?}\nstdout: {stdout}").into()); } let stdout = str::from_utf8(&out.stdout)?; Ok(shell_words::split(stdout.trim())?) } #[derive(Copy, Clone, Debug, Eq, PartialEq)] struct Layout { size: usize, alignment: usize, } #[derive(Copy, Clone, Debug, Default, Eq, PartialEq)] struct Results { /// Number of successfully completed tests. passed: usize, /// Total number of failed tests (including those that failed to compile). failed: usize, } impl Results { fn record_passed(&mut self) { self.passed += 1; } fn record_failed(&mut self) { self.failed += 1; } fn summary(&self) -> String { format!("{} passed; {} failed", self.passed, self.failed) } fn expect_total_success(&self) { if self.failed == 0 { println!("OK: {}", self.summary()); } else { panic!("FAILED: {}", self.summary()); }; } } #[test] fn cross_validate_constants_with_c() { let mut c_constants: Vec<(String, String)> = Vec::new(); for l in get_c_output("constant").unwrap().lines() { let (name, value) = l.split_once(';').expect("Missing ';' separator"); c_constants.push((name.to_owned(), value.to_owned())); } let mut results = Results::default(); for ((rust_name, rust_value), (c_name, c_value)) in RUST_CONSTANTS.iter().zip(c_constants.iter()) { if rust_name != c_name { results.record_failed(); eprintln!("Name mismatch:\nRust: {rust_name:?}\nC: {c_name:?}"); continue; } if rust_value != c_value { results.record_failed(); eprintln!( "Constant value mismatch for {rust_name}\nRust: {rust_value:?}\nC: {c_value:?}", ); continue; } results.record_passed(); } results.expect_total_success(); } #[test] fn cross_validate_layout_with_c() { let mut c_layouts = Vec::new(); for l in get_c_output("layout").unwrap().lines() { let (name, value) = l.split_once(';').expect("Missing first ';' separator"); let (size, alignment) = value.split_once(';').expect("Missing second ';' separator"); let size = size.parse().expect("Failed to parse size"); let alignment = alignment.parse().expect("Failed to parse alignment"); c_layouts.push((name.to_owned(), Layout { size, alignment })); } let mut results = Results::default(); for ((rust_name, rust_layout), (c_name, c_layout)) in RUST_LAYOUTS.iter().zip(c_layouts.iter()) { if rust_name != c_name { results.record_failed(); eprintln!("Name mismatch:\nRust: {rust_name:?}\nC: {c_name:?}"); continue; } if rust_layout != c_layout { results.record_failed(); eprintln!("Layout mismatch for {rust_name}\nRust: {rust_layout:?}\nC: {c_layout:?}",); continue; } results.record_passed(); } results.expect_total_success(); } fn get_c_output(name: &str) -> Result> { let tmpdir = Builder::new().prefix("abi").tempdir()?; let exe = tmpdir.path().join(name); let c_file = Path::new("tests").join(name).with_extension("c"); let cc = Compiler::new().expect("configured compiler"); cc.compile(&c_file, &exe)?; let mut cmd = Command::new(exe); cmd.stderr(Stdio::inherit()); let out = cmd.output()?; if !out.status.success() { let (status, stdout) = (out.status, String::from_utf8_lossy(&out.stdout)); return Err(format!("command {cmd:?} failed, {status:?}\nstdout: {stdout}").into()); } Ok(String::from_utf8(out.stdout)?) } const RUST_LAYOUTS: &[(&str, Layout)] = &[ ( "GstRTSPAddress", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPAddressFlags", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPAddressPool", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPAddressPoolClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPAddressPoolResult", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPAuth", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPAuthClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPClient", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPClientClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPContext", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPFilterResult", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPMedia", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPMediaClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPMediaFactory", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPMediaFactoryClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPMediaFactoryURI", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPMediaFactoryURIClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPMediaStatus", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPMountPoints", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPMountPointsClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPOnvifClient", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPOnvifClientClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPOnvifMedia", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPOnvifMediaClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPOnvifMediaFactory", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPOnvifMediaFactoryClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPOnvifServer", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPOnvifServerClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPPermissions", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPPublishClockMode", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPServer", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPServerClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPSession", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPSessionClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPSessionMedia", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPSessionMediaClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPSessionPool", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPSessionPoolClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPStream", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPStreamClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPStreamTransport", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPStreamTransportClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPSuspendMode", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPThread", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPThreadPool", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPThreadPoolClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPThreadType", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPToken", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstRTSPTransportMode", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstSDPInfo", Layout { size: size_of::(), alignment: align_of::(), }, ), ]; const RUST_CONSTANTS: &[(&str, &str)] = &[ ("(guint) GST_RTSP_ADDRESS_FLAG_EVEN_PORT", "4"), ("(guint) GST_RTSP_ADDRESS_FLAG_IPV4", "1"), ("(guint) GST_RTSP_ADDRESS_FLAG_IPV6", "2"), ("(guint) GST_RTSP_ADDRESS_FLAG_MULTICAST", "8"), ("(guint) GST_RTSP_ADDRESS_FLAG_NONE", "0"), ("(guint) GST_RTSP_ADDRESS_FLAG_UNICAST", "16"), ("GST_RTSP_ADDRESS_POOL_ANY_IPV4", "0.0.0.0"), ("GST_RTSP_ADDRESS_POOL_ANY_IPV6", "::"), ("(gint) GST_RTSP_ADDRESS_POOL_EINVAL", "-1"), ("(gint) GST_RTSP_ADDRESS_POOL_ELAST", "-4"), ("(gint) GST_RTSP_ADDRESS_POOL_ERANGE", "-3"), ("(gint) GST_RTSP_ADDRESS_POOL_ERESERVED", "-2"), ("(gint) GST_RTSP_ADDRESS_POOL_OK", "0"), ("GST_RTSP_AUTH_CHECK_CONNECT", "auth.check.connect"), ( "GST_RTSP_AUTH_CHECK_MEDIA_FACTORY_ACCESS", "auth.check.media.factory.access", ), ( "GST_RTSP_AUTH_CHECK_MEDIA_FACTORY_CONSTRUCT", "auth.check.media.factory.construct", ), ( "GST_RTSP_AUTH_CHECK_TRANSPORT_CLIENT_SETTINGS", "auth.check.transport.client-settings", ), ("GST_RTSP_AUTH_CHECK_URL", "auth.check.url"), ("(gint) GST_RTSP_FILTER_KEEP", "1"), ("(gint) GST_RTSP_FILTER_REF", "2"), ("(gint) GST_RTSP_FILTER_REMOVE", "0"), ("(gint) GST_RTSP_MEDIA_STATUS_ERROR", "5"), ("(gint) GST_RTSP_MEDIA_STATUS_PREPARED", "3"), ("(gint) GST_RTSP_MEDIA_STATUS_PREPARING", "2"), ("(gint) GST_RTSP_MEDIA_STATUS_SUSPENDED", "4"), ("(gint) GST_RTSP_MEDIA_STATUS_UNPREPARED", "0"), ("(gint) GST_RTSP_MEDIA_STATUS_UNPREPARING", "1"), ( "GST_RTSP_ONVIF_BACKCHANNEL_REQUIREMENT", "www.onvif.org/ver20/backchannel", ), ("GST_RTSP_ONVIF_REPLAY_REQUIREMENT", "onvif-replay"), ("GST_RTSP_PERM_MEDIA_FACTORY_ACCESS", "media.factory.access"), ( "GST_RTSP_PERM_MEDIA_FACTORY_CONSTRUCT", "media.factory.construct", ), ("(gint) GST_RTSP_PUBLISH_CLOCK_MODE_CLOCK", "1"), ("(gint) GST_RTSP_PUBLISH_CLOCK_MODE_CLOCK_AND_OFFSET", "2"), ("(gint) GST_RTSP_PUBLISH_CLOCK_MODE_NONE", "0"), ("(gint) GST_RTSP_SUSPEND_MODE_NONE", "0"), ("(gint) GST_RTSP_SUSPEND_MODE_PAUSE", "1"), ("(gint) GST_RTSP_SUSPEND_MODE_RESET", "2"), ("(gint) GST_RTSP_THREAD_TYPE_CLIENT", "0"), ("(gint) GST_RTSP_THREAD_TYPE_MEDIA", "1"), ("GST_RTSP_TOKEN_MEDIA_FACTORY_ROLE", "media.factory.role"), ( "GST_RTSP_TOKEN_TRANSPORT_CLIENT_SETTINGS", "transport.client-settings", ), ("(guint) GST_RTSP_TRANSPORT_MODE_PLAY", "1"), ("(guint) GST_RTSP_TRANSPORT_MODE_RECORD", "2"), ];