diff options
| author | Sebastian Dröge <sebastian@centricular.com> | 2023-10-30 18:38:46 +0300 |
|---|---|---|
| committer | Sebastian Dröge <sebastian@centricular.com> | 2023-11-10 18:47:41 +0300 |
| commit | eff3618ebdc3ee33af11674e2aa944164025d21e (patch) | |
| tree | 07ea07fdefcc6d8d015a625fedd91dee00506c38 | |
| parent | 9ffcb146170e2709278599a64303632947fc6dc3 (diff) | |
Set sync=false in rsfilesink / s3sink
BaseSink defaults to sync=true and that doesn't make much sense for
these elements.
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1387>
| -rw-r--r-- | generic/file/src/filesink/imp.rs | 7 | ||||
| -rw-r--r-- | net/aws/src/s3sink/imp.rs | 7 |
2 files changed, 14 insertions, 0 deletions
diff --git a/generic/file/src/filesink/imp.rs b/generic/file/src/filesink/imp.rs index 8d31dcbad..0d70cf1ac 100644 --- a/generic/file/src/filesink/imp.rs +++ b/generic/file/src/filesink/imp.rs @@ -13,6 +13,7 @@ use gst::glib; use gst::prelude::*; use gst::subclass::prelude::*; +use gst_base::prelude::*; use gst_base::subclass::prelude::*; use std::fs::File; @@ -112,6 +113,12 @@ impl ObjectSubclass for FileSink { } impl ObjectImpl for FileSink { + fn constructed(&self) { + self.parent_constructed(); + + self.obj().set_sync(false); + } + fn properties() -> &'static [glib::ParamSpec] { static PROPERTIES: Lazy<Vec<glib::ParamSpec>> = Lazy::new(|| { vec![glib::ParamSpecString::builder("location") diff --git a/net/aws/src/s3sink/imp.rs b/net/aws/src/s3sink/imp.rs index 652c6a240..4be7987da 100644 --- a/net/aws/src/s3sink/imp.rs +++ b/net/aws/src/s3sink/imp.rs @@ -9,6 +9,7 @@ use gst::glib; use gst::prelude::*; use gst::subclass::prelude::*; +use gst_base::prelude::*; use gst_base::subclass::prelude::*; use aws_sdk_s3::client::fluent_builders::{ @@ -654,6 +655,12 @@ impl ObjectSubclass for S3Sink { } impl ObjectImpl for S3Sink { + fn constructed(&self) { + self.parent_constructed(); + + self.obj().set_sync(false); + } + fn properties() -> &'static [glib::ParamSpec] { static PROPERTIES: Lazy<Vec<glib::ParamSpec>> = Lazy::new(|| { vec![ |