commit 00a8839d47c53914cde58f7ff26aa1e1ee4128e3
author Jakob Ivarsson <jakobi@webrtc.org> Tue Apr 23 13:03:29 2024
committer WebRTC LUCI CQ <webrtc-scoped@luci-project-accounts.iam.gserviceaccount.com> Tue Apr 23 14:31:46 2024
tree 2a0ae08d5a9e8c543d168f508ba3ee6463f07415
parent dc3cdf98e02c5b634ad59096b1a0d70d399252ca

Allow source tracker to be called synchronously on a single thread.

Bug: None
Change-Id: I699c0c787d28fe79959e93b3e1eda2634c931cef
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/348840
Reviewed-by: Danil Chapovalov <danilchap@webrtc.org>
Commit-Queue: Jakob Ivarsson‎ <jakobi@webrtc.org>
Cr-Commit-Position: refs/heads/main@{#42154}

modules/rtp_rtcp/source/source_tracker.cc

diff --git a/modules/rtp_rtcp/source/source_tracker.cc b/modules/rtp_rtcp/source/source_tracker.cc
index 51e8f1c..cd881f1 100644
--- a/modules/rtp_rtcp/source/source_tracker.cc
+++ b/modules/rtp_rtcp/source/source_tracker.cc
@@ -29,12 +29,17 @@
   }
 
   Timestamp now = clock_->CurrentTime();
-  worker_thread_->PostTask(
-      SafeTask(worker_safety_.flag(),
-               [this, packet_infos = std::move(packet_infos), now]() {
-                 RTC_DCHECK_RUN_ON(worker_thread_);
-                 OnFrameDeliveredInternal(now, packet_infos);
-               }));
+  if (worker_thread_->IsCurrent()) {
+    RTC_DCHECK_RUN_ON(worker_thread_);
+    OnFrameDeliveredInternal(now, packet_infos);
+  } else {
+    worker_thread_->PostTask(
+        SafeTask(worker_safety_.flag(),
+                 [this, packet_infos = std::move(packet_infos), now]() {
+                   RTC_DCHECK_RUN_ON(worker_thread_);
+                   OnFrameDeliveredInternal(now, packet_infos);
+                 }));
+  }
 }
 
 void SourceTracker::OnFrameDeliveredInternal(