fix ConnectionState::Failed

rtc-ice/examples/ping_pong.rs

@@ -162,7 +162,11 @@ async fn main() -> Result<(), Error> {
 
     let port = if cli.controlling { 4000 } else { 4001 };
     let udp_socket = UdpSocket::bind(("0.0.0.0", port)).await?;
-    let mut ice_agent = Agent::new(AgentConfig::default())?;
+    let mut ice_agent = Agent::new(AgentConfig {
+        disconnected_timeout: Some(Duration::from_secs(5)),
+        failed_timeout: Some(Duration::from_secs(5)),
+        ..Default::default()
+    })?;
 
     let client = Arc::new(Client::new());
 
@@ -260,6 +264,9 @@ async fn main() -> Result<(), Error> {
 
     ice_agent.start_connectivity_checks(cli.controlling, remote_ufrag, remote_pwd)?;
 
+    println!("Press 'Enter' when both processes have started");
+    let _ = io::stdin().read_line(&mut input)?;
+
     println!("Enter bye to stop");
     let (mut tx, mut rx) = futures::channel::mpsc::channel(8);
     std::thread::spawn(move || {

rtc-ice/src/agent/mod.rs

@@ -127,6 +127,7 @@ pub struct Agent {
     pub(crate) keepalive_interval: Duration,
     // How often should we run our internal taskLoop to check for state changes when connecting
     pub(crate) check_interval: Duration,
+    pub(crate) checking_duration: Instant,
     pub(crate) last_checking_time: Instant,
 
     pub(crate) candidate_types: Vec<CandidateType>,
@@ -239,6 +240,7 @@ impl Agent {
             } else {
                 config.check_interval
             },
+            checking_duration: Instant::now(),
             last_checking_time: Instant::now(),
             last_connection_state: ConnectionState::Unspecified,
 
@@ -520,12 +522,12 @@ impl Agent {
         if self.connection_state == ConnectionState::Checking {
             // We have just entered checking for the first time so update our checking timer
             if self.last_connection_state != self.connection_state {
-                self.last_checking_time = now;
+                self.checking_duration = now;
             }
 
             // We have been in checking longer then Disconnect+Failed timeout, set the connection to Failed
             if now
-                .checked_duration_since(self.last_checking_time)
+                .checked_duration_since(self.checking_duration)
                 .unwrap_or_else(|| Duration::from_secs(0))
                 > self.disconnected_timeout + self.failed_timeout
             {
@@ -661,7 +663,7 @@ impl Agent {
         };
 
         if valid {
-            // Only allow transitions to failed if a.failedTimeout is non-zero
+            // Only allow transitions to fail if a.failedTimeout is non-zero
             if self.failed_timeout != Duration::from_secs(0) {
                 self.failed_timeout += self.disconnected_timeout;
             }
@@ -833,12 +835,14 @@ impl Agent {
         }
 
         *pending_binding_requests = temp;
-        let bind_requests_removed = initial_size - pending_binding_requests.len();
+        let bind_requests_remaining = pending_binding_requests.len();
+        let bind_requests_removed = initial_size - bind_requests_remaining;
         if bind_requests_removed > 0 {
             trace!(
-                "[{}]: Discarded {} binding requests because they expired",
+                "[{}]: Discarded {} binding requests because they expired, still {} remaining",
                 self.get_name(),
-                bind_requests_removed
+                bind_requests_removed,
+                bind_requests_remaining,
             );
         }
     }