Index: components/task_scheduler_util/common/variations_util_unittest.cc |
diff --git a/components/task_scheduler_util/common/variations_util_unittest.cc b/components/task_scheduler_util/common/variations_util_unittest.cc |
index 5618106542a59be20d9c83f0511e1267b1f1acdd..f07954a3ba1e76d75736808e93a4ac446ab79294 100644 |
--- a/components/task_scheduler_util/common/variations_util_unittest.cc |
+++ b/components/task_scheduler_util/common/variations_util_unittest.cc |
@@ -14,7 +14,6 @@ |
#include "base/metrics/field_trial.h" |
#include "base/task_scheduler/scheduler_worker_params.h" |
#include "base/task_scheduler/scheduler_worker_pool_params.h" |
-#include "base/threading/platform_thread.h" |
#include "components/variations/variations_associated_data.h" |
#include "testing/gtest/include/gtest/gtest.h" |
@@ -24,7 +23,7 @@ namespace { |
using StandbyThreadPolicy = |
base::SchedulerWorkerPoolParams::StandbyThreadPolicy; |
-using ThreadPriority = base::ThreadPriority; |
+using SchedulerBackwardCompatibility = base::SchedulerBackwardCompatibility; |
#if !defined(OS_IOS) |
constexpr char kFieldTrialName[] = "BrowserScheduler"; |
@@ -33,20 +32,6 @@ constexpr char kTaskSchedulerVariationParamsSwitch[] = |
"task-scheduler-variation-params"; |
#endif // !defined(OS_IOS) |
-std::vector<SchedulerImmutableWorkerPoolParams> GetImmutableWorkerPoolParams() { |
- std::vector<SchedulerImmutableWorkerPoolParams> constant_worker_pool_params; |
- constant_worker_pool_params.emplace_back("Background", |
- ThreadPriority::BACKGROUND); |
- constant_worker_pool_params.emplace_back("BackgroundFileIO", |
- ThreadPriority::BACKGROUND); |
- constant_worker_pool_params.emplace_back("Foreground", |
- ThreadPriority::NORMAL); |
- constant_worker_pool_params.emplace_back( |
- "ForegroundFileIO", ThreadPriority::NORMAL, |
- base::SchedulerBackwardCompatibility::INIT_COM_STA); |
- return constant_worker_pool_params; |
-} |
- |
class TaskSchedulerUtilVariationsUtilTest : public testing::Test { |
public: |
TaskSchedulerUtilVariationsUtilTest() : field_trial_list_(nullptr) {} |
@@ -66,129 +51,55 @@ class TaskSchedulerUtilVariationsUtilTest : public testing::Test { |
} // namespace |
TEST_F(TaskSchedulerUtilVariationsUtilTest, OrderingParams5) { |
- std::map<std::string, std::string> variation_params; |
- variation_params["Background"] = "1;1;1;0;42"; |
- variation_params["BackgroundFileIO"] = "2;2;1;0;52"; |
- variation_params["Foreground"] = "4;4;1;0;62"; |
- variation_params["ForegroundFileIO"] = "8;8;1;0;72"; |
- |
- auto params_vector = |
- GetWorkerPoolParams(GetImmutableWorkerPoolParams(), variation_params); |
- ASSERT_EQ(4U, params_vector.size()); |
- |
- EXPECT_EQ("Background", params_vector[0].name()); |
- EXPECT_EQ(ThreadPriority::BACKGROUND, params_vector[0].priority_hint()); |
- EXPECT_EQ(StandbyThreadPolicy::ONE, params_vector[0].standby_thread_policy()); |
- EXPECT_EQ(1U, params_vector[0].max_threads()); |
+ const auto worker_pool_params_a = StringToWorkerPoolParams( |
+ "1;1;1;0;42", SchedulerBackwardCompatibility::DISABLED); |
+ EXPECT_EQ(StandbyThreadPolicy::ONE, |
+ worker_pool_params_a.standby_thread_policy()); |
+ EXPECT_EQ(1U, worker_pool_params_a.max_threads()); |
EXPECT_EQ(base::TimeDelta::FromMilliseconds(42), |
- params_vector[0].suggested_reclaim_time()); |
- EXPECT_EQ(base::SchedulerBackwardCompatibility::DISABLED, |
- params_vector[0].backward_compatibility()); |
- |
- EXPECT_EQ("BackgroundFileIO", params_vector[1].name()); |
- EXPECT_EQ(ThreadPriority::BACKGROUND, params_vector[1].priority_hint()); |
- EXPECT_EQ(StandbyThreadPolicy::ONE, params_vector[1].standby_thread_policy()); |
- EXPECT_EQ(2U, params_vector[1].max_threads()); |
- EXPECT_EQ(base::TimeDelta::FromMilliseconds(52), |
- params_vector[1].suggested_reclaim_time()); |
+ worker_pool_params_a.suggested_reclaim_time()); |
EXPECT_EQ(base::SchedulerBackwardCompatibility::DISABLED, |
- params_vector[1].backward_compatibility()); |
+ worker_pool_params_a.backward_compatibility()); |
- EXPECT_EQ("Foreground", params_vector[2].name()); |
- EXPECT_EQ(ThreadPriority::NORMAL, params_vector[2].priority_hint()); |
- EXPECT_EQ(StandbyThreadPolicy::ONE, params_vector[2].standby_thread_policy()); |
- EXPECT_EQ(4U, params_vector[2].max_threads()); |
- EXPECT_EQ(base::TimeDelta::FromMilliseconds(62), |
- params_vector[2].suggested_reclaim_time()); |
- EXPECT_EQ(base::SchedulerBackwardCompatibility::DISABLED, |
- params_vector[2].backward_compatibility()); |
- |
- EXPECT_EQ("ForegroundFileIO", params_vector[3].name()); |
- EXPECT_EQ(ThreadPriority::NORMAL, params_vector[3].priority_hint()); |
- EXPECT_EQ(StandbyThreadPolicy::ONE, params_vector[3].standby_thread_policy()); |
- EXPECT_EQ(8U, params_vector[3].max_threads()); |
+ const auto worker_pool_params_b = StringToWorkerPoolParams( |
+ "8;8;1;0;72", SchedulerBackwardCompatibility::ENABLED); |
+ EXPECT_EQ(StandbyThreadPolicy::ONE, |
+ worker_pool_params_b.standby_thread_policy()); |
+ EXPECT_EQ(8U, worker_pool_params_b.max_threads()); |
EXPECT_EQ(base::TimeDelta::FromMilliseconds(72), |
- params_vector[3].suggested_reclaim_time()); |
+ worker_pool_params_b.suggested_reclaim_time()); |
EXPECT_EQ(base::SchedulerBackwardCompatibility::INIT_COM_STA, |
- params_vector[3].backward_compatibility()); |
+ worker_pool_params_b.backward_compatibility()); |
} |
TEST_F(TaskSchedulerUtilVariationsUtilTest, OrderingParams6) { |
- std::map<std::string, std::string> variation_params; |
- variation_params["Background"] = "1;1;1;0;42;lazy"; |
- variation_params["BackgroundFileIO"] = "2;2;1;0;52;one"; |
- variation_params["Foreground"] = "4;4;1;0;62;lazy"; |
- variation_params["ForegroundFileIO"] = "8;8;1;0;72;one"; |
- |
- auto params_vector = |
- GetWorkerPoolParams(GetImmutableWorkerPoolParams(), variation_params); |
- ASSERT_EQ(4U, params_vector.size()); |
- |
- EXPECT_EQ("Background", params_vector[0].name()); |
- EXPECT_EQ(ThreadPriority::BACKGROUND, params_vector[0].priority_hint()); |
+ const auto worker_pool_params_a = StringToWorkerPoolParams( |
+ "1;1;1;0;42;lazy", SchedulerBackwardCompatibility::DISABLED); |
EXPECT_EQ(StandbyThreadPolicy::LAZY, |
- params_vector[0].standby_thread_policy()); |
- EXPECT_EQ(1U, params_vector[0].max_threads()); |
+ worker_pool_params_a.standby_thread_policy()); |
+ EXPECT_EQ(1U, worker_pool_params_a.max_threads()); |
EXPECT_EQ(base::TimeDelta::FromMilliseconds(42), |
- params_vector[0].suggested_reclaim_time()); |
+ worker_pool_params_a.suggested_reclaim_time()); |
EXPECT_EQ(base::SchedulerBackwardCompatibility::DISABLED, |
- params_vector[0].backward_compatibility()); |
+ worker_pool_params_a.backward_compatibility()); |
- EXPECT_EQ("BackgroundFileIO", params_vector[1].name()); |
- EXPECT_EQ(ThreadPriority::BACKGROUND, params_vector[1].priority_hint()); |
- EXPECT_EQ(StandbyThreadPolicy::ONE, params_vector[1].standby_thread_policy()); |
- EXPECT_EQ(2U, params_vector[1].max_threads()); |
- EXPECT_EQ(base::TimeDelta::FromMilliseconds(52), |
- params_vector[1].suggested_reclaim_time()); |
- EXPECT_EQ(base::SchedulerBackwardCompatibility::DISABLED, |
- params_vector[1].backward_compatibility()); |
- |
- EXPECT_EQ("Foreground", params_vector[2].name()); |
- EXPECT_EQ(ThreadPriority::NORMAL, params_vector[2].priority_hint()); |
- EXPECT_EQ(StandbyThreadPolicy::LAZY, |
- params_vector[2].standby_thread_policy()); |
- EXPECT_EQ(4U, params_vector[2].max_threads()); |
- EXPECT_EQ(base::TimeDelta::FromMilliseconds(62), |
- params_vector[2].suggested_reclaim_time()); |
- EXPECT_EQ(base::SchedulerBackwardCompatibility::DISABLED, |
- params_vector[2].backward_compatibility()); |
- |
- EXPECT_EQ("ForegroundFileIO", params_vector[3].name()); |
- EXPECT_EQ(ThreadPriority::NORMAL, params_vector[3].priority_hint()); |
- EXPECT_EQ(StandbyThreadPolicy::ONE, params_vector[3].standby_thread_policy()); |
- EXPECT_EQ(8U, params_vector[3].max_threads()); |
+ const auto worker_pool_params_b = StringToWorkerPoolParams( |
+ "8;8;1;0;72;one", SchedulerBackwardCompatibility::ENABLED); |
+ EXPECT_EQ(StandbyThreadPolicy::ONE, |
+ worker_pool_params_b.standby_thread_policy()); |
+ EXPECT_EQ(8U, worker_pool_params_b.max_threads()); |
EXPECT_EQ(base::TimeDelta::FromMilliseconds(72), |
- params_vector[3].suggested_reclaim_time()); |
+ worker_pool_params_b.suggested_reclaim_time()); |
EXPECT_EQ(base::SchedulerBackwardCompatibility::INIT_COM_STA, |
- params_vector[3].backward_compatibility()); |
-} |
- |
-TEST_F(TaskSchedulerUtilVariationsUtilTest, NoData) { |
- EXPECT_TRUE(GetWorkerPoolParams(GetImmutableWorkerPoolParams(), |
- std::map<std::string, std::string>()) |
- .empty()); |
+ worker_pool_params_b.backward_compatibility()); |
} |
TEST_F(TaskSchedulerUtilVariationsUtilTest, IncompleteParameters) { |
- std::map<std::string, std::string> variation_params; |
- variation_params["Background"] = "1;1;1;0"; |
- variation_params["BackgroundFileIO"] = "2;2;1;0"; |
- variation_params["Foreground"] = "4;4;1;0"; |
- variation_params["ForegroundFileIO"] = "8;8;1;0"; |
- EXPECT_TRUE( |
- GetWorkerPoolParams(GetImmutableWorkerPoolParams(), variation_params) |
- .empty()); |
+ EXPECT_FALSE(StringToWorkerPoolParams("1;1;1;0").IsValid()); |
} |
TEST_F(TaskSchedulerUtilVariationsUtilTest, InvalidParameters) { |
- std::map<std::string, std::string> variation_params; |
- variation_params["Background"] = "a;b;c;d;e"; |
- variation_params["BackgroundFileIO"] = "a;b;c;d;e"; |
- variation_params["Foreground"] = "a;b;c;d;e"; |
- variation_params["ForegroundFileIO"] = "a;b;c;d;e"; |
- EXPECT_TRUE( |
- GetWorkerPoolParams(GetImmutableWorkerPoolParams(), variation_params) |
- .empty()); |
+ EXPECT_FALSE(StringToWorkerPoolParams("a;b;c;d;e").IsValid()); |
} |
#if !defined(OS_IOS) |