src: lib: stream: Improve RTSP latency

mavlink · Jul 18, 2024 · b831638 · b831638
1 parent bf983e0
commit b831638
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/lib/stream/rtsp/rtsp_server.rs b/src/lib/stream/rtsp/rtsp_server.rs
@@ -165,7 +165,7 @@ impl RTSPServer {
             "H264" => {
                 format!(
                     concat!(
-                        "shmsrc socket-path={socket_path} do-timestamp=true is-live=true",
+                        "shmsrc socket-path={socket_path} do-timestamp=true is-live=false",
                         " ! queue leaky=downstream flush-on-eos=true silent=true max-size-buffers=0",
                         " ! capsfilter caps={rtp_caps:?}",
                         " ! rtph264depay",
@@ -178,7 +178,7 @@ impl RTSPServer {
             "RAW" => {
                 format!(
                     concat!(
-                        "shmsrc socket-path={socket_path} do-timestamp=true is-live=true",
+                        "shmsrc socket-path={socket_path} do-timestamp=true is-live=false",
                         " ! queue leaky=downstream flush-on-eos=true silent=true max-size-buffers=0",
                         " ! capsfilter caps={rtp_caps:?}",
                         " ! rtpvrawdepay",
@@ -191,7 +191,7 @@ impl RTSPServer {
             "JPEG" => {
                 format!(
                     concat!(
-                        "shmsrc socket-path={socket_path} do-timestamp=true is-live=true",
+                        "shmsrc socket-path={socket_path} do-timestamp=true is-live=false",
                         " ! queue leaky=downstream flush-on-eos=true silent=true max-size-buffers=10",
                         " ! capsfilter caps={rtp_caps:?}",
                         " ! rtpjpegdepay",

diff --git a/src/lib/stream/sink/rtsp_sink.rs b/src/lib/stream/sink/rtsp_sink.rs
@@ -251,7 +251,7 @@ impl RtspSink {
         let socket_path = format!("/tmp/{id}");
         let sink = gst::ElementFactory::make("shmsink")
             .property_from_str("socket-path", &socket_path)
-            .property("sync", true)
+            .property("sync", false)
             .property("wait-for-connection", true)
             .property("shm-size", 10_000_000u32)
             .property("enable-last-sample", false)