From 95d06e160b21df29a62926fefd46c9f318c2cae1 Mon Sep 17 00:00:00 2001
From: Kingtous <kingtous@qq.com>
Date: Mon, 30 Jan 2023 11:51:03 +0800
Subject: [PATCH] fix: latency

---
 src/client/helper.rs | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/src/client/helper.rs b/src/client/helper.rs
index 248cf5928..e3acf3a44 100644
--- a/src/client/helper.rs
+++ b/src/client/helper.rs
@@ -27,7 +27,7 @@ impl Default for LatencyController {
             last_video_remote_ts: Default::default(),
             update_time: Instant::now(),
             allow_audio: Default::default(),
-            audio_only: true
+            audio_only: false
         }
     }
 }
@@ -53,7 +53,11 @@ impl LatencyController {
     pub fn check_audio(&mut self, timestamp: i64) -> bool {
         // Compute audio latency.
         let expected = self.update_time.elapsed().as_millis() as i64 + self.last_video_remote_ts;
-        let latency = expected - timestamp;
+        let latency = if self.audio_only {
+            expected
+        } else {
+            expected - timestamp
+        };
         // Set MAX and MIN, avoid fixing too frequently.
         if self.allow_audio {
             if latency.abs() > MAX_LATENCY {
@@ -66,11 +70,9 @@ impl LatencyController {
                 self.allow_audio = true;
             }
         }
-        // No video frame here, which means the update time is not triggered.
+        // No video frame here, which means the update time is not up to date.
         // We manually update the time here.
-        if self.audio_only {
-            self.update_time = Instant::now();
-        }
+        self.update_time = Instant::now();
         self.allow_audio
     }
 }