Bug: webrtc:42223992,webrtc:469327588 Change-Id: I9b7646b9ba4809a924fbb8186594e2516a6a6964 Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/448283 Auto-Submit: Evan Shrubsole <eshr@webrtc.org> Commit-Queue: Tomas Gunnarsson <tommi@webrtc.org> Reviewed-by: Tomas Gunnarsson <tommi@webrtc.org> Cr-Commit-Position: refs/heads/main@{#46875}
54 lines
1.6 KiB
C++
54 lines
1.6 KiB
C++
/*
|
|
* Copyright 2012 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/null_socket_server.h"
|
|
|
|
#include <memory>
|
|
|
|
#include "api/environment/environment.h"
|
|
#include "api/units/time_delta.h"
|
|
#include "api/units/timestamp.h"
|
|
#include "rtc_base/socket_server.h"
|
|
#include "rtc_base/thread.h"
|
|
#include "test/create_test_environment.h"
|
|
#include "test/gtest.h"
|
|
#include "test/run_loop.h"
|
|
|
|
namespace webrtc {
|
|
|
|
TEST(NullSocketServerTest, WaitAndSet) {
|
|
test::RunLoop run_loop;
|
|
NullSocketServer ss;
|
|
auto thread = Thread::Create();
|
|
EXPECT_TRUE(thread->Start());
|
|
thread->PostTask([&ss] { ss.WakeUp(); });
|
|
// The process_io will be ignored.
|
|
const bool process_io = true;
|
|
bool wait_result = false;
|
|
run_loop.PostTask([&] {
|
|
wait_result = ss.Wait(SocketServer::kForever, process_io);
|
|
run_loop.Quit();
|
|
});
|
|
run_loop.RunFor(TimeDelta::Seconds(5));
|
|
EXPECT_TRUE(wait_result);
|
|
}
|
|
|
|
TEST(NullSocketServerTest, TestWait) {
|
|
Environment env = CreateTestEnvironment();
|
|
NullSocketServer ss;
|
|
Timestamp start = env.clock().CurrentTime();
|
|
ss.Wait(TimeDelta::Millis(200), true);
|
|
// The actual wait time is dependent on the resolution of the timer used by
|
|
// the Event class. Allow for the event to signal ~20ms early.
|
|
EXPECT_GE(env.clock().CurrentTime() - start, TimeDelta::Millis(180));
|
|
}
|
|
|
|
} // namespace webrtc
|