1
0
mirror of https://github.com/systemd/systemd synced 2025-10-04 11:14:45 +02:00

Compare commits

...

6 Commits

Author SHA1 Message Date
msizanoen
09928421ea core/cgroup: Properly handle aborting a pending freeze operation
We must thaw the cgroup even if cgroup.events/frozen=0 if a freeze
operation is in flight as it means the cgroup is already partially
frozen.

Fixes #37590.
Fixes #38337.

(cherry picked from commit 85d00912c0fa08c80785d18a6818e7d92d40743e)
(cherry picked from commit 4bf37df99c905d21cf0febde59190d885ad201dc)
2025-07-29 13:08:03 +02:00
Mike Yuan
71e09b0a4f core/unit: introduce unit_set_freezer_state, make logging consistent
Also, emit PropertiesChanged signal for FreezerState too.

Fixes #31115

(cherry picked from commit 0064290a54fe46047889d44b3215d04b60e77c17)
2025-07-29 13:08:03 +02:00
Mike Yuan
63703510d9 core/cgroup: skip freezer action wholly if current == objective
(cherry picked from commit a9dc19617943d1db4f137005f5e467188c66e5a9)
2025-07-29 13:08:03 +02:00
Mike Yuan
90753f7fb0 core/cgroup: replace hardcoded state set with freezer_state_finish()
This makes code simpler and more readable.

(cherry picked from commit 27344f9acf7b23225020cc4a2d63d5e10d35308f)
2025-07-29 13:08:03 +02:00
Mike Yuan
29d2e9c8fa core/unit: rename freezer "target" to "objective"
(cherry picked from commit f27f461b01926f08e9d1e88833b69b9b2ba4995c)
2025-07-29 13:08:03 +02:00
Mike Yuan
ee9d32dfcb core/cgroup: check CGroupRuntime.cgroup_path rather than _realized for freezer
The same check is used everywhere else.

(cherry picked from commit c97c79aded8d313237e0952062a2cce71fb88eb5)
2025-07-29 13:08:03 +02:00
3 changed files with 62 additions and 34 deletions

View File

@ -5123,7 +5123,8 @@ static int unit_cgroup_freezer_kernel_state(Unit *u, FreezerState *ret) {
int unit_cgroup_freezer_action(Unit *u, FreezerAction action) {
_cleanup_free_ char *path = NULL;
FreezerState target, current, next;
FreezerState current, next, objective;
bool action_in_progress = false;
int r;
assert(u);
@ -5133,25 +5134,32 @@ int unit_cgroup_freezer_action(Unit *u, FreezerAction action) {
if (!cg_freezer_supported())
return 0;
unit_next_freezer_state(u, action, &next, &target);
unit_next_freezer_state(u, action, &next, &objective);
CGroupRuntime *crt = unit_get_cgroup_runtime(u);
if (!crt || !crt->cgroup_realized) {
if (!crt || !crt->cgroup_path)
/* No realized cgroup = nothing to freeze */
u->freezer_state = freezer_state_finish(next);
return 0;
}
goto finish;
r = unit_cgroup_freezer_kernel_state(u, &current);
if (r < 0)
return r;
if (current == target)
next = freezer_state_finish(next);
else if (IN_SET(next, FREEZER_FROZEN, FREEZER_FROZEN_BY_PARENT, FREEZER_RUNNING)) {
/* We're transitioning into a finished state, which implies that the cgroup's
* current state already matches the target and thus we'd return 0. But, reality
* shows otherwise. This indicates that our freezer_state tracking has diverged
if (current == objective) {
if (objective == FREEZER_FROZEN)
goto finish;
/* Skip thaw only if no freeze operation was in flight */
if (IN_SET(u->freezer_state, FREEZER_RUNNING, FREEZER_THAWING))
goto finish;
} else
action_in_progress = true;
if (next == freezer_state_finish(next)) {
/* We're directly transitioning into a finished state, which in theory means that
* the cgroup's current state already matches the objective and thus we'd return 0.
* But, reality shows otherwise (such case would have been handled by current == objective
* branch above). This indicates that our freezer_state tracking has diverged
* from the real state of the cgroup, which can happen if someone meddles with the
* cgroup from underneath us. This really shouldn't happen during normal operation,
* though. So, let's warn about it and fix up the state to be valid */
@ -5165,22 +5173,25 @@ int unit_cgroup_freezer_action(Unit *u, FreezerAction action) {
next = FREEZER_FREEZING_BY_PARENT;
else if (next == FREEZER_RUNNING)
next = FREEZER_THAWING;
else
assert_not_reached();
}
r = cg_get_path(SYSTEMD_CGROUP_CONTROLLER, crt->cgroup_path, "cgroup.freeze", &path);
if (r < 0)
return r;
log_unit_debug(u, "Unit freezer state was %s, now %s.",
freezer_state_to_string(u->freezer_state),
freezer_state_to_string(next));
r = write_string_file(path, one_zero(target == FREEZER_FROZEN), WRITE_STRING_FILE_DISABLE_BUFFER);
r = write_string_file(path, one_zero(objective == FREEZER_FROZEN), WRITE_STRING_FILE_DISABLE_BUFFER);
if (r < 0)
return r;
u->freezer_state = next;
return target != current;
finish:
if (action_in_progress)
unit_set_freezer_state(u, next);
else
unit_set_freezer_state(u, freezer_state_finish(next));
return action_in_progress;
}
int unit_get_cpuset(Unit *u, CPUSet *cpus, const char *name) {

View File

@ -6188,26 +6188,26 @@ bool unit_can_isolate_refuse_manual(Unit *u) {
return unit_can_isolate(u) && !u->refuse_manual_start;
}
void unit_next_freezer_state(Unit *u, FreezerAction action, FreezerState *ret, FreezerState *ret_target) {
Unit *slice;
FreezerState curr, parent, next, tgt;
void unit_next_freezer_state(Unit *u, FreezerAction action, FreezerState *ret, FreezerState *ret_objective) {
FreezerState curr, parent, next, objective;
assert(u);
assert(IN_SET(action, FREEZER_FREEZE, FREEZER_PARENT_FREEZE,
FREEZER_THAW, FREEZER_PARENT_THAW));
assert(ret);
assert(ret_target);
assert(ret_objective);
/* This function determines the correct freezer state transitions for a unit
* given the action being requested. It returns the next state, and also the "target",
* given the action being requested. It returns the next state, and also the "objective",
* which is either FREEZER_FROZEN or FREEZER_RUNNING, depending on what actual state we
* ultimately want to achieve. */
curr = u->freezer_state;
slice = UNIT_GET_SLICE(u);
if (slice)
curr = u->freezer_state;
Unit *slice = UNIT_GET_SLICE(u);
if (slice)
parent = slice->freezer_state;
else
else
parent = FREEZER_RUNNING;
if (action == FREEZER_FREEZE) {
@ -6251,13 +6251,13 @@ void unit_next_freezer_state(Unit *u, FreezerAction action, FreezerState *ret, F
next = FREEZER_THAWING;
}
tgt = freezer_state_finish(next);
if (tgt == FREEZER_FROZEN_BY_PARENT)
tgt = FREEZER_FROZEN;
assert(IN_SET(tgt, FREEZER_RUNNING, FREEZER_FROZEN));
objective = freezer_state_finish(next);
if (objective == FREEZER_FROZEN_BY_PARENT)
objective = FREEZER_FROZEN;
assert(IN_SET(objective, FREEZER_RUNNING, FREEZER_FROZEN));
*ret = next;
*ret_target = tgt;
*ret_objective = objective;
}
bool unit_can_freeze(Unit *u) {
@ -6272,6 +6272,22 @@ bool unit_can_freeze(Unit *u) {
return UNIT_VTABLE(u)->freezer_action;
}
void unit_set_freezer_state(Unit *u, FreezerState state) {
assert(u);
assert(state >= 0);
assert(state < _FREEZER_STATE_MAX);
if (u->freezer_state == state)
return;
log_unit_debug(u, "Freezer state changed %s -> %s",
freezer_state_to_string(u->freezer_state), freezer_state_to_string(state));
u->freezer_state = state;
unit_add_to_dbus_queue(u);
}
void unit_frozen(Unit *u) {
assert(u);

View File

@ -1040,7 +1040,8 @@ bool unit_can_isolate_refuse_manual(Unit *u);
bool unit_can_freeze(Unit *u);
int unit_freezer_action(Unit *u, FreezerAction action);
void unit_next_freezer_state(Unit *u, FreezerAction a, FreezerState *ret, FreezerState *ret_tgt);
void unit_next_freezer_state(Unit *u, FreezerAction a, FreezerState *ret, FreezerState *ret_objective);
void unit_set_freezer_state(Unit *u, FreezerState state);
void unit_frozen(Unit *u);
void unit_thawed(Unit *u);