src: stream: sink: Silent Queues

Since we are not using their signals, we can silent them, making them
more lightweight

src/stream/rtsp/rtsp_server.rs

@@ -139,7 +139,7 @@ impl RTSPServer {
                 format!(
                     concat!(
                         "shmsrc socket-path={socket_path} do-timestamp=true",
-                        " ! queue leaky=downstream flush-on-eos=true max-size-buffers=0",
+                        " ! queue leaky=downstream flush-on-eos=true silent=true max-size-buffers=0",
                         " ! capsfilter caps={rtp_caps:?}",
                         " ! rtph264depay",
                         " ! rtph264pay name=pay0 aggregate-mode=zero-latency config-interval=10 pt=96",
@@ -152,7 +152,7 @@ impl RTSPServer {
                 format!(
                     concat!(
                         "shmsrc socket-path={socket_path} do-timestamp=true",
-                        " ! queue leaky=downstream flush-on-eos=true max-size-buffers=0",
+                        " ! queue leaky=downstream flush-on-eos=true silent=true max-size-buffers=0",
                         " ! capsfilter caps={rtp_caps:?}",
                         " ! rtpvrawdepay",
                         " ! rtpvrawpay name=pay0 pt=96",
@@ -165,7 +165,7 @@ impl RTSPServer {
                 format!(
                     concat!(
                         "shmsrc socket-path={socket_path} do-timestamp=true",
-                        " ! queue leaky=downstream flush-on-eos=true max-size-buffers=0",
+                        " ! queue leaky=downstream flush-on-eos=true silent=true max-size-buffers=10",
                         " ! capsfilter caps={rtp_caps:?}",
                         " ! rtpjpegdepay",
                         " ! rtpjpegpay name=pay0 pt=96",

src/stream/sink/image_sink.rs

@@ -294,6 +294,7 @@ impl ImageSink {
     pub fn try_new(sink_id: uuid::Uuid, encoding: VideoEncodeType) -> Result<Self> {
         let queue = gst::ElementFactory::make("queue")
             .property_from_str("leaky", "downstream") // Throw away any data
+            .property("silent", true)
             .property("flush-on-eos", true)
             .property("max-size-buffers", 0u32) // Disable buffers
             .build()?;
@@ -315,6 +316,7 @@ impl ImageSink {
                 {
                     Some(element) => {
                         element.set_property_from_str("leaky", "downstream"); // Throw away any data
+                        element.set_property("silent", true);
                         element.set_property("flush-on-eos", true);
                         element.set_property("max-size-buffers", 0u32); // Disable buffers
                     }

src/stream/sink/rtsp_sink.rs

@@ -227,6 +227,7 @@ impl RtspSink {
     pub fn try_new(id: uuid::Uuid, addresses: Vec<url::Url>) -> Result<Self> {
         let queue = gst::ElementFactory::make("queue")
             .property_from_str("leaky", "downstream") // Throw away any data
+            .property("silent", true)
             .property("flush-on-eos", true)
             .property("max-size-buffers", 0u32) // Disable buffers
             .build()?;

src/stream/sink/udp_sink.rs

@@ -274,6 +274,7 @@ impl UdpSink {
     pub fn try_new(sink_id: uuid::Uuid, addresses: Vec<url::Url>) -> Result<Self> {
         let queue = gst::ElementFactory::make("queue")
             .property_from_str("leaky", "downstream") // Throw away any data
+            .property("silent", true)
             .property("flush-on-eos", true)
             .property("max-size-buffers", 0u32) // Disable buffers
             .build()?;

src/stream/sink/webrtc_sink.rs

@@ -310,6 +310,7 @@ impl WebRTCSink {
     ) -> Result<Self> {
         let queue = gst::ElementFactory::make("queue")
             .property_from_str("leaky", "downstream") // Throw away any data
+            .property("silent", true)
             .property("flush-on-eos", true)
             .property("max-size-buffers", 0u32) // Disable buffers
             .build()?;