6461ca7c3e
We're about to add two new priorities. Ensure we're respecting go/cstyle#Enumerator_Names before adding them. WANT_LGTM=ANY Bug: chromium:470337728 Change-Id: I01c6f237a7c67df6a3083f1165ee07bffc9d3523 Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/443420 Reviewed-by: Harald Alvestrand <hta@webrtc.org> Reviewed-by: Tomas Gunnarsson <tommi@webrtc.org> Commit-Queue: Markus Handell <handellm@webrtc.org> Cr-Commit-Position: refs/heads/main@{#46740}
67 lines
2.0 KiB
C++
67 lines
2.0 KiB
C++
/*
|
|
* Copyright 2022 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/task_queue_stdlib.h"
|
|
|
|
#include <memory>
|
|
#include <string>
|
|
|
|
#include "absl/strings/string_view.h"
|
|
#include "api/field_trials_view.h"
|
|
#include "api/task_queue/task_queue_factory.h"
|
|
#include "api/task_queue/task_queue_test.h"
|
|
#include "api/units/time_delta.h"
|
|
#include "rtc_base/event.h"
|
|
#include "rtc_base/logging.h"
|
|
#include "rtc_base/thread.h"
|
|
#include "test/gtest.h"
|
|
|
|
namespace webrtc {
|
|
namespace {
|
|
|
|
std::unique_ptr<TaskQueueFactory> CreateTaskQueueFactory(
|
|
const FieldTrialsView*) {
|
|
return CreateTaskQueueStdlibFactory();
|
|
}
|
|
|
|
INSTANTIATE_TEST_SUITE_P(TaskQueueStdlib,
|
|
TaskQueueTest,
|
|
::testing::Values(CreateTaskQueueFactory));
|
|
|
|
class StringPtrLogSink : public LogSink {
|
|
public:
|
|
explicit StringPtrLogSink(std::string* log_data) : log_data_(log_data) {}
|
|
|
|
private:
|
|
void OnLogMessage(const std::string& message) override {
|
|
OnLogMessage(absl::string_view(message));
|
|
}
|
|
void OnLogMessage(absl::string_view message) override {
|
|
log_data_->append(message.begin(), message.end());
|
|
}
|
|
std::string* const log_data_;
|
|
};
|
|
|
|
TEST(TaskQueueStdlib, AvoidsSpammingLogOnInactivity) {
|
|
std::string log_output;
|
|
StringPtrLogSink stream(&log_output);
|
|
LogMessage::AddLogToStream(&stream, LS_VERBOSE);
|
|
auto task_queue = CreateTaskQueueStdlibFactory()->CreateTaskQueue(
|
|
"test", TaskQueueFactory::Priority::kNormal);
|
|
auto wait_duration = Event::kDefaultWarnDuration + TimeDelta::Seconds(1);
|
|
Thread::SleepMs(wait_duration.ms());
|
|
EXPECT_EQ(log_output.length(), 0u);
|
|
task_queue = nullptr;
|
|
LogMessage::RemoveLogToStream(&stream);
|
|
}
|
|
|
|
} // namespace
|
|
} // namespace webrtc
|