1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
// Copyright 2019 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chromeos/ash/components/scheduler_config/scheduler_configuration_manager.h"
#include <string>
#include "ash/constants/ash_features.h"
#include "ash/constants/ash_pref_names.h"
#include "ash/constants/ash_switches.h"
#include "base/command_line.h"
#include "base/functional/bind.h"
#include "base/metrics/field_trial_params.h"
#include "chromeos/ash/components/dbus/debug_daemon/debug_daemon_client.h"
#include "components/prefs/pref_registry_simple.h"
#include "components/prefs/pref_service.h"
#include "third_party/cros_system_api/dbus/debugd/dbus-constants.h"
namespace ash {
namespace {
constexpr base::FeatureParam<std::string> kSchedulerConfigurationParam{
&features::kSchedulerConfiguration, "config", ""};
} // namespace
SchedulerConfigurationManager::SchedulerConfigurationManager(
DebugDaemonClient* debug_daemon_client,
PrefService* local_state)
: debug_daemon_client_(debug_daemon_client) {
observer_.Init(local_state);
observer_.Add(
prefs::kSchedulerConfiguration,
base::BindRepeating(&SchedulerConfigurationManager::OnPrefChange,
base::Unretained(this)));
debug_daemon_client_->WaitForServiceToBeAvailable(
base::BindOnce(&SchedulerConfigurationManager::OnDebugDaemonReady,
weak_ptr_factory_.GetWeakPtr()));
}
SchedulerConfigurationManager::~SchedulerConfigurationManager() = default;
// static
void SchedulerConfigurationManager::RegisterLocalStatePrefs(
PrefRegistrySimple* registry) {
// Ideally the pref would be registered specifying the default provided via
// the feature parameter. This is unfortunately not possible though because
// the feature API initialization depends on the local state PrefService, so
// this function runs before feature parameters are available.
registry->RegisterStringPref(prefs::kSchedulerConfiguration, std::string());
}
std::optional<std::pair<bool, size_t>>
SchedulerConfigurationManager::GetLastReply() const {
return last_reply_;
}
void SchedulerConfigurationManager::OnDebugDaemonReady(bool service_is_ready) {
if (!service_is_ready) {
LOG(ERROR) << "Debug daemon unavailable";
return;
}
// Initialize the system.
debug_daemon_ready_ = true;
OnPrefChange();
}
void SchedulerConfigurationManager::OnPrefChange() {
// No point in calling debugd if it isn't ready yet. The ready callback will
// will call this function again to set the initial configuration.
if (!debug_daemon_ready_) {
return;
}
// Determine the effective configuration name.
std::string config_name;
PrefService* local_state = observer_.prefs();
std::string feature_param_value = kSchedulerConfigurationParam.Get();
std::string cmdline_default =
base::CommandLine::ForCurrentProcess()->GetSwitchValueASCII(
switches::kSchedulerConfigurationDefault);
// A user-set or policy-set configuration takes precedence.
if (local_state->HasPrefPath(prefs::kSchedulerConfiguration)) {
config_name = local_state->GetString(prefs::kSchedulerConfiguration);
} else if (!feature_param_value.empty()) {
// Next check for a Finch feature setting.
config_name = feature_param_value;
} else if (!cmdline_default.empty()) {
// Next, if Finch isn't set, see if the command line passed in a default.
config_name = cmdline_default;
} else {
// If nothing is found, default to core isolation scheduling. Note that
// only some kernels support core isolation. debugd checks for support and
// reverts to conservative if core isolation is unavailable.
config_name = debugd::scheduler_configuration::kCoreIsolationScheduler;
}
// NB: Also send an update when the config gets reset to let the system pick
// whatever default. Note that the value we read in this case will be the
// default specified on pref registration, e.g. empty string.
debug_daemon_client_->SetSchedulerConfigurationV2(
config_name,
/*lock_policy=*/false,
base::BindOnce(&SchedulerConfigurationManager::OnConfigurationSet,
weak_ptr_factory_.GetWeakPtr()));
}
void SchedulerConfigurationManager::OnConfigurationSet(
bool result,
size_t num_cores_disabled) {
last_reply_ = std::make_pair(result, num_cores_disabled);
if (result) {
VLOG(1) << num_cores_disabled << " logical CPU cores are disabled";
} else {
LOG(ERROR) << "Failed to update scheduler configuration";
}
for (Observer& obs : observer_list_)
obs.OnConfigurationSet(result, num_cores_disabled);
}
} // namespace ash
|
