forked from mavlink/mavlink-camera-manager
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
1c80552
commit 2a78a1c
Showing
3 changed files
with
200 additions
and
8 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,162 @@ | ||
| use crate::{ | ||
| stream::types::CaptureConfiguration, | ||
| video::{ | ||
| types::{VideoEncodeType, VideoSourceType}, | ||
| video_source_gst::VideoSourceGstType, | ||
| }, | ||
| video_stream::types::VideoAndStreamInformation, | ||
| }; | ||
|
|
||
| use super::{ | ||
| PipelineGstreamerInterface, PipelineState, PIPELINE_FILTER_NAME, PIPELINE_RTP_TEE_NAME, | ||
| PIPELINE_VIDEO_TEE_NAME, | ||
| }; | ||
|
|
||
| use anyhow::{anyhow, Result}; | ||
|
|
||
| use tracing::*; | ||
|
|
||
| use gst::prelude::*; | ||
|
|
||
| #[derive(Debug)] | ||
| pub struct QrPipeline { | ||
| pub state: PipelineState, | ||
| } | ||
|
|
||
| impl QrPipeline { | ||
| #[instrument(level = "debug")] | ||
| pub fn try_new( | ||
| pipeline_id: &uuid::Uuid, | ||
| video_and_stream_information: &VideoAndStreamInformation, | ||
| ) -> Result<gst::Pipeline> { | ||
| let configuration = match &video_and_stream_information | ||
| .stream_information | ||
| .configuration | ||
| { | ||
| CaptureConfiguration::Video(configuration) => configuration, | ||
| unsupported => { | ||
| return Err(anyhow!("{unsupported:?} is not supported as Fake Pipeline")) | ||
| } | ||
| }; | ||
|
|
||
| let video_source = match &video_and_stream_information.video_source { | ||
| VideoSourceType::Gst(source) => source, | ||
| unsupported => { | ||
| return Err(anyhow!( | ||
| "SourceType {unsupported:?} is not supported as Fake Pipeline" | ||
| )) | ||
| } | ||
| }; | ||
|
|
||
| let pattern = match &video_source.source { | ||
| VideoSourceGstType::Fake(pattern) => pattern, | ||
| unsupported => { | ||
| return Err(anyhow!( | ||
| "SourceType {unsupported:?} is not supported as Fake Pipeline" | ||
| )) | ||
| } | ||
| }; | ||
|
|
||
| let filter_name = format!("{PIPELINE_FILTER_NAME}-{pipeline_id}"); | ||
| let video_tee_name = format!("{PIPELINE_VIDEO_TEE_NAME}-{pipeline_id}"); | ||
| let rtp_tee_name = format!("{PIPELINE_RTP_TEE_NAME}-{pipeline_id}"); | ||
|
|
||
| // Fakes (videotestsrc) are only "video/x-raw" or "video/x-bayer", | ||
| // and to be able to encode it, we need to define an available | ||
| // format for both its src the next element's sink pad. | ||
| // We are choosing "UYVY" because it is compatible with the | ||
| // application-rtp template capabilities. | ||
| // For more information: https://gstreamer.freedesktop.org/documentation/additional/design/mediatype-video-raw.html?gi-language=c#formats | ||
| let description = match &configuration.encode { | ||
| VideoEncodeType::H264 => { | ||
| format!(concat!( | ||
| "videotestsrc pattern={pattern} is-live=true do-timestamp=true", | ||
| " ! timeoverlay", | ||
| " ! video/x-raw,format=I420", | ||
| " ! x264enc tune=zerolatency speed-preset=ultrafast bitrate=5000", | ||
| " ! h264parse", | ||
| " ! capsfilter name={filter_name} caps=video/x-h264,profile={profile},stream-format=avc,alignment=au,width={width},height={height},framerate={interval_denominator}/{interval_numerator}", | ||
| " ! tee name={video_tee_name} allow-not-linked=true", | ||
| " ! rtph264pay aggregate-mode=zero-latency config-interval=10 pt=96", | ||
| " ! tee name={rtp_tee_name} allow-not-linked=true" | ||
| ), | ||
| pattern = pattern, | ||
| profile = "constrained-baseline", | ||
| width = configuration.width, | ||
| height = configuration.height, | ||
| interval_denominator = configuration.frame_interval.denominator, | ||
| interval_numerator = configuration.frame_interval.numerator, | ||
| filter_name = filter_name, | ||
| video_tee_name = video_tee_name, | ||
| rtp_tee_name = rtp_tee_name, | ||
| ) | ||
| } | ||
| VideoEncodeType::Yuyv => { | ||
| format!( | ||
| concat!( | ||
| // Because application-rtp templates doesn't accept "YUY2", we | ||
| // need to transcode it. We are arbitrarily chosing the closest | ||
| // format available ("UYVY"). | ||
| "videotestsrc pattern={pattern} is-live=true do-timestamp=true", | ||
| " ! timeoverlay", | ||
| " ! video/x-raw,format=I420", | ||
| " ! capsfilter name={filter_name} caps=video/x-raw,format=I420,width={width},height={height},framerate={interval_denominator}/{interval_numerator}", | ||
| " ! tee name={video_tee_name} allow-not-linked=true", | ||
| " ! rtpvrawpay pt=96", | ||
| " ! tee name={rtp_tee_name} allow-not-linked=true", | ||
| ), | ||
| pattern = pattern, | ||
| width = configuration.width, | ||
| height = configuration.height, | ||
| interval_denominator = configuration.frame_interval.denominator, | ||
| interval_numerator = configuration.frame_interval.numerator, | ||
| filter_name = filter_name, | ||
| video_tee_name = video_tee_name, | ||
| rtp_tee_name = rtp_tee_name, | ||
| ) | ||
| } | ||
| VideoEncodeType::Mjpg => { | ||
| format!( | ||
| concat!( | ||
| "videotestsrc pattern={pattern} is-live=true do-timestamp=true", | ||
| " ! timeoverlay", | ||
| " ! video/x-raw,format=I420", | ||
| " ! jpegenc quality=85 idct-method=1", | ||
| " ! capsfilter name={filter_name} caps=image/jpeg,width={width},height={height},framerate={interval_denominator}/{interval_numerator}", | ||
| " ! tee name={video_tee_name} allow-not-linked=true", | ||
| " ! rtpjpegpay pt=96", | ||
| " ! tee name={rtp_tee_name} allow-not-linked=true", | ||
| ), | ||
| pattern = pattern, | ||
| width = configuration.width, | ||
| height = configuration.height, | ||
| interval_denominator = configuration.frame_interval.denominator, | ||
| interval_numerator = configuration.frame_interval.numerator, | ||
| filter_name = filter_name, | ||
| video_tee_name = video_tee_name, | ||
| rtp_tee_name = rtp_tee_name, | ||
| ) | ||
| } | ||
| unsupported => { | ||
| return Err(anyhow!( | ||
| "Encode {unsupported:?} is not supported for Test Pipeline" | ||
| )) | ||
| } | ||
| }; | ||
|
|
||
| let pipeline = gst::parse::launch(&description)?; | ||
|
|
||
| let pipeline = pipeline | ||
| .downcast::<gst::Pipeline>() | ||
| .expect("Couldn't downcast pipeline"); | ||
|
|
||
| Ok(pipeline) | ||
| } | ||
| } | ||
|
|
||
| impl PipelineGstreamerInterface for QrPipeline { | ||
| #[instrument(level = "trace")] | ||
| fn is_running(&self) -> bool { | ||
| self.state.pipeline_runner.is_running() | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters