summaryrefslogtreecommitdiffstats
path: root/third_party/libwebrtc/rtc_base/event_unittest.cc
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-07 19:33:14 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-07 19:33:14 +0000
commit36d22d82aa202bb199967e9512281e9a53db42c9 (patch)
tree105e8c98ddea1c1e4784a60a5a6410fa416be2de /third_party/libwebrtc/rtc_base/event_unittest.cc
parentInitial commit. (diff)
downloadfirefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.tar.xz
firefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.zip
Adding upstream version 115.7.0esr.upstream/115.7.0esr
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'third_party/libwebrtc/rtc_base/event_unittest.cc')
-rw-r--r--third_party/libwebrtc/rtc_base/event_unittest.cc115
1 files changed, 115 insertions, 0 deletions
diff --git a/third_party/libwebrtc/rtc_base/event_unittest.cc b/third_party/libwebrtc/rtc_base/event_unittest.cc
new file mode 100644
index 0000000000..17f50dc2d1
--- /dev/null
+++ b/third_party/libwebrtc/rtc_base/event_unittest.cc
@@ -0,0 +1,115 @@
+/*
+ * Copyright 2004 The WebRTC Project Authors. All rights reserved.
+ *
+ * Use of this source code is governed by a BSD-style license
+ * that can be found in the LICENSE file in the root of the source
+ * tree. An additional intellectual property rights grant can be found
+ * in the file PATENTS. All contributing project authors may
+ * be found in the AUTHORS file in the root of the source tree.
+ */
+
+#include "rtc_base/event.h"
+
+#include "api/units/time_delta.h"
+#include "rtc_base/platform_thread.h"
+#include "system_wrappers/include/clock.h"
+#include "test/gtest.h"
+
+namespace rtc {
+
+TEST(EventTest, InitiallySignaled) {
+ Event event(false, true);
+ ASSERT_TRUE(event.Wait(webrtc::TimeDelta::Zero()));
+}
+
+TEST(EventTest, ManualReset) {
+ Event event(true, false);
+ ASSERT_FALSE(event.Wait(webrtc::TimeDelta::Zero()));
+
+ event.Set();
+ ASSERT_TRUE(event.Wait(webrtc::TimeDelta::Zero()));
+ ASSERT_TRUE(event.Wait(webrtc::TimeDelta::Zero()));
+
+ event.Reset();
+ ASSERT_FALSE(event.Wait(webrtc::TimeDelta::Zero()));
+}
+
+TEST(EventTest, AutoReset) {
+ Event event;
+ ASSERT_FALSE(event.Wait(webrtc::TimeDelta::Zero()));
+
+ event.Set();
+ ASSERT_TRUE(event.Wait(webrtc::TimeDelta::Zero()));
+ ASSERT_FALSE(event.Wait(webrtc::TimeDelta::Zero()));
+}
+
+class SignalerThread {
+ public:
+ void Start(Event* writer, Event* reader) {
+ writer_ = writer;
+ reader_ = reader;
+ thread_ = PlatformThread::SpawnJoinable(
+ [this] {
+ while (!stop_event_.Wait(webrtc::TimeDelta::Zero())) {
+ writer_->Set();
+ reader_->Wait(Event::kForever);
+ }
+ },
+ "EventPerf");
+ }
+ void Stop() {
+ stop_event_.Set();
+ thread_.Finalize();
+ }
+ Event stop_event_;
+ Event* writer_;
+ Event* reader_;
+ PlatformThread thread_;
+};
+
+TEST(EventTest, UnsignaledWaitDoesNotReturnBeforeTimeout) {
+ constexpr webrtc::TimeDelta kDuration = webrtc::TimeDelta::Micros(10'499);
+ Event event;
+ auto begin = webrtc::Clock::GetRealTimeClock()->CurrentTime();
+ EXPECT_FALSE(event.Wait(kDuration));
+ EXPECT_GE(webrtc::Clock::GetRealTimeClock()->CurrentTime(),
+ begin + kDuration);
+}
+
+// These tests are disabled by default and only intended to be run manually.
+TEST(EventTest, DISABLED_PerformanceSingleThread) {
+ static const int kNumIterations = 10000000;
+ Event event;
+ for (int i = 0; i < kNumIterations; ++i) {
+ event.Set();
+ event.Wait(webrtc::TimeDelta::Zero());
+ }
+}
+
+TEST(EventTest, DISABLED_PerformanceMultiThread) {
+ static const int kNumIterations = 10000;
+ Event read;
+ Event write;
+ SignalerThread thread;
+ thread.Start(&read, &write);
+
+ for (int i = 0; i < kNumIterations; ++i) {
+ write.Set();
+ read.Wait(Event::kForever);
+ }
+ write.Set();
+
+ thread.Stop();
+}
+
+#if RTC_DCHECK_IS_ON && GTEST_HAS_DEATH_TEST && !defined(WEBRTC_ANDROID)
+// Tests that we crash if we attempt to call rtc::Event::Wait while we're
+// not allowed to (as per `RTC_DISALLOW_WAIT()`).
+TEST(EventTestDeathTest, DisallowEventWait) {
+ Event event;
+ RTC_DISALLOW_WAIT();
+ EXPECT_DEATH(event.Wait(Event::kForever), "");
+}
+#endif // RTC_DCHECK_IS_ON && GTEST_HAS_DEATH_TEST && !defined(WEBRTC_ANDROID)
+
+} // namespace rtc