xref: /aosp_15_r20/external/webrtc/rtc_base/task_queue_unittest.cc (revision d9f758449e529ab9291ac668be2861e7a55c2422)
1 /*
2  *  Copyright 2016 The WebRTC Project Authors. All rights reserved.
3  *
4  *  Use of this source code is governed by a BSD-style license
5  *  that can be found in the LICENSE file in the root of the source
6  *  tree. An additional intellectual property rights grant can be found
7  *  in the file PATENTS.  All contributing project authors may
8  *  be found in the AUTHORS file in the root of the source tree.
9  */
10 
11 #if defined(WEBRTC_WIN)
12 // clang-format off
13 #include <windows.h>  // Must come first.
14 #include <mmsystem.h>
15 // clang-format on
16 #endif
17 
18 #include <stdint.h>
19 
20 #include <memory>
21 #include <utility>
22 #include <vector>
23 
24 #include "absl/memory/memory.h"
25 #include "api/units/time_delta.h"
26 #include "rtc_base/event.h"
27 #include "rtc_base/task_queue_for_test.h"
28 #include "rtc_base/time_utils.h"
29 #include "test/gtest.h"
30 
31 namespace rtc {
32 
33 namespace {
34 using ::webrtc::TimeDelta;
35 // Noop on all platforms except Windows, where it turns on high precision
36 // multimedia timers which increases the precision of TimeMillis() while in
37 // scope.
38 class EnableHighResTimers {
39  public:
40 #if !defined(WEBRTC_WIN)
EnableHighResTimers()41   EnableHighResTimers() {}
42 #else
43   EnableHighResTimers() : enabled_(timeBeginPeriod(1) == TIMERR_NOERROR) {}
44   ~EnableHighResTimers() {
45     if (enabled_)
46       timeEndPeriod(1);
47   }
48 
49  private:
50   const bool enabled_;
51 #endif
52 };
53 
CheckCurrent(Event * signal,TaskQueue * queue)54 void CheckCurrent(Event* signal, TaskQueue* queue) {
55   EXPECT_TRUE(queue->IsCurrent());
56   if (signal)
57     signal->Set();
58 }
59 
60 }  // namespace
61 
62 // This task needs to be run manually due to the slowness of some of our bots.
63 // TODO(tommi): Can we run this on the perf bots?
TEST(TaskQueueTest,DISABLED_PostDelayedHighRes)64 TEST(TaskQueueTest, DISABLED_PostDelayedHighRes) {
65   EnableHighResTimers high_res_scope;
66 
67   static const char kQueueName[] = "PostDelayedHighRes";
68   Event event;
69   webrtc::TaskQueueForTest queue(kQueueName, TaskQueue::Priority::HIGH);
70 
71   uint32_t start = Time();
72   queue.PostDelayedTask([&event, &queue] { CheckCurrent(&event, &queue); },
73                         TimeDelta::Millis(3));
74   EXPECT_TRUE(event.Wait(webrtc::TimeDelta::Seconds(1)));
75   uint32_t end = TimeMillis();
76   // These tests are a little relaxed due to how "powerful" our test bots can
77   // be.  Most recently we've seen windows bots fire the callback after 94-99ms,
78   // which is why we have a little bit of leeway backwards as well.
79   EXPECT_GE(end - start, 3u);
80   EXPECT_NEAR(end - start, 3, 3u);
81 }
82 
83 }  // namespace rtc
84