commit 5286dcfab671b32841e089fa22fa920dbdbd4955
author Danil Chapovalov <danilchap@webrtc.org> Mon Jul 18 15:04:56 2022
committer WebRTC LUCI CQ <webrtc-scoped@luci-project-accounts.iam.gserviceaccount.com> Tue Jul 19 10:57:42 2022
tree 78b918aab80fca97d738554f06a9c39daddef988
parent 049dde6c8ef0eaaa00896787783f6725c9a2fe78

Migrate rtc_base and rtc_tools to absl::AnyInvocable based TaskQueueBase interface

Bug: webrtc:14245
Change-Id: I71abe3db7a23ad33bd175297e23fa8e927fa9628
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/268768
Reviewed-by: Mirko Bonadei <mbonadei@webrtc.org>
Commit-Queue: Danil Chapovalov <danilchap@webrtc.org>
Cr-Commit-Position: refs/heads/main@{#37553}

rtc_tools/video_replay.cc

diff --git a/rtc_tools/video_replay.cc b/rtc_tools/video_replay.cc
index 346d962..3f35a55 100644
--- a/rtc_tools/video_replay.cc
+++ b/rtc_tools/video_replay.cc
@@ -355,7 +355,7 @@
 
     // Creation of the streams must happen inside a task queue because it is
     // resued as a worker thread.
-    worker_thread->PostTask(ToQueuedTask([&]() {
+    worker_thread->PostTask([&]() {
       call.reset(Call::Create(call_config));
 
       // Attempt to load the configuration
@@ -375,7 +375,7 @@
         receive_stream->Start();
       }
       sync_event.Set();
-    }));
+    });
 
     // Attempt to create an RtpReader from the input file.
     std::unique_ptr<test::RtpFileReader> rtp_reader =
@@ -392,7 +392,7 @@
 
     // Destruction of streams and the call must happen on the same thread as
     // their creation.
-    worker_thread->PostTask(ToQueuedTask([&]() {
+    worker_thread->PostTask([&]() {
       for (const auto& receive_stream : stream_state->receive_streams) {
         call->DestroyVideoReceiveStream(receive_stream);
       }
@@ -401,7 +401,7 @@
       }
       call.reset();
       sync_event.Set();
-    }));
+    });
     sync_event.Wait(/*give_up_after_ms=*/10000);
   }
 
@@ -606,12 +606,12 @@
 
       ++num_packets;
       PacketReceiver::DeliveryStatus result = PacketReceiver::DELIVERY_OK;
-      worker_thread->PostTask(ToQueuedTask([&]() {
+      worker_thread->PostTask([&]() {
         result = call->Receiver()->DeliverPacket(webrtc::MediaType::VIDEO,
                                                  std::move(packet_buffer),
                                                  /* packet_time_us */ -1);
         event.Set();
-      }));
+      });
       event.Wait(/*give_up_after_ms=*/10000);
       switch (result) {
         case PacketReceiver::DELIVERY_OK: