Skip to content

Commit

Permalink
misc: add name for the queue before the encoders
Browse files Browse the repository at this point in the history
  • Loading branch information
SeaDve committed Feb 26, 2024
1 parent 275a98a commit dafde10
Showing 1 changed file with 6 additions and 2 deletions.
8 changes: 6 additions & 2 deletions src/pipeline.rs
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,9 @@ impl PipelineBuilder {

let videosrc_bin = make_pipewiresrc_bin(self.fd, &self.streams, self.framerate)
.context("Failed to create videosrc bin")?;
let videoenc_queue = gst::ElementFactory::make("queue").build()?;
let videoenc_queue = gst::ElementFactory::make("queue")
.name("kooha-videoenc-queue")
.build()?;
let filesink = gst::ElementFactory::make("filesink")
.property(
"location",
Expand Down Expand Up @@ -136,7 +138,9 @@ impl PipelineBuilder {
.collect::<Result<Vec<_>>>()?,
)
.context("Failed to create audiosrc bin")?;
let audioenc_queue = gst::ElementFactory::make("queue").build()?;
let audioenc_queue = gst::ElementFactory::make("queue")
.name("kooha-audioenc-queue")
.build()?;

pipeline.add_many([audiosrc_bin.upcast_ref(), &audioenc_queue])?;
audiosrc_bin.link(&audioenc_queue)?;
Expand Down

0 comments on commit dafde10

Please sign in to comment.