freezer for cgroup v2
Subsystems (7)
v9 cover freezer for cgroup v2
This patchset implements freezer for cgroup v2.
It provides similar functionality as v1 freezer, but the interface conforms to the cgroup v2 interface design principles, and it provides a better user experience: tasks can be killed, ptrace works, there is no separate controller, which has to be enabled, etc.
Patches (1), (2) and (3) are some preparational work, patch (4) contains the implementation, patch (5) is a small cgroup kselftest fix, patch (6) covers freezer adds 6 new kselftests to cover the freezer functionality. Patchse (7) and (8) adding tracing points to simplify the debugging process. Patch (9) adds corresponding docs.
v9->v8:
- added support for vfork
- added a kselftest test for vfork case
- several tests fixes/improvements
- renamed stopped* into frozen* across the patchset
- added trace points
- other minor fixes
v8->v7:
- reworked/simplified cgroup frozen task accounting by merging nr_stopped and nr_frozen and removing nr_tasks_to_freeze
- don't notify the parent process if the child is going from the stopped to the frozen state
v7->v6:
- handle properly the case, when a task is both stopped and frozen
- check for CGRP_FREEZE instead of CGRP_FROZEN in cgroup_exit()
- minor cosmetic changes and rebase
v6->v5:
- reverted to clear TIF_SIGPENDING with additional checks before schedule(), as proposed by Oleg Nesterov
- made cgroup v2 freezer working with the system freezer (by using freezable_schedule())
- make freezer working with SIGSTOPped and PTRACEd tasks
- added tests to cover freezing a cgroup with SIGSTOPped and PTRACEd tasks
v5->v4:
- rewored cgroup state transition code (suggested by Tejun Heo)
- look at JOBCTL_TRAP_FREEZE instead of task->frozen in recalc_sigpending(), check for task->frozen and JOBCTL_TRAP_FREEZE in signal_pending_state() (suggested by Oleg Nesterov)
- some cosmetic changes in signal.c (suggested by Oleg Nesterov)
- cleaned up comments
v4->v3:
- reading nr_descendants doesn't require taking css_set_lock anymore
- fixed docs based on Mike Rapoport's feedback
- fixed double irq lock found by Dan Carpenter
v3->v2:
- dropped TASK_FROZEN for now, frozen tasks are put into TASK_INTERRUPTIBLE state; it's probably not the final version, but the API question can be discussed separately
- don't clear TIF_SIGPENDING before going to sleep, instead add task->frozen check in signal_pending_state() and recalc_sigpending()
- cgroup-level counter are now synchronized using css_set_lock, which simplified the whole code (e.g. per-cgroup works were removed)
- the amount of comments increased significantly
- many other improvements incorporating feedback from Tejun and Oleg
v2->v1:
- fixed locking aroung calling cgroup_freezer_leave()
- added docs
Roman Gushchin (9):
cgroup: rename freezer.c into legacy_freezer.c
cgroup: implement __cgroup_task_count() helper
cgroup: protect cgroup->nr_(dying_)descendants by css_set_lock
cgroup: cgroup v2 freezer
kselftests: cgroup: don't fail on cg_kill_all() error in cg_destroy()
kselftests: cgroup: add freezer controller self-tests
cgroup: make TRACE_CGROUP_PATH irq-safe
cgroup: add tracing points for cgroup v2 freezer
cgroup: document cgroup v2 freezer interface
Documentation/admin-guide/cgroup-v2.rst | 27 + include/linux/cgroup-defs.h | 33 + include/linux/cgroup.h | 43 + include/linux/sched.h | 2 + include/linux/sched/jobctl.h | 2 + include/trace/events/cgroup.h | 55 ++ kernel/cgroup/Makefile | 4 +- kernel/cgroup/cgroup-internal.h | 8 +- kernel/cgroup/cgroup-v1.c | 16 - kernel/cgroup/cgroup.c | 150 ++- kernel/cgroup/freezer.c | 640 +++++-------- kernel/cgroup/legacy_freezer.c | 481 ++++++++++ kernel/fork.c | 6 + kernel/signal.c | 75 +- tools/testing/selftests/cgroup/.gitignore | 1 + tools/testing/selftests/cgroup/Makefile | 2 + tools/testing/selftests/cgroup/cgroup_util.c | 58 +- tools/testing/selftests/cgroup/cgroup_util.h | 5 + tools/testing/selftests/cgroup/test_freezer.c | 851 ++++++++++++++++++ 19 files changed, 2028 insertions(+), 431 deletions(-) create mode 100644 kernel/cgroup/legacy_freezer.c create mode 100644 tools/testing/selftests/cgroup/test_freezer.c
Signature · 1 line
2.20.1
PATCH v9 1/9 cgroup: rename freezer.c into legacy_freezer.c
Freezer.c will contain an implementation of cgroup v2 freezer, so let's rename the v1 freezer to avoid naming conflicts.
---
kernel/cgroup/Makefile | 2 +-
kernel/cgroup/{freezer.c => legacy_freezer.c} | 0
2 files changed, 1 insertion(+), 1 deletion(-)
rename kernel/cgroup/{freezer.c => legacy_freezer.c} (100%)kernel/cgroup/Makefile +1 -1
@@ -1,7 +1,7 @@ # SPDX-License-Identifier: GPL-2.0 obj-y := cgroup.o rstat.o namespace.o cgroup-v1.o -obj-$(CONFIG_CGROUP_FREEZER) += freezer.o +obj-$(CONFIG_CGROUP_FREEZER) += legacy_freezer.o obj-$(CONFIG_CGROUP_PIDS) += pids.o obj-$(CONFIG_CGROUP_RDMA) += rdma.o obj-$(CONFIG_CPUSETS) += cpuset.o
kernel/cgroup/legacy_freezer.c renamed from kernel/cgroup/freezer.c +0 -0
Signature · 1 line
2.20.1
PATCH v9 2/9 cgroup: implement __cgroup_task_count() helper
In reply to Roman GushchinThe helper is identical to the existing cgroup_task_count() except it doesn't take the css_set_lock by itself, assuming that the caller does.
Also, move cgroup_task_count() implementation into kernel/cgroup/cgroup.c, as there is nothing specific to cgroup v1.
--- kernel/cgroup/cgroup-internal.h | 1 + kernel/cgroup/cgroup-v1.c | 16 ---------------- kernel/cgroup/cgroup.c | 33 +++++++++++++++++++++++++++++++++ 3 files changed, 34 insertions(+), 16 deletions(-)
kernel/cgroup/cgroup-internal.h +1 -0
@@ -226,6 +226,7 @@ int cgroup_rmdir(struct kernfs_node *kn);int cgroup_show_path (struct seq_file *sf,struct kernfs_node *kf_node,struct kernfs_root *kf_root); +int __cgroup_task_count (const struct cgroup *cgrp);int cgroup_task_count (const struct cgroup *cgrp);/*
kernel/cgroup/cgroup-v1.c +0 -16
@@ -339,22 +339,6 @@ static struct cgroup_pidlist *cgroup_pidlist_find_create(struct cgroup *cgrp,return l; } -/** -* cgroup_task_count - count the number of tasks in a cgroup. -* @cgrp: the cgroup in question -*/ -int cgroup_task_count (const struct cgroup *cgrp) -{ -int count =0 ; -struct cgrp_cset_link *link; - -spin_lock_irq (&css_set_lock); -list_for_each_entry (link, &cgrp->cset_links, cset_link) - count += link->cset->nr_tasks; -spin_unlock_irq (&css_set_lock); -return count; -} -/* * Load a cgroup's pidarray with either procs' tgids or tasks' pids */
kernel/cgroup/cgroup.c +33 -0
@@ -592,6 +592,39 @@ static void cgroup_get_live(struct cgroup *cgrp)css_get (&cgrp->self); } +/** +* __cgroup_task_count - count the number of tasks in a cgroup. The caller +* is responsible for taking the css_set_lock. +* @cgrp: the cgroup in question +*/ +int __cgroup_task_count (const struct cgroup *cgrp) +{ +int count =0 ; +struct cgrp_cset_link *link; + +lockdep_assert_held (&css_set_lock); + +list_for_each_entry (link, &cgrp->cset_links, cset_link) + count += link->cset->nr_tasks; + +return count; +} + +/** +* cgroup_task_count - count the number of tasks in a cgroup. +* @cgrp: the cgroup in question +*/ +int cgroup_task_count (const struct cgroup *cgrp) +{ +int count; + +spin_lock_irq (&css_set_lock); + count =__cgroup_task_count (cgrp); +spin_unlock_irq (&css_set_lock); + +return count; +} +struct cgroup_subsys_state *of_css (struct kernfs_open_file *of) {struct cgroup *cgrp = of->kn->parent->priv;
Signature · 1 line
2.20.1
PATCH v9 3/9 cgroup: protect cgroup->nr_(dying_)descendants by css_set_lock
In reply to Roman GushchinThe number of descendant cgroups and the number of dying descendant cgroups are currently synchronized using the cgroup_mutex.
The number of descendant cgroups will be required by the cgroup v2 freezer, which will use it to determine if a cgroup is frozen (depending on total number of descendants and number of frozen descendants). It's not always acceptable to grab the cgroup_mutex, especially from quite hot paths (e.g. exit()).
To avoid this, let's additionally synchronize these counters using the css_set_lock.
So, it's safe to read these counters with either cgroup_mutex or css_set_lock locked, and for changing both locks should be acquired.
--- include/linux/cgroup-defs.h | 5 +++++ kernel/cgroup/cgroup.c | 6 ++++++ 2 files changed, 11 insertions(+)
include/linux/cgroup-defs.h +5 -0
@@ -348,6 +348,11 @@ struct cgroup {* Dying cgroups are cgroups which were deleted by a user, * but are still existing because someone else is holding a reference. * max_descendants is a maximum allowed number of descent cgroups. +* +* nr_descendants and nr_dying_descendants are protected +* by cgroup_mutex and css_set_lock. It's fine to read them holding +* any of cgroup_mutex and css_set_lock; for writing both locks +* should be held. */ int nr_descendants;int nr_dying_descendants;
kernel/cgroup/cgroup.c +6 -0
@@ -4758,9 +4758,11 @@ static void css_release_work_fn(struct work_struct *work)if (cgroup_on_dfl (cgrp))cgroup_rstat_flush (cgrp); +spin_lock_irq (&css_set_lock);for (tcgrp =cgroup_parent (cgrp); tcgrp; tcgrp =cgroup_parent (tcgrp)) tcgrp->nr_dying_descendants--; +spin_unlock_irq (&css_set_lock);cgroup_idr_remove (&cgrp->root->cgroup_idr, cgrp->id); cgrp->id =-1 ;
@@ -4978,12 +4980,14 @@ static struct cgroup *cgroup_create(struct cgroup *parent)if (ret) goto out_psi_free; +spin_lock_irq (&css_set_lock);for (tcgrp = cgrp; tcgrp; tcgrp =cgroup_parent (tcgrp)) { cgrp->ancestor_ids[tcgrp->level] = tcgrp->id;if (tcgrp != cgrp) tcgrp->nr_descendants++; } +spin_unlock_irq (&css_set_lock);if (notify_on_release (parent))set_bit (CGRP_NOTIFY_ON_RELEASE , &cgrp->flags);
@@ -5268,10 +5272,12 @@ static int cgroup_destroy_locked(struct cgroup *cgrp)if (parent &&cgroup_is_threaded (cgrp)) parent->nr_threaded_children--; +spin_lock_irq (&css_set_lock);for (tcgrp =cgroup_parent (cgrp); tcgrp; tcgrp =cgroup_parent (tcgrp)) { tcgrp->nr_descendants--; tcgrp->nr_dying_descendants++; } +spin_unlock_irq (&css_set_lock);cgroup1_check_for_release (parent);
Signature · 1 line
2.20.1
PATCH v9 4/9 cgroup: cgroup v2 freezer
In reply to Roman GushchinCgroup v1 implements the freezer controller, which provides an ability to stop the workload in a cgroup and temporarily free up some resources (cpu, io, network bandwidth and, potentially, memory) for some other tasks. Cgroup v2 lacks this functionality.
This patch implements freezer for cgroup v2.
Cgroup v2 freezer tries to put tasks into a state similar to jobctl stop. This means that tasks can be killed, ptraced (using PTRACE_SEIZE*), and interrupted. It is possible to attach to a frozen task, get some information (e.g. read registers) and detach. It's also possible to migrate a frozen tasks to another cgroup.
This differs cgroup v2 freezer from cgroup v1 freezer, which mostly tried to imitate the system-wide freezer. However uninterruptible sleep is fine when all tasks are going to be frozen (hibernation case), it's not the acceptable state for some subset of the system.
Cgroup v2 freezer is not supporting freezing kthreads.
If a non-root cgroup contains kthread, the cgroup still can be frozen, but the kthread will remain running, the cgroup will be shown as non-frozen, and the notification will not be delivered.
* PTRACE_ATTACH is not working because non-fatal signal delivery is blocked in frozen state.
There are some interface differences between cgroup v1 and cgroup v2 freezer too, which are required to conform the cgroup v2 interface design principles:
1) There is no separate controller, which has to be turned on:
the functionality is always available and is represented by cgroup.freeze and cgroup.events cgroup control files.
2) The desired state is defined by the cgroup.freeze control file. Any hierarchical configuration is allowed.
3) The interface is asynchronous. The actual state is available using cgroup.events control file ("frozen" field). There are no dedicated transitional states.
4) It's allowed to make any changes with the cgroup hierarchy (create new cgroups, remove old cgroups, move tasks between cgroups) no matter if some cgroups are frozen.
--- include/linux/cgroup-defs.h | 28 ++++ include/linux/cgroup.h | 43 +++++ include/linux/sched.h | 2 + include/linux/sched/jobctl.h | 2 + kernel/cgroup/Makefile | 2 +- kernel/cgroup/cgroup.c | 109 +++++++++++- kernel/cgroup/freezer.c | 310 +++++++++++++++++++++++++++++++++++ kernel/fork.c | 6 + kernel/signal.c | 75 ++++++++- 9 files changed, 568 insertions(+), 9 deletions(-) create mode 100644 kernel/cgroup/freezer.c
include/linux/cgroup-defs.h +28 -0
@@ -64,6 +64,12 @@ enum {* specified at mount time and thus is implemented here. */ CGRP_CPUSET_CLONE_CHILDREN , + +/* Control group has to be frozen. */ +CGRP_FREEZE , + +/* Cgroup is frozen. */ + CGRP_FROZEN, };/* cgroup_root->flags */
@@ -316,6 +322,25 @@ struct cgroup_rstat_cpu {struct cgroup *updated_next;/* NULL iff not on the list */ }; +struct cgroup_freezer_state { +/* Should the cgroup and its descendants be frozen. */ +bool freeze; + +/* Should the cgroup actually be frozen? */ +int e_freeze; + +/* Fields below are protected by css_set_lock */ + +/* Number of frozen descendant cgroups */ +int nr_frozen_descendants; + +/* +* Number of tasks, which are counted as frozen: +* frozen, SIGSTOPped, and PTRACEd. +*/ +int nr_frozen_tasks; +}; +struct cgroup {/* self css with NULL ->ss, points back to this cgroup */ struct cgroup_subsys_state self;
@@ -452,6 +477,9 @@ struct cgroup {/* If there is block congestion on this cgroup. */ atomic_t congestion_count; +/* Used to store internal freezer state */ +struct cgroup_freezer_state freezer; +/* ids of the ancestors at each level including self */ int ancestor_ids[]; };
include/linux/cgroup.h +43 -0
47 lines not on this page · raw message
include/linux/sched.h +2 -0
@@ -733,6 +733,8 @@ struct task_struct {#ifdef CONFIG_CGROUPS /* disallow userland-initiated cgroup migration */ unsigned no_cgroup_migration:1; +/* task is frozen/stopped (used by the cgroup freezer) */ + unsigned frozen:1;#endif #ifdef CONFIG_BLK_CGROUP /* to be used once the psi infrastructure lands upstream. */
include/linux/sched/jobctl.h +2 -0
@@ -18,6 +18,7 @@ struct task_struct;#define JOBCTL_TRAP_NOTIFY_BIT 20/* trap for NOTIFY */ #define JOBCTL_TRAPPING_BIT 21/* switching to TRACED */ #define JOBCTL_LISTENING_BIT 22/* ptracer is listening for events */ +#define JOBCTL_TRAP_FREEZE_BIT 23/* trap for cgroup freezer */ #define JOBCTL_STOP_DEQUEUED (1UL << JOBCTL_STOP_DEQUEUED_BIT)#define JOBCTL_STOP_PENDING (1UL << JOBCTL_STOP_PENDING_BIT)
@@ -26,6 +27,7 @@ struct task_struct;#define JOBCTL_TRAP_NOTIFY (1UL << JOBCTL_TRAP_NOTIFY_BIT)#define JOBCTL_TRAPPING (1UL << JOBCTL_TRAPPING_BIT)#define JOBCTL_LISTENING (1UL << JOBCTL_LISTENING_BIT) +#define JOBCTL_TRAP_FREEZE (1UL << JOBCTL_TRAP_FREEZE_BIT)#define JOBCTL_TRAP_MASK (JOBCTL_TRAP_STOP | JOBCTL_TRAP_NOTIFY)#define JOBCTL_PENDING_MASK (JOBCTL_STOP_PENDING | JOBCTL_TRAP_MASK)
kernel/cgroup/Makefile +1 -1
@@ -1,5 +1,5 @@ # SPDX-License-Identifier: GPL-2.0 -obj-y := cgroup.o rstat.o namespace.o cgroup-v1.o +obj-y := cgroup.o rstat.o namespace.o cgroup-v1.o freezer.o obj-$(CONFIG_CGROUP_FREEZER) += legacy_freezer.o obj-$(CONFIG_CGROUP_PIDS) += pids.o
kernel/cgroup/cgroup.c +105 -4
163 lines not on this page · raw message
kernel/cgroup/freezer.c new file +310 -0
310 lines not on this page · raw message
kernel/fork.c +6 -0
@@ -912,6 +912,10 @@ static struct task_struct *dup_task_struct(struct task_struct *orig, int node) tsk->fail_nth =0 ;#endif +#ifdef CONFIG_CGROUPS + tsk->frozen =0 ; +#endif +#ifdef CONFIG_BLK_CGROUP tsk->throttle_queue =NULL ; tsk->use_memdelay =0 ;
@@ -1223,7 +1227,9 @@ static int wait_for_vfork_done(struct task_struct *child,int killed;freezer_do_not_count (); +cgroup_enter_frozen (); killed =wait_for_completion_killable (vfork); +cgroup_leave_frozen (false);freezer_count ();if (killed) {
kernel/signal.c +71 -4
114 lines not on this page · raw message
Signature · 1 line
2.20.1
Re: [PATCH v9 4/9] cgroup: cgroup v2 freezer
Hi Roman,
let me apologize again for the huge delay.
I see nothing really wrong in this version, so no objections from me.
However, 4/9 doesn't apply, so it seems you will need to make v10 anyway to adapt these changes to the recent changes in kernel/signal.c ;)
Just a couple of minor nits below...
Quoted 11 lines · Roman Gushchin
+ * If
always_leaveis not set, and the cgroup is freezing,
+ * we're racing with the cgroup freezing. In this case, we don't
+ * drop the frozen counter to avoid a transient switch to
+ * the unfrozen state. To make sure that the task won't go
+ * to the userspace before reaching the signal handler loop,
+ * let's setTIF_SIGPENDINGflag.
+ */kernel/cgroup/freezer.c new file +3
-0+void cgroup_leave_frozen (bool always_leave) +{ +struct cgroup *cgrp;
kernel/cgroup/freezer.c line 140
Quoted 10 lines
kernel/cgroup/freezer.c new file +10
-0+ +spin_lock_irq (&css_set_lock); + cgrp =task_dfl_cgroup (current); +if (always_leave || !test_bit (CGRP_FREEZE , &cgrp->flags)) { +cgroup_dec_frozen_cnt (cgrp); +cgroup_update_frozen (cgrp); +WARN_ON_ONCE (!current->frozen); + current->frozen = false; + }else { +set_tsk_thread_flag (current,TIF_SIGPENDING );
The setting of TIF_SIGPENDING looks unnecessary and even not correct; because this flag must not be updated without ->siglock held (even if "set" is more or less safe).
If JOBCTL_TRAP_FREEZE is already set, then TIF_SIGPENDING must be set too.
Otherwise set_tsk_thread_flag(TIF_SIGPENDING) can't help because the task can do recalc_sigpending() at any moment.
In particular, get_signal() does dequeue_signal()->recalc_sigpending() right after cgroup_leave_frozen(), so I fail to understand why do we need to set TIF_SIGPENDING.
kernel/fork.c static struct task_struct *dup_task_struct(struct task_struct *orig, int node) · line 917
Quoted 7 lines
kernel/fork.c +3
-0@@ -912,6 +912,10 @@ static struct task_struct *dup_task_struct(struct task_struct *orig, int node) tsk->fail_nth =0 ;#endif +#ifdef CONFIG_CGROUPS + tsk->frozen =0 ; +#endif
Hmm, do we really need this? How can a cgroup_task_frozen() task call copy_process() ?
Quoted 12 lines
kernel/signal.c +12
-0+static void do_freezer_trap (void ) + __releases(¤t->sighand->siglock) +{ +/* +* If a fatal signal is pending, there is no way back for the process, +* so let it escape from the freezer trap and exit. +* If the task has been frozen, cgroup_leave_frozen() will be invoked +* to update the cgroup state, if necessary. +*/ +if (fatal_signal_pending (current)) { + current->jobctl &= ~JOBCTL_TRAP_FREEZE ; +spin_unlock_irq (¤t->sighand->siglock);
kernel/signal.c static void do_jobctl_trap(void) · line 2326
Quoted 10 lines
kernel/signal.c +10
-0+return ; + } + +/* +* If there are other trap bits pending except JOBCTL_TRAP_FREEZE, +* let's make another loop to give it a chance to be handled. +* In any case, we'll return back. +*/ +if (((current->jobctl & (JOBCTL_PENDING_MASK |JOBCTL_TRAP_FREEZE )) != +JOBCTL_TRAP_FREEZE ) ||fatal_signal_pending (current)) {
^^^^^^^^^^^^^^^^^^^^
We have already checked fatal_signal_pending() at the start?
And in fact, you can probably remove fatal_signal_pending() altogether... Note that with recent changes get_signal() does
if (signal_group_exit(signal)) {
ksig->info.si_signo = signr = SIGKILL;
sigdelset(¤t->pending.signal, SIGKILL);
recalc_sigpending();
goto fatal;
}before the main loop, so afaics fatal_signal_pending() == T in do_freezer_trap() is simply impossible. This means that you can't clear JOBCTL_TRAP_FREEZE, but this is probably fine... if not, you can add jobctl &= ~JOBCTL_TRAP_FREEZE into the "if (signal_group_exit(signal))" above.
Quoted 16 lines
kernel/signal.c +8
-3@@ -2401,12 +2453,27 @@ bool get_signal(struct ksignal *ksig) do_signal_stop(0)) goto relock; -if (unlikely (current->jobctl &JOBCTL_TRAP_MASK )) { -do_jobctl_trap (); -spin_unlock_irq (&sighand->siglock); +if (unlikely (current->jobctl & + (JOBCTL_TRAP_MASK |JOBCTL_TRAP_FREEZE ))) { +if (current->jobctl &JOBCTL_TRAP_MASK ) { +do_jobctl_trap (); +spin_unlock_irq (&sighand->siglock); + }else if (current->jobctl &JOBCTL_TRAP_FREEZE ) +do_freezer_trap (); + goto relock;
kernel/signal.c bool get_signal(struct ksignal *ksig) · line 2474
Quoted 10 lines
kernel/signal.c +8
-0} +/* +* If the task is leaving the frozen state, let's update +* cgroup counters and reset the frozen bit. +*/ +if (unlikely (cgroup_task_frozen (current))) { +spin_unlock_irq (&sighand->siglock); +cgroup_leave_frozen (true); +spin_lock_irq (&sighand->siglock);
I'd suggest to do "goto relock" rather than spin_lock_irq(&sighand->siglock). To ensure we can't miss SIGKILL which can come right after we drop siglock, note again the new signal_group_exit() check above.
Oleg.
Re: [PATCH v9 4/9] cgroup: cgroup v2 freezer
Hi Oleg,
Thank you very much for your time! Really appreciate it.
I'll rebase the patchset, address your comments and send v10 soon-ish.
Please, find some notes below.
Quoted 38 lines · Oleg Nesterov
Hi Roman,
let me apologize again for the huge delay.
I see nothing really wrong in this version, so no objections from me.
However, 4/9 doesn't apply, so it seems you will need to make v10 anyway to adapt these changes to the recent changes in
kernel/signal.c;)Just a couple of minor nits below...
Quoted 11 lines · Roman Gushchin
+ * If
always_leaveis not set, and the cgroup is freezing,
+ * we're racing with the cgroup freezing. In this case, we don't
+ * drop the frozen counter to avoid a transient switch to
+ * the unfrozen state. To make sure that the task won't go
+ * to the userspace before reaching the signal handler loop,
+ * let's setTIF_SIGPENDINGflag.
+ */kernel/cgroup/freezer.c new file +3
-0+void cgroup_leave_frozen (bool always_leave) +{ +struct cgroup *cgrp;kernel/cgroup/freezer.c line 140
Quoted 10 lines
kernel/cgroup/freezer.c new file +10
-0+ +spin_lock_irq (&css_set_lock); + cgrp =task_dfl_cgroup (current); +if (always_leave || !test_bit (CGRP_FREEZE , &cgrp->flags)) { +cgroup_dec_frozen_cnt (cgrp); +cgroup_update_frozen (cgrp); +WARN_ON_ONCE (!current->frozen); + current->frozen = false; + }else { +set_tsk_thread_flag (current,TIF_SIGPENDING );The setting of
TIF_SIGPENDINGlooks unnecessary and even not correct; because this flag must not be updated without ->siglock held (even if "set" is more or less safe).
Quoted 8 lines
If
JOBCTL_TRAP_FREEZEis already set, thenTIF_SIGPENDINGmust be set too.Otherwise
set_tsk_thread_flag(TIF_SIGPENDING)can't help because the task can dorecalc_sigpending()at any moment.In particular,
get_signal()does dequeue_signal()->recalc_sigpending() right aftercgroup_leave_frozen(), so I fail to understand why do we need to setTIF_SIGPENDING.
So this "else" part is only for vfork path. What I'm trying to do, is to avoid flipping the cgroup state from frozen to unfrozen and back to frozen.
You're right, TIF_SIGPENDING isn't enough, we need proper cgroup_freeze_task() with some additional synchronization.
Quoted 6 lines
Quoted 6 lines
kernel/fork.c +0
-0@@ -912,6 +912,10 @@ static struct task_struct *dup_task_struct(struct task_struct *orig, int node) tsk->fail_nth =0 ;#endif
Quoted 6 lines
kernel/fork.c static struct task_struct *dup_task_struct(struct task_struct *orig, int node) · line 917
Quoted 3 lines
kernel/fork.c +3
-0+#ifdef CONFIG_CGROUPS + tsk->frozen =0 ; +#endif Hmm, do we really need this? How can a
cgroup_task_frozen()task callcopy_process()?
We shouldn't, but let me double check it.
Quoted 25 lines
Quoted 13 lines
kernel/signal.c +12
-0+static void do_freezer_trap (void ) + __releases(¤t->sighand->siglock) +{ +/* +* If a fatal signal is pending, there is no way back for the process, +* so let it escape from the freezer trap and exit. +* If the task has been frozen, cgroup_leave_frozen() will be invoked +* to update the cgroup state, if necessary. +*/ +if (fatal_signal_pending (current)) { + current->jobctl &= ~JOBCTL_TRAP_FREEZE ; +spin_unlock_irq (¤t->sighand->siglock);kernel/signal.c static void do_jobctl_trap(void) · line 2326
Quoted 10 lines
kernel/signal.c +10
-0+return ; + } + +/* +* If there are other trap bits pending except JOBCTL_TRAP_FREEZE, +* let's make another loop to give it a chance to be handled. +* In any case, we'll return back. +*/ +if (((current->jobctl & (JOBCTL_PENDING_MASK |JOBCTL_TRAP_FREEZE )) != +JOBCTL_TRAP_FREEZE ) ||fatal_signal_pending (current)) {^^^^^^^^^^^^^^^^^^^^
Quoted 1 line
We have already checked
fatal_signal_pending()at the start?
Yeah, I'll remove the second call. Thanks!
Quoted 11 lines
And in fact, you can probably remove
fatal_signal_pending()altogether... Note that with recent changesget_signal()doesif (signal_group_exit(signal)) { ksig->info.si_signo = signr = SIGKILL; sigdelset(¤t->pending.signal, SIGKILL); recalc_sigpending(); goto fatal; }
Quoted 4 lines
before the main loop, so afaics
fatal_signal_pending()== T indo_freezer_trap()is simply impossible. This means that you can't clearJOBCTL_TRAP_FREEZE, but this is probably fine... if not, you can add jobctl &= ~JOBCTL_TRAP_FREEZE into the "if (signal_group_exit(signal))" above.
I'll try.
Quoted 19 lines
Quoted 19 lines
kernel/signal.c +8
-3@@ -2401,12 +2453,27 @@ bool get_signal(struct ksignal *ksig) do_signal_stop(0)) goto relock; -if (unlikely (current->jobctl &JOBCTL_TRAP_MASK )) { -do_jobctl_trap (); -spin_unlock_irq (&sighand->siglock); +if (unlikely (current->jobctl & + (JOBCTL_TRAP_MASK |JOBCTL_TRAP_FREEZE ))) { +if (current->jobctl &JOBCTL_TRAP_MASK ) { +do_jobctl_trap (); +spin_unlock_irq (&sighand->siglock); + }else if (current->jobctl &JOBCTL_TRAP_FREEZE ) +do_freezer_trap (); + goto relock; }
Quoted 12 lines
kernel/signal.c bool get_signal(struct ksignal *ksig) · line 2474
Quoted 8 lines
kernel/signal.c +8
-0+/* +* If the task is leaving the frozen state, let's update +* cgroup counters and reset the frozen bit. +*/ +if (unlikely (cgroup_task_frozen (current))) { +spin_unlock_irq (&sighand->siglock); +cgroup_leave_frozen (true); +spin_lock_irq (&sighand->siglock);I'd suggest to do "goto relock" rather than
spin_lock_irq(&sighand->siglock). To ensure we can't miss SIGKILL which can come right after we drop siglock, note again the newsignal_group_exit()check above.
Sure, will switch to "goto relock".
Thank you!
Roman
PATCH v9 5/9 kselftests: cgroup: don't fail on cg_kill_all() error in cg_destroy()
In reply to Roman GushchinIf the cgroup destruction races with an exit() of a belonging process(es), cg_kill_all() may fail. It's not a good reason to make cg_destroy() fail and leave the cgroup in place, potentially causing next test runs to fail.
--- tools/testing/selftests/cgroup/cgroup_util.c | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-)
tools/testing/selftests/cgroup/cgroup_util.c +1 -3
@@ -227,9 +227,7 @@ int cg_destroy(const char *cgroup) retry: ret =rmdir (cgroup);if (ret && errno ==EBUSY ) { - ret =cg_killall (cgroup); -if (ret) -return ret; +cg_killall (cgroup);usleep (100 ); goto retry; }
Signature · 1 line
2.20.1
PATCH v9 6/9 kselftests: cgroup: add freezer controller self-tests
In reply to Roman GushchinThis patch implements 9 tests for the freezer controller for cgroup v2:
1) a simple test, which aims to freeze and unfreeze a cgroup with 100 processes
2) a more complicated tree test, which creates a hierarchy of cgroups, puts some processes in some cgroups, and tries to freeze and unfreeze different parts of the subtree
3) a forkbomb test: the test aims to freeze a forkbomb running in a cgroup, kill all tasks in the cgroup and remove the cgroup without the unfreezing.
4) rmdir test: the test creates two nested cgroups, freezes the parent one, checks that the child can be successfully removed, and a new child can be created
5) migration tests: the test checks migration of a task between frozen cgroups: from a frozen to a running, from a running to a frozen, and from a frozen to a frozen.
6) ptrace test: the test checks that it's possible to attach to a process in a frozen cgroup, get some information and detach, and the cgroup will remain frozen.
7) stopped test: the test checks that it's possible to freeze a cgroup with a stopped task
8) ptraced test: the test checks that it's possible to freeze a cgroup with a ptraced task
9) vfork test: the test checks that it's possible to freeze a cgroup with a parent process waiting for the child process in vfork()
Expected output:
$ ./test_freezer ok 1 test_cgfreezer_simple ok 2 test_cgfreezer_tree ok 3 test_cgfreezer_forkbomb ok 4 test_cgrreezer_rmdir ok 5 test_cgfreezer_migrate ok 6 test_cgfreezer_ptrace ok 7 test_cgfreezer_stopped ok 8 test_cgfreezer_ptraced ok 9 test_cgfreezer_vfork
--- tools/testing/selftests/cgroup/.gitignore | 1 + tools/testing/selftests/cgroup/Makefile | 2 + tools/testing/selftests/cgroup/cgroup_util.c | 54 +- tools/testing/selftests/cgroup/cgroup_util.h | 5 + tools/testing/selftests/cgroup/test_freezer.c | 851 ++++++++++++++++++ 5 files changed, 912 insertions(+), 1 deletion(-) create mode 100644 tools/testing/selftests/cgroup/test_freezer.c
tools/testing/selftests/cgroup/.gitignore +1 -0
@@ -1,2 +1,3 @@ test_memcontrol test_core +test_freezer
tools/testing/selftests/cgroup/Makefile +2 -0
@@ -5,8 +5,10 @@ all: TEST_GEN_PROGS = test_memcontrol TEST_GEN_PROGS += test_core +TEST_GEN_PROGS += test_freezer include ../lib.mk $(OUTPUT)/test_memcontrol: cgroup_util.c $(OUTPUT)/test_core: cgroup_util.c +$(OUTPUT)/test_freezer: cgroup_util.c
tools/testing/selftests/cgroup/cgroup_util.c +53 -1
75 lines not on this page · raw message
tools/testing/selftests/cgroup/cgroup_util.h +5 -0
@@ -18,6 +18,7 @@ static inline int values_close(long a, long b, int err)extern int cg_find_unified_root (char *root,size_t len);extern char *cg_name (const char *root,const char *name);extern char *cg_name_indexed (const char *root,const char *name,int index); +extern char *cg_control (const char *cgroup,const char *control);extern int cg_create (const char *cgroup);extern int cg_destroy (const char *cgroup); extern int cg_read(const char *cgroup, const char *control,
@@ -32,6 +33,7 @@ extern int cg_write(const char *cgroup, const char *control, char *buf);extern int cg_run (const char *cgroup,int (*fn)(const char *cgroup,void *arg),void *arg); +extern int cg_enter (const char *cgroup,int pid);extern int cg_enter_current (const char *cgroup); extern int cg_run_nowait(const char *cgroup, int (*fn)(const char *cgroup, void *arg),
@@ -41,3 +43,6 @@ extern int alloc_pagecache(int fd, size_t size);extern int alloc_anon (const char *cgroup,void *arg);extern int is_swap_enabled (void );extern int set_oom_adj_score (int pid,int score); +extern int cg_wait_for_proc_count (const char *cgroup,int count); +extern int cg_killall (const char *cgroup); +extern char proc_read_text (int pid,const char *item,char *buf,size_t size);
tools/testing/selftests/cgroup/test_freezer.c new file +851 -0
851 lines not on this page · raw message
Signature · 1 line
2.20.1
PATCH v9 7/9 cgroup: make TRACE_CGROUP_PATH irq-safe
In reply to Roman GushchinTo use the TRACE_CGROUP_PATH() macro with css_set_lock locked, let's make the macro irq-safe.
It's necessary in order to trace cgroup freezer state transitions (frozen/not frozen), which are happening with css_set_lock locked.
--- kernel/cgroup/cgroup-internal.h | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-)
kernel/cgroup/cgroup-internal.h +5 -2
@@ -27,12 +27,15 @@ extern void __init enable_debug_cgroup(void);#define TRACE_CGROUP_PATH (type, cgrp, ...) \ do { \ if (trace_cgroup_##type##_enabled()) { \ - spin_lock(&trace_cgroup_path_lock); \ + unsigned long flags; \ + spin_lock_irqsave(&trace_cgroup_path_lock, \ + flags); \ cgroup_path(cgrp, trace_cgroup_path, \ TRACE_CGROUP_PATH_LEN); \ trace_cgroup_##type(cgrp, trace_cgroup_path, \ ##__VA_ARGS__); \ - spin_unlock(&trace_cgroup_path_lock); \ + spin_unlock_irqrestore(&trace_cgroup_path_lock, \ + flags); \ } \ } while (0)
Signature · 1 line
2.20.1
PATCH v9 8/9 cgroup: add tracing points for cgroup v2 freezer
In reply to Roman GushchinAdd cgroup:cgroup_freeze and cgroup:cgroup_unfreeze events, which are using the existing cgroup tracing infrastructure.
Add the cgroup_event event class, which is similar to the cgroup class, but contains an additional integer field to store a new value (the level field is dropped).
Also add two tracing events: cgroup_notify_populated and cgroup_notify_frozen, which are raised in a generic way using the TRACE_CGROUP_PATH() macro.
This allows to trace cgroup state transitions and is generally helpful for debugging the cgroup freezer code.
--- include/trace/events/cgroup.h | 55 +++++++++++++++++++++++++++++++++++ kernel/cgroup/cgroup.c | 2 ++ kernel/cgroup/freezer.c | 15 +++++++++- 3 files changed, 71 insertions(+), 1 deletion(-)
include/trace/events/cgroup.h +55 -0
@@ -103,6 +103,20 @@ DEFINE_EVENT(cgroup, cgroup_rename,TP_ARGS (cgrp, path) ); +DEFINE_EVENT (cgroup, cgroup_freeze, + + TP_PROTO(struct cgroup *cgrp, const char *path), + +TP_ARGS (cgrp, path) +); + +DEFINE_EVENT (cgroup, cgroup_unfreeze, + + TP_PROTO(struct cgroup *cgrp, const char *path), + +TP_ARGS (cgrp, path) +); + DECLARE_EVENT_CLASS(cgroup_migrate, TP_PROTO(struct cgroup *dst_cgrp, const char *path,
@@ -149,6 +163,47 @@ DEFINE_EVENT(cgroup_migrate, cgroup_transfer_tasks,TP_ARGS (dst_cgrp, path, task, threadgroup) ); +DECLARE_EVENT_CLASS (cgroup_event, + + TP_PROTO(struct cgroup *cgrp, const char *path, int val), + +TP_ARGS (cgrp, path, val), + +TP_STRUCT__entry ( + __field( int, root ) + __field( int, id ) + __field( int, level ) + __string( path, path ) +__field ( int, val ) + ), + +TP_fast_assign ( + __entry->root = cgrp->root->hierarchy_id; + __entry->id = cgrp->id; + __entry->level = cgrp->level; + __assign_str(path, path); + __entry->val = val; + ), + +TP_printk ("root=%d id=%d level=%d path=%s val=%d" , + __entry->root, __entry->id, __entry->level,__get_str (path), + __entry->val) +); + +DEFINE_EVENT (cgroup_event, cgroup_notify_populated, + + TP_PROTO(struct cgroup *cgrp, const char *path, int val), + +TP_ARGS (cgrp, path, val) +); + +DEFINE_EVENT (cgroup_event, cgroup_notify_frozen, + + TP_PROTO(struct cgroup *cgrp, const char *path, int val), + +TP_ARGS (cgrp, path, val) +); +#endif /* _TRACE_CGROUP_H */ /* This part must be outside protection */
kernel/cgroup/cgroup.c +2 -0
@@ -815,6 +815,8 @@ static void cgroup_update_populated(struct cgroup *cgrp, bool populated)break ;cgroup1_check_for_release (cgrp); +TRACE_CGROUP_PATH (notify_populated, cgrp, +cgroup_is_populated (cgrp));cgroup_file_notify (&cgrp->events_file); child = cgrp;
kernel/cgroup/freezer.c +14 -1
@@ -6,6 +6,8 @@#include "cgroup-internal.h" +#include <trace/events/cgroup.h> +/* * Propagate the cgroup frozen state upwards by the cgroup tree. */
@@ -28,6 +30,7 @@ static void cgroup_propagate_frozen(struct cgroup *cgrp, bool frozen) cgrp->nr_descendants) {set_bit (CGRP_FROZEN , &cgrp->flags);cgroup_file_notify (&cgrp->events_file); +TRACE_CGROUP_PATH (notify_frozen, cgrp,1 ); desc++; } }else {
@@ -35,6 +38,7 @@ static void cgroup_propagate_frozen(struct cgroup *cgrp, bool frozen)if (test_bit (CGRP_FROZEN , &cgrp->flags)) {clear_bit (CGRP_FROZEN , &cgrp->flags);cgroup_file_notify (&cgrp->events_file); +TRACE_CGROUP_PATH (notify_frozen, cgrp,0 ); desc++; } }
@@ -73,6 +77,7 @@ void cgroup_update_frozen(struct cgroup *cgrp)clear_bit (CGRP_FROZEN , &cgrp->flags); }cgroup_file_notify (&cgrp->events_file); +TRACE_CGROUP_PATH (notify_frozen, cgrp, frozen);/* Update the state of ancestor cgroups. */ cgroup_propagate_frozen (cgrp, frozen);
@@ -182,6 +187,11 @@ static void cgroup_do_freeze(struct cgroup *cgrp, bool freeze)clear_bit (CGRP_FREEZE , &cgrp->flags);spin_unlock_irq (&css_set_lock); +if (freeze) +TRACE_CGROUP_PATH (freeze, cgrp); +else +TRACE_CGROUP_PATH (unfreeze, cgrp); +css_task_iter_start (&cgrp->self,0 , &it);while ((task =css_task_iter_next (&it))) {/*
@@ -305,6 +315,9 @@ void cgroup_freeze(struct cgroup *cgrp, bool freeze)* In both cases it's better to notify a user, that there is * nothing to wait for. */ -if (!applied) +if (!applied) { +TRACE_CGROUP_PATH (notify_frozen, cgrp, +test_bit (CGRP_FROZEN , &cgrp->flags));cgroup_file_notify (&cgrp->events_file); + } }
Signature · 1 line
2.20.1
PATCH v9 9/9 cgroup: document cgroup v2 freezer interface
In reply to Roman GushchinDescribe cgroup v2 freezer interface in the cgroup v2 admin guide.
--- Documentation/admin-guide/cgroup-v2.rst | 27 +++++++++++++++++++++++++ 1 file changed, 27 insertions(+)
Documentation/admin-guide/cgroup-v2.rst +27 -0
@@ -864,6 +864,8 @@ All cgroup core files are prefixed with "cgroup." populated 1 if the cgroup or its descendants contains any live processes; otherwise, 0. + frozen + 1 if the cgroup is frozen; otherwise, 0. cgroup.max.descendants A read-write single value files. The default is "max".
@@ -897,6 +899,31 @@ All cgroup core files are prefixed with "cgroup." A dying cgroup can consume system resources not exceeding limits, which were active at the moment of cgroup deletion. + cgroup.freeze + A read-write single value file which exists on non-root cgroups. + Allowed values are "0" and "1". The default is "0". + + Writing "1" to the file causes freezing of the cgroup and all + descendant cgroups. This means that all belonging processes will + be stopped and will not run until the cgroup will be explicitly + unfrozen. Freezing of the cgroup may take some time; when this action + is completed, the "frozen" value in the cgroup.events control file + will be updated to "1" and the corresponding notification will be + issued. + + A cgroup can be frozen either by its own settings, or by settings + of any ancestor cgroups. If any of ancestor cgroups is frozen, the + cgroup will remain frozen. + + Processes in the frozen cgroup can be killed by a fatal signal. + They also can enter and leave a frozen cgroup: either by an explicit + move by a user, or if freezing of the cgroup races with fork(). + If a process is moved to a frozen cgroup, it stops. If a process is + moved out of a frozen cgroup, it becomes running. + + Frozen status of a cgroup doesn't affect any cgroup tree operations: + it's possible to delete a frozen (and empty) cgroup, as well as + create new sub-cgroups. Controllers ===========
Signature · 1 line
2.20.1
Hello, Oleg!
Can you, please, take a look at the latest version of the patchset? I'd really appreciate it!
Thank you!
Roman
Quoted 20 lines · Roman Gushchin
This patchset implements freezer for cgroup v2.
It provides similar functionality as v1 freezer, but the interface conforms to the cgroup v2 interface design principles, and it provides a better user experience: tasks can be killed, ptrace works, there is no separate controller, which has to be enabled, etc.
Patches (1), (2) and (3) are some preparational work, patch (4) contains the implementation, patch (5) is a small cgroup kselftest fix, patch (6) covers freezer adds 6 new kselftests to cover the freezer functionality. Patchse (7) and (8) adding tracing points to simplify the debugging process. Patch (9) adds corresponding docs.
v9->v8:
- added support for vfork
- added a kselftest test for vfork case
- several tests fixes/improvements
- renamed stopped* into frozen* across the patchset
- added trace points
- other minor fixes