// This file was generated by gir (https://github.com/gtk-rs/gir @ 062b3d6) // from gir-files (https://github.com/gtk-rs/gir-files @ b84cead5) // DO NOT EDIT extern crate gstreamer_webrtc_sys; extern crate shell_words; extern crate tempfile; use gstreamer_webrtc_sys::*; use std::env; use std::error::Error; use std::mem::{align_of, size_of}; use std::path::Path; use std::process::Command; use std::str; use tempfile::Builder; static PACKAGES: &[&str] = &["gstreamer-webrtc-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 %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(Compiler { args }) } pub fn define<'a, V: Into>>(&mut self, var: &str, val: V) { let arg = match val.into() { None => format!("-D{}", var), Some(val) => format!("-D{}={}", var, val), }; self.args.push(arg); } 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 {:?} failed, {}", &cmd, 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 mut cmd = Command::new("pkg-config"); cmd.arg("--cflags"); cmd.args(packages); let out = cmd.output()?; if !out.status.success() { return Err(format!("command {:?} returned {}", &cmd, out.status).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, /// Number of tests that failed to compile. failed_to_compile: usize, } impl Results { fn record_passed(&mut self) { self.passed += 1; } fn record_failed(&mut self) { self.failed += 1; } fn record_failed_to_compile(&mut self) { self.failed += 1; self.failed_to_compile += 1; } fn summary(&self) -> String { format!( "{} passed; {} failed (compilation errors: {})", self.passed, self.failed, self.failed_to_compile ) } 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 tmpdir = Builder::new() .prefix("abi") .tempdir() .expect("temporary directory"); let cc = Compiler::new().expect("configured compiler"); assert_eq!( "1", get_c_value(tmpdir.path(), &cc, "1").expect("C constant"), "failed to obtain correct constant value for 1" ); let mut results: Results = Default::default(); for (i, &(name, rust_value)) in RUST_CONSTANTS.iter().enumerate() { match get_c_value(tmpdir.path(), &cc, name) { Err(e) => { results.record_failed_to_compile(); eprintln!("{}", e); } Ok(ref c_value) => { if rust_value == c_value { results.record_passed(); } else { results.record_failed(); eprintln!( "Constant value mismatch for {}\nRust: {:?}\nC: {:?}", name, rust_value, c_value ); } } }; if (i + 1) % 25 == 0 { println!("constants ... {}", results.summary()); } } results.expect_total_success(); } #[test] fn cross_validate_layout_with_c() { let tmpdir = Builder::new() .prefix("abi") .tempdir() .expect("temporary directory"); let cc = Compiler::new().expect("configured compiler"); assert_eq!( Layout { size: 1, alignment: 1 }, get_c_layout(tmpdir.path(), &cc, "char").expect("C layout"), "failed to obtain correct layout for char type" ); let mut results: Results = Default::default(); for (i, &(name, rust_layout)) in RUST_LAYOUTS.iter().enumerate() { match get_c_layout(tmpdir.path(), &cc, name) { Err(e) => { results.record_failed_to_compile(); eprintln!("{}", e); } Ok(c_layout) => { if rust_layout == c_layout { results.record_passed(); } else { results.record_failed(); eprintln!( "Layout mismatch for {}\nRust: {:?}\nC: {:?}", name, rust_layout, &c_layout ); } } }; if (i + 1) % 25 == 0 { println!("layout ... {}", results.summary()); } } results.expect_total_success(); } fn get_c_layout(dir: &Path, cc: &Compiler, name: &str) -> Result> { let exe = dir.join("layout"); let mut cc = cc.clone(); cc.define("ABI_TYPE_NAME", name); cc.compile(Path::new("tests/layout.c"), &exe)?; let mut abi_cmd = Command::new(exe); let output = abi_cmd.output()?; if !output.status.success() { return Err(format!("command {:?} failed, {:?}", &abi_cmd, &output).into()); } let stdout = str::from_utf8(&output.stdout)?; let mut words = stdout.trim().split_whitespace(); let size = words.next().unwrap().parse().unwrap(); let alignment = words.next().unwrap().parse().unwrap(); Ok(Layout { size, alignment }) } fn get_c_value(dir: &Path, cc: &Compiler, name: &str) -> Result> { let exe = dir.join("constant"); let mut cc = cc.clone(); cc.define("ABI_CONSTANT_NAME", name); cc.compile(Path::new("tests/constant.c"), &exe)?; let mut abi_cmd = Command::new(exe); let output = abi_cmd.output()?; if !output.status.success() { return Err(format!("command {:?} failed, {:?}", &abi_cmd, &output).into()); } let output = str::from_utf8(&output.stdout)?.trim(); if !output.starts_with("###gir test###") || !output.ends_with("###gir test###") { return Err(format!( "command {:?} return invalid output, {:?}", &abi_cmd, &output ) .into()); } Ok(String::from(&output[14..(output.len() - 14)])) } const RUST_LAYOUTS: &[(&str, Layout)] = &[ ( "GstWebRTCBundlePolicy", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCDTLSSetup", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCDTLSTransport", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCDTLSTransportClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCDTLSTransportState", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCDataChannel", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCDataChannelClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCDataChannelState", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCFECType", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCICEComponent", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCICEConnectionState", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCICEGatheringState", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCICERole", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCICETransport", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCICETransportClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCICETransportPolicy", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCPeerConnectionState", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCPriorityType", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCRTPReceiver", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCRTPReceiverClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCRTPSender", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCRTPSenderClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCRTPTransceiver", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCRTPTransceiverClass", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCRTPTransceiverDirection", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCSCTPTransportState", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCSDPType", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCSessionDescription", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCSignalingState", Layout { size: size_of::(), alignment: align_of::(), }, ), ( "GstWebRTCStatsType", Layout { size: size_of::(), alignment: align_of::(), }, ), ]; const RUST_CONSTANTS: &[(&str, &str)] = &[ ("(gint) GST_WEBRTC_BUNDLE_POLICY_BALANCED", "1"), ("(gint) GST_WEBRTC_BUNDLE_POLICY_MAX_BUNDLE", "3"), ("(gint) GST_WEBRTC_BUNDLE_POLICY_MAX_COMPAT", "2"), ("(gint) GST_WEBRTC_BUNDLE_POLICY_NONE", "0"), ("(gint) GST_WEBRTC_DATA_CHANNEL_STATE_CLOSED", "4"), ("(gint) GST_WEBRTC_DATA_CHANNEL_STATE_CLOSING", "3"), ("(gint) GST_WEBRTC_DATA_CHANNEL_STATE_CONNECTING", "1"), ("(gint) GST_WEBRTC_DATA_CHANNEL_STATE_NEW", "0"), ("(gint) GST_WEBRTC_DATA_CHANNEL_STATE_OPEN", "2"), ("(gint) GST_WEBRTC_DTLS_SETUP_ACTIVE", "2"), ("(gint) GST_WEBRTC_DTLS_SETUP_ACTPASS", "1"), ("(gint) GST_WEBRTC_DTLS_SETUP_NONE", "0"), ("(gint) GST_WEBRTC_DTLS_SETUP_PASSIVE", "3"), ("(gint) GST_WEBRTC_DTLS_TRANSPORT_STATE_CLOSED", "1"), ("(gint) GST_WEBRTC_DTLS_TRANSPORT_STATE_CONNECTED", "4"), ("(gint) GST_WEBRTC_DTLS_TRANSPORT_STATE_CONNECTING", "3"), ("(gint) GST_WEBRTC_DTLS_TRANSPORT_STATE_FAILED", "2"), ("(gint) GST_WEBRTC_DTLS_TRANSPORT_STATE_NEW", "0"), ("(gint) GST_WEBRTC_FEC_TYPE_NONE", "0"), ("(gint) GST_WEBRTC_FEC_TYPE_ULP_RED", "1"), ("(gint) GST_WEBRTC_ICE_COMPONENT_RTCP", "1"), ("(gint) GST_WEBRTC_ICE_COMPONENT_RTP", "0"), ("(gint) GST_WEBRTC_ICE_CONNECTION_STATE_CHECKING", "1"), ("(gint) GST_WEBRTC_ICE_CONNECTION_STATE_CLOSED", "6"), ("(gint) GST_WEBRTC_ICE_CONNECTION_STATE_COMPLETED", "3"), ("(gint) GST_WEBRTC_ICE_CONNECTION_STATE_CONNECTED", "2"), ("(gint) GST_WEBRTC_ICE_CONNECTION_STATE_DISCONNECTED", "5"), ("(gint) GST_WEBRTC_ICE_CONNECTION_STATE_FAILED", "4"), ("(gint) GST_WEBRTC_ICE_CONNECTION_STATE_NEW", "0"), ("(gint) GST_WEBRTC_ICE_GATHERING_STATE_COMPLETE", "2"), ("(gint) GST_WEBRTC_ICE_GATHERING_STATE_GATHERING", "1"), ("(gint) GST_WEBRTC_ICE_GATHERING_STATE_NEW", "0"), ("(gint) GST_WEBRTC_ICE_ROLE_CONTROLLED", "0"), ("(gint) GST_WEBRTC_ICE_ROLE_CONTROLLING", "1"), ("(gint) GST_WEBRTC_ICE_TRANSPORT_POLICY_ALL", "0"), ("(gint) GST_WEBRTC_ICE_TRANSPORT_POLICY_RELAY", "1"), ("(gint) GST_WEBRTC_PEER_CONNECTION_STATE_CLOSED", "5"), ("(gint) GST_WEBRTC_PEER_CONNECTION_STATE_CONNECTED", "2"), ("(gint) GST_WEBRTC_PEER_CONNECTION_STATE_CONNECTING", "1"), ("(gint) GST_WEBRTC_PEER_CONNECTION_STATE_DISCONNECTED", "3"), ("(gint) GST_WEBRTC_PEER_CONNECTION_STATE_FAILED", "4"), ("(gint) GST_WEBRTC_PEER_CONNECTION_STATE_NEW", "0"), ("(gint) GST_WEBRTC_PRIORITY_TYPE_HIGH", "4"), ("(gint) GST_WEBRTC_PRIORITY_TYPE_LOW", "2"), ("(gint) GST_WEBRTC_PRIORITY_TYPE_MEDIUM", "3"), ("(gint) GST_WEBRTC_PRIORITY_TYPE_VERY_LOW", "1"), ("(gint) GST_WEBRTC_RTP_TRANSCEIVER_DIRECTION_INACTIVE", "1"), ("(gint) GST_WEBRTC_RTP_TRANSCEIVER_DIRECTION_NONE", "0"), ("(gint) GST_WEBRTC_RTP_TRANSCEIVER_DIRECTION_RECVONLY", "3"), ("(gint) GST_WEBRTC_RTP_TRANSCEIVER_DIRECTION_SENDONLY", "2"), ("(gint) GST_WEBRTC_RTP_TRANSCEIVER_DIRECTION_SENDRECV", "4"), ("(gint) GST_WEBRTC_SCTP_TRANSPORT_STATE_CLOSED", "3"), ("(gint) GST_WEBRTC_SCTP_TRANSPORT_STATE_CONNECTED", "2"), ("(gint) GST_WEBRTC_SCTP_TRANSPORT_STATE_CONNECTING", "1"), ("(gint) GST_WEBRTC_SCTP_TRANSPORT_STATE_NEW", "0"), ("(gint) GST_WEBRTC_SDP_TYPE_ANSWER", "3"), ("(gint) GST_WEBRTC_SDP_TYPE_OFFER", "1"), ("(gint) GST_WEBRTC_SDP_TYPE_PRANSWER", "2"), ("(gint) GST_WEBRTC_SDP_TYPE_ROLLBACK", "4"), ("(gint) GST_WEBRTC_SIGNALING_STATE_CLOSED", "1"), ("(gint) GST_WEBRTC_SIGNALING_STATE_HAVE_LOCAL_OFFER", "2"), ("(gint) GST_WEBRTC_SIGNALING_STATE_HAVE_LOCAL_PRANSWER", "4"), ("(gint) GST_WEBRTC_SIGNALING_STATE_HAVE_REMOTE_OFFER", "3"), ( "(gint) GST_WEBRTC_SIGNALING_STATE_HAVE_REMOTE_PRANSWER", "5", ), ("(gint) GST_WEBRTC_SIGNALING_STATE_STABLE", "0"), ("(gint) GST_WEBRTC_STATS_CANDIDATE_PAIR", "11"), ("(gint) GST_WEBRTC_STATS_CERTIFICATE", "14"), ("(gint) GST_WEBRTC_STATS_CODEC", "1"), ("(gint) GST_WEBRTC_STATS_CSRC", "6"), ("(gint) GST_WEBRTC_STATS_DATA_CHANNEL", "8"), ("(gint) GST_WEBRTC_STATS_INBOUND_RTP", "2"), ("(gint) GST_WEBRTC_STATS_LOCAL_CANDIDATE", "12"), ("(gint) GST_WEBRTC_STATS_OUTBOUND_RTP", "3"), ("(gint) GST_WEBRTC_STATS_PEER_CONNECTION", "7"), ("(gint) GST_WEBRTC_STATS_REMOTE_CANDIDATE", "13"), ("(gint) GST_WEBRTC_STATS_REMOTE_INBOUND_RTP", "4"), ("(gint) GST_WEBRTC_STATS_REMOTE_OUTBOUND_RTP", "5"), ("(gint) GST_WEBRTC_STATS_STREAM", "9"), ("(gint) GST_WEBRTC_STATS_TRANSPORT", "10"), ];