diff --git a/docs/plugins/gst_plugins_cache.json b/docs/plugins/gst_plugins_cache.json index f32d70b3..5e95a7dd 100644 --- a/docs/plugins/gst_plugins_cache.json +++ b/docs/plugins/gst_plugins_cache.json @@ -6406,7 +6406,7 @@ "construct": false, "construct-only": false, "controllable": false, - "default": "2000000000", + "default": "5000000000", "max": "18446744073709551614", "min": "0", "mutable": "ready", diff --git a/net/rtsp/src/rtspsrc/imp.rs b/net/rtsp/src/rtspsrc/imp.rs index 34563b41..3306188a 100644 --- a/net/rtsp/src/rtspsrc/imp.rs +++ b/net/rtsp/src/rtspsrc/imp.rs @@ -52,7 +52,7 @@ use super::sdp; use super::transport::RtspTransportInfo; const DEFAULT_LOCATION: Option = None; -const DEFAULT_TIMEOUT: gst::ClockTime = gst::ClockTime::from_seconds(2); +const DEFAULT_TIMEOUT: gst::ClockTime = gst::ClockTime::from_seconds(5); const DEFAULT_PORT_START: u16 = 0; // Priority list has multicast first, because we want to prefer multicast if it's available const DEFAULT_PROTOCOLS: &str = "udp-mcast,udp,tcp"; @@ -1873,9 +1873,10 @@ async fn udp_rtp_task( let _ = socket.connect(addr).await; Ok(addr) } - Ok(Err(_elapsed)) => { - Err(format!("No data after {DEFAULT_TIMEOUT} seconds, exiting")) - } + Ok(Err(_elapsed)) => Err(format!( + "No data after {} seconds, exiting", + timeout.seconds() + )), Err(err) => Err(format!("UDP socket was closed: {err:?}")), }; match ret { @@ -1939,7 +1940,9 @@ async fn udp_rtp_task( break format!("UDP buffer push failed: {err:?}"); } } - Ok(Err(_elapsed)) => break format!("No data after {DEFAULT_TIMEOUT} seconds, exiting"), + Ok(Err(_elapsed)) => { + break format!("No data after {} seconds, exiting", timeout.seconds()) + } Err(err) => break format!("UDP socket was closed: {err:?}"), }; };