cgroup.c 159.7 KB
Newer Older
1 2 3 4 5 6
/*
 *  Generic process-grouping system.
 *
 *  Based originally on the cpuset system, extracted by Paul Menage
 *  Copyright (C) 2006 Google, Inc
 *
7 8 9 10
 *  Notifications support
 *  Copyright (C) 2009 Nokia Corporation
 *  Author: Kirill A. Shutemov
 *
11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
 *  Copyright notices from the original cpuset code:
 *  --------------------------------------------------
 *  Copyright (C) 2003 BULL SA.
 *  Copyright (C) 2004-2006 Silicon Graphics, Inc.
 *
 *  Portions derived from Patrick Mochel's sysfs code.
 *  sysfs is Copyright (c) 2001-3 Patrick Mochel
 *
 *  2003-10-10 Written by Simon Derr.
 *  2003-10-22 Updates by Stephen Hemminger.
 *  2004 May-July Rework by Paul Jackson.
 *  ---------------------------------------------------
 *
 *  This file is subject to the terms and conditions of the GNU General Public
 *  License.  See the file COPYING in the main directory of the Linux
 *  distribution for more details.
 */

29 30
#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt

31
#include <linux/cgroup.h>
32
#include <linux/cred.h>
33
#include <linux/ctype.h>
34
#include <linux/errno.h>
35
#include <linux/init_task.h>
36 37
#include <linux/kernel.h>
#include <linux/list.h>
38
#include <linux/magic.h>
39 40 41 42
#include <linux/mm.h>
#include <linux/mutex.h>
#include <linux/mount.h>
#include <linux/pagemap.h>
43
#include <linux/proc_fs.h>
44 45 46 47
#include <linux/rcupdate.h>
#include <linux/sched.h>
#include <linux/slab.h>
#include <linux/spinlock.h>
48
#include <linux/percpu-rwsem.h>
49
#include <linux/string.h>
50
#include <linux/sort.h>
51
#include <linux/kmod.h>
B
Balbir Singh 已提交
52 53
#include <linux/delayacct.h>
#include <linux/cgroupstats.h>
54
#include <linux/hashtable.h>
L
Li Zefan 已提交
55
#include <linux/pid_namespace.h>
56
#include <linux/idr.h>
57
#include <linux/vmalloc.h> /* TODO: replace with more sophisticated array */
58
#include <linux/kthread.h>
T
Tejun Heo 已提交
59
#include <linux/delay.h>
B
Balbir Singh 已提交
60

A
Arun Sharma 已提交
61
#include <linux/atomic.h>
62

63 64 65 66 67 68 69 70
/*
 * pidlists linger the following amount before being destroyed.  The goal
 * is avoiding frequent destruction in the middle of consecutive read calls
 * Expiring in the middle is a performance problem not a correctness one.
 * 1 sec should be enough.
 */
#define CGROUP_PIDLIST_DESTROY_DELAY	HZ

T
Tejun Heo 已提交
71 72 73
#define CGROUP_FILE_NAME_MAX		(MAX_CGROUP_TYPE_NAMELEN +	\
					 MAX_CFTYPE_NAME + 2)

T
Tejun Heo 已提交
74 75 76 77
/*
 * cgroup_mutex is the master lock.  Any modification to cgroup or its
 * hierarchy must be performed while holding it.
 *
78
 * css_set_lock protects task->cgroups pointer, the list of css_set
79
 * objects, and the chain of tasks off each css_set.
T
Tejun Heo 已提交
80
 *
81 82
 * These locks are exported if CONFIG_PROVE_RCU so that accessors in
 * cgroup.h can use them for lockdep annotations.
T
Tejun Heo 已提交
83
 */
T
Tejun Heo 已提交
84 85
#ifdef CONFIG_PROVE_RCU
DEFINE_MUTEX(cgroup_mutex);
86
DEFINE_SPINLOCK(css_set_lock);
87
EXPORT_SYMBOL_GPL(cgroup_mutex);
88
EXPORT_SYMBOL_GPL(css_set_lock);
T
Tejun Heo 已提交
89
#else
90
static DEFINE_MUTEX(cgroup_mutex);
91
static DEFINE_SPINLOCK(css_set_lock);
T
Tejun Heo 已提交
92 93
#endif

94
/*
95 96
 * Protects cgroup_idr and css_idr so that IDs can be released without
 * grabbing cgroup_mutex.
97 98 99
 */
static DEFINE_SPINLOCK(cgroup_idr_lock);

100 101 102 103 104
/*
 * Protects cgroup_subsys->release_agent_path.  Modifying it also requires
 * cgroup_mutex.  Reading requires either cgroup_mutex or this spinlock.
 */
static DEFINE_SPINLOCK(release_agent_path_lock);
105

106 107
struct percpu_rw_semaphore cgroup_threadgroup_rwsem;

T
Tejun Heo 已提交
108
#define cgroup_assert_mutex_or_rcu_locked()				\
109 110
	RCU_LOCKDEP_WARN(!rcu_read_lock_held() &&			\
			   !lockdep_is_held(&cgroup_mutex),		\
T
Tejun Heo 已提交
111
			   "cgroup_mutex or RCU read lock required");
112

113 114 115 116 117 118 119 120
/*
 * cgroup destruction makes heavy use of work items and there can be a lot
 * of concurrent destructions.  Use a separate workqueue so that cgroup
 * destruction work items don't end up filling up max_active of system_wq
 * which may lead to deadlock.
 */
static struct workqueue_struct *cgroup_destroy_wq;

121 122 123 124 125 126
/*
 * pidlist destructions need to be flushed on cgroup destruction.  Use a
 * separate workqueue as flush domain.
 */
static struct workqueue_struct *cgroup_pidlist_destroy_wq;

T
Tejun Heo 已提交
127
/* generate an array of cgroup subsystem pointers */
128
#define SUBSYS(_x) [_x ## _cgrp_id] = &_x ## _cgrp_subsys,
T
Tejun Heo 已提交
129
static struct cgroup_subsys *cgroup_subsys[] = {
130 131
#include <linux/cgroup_subsys.h>
};
132 133 134 135 136
#undef SUBSYS

/* array of cgroup subsystem names */
#define SUBSYS(_x) [_x ## _cgrp_id] = #_x,
static const char *cgroup_subsys_name[] = {
137 138
#include <linux/cgroup_subsys.h>
};
139
#undef SUBSYS
140

141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161
/* array of static_keys for cgroup_subsys_enabled() and cgroup_subsys_on_dfl() */
#define SUBSYS(_x)								\
	DEFINE_STATIC_KEY_TRUE(_x ## _cgrp_subsys_enabled_key);			\
	DEFINE_STATIC_KEY_TRUE(_x ## _cgrp_subsys_on_dfl_key);			\
	EXPORT_SYMBOL_GPL(_x ## _cgrp_subsys_enabled_key);			\
	EXPORT_SYMBOL_GPL(_x ## _cgrp_subsys_on_dfl_key);
#include <linux/cgroup_subsys.h>
#undef SUBSYS

#define SUBSYS(_x) [_x ## _cgrp_id] = &_x ## _cgrp_subsys_enabled_key,
static struct static_key_true *cgroup_subsys_enabled_key[] = {
#include <linux/cgroup_subsys.h>
};
#undef SUBSYS

#define SUBSYS(_x) [_x ## _cgrp_id] = &_x ## _cgrp_subsys_on_dfl_key,
static struct static_key_true *cgroup_subsys_on_dfl_key[] = {
#include <linux/cgroup_subsys.h>
};
#undef SUBSYS

162
/*
163
 * The default hierarchy, reserved for the subsystems that are otherwise
164 165
 * unattached - it never has more than a single cgroup, and all tasks are
 * part of that cgroup.
166
 */
T
Tejun Heo 已提交
167
struct cgroup_root cgrp_dfl_root;
T
Tejun Heo 已提交
168
EXPORT_SYMBOL_GPL(cgrp_dfl_root);
169

T
Tejun Heo 已提交
170 171 172 173 174
/*
 * The default hierarchy always exists but is hidden until mounted for the
 * first time.  This is for backward compatibility.
 */
static bool cgrp_dfl_root_visible;
175

176
/* some controllers are not supported in the default hierarchy */
177
static unsigned long cgrp_dfl_root_inhibit_ss_mask;
178

179 180
/* The list of hierarchy roots */

181 182
static LIST_HEAD(cgroup_roots);
static int cgroup_root_count;
183

T
Tejun Heo 已提交
184
/* hierarchy ID allocation and mapping, protected by cgroup_mutex */
185
static DEFINE_IDR(cgroup_hierarchy_idr);
186

187
/*
188 189 190 191 192
 * Assign a monotonically increasing serial number to csses.  It guarantees
 * cgroups with bigger numbers are newer than those with smaller numbers.
 * Also, as csses are always appended to the parent's ->children list, it
 * guarantees that sibling csses are always sorted in the ascending serial
 * number order on the list.  Protected by cgroup_mutex.
193
 */
194
static u64 css_serial_nr_next = 1;
195

196 197 198 199
/*
 * These bitmask flags indicate whether tasks in the fork and exit paths have
 * fork/exit handlers to call. This avoids us having to do extra work in the
 * fork/exit path to check which subsystems have fork/exit callbacks.
200
 */
201 202
static unsigned long have_fork_callback __read_mostly;
static unsigned long have_exit_callback __read_mostly;
203
static unsigned long have_free_callback __read_mostly;
204

205 206 207
/* Ditto for the can_fork callback. */
static unsigned long have_canfork_callback __read_mostly;

208 209
static struct cftype cgroup_dfl_base_files[];
static struct cftype cgroup_legacy_base_files[];
210

211
static int rebind_subsystems(struct cgroup_root *dst_root,
212
			     unsigned long ss_mask);
213
static void css_task_iter_advance(struct css_task_iter *it);
214
static int cgroup_destroy_locked(struct cgroup *cgrp);
215 216
static int create_css(struct cgroup *cgrp, struct cgroup_subsys *ss,
		      bool visible);
217
static void css_release(struct percpu_ref *ref);
218
static void kill_css(struct cgroup_subsys_state *css);
219 220
static int cgroup_addrm_files(struct cgroup_subsys_state *css,
			      struct cgroup *cgrp, struct cftype cfts[],
221
			      bool is_add);
222

223 224 225 226 227 228 229 230 231 232 233 234 235
/**
 * cgroup_ssid_enabled - cgroup subsys enabled test by subsys ID
 * @ssid: subsys ID of interest
 *
 * cgroup_subsys_enabled() can only be used with literal subsys names which
 * is fine for individual subsystems but unsuitable for cgroup core.  This
 * is slower static_key_enabled() based test indexed by @ssid.
 */
static bool cgroup_ssid_enabled(int ssid)
{
	return static_key_enabled(cgroup_subsys_enabled_key[ssid]);
}

236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293
/**
 * cgroup_on_dfl - test whether a cgroup is on the default hierarchy
 * @cgrp: the cgroup of interest
 *
 * The default hierarchy is the v2 interface of cgroup and this function
 * can be used to test whether a cgroup is on the default hierarchy for
 * cases where a subsystem should behave differnetly depending on the
 * interface version.
 *
 * The set of behaviors which change on the default hierarchy are still
 * being determined and the mount option is prefixed with __DEVEL__.
 *
 * List of changed behaviors:
 *
 * - Mount options "noprefix", "xattr", "clone_children", "release_agent"
 *   and "name" are disallowed.
 *
 * - When mounting an existing superblock, mount options should match.
 *
 * - Remount is disallowed.
 *
 * - rename(2) is disallowed.
 *
 * - "tasks" is removed.  Everything should be at process granularity.  Use
 *   "cgroup.procs" instead.
 *
 * - "cgroup.procs" is not sorted.  pids will be unique unless they got
 *   recycled inbetween reads.
 *
 * - "release_agent" and "notify_on_release" are removed.  Replacement
 *   notification mechanism will be implemented.
 *
 * - "cgroup.clone_children" is removed.
 *
 * - "cgroup.subtree_populated" is available.  Its value is 0 if the cgroup
 *   and its descendants contain no task; otherwise, 1.  The file also
 *   generates kernfs notification which can be monitored through poll and
 *   [di]notify when the value of the file changes.
 *
 * - cpuset: tasks will be kept in empty cpusets when hotplug happens and
 *   take masks of ancestors with non-empty cpus/mems, instead of being
 *   moved to an ancestor.
 *
 * - cpuset: a task can be moved into an empty cpuset, and again it takes
 *   masks of ancestors.
 *
 * - memcg: use_hierarchy is on by default and the cgroup file for the flag
 *   is not created.
 *
 * - blkcg: blk-throttle becomes properly hierarchical.
 *
 * - debug: disallowed on the default hierarchy.
 */
static bool cgroup_on_dfl(const struct cgroup *cgrp)
{
	return cgrp->root == &cgrp_dfl_root;
}

294 295 296 297 298 299 300
/* IDR wrappers which synchronize using cgroup_idr_lock */
static int cgroup_idr_alloc(struct idr *idr, void *ptr, int start, int end,
			    gfp_t gfp_mask)
{
	int ret;

	idr_preload(gfp_mask);
T
Tejun Heo 已提交
301
	spin_lock_bh(&cgroup_idr_lock);
V
Vladimir Davydov 已提交
302
	ret = idr_alloc(idr, ptr, start, end, gfp_mask & ~__GFP_WAIT);
T
Tejun Heo 已提交
303
	spin_unlock_bh(&cgroup_idr_lock);
304 305 306 307 308 309 310 311
	idr_preload_end();
	return ret;
}

static void *cgroup_idr_replace(struct idr *idr, void *ptr, int id)
{
	void *ret;

T
Tejun Heo 已提交
312
	spin_lock_bh(&cgroup_idr_lock);
313
	ret = idr_replace(idr, ptr, id);
T
Tejun Heo 已提交
314
	spin_unlock_bh(&cgroup_idr_lock);
315 316 317 318 319
	return ret;
}

static void cgroup_idr_remove(struct idr *idr, int id)
{
T
Tejun Heo 已提交
320
	spin_lock_bh(&cgroup_idr_lock);
321
	idr_remove(idr, id);
T
Tejun Heo 已提交
322
	spin_unlock_bh(&cgroup_idr_lock);
323 324
}

T
Tejun Heo 已提交
325 326 327 328 329 330 331 332 333
static struct cgroup *cgroup_parent(struct cgroup *cgrp)
{
	struct cgroup_subsys_state *parent_css = cgrp->self.parent;

	if (parent_css)
		return container_of(parent_css, struct cgroup, self);
	return NULL;
}

T
Tejun Heo 已提交
334 335 336
/**
 * cgroup_css - obtain a cgroup's css for the specified subsystem
 * @cgrp: the cgroup of interest
337
 * @ss: the subsystem of interest (%NULL returns @cgrp->self)
T
Tejun Heo 已提交
338
 *
339 340 341 342 343
 * Return @cgrp's css (cgroup_subsys_state) associated with @ss.  This
 * function must be called either under cgroup_mutex or rcu_read_lock() and
 * the caller is responsible for pinning the returned css if it wants to
 * keep accessing it outside the said locks.  This function may return
 * %NULL if @cgrp doesn't have @subsys_id enabled.
T
Tejun Heo 已提交
344 345
 */
static struct cgroup_subsys_state *cgroup_css(struct cgroup *cgrp,
346
					      struct cgroup_subsys *ss)
T
Tejun Heo 已提交
347
{
348
	if (ss)
349
		return rcu_dereference_check(cgrp->subsys[ss->id],
T
Tejun Heo 已提交
350
					lockdep_is_held(&cgroup_mutex));
351
	else
352
		return &cgrp->self;
T
Tejun Heo 已提交
353
}
354

355 356 357
/**
 * cgroup_e_css - obtain a cgroup's effective css for the specified subsystem
 * @cgrp: the cgroup of interest
358
 * @ss: the subsystem of interest (%NULL returns @cgrp->self)
359
 *
C
Chen Hanxiao 已提交
360
 * Similar to cgroup_css() but returns the effective css, which is defined
361 362 363 364 365 366 367 368 369 370
 * as the matching css of the nearest ancestor including self which has @ss
 * enabled.  If @ss is associated with the hierarchy @cgrp is on, this
 * function is guaranteed to return non-NULL css.
 */
static struct cgroup_subsys_state *cgroup_e_css(struct cgroup *cgrp,
						struct cgroup_subsys *ss)
{
	lockdep_assert_held(&cgroup_mutex);

	if (!ss)
371
		return &cgrp->self;
372 373 374 375

	if (!(cgrp->root->subsys_mask & (1 << ss->id)))
		return NULL;

T
Tejun Heo 已提交
376 377 378 379
	/*
	 * This function is used while updating css associations and thus
	 * can't test the csses directly.  Use ->child_subsys_mask.
	 */
T
Tejun Heo 已提交
380 381 382
	while (cgroup_parent(cgrp) &&
	       !(cgroup_parent(cgrp)->child_subsys_mask & (1 << ss->id)))
		cgrp = cgroup_parent(cgrp);
383 384

	return cgroup_css(cgrp, ss);
T
Tejun Heo 已提交
385
}
386

T
Tejun Heo 已提交
387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419
/**
 * cgroup_get_e_css - get a cgroup's effective css for the specified subsystem
 * @cgrp: the cgroup of interest
 * @ss: the subsystem of interest
 *
 * Find and get the effective css of @cgrp for @ss.  The effective css is
 * defined as the matching css of the nearest ancestor including self which
 * has @ss enabled.  If @ss is not mounted on the hierarchy @cgrp is on,
 * the root css is returned, so this function always returns a valid css.
 * The returned css must be put using css_put().
 */
struct cgroup_subsys_state *cgroup_get_e_css(struct cgroup *cgrp,
					     struct cgroup_subsys *ss)
{
	struct cgroup_subsys_state *css;

	rcu_read_lock();

	do {
		css = cgroup_css(cgrp, ss);

		if (css && css_tryget_online(css))
			goto out_unlock;
		cgrp = cgroup_parent(cgrp);
	} while (cgrp);

	css = init_css_set.subsys[ss->id];
	css_get(css);
out_unlock:
	rcu_read_unlock();
	return css;
}

420
/* convenient tests for these bits */
421
static inline bool cgroup_is_dead(const struct cgroup *cgrp)
422
{
423
	return !(cgrp->self.flags & CSS_ONLINE);
424 425
}

T
Tejun Heo 已提交
426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441
static void cgroup_get(struct cgroup *cgrp)
{
	WARN_ON_ONCE(cgroup_is_dead(cgrp));
	css_get(&cgrp->self);
}

static bool cgroup_tryget(struct cgroup *cgrp)
{
	return css_tryget(&cgrp->self);
}

static void cgroup_put(struct cgroup *cgrp)
{
	css_put(&cgrp->self);
}

T
Tejun Heo 已提交
442
struct cgroup_subsys_state *of_css(struct kernfs_open_file *of)
443
{
T
Tejun Heo 已提交
444
	struct cgroup *cgrp = of->kn->parent->priv;
T
Tejun Heo 已提交
445
	struct cftype *cft = of_cft(of);
T
Tejun Heo 已提交
446 447 448 449 450 451 452 453 454 455 456 457

	/*
	 * This is open and unprotected implementation of cgroup_css().
	 * seq_css() is only called from a kernfs file operation which has
	 * an active reference on the file.  Because all the subsystem
	 * files are drained before a css is disassociated with a cgroup,
	 * the matching css from the cgroup's subsys table is guaranteed to
	 * be and stay valid until the enclosing operation is complete.
	 */
	if (cft->ss)
		return rcu_dereference_raw(cgrp->subsys[cft->ss->id]);
	else
458
		return &cgrp->self;
459
}
T
Tejun Heo 已提交
460
EXPORT_SYMBOL_GPL(of_css);
461

462 463 464 465 466 467 468 469 470 471 472 473 474 475
/**
 * cgroup_is_descendant - test ancestry
 * @cgrp: the cgroup to be tested
 * @ancestor: possible ancestor of @cgrp
 *
 * Test whether @cgrp is a descendant of @ancestor.  It also returns %true
 * if @cgrp == @ancestor.  This function is safe to call as long as @cgrp
 * and @ancestor are accessible.
 */
bool cgroup_is_descendant(struct cgroup *cgrp, struct cgroup *ancestor)
{
	while (cgrp) {
		if (cgrp == ancestor)
			return true;
T
Tejun Heo 已提交
476
		cgrp = cgroup_parent(cgrp);
477 478 479
	}
	return false;
}
480

481
static int notify_on_release(const struct cgroup *cgrp)
482
{
483
	return test_bit(CGRP_NOTIFY_ON_RELEASE, &cgrp->flags);
484 485
}

T
Tejun Heo 已提交
486 487 488 489 490 491
/**
 * for_each_css - iterate all css's of a cgroup
 * @css: the iteration cursor
 * @ssid: the index of the subsystem, CGROUP_SUBSYS_COUNT after reaching the end
 * @cgrp: the target cgroup to iterate css's of
 *
492
 * Should be called under cgroup_[tree_]mutex.
T
Tejun Heo 已提交
493 494 495 496 497 498 499 500
 */
#define for_each_css(css, ssid, cgrp)					\
	for ((ssid) = 0; (ssid) < CGROUP_SUBSYS_COUNT; (ssid)++)	\
		if (!((css) = rcu_dereference_check(			\
				(cgrp)->subsys[(ssid)],			\
				lockdep_is_held(&cgroup_mutex)))) { }	\
		else

501 502 503 504 505 506 507 508 509 510 511 512 513 514
/**
 * for_each_e_css - iterate all effective css's of a cgroup
 * @css: the iteration cursor
 * @ssid: the index of the subsystem, CGROUP_SUBSYS_COUNT after reaching the end
 * @cgrp: the target cgroup to iterate css's of
 *
 * Should be called under cgroup_[tree_]mutex.
 */
#define for_each_e_css(css, ssid, cgrp)					\
	for ((ssid) = 0; (ssid) < CGROUP_SUBSYS_COUNT; (ssid)++)	\
		if (!((css) = cgroup_e_css(cgrp, cgroup_subsys[(ssid)]))) \
			;						\
		else

515
/**
T
Tejun Heo 已提交
516
 * for_each_subsys - iterate all enabled cgroup subsystems
517
 * @ss: the iteration cursor
518
 * @ssid: the index of @ss, CGROUP_SUBSYS_COUNT after reaching the end
519
 */
520
#define for_each_subsys(ss, ssid)					\
T
Tejun Heo 已提交
521 522
	for ((ssid) = 0; (ssid) < CGROUP_SUBSYS_COUNT &&		\
	     (((ss) = cgroup_subsys[ssid]) || true); (ssid)++)
523

524 525 526 527 528 529 530 531 532 533 534
/**
 * for_each_subsys_which - filter for_each_subsys with a bitmask
 * @ss: the iteration cursor
 * @ssid: the index of @ss, CGROUP_SUBSYS_COUNT after reaching the end
 * @ss_maskp: a pointer to the bitmask
 *
 * The block will only run for cases where the ssid-th bit (1 << ssid) of
 * mask is set to 1.
 */
#define for_each_subsys_which(ss, ssid, ss_maskp)			\
	if (!CGROUP_SUBSYS_COUNT) /* to avoid spurious gcc warning */	\
535
		(ssid) = 0;						\
536 537 538 539 540 541
	else								\
		for_each_set_bit(ssid, ss_maskp, CGROUP_SUBSYS_COUNT)	\
			if (((ss) = cgroup_subsys[ssid]) && false)	\
				break;					\
			else

542 543
/* iterate across the hierarchies */
#define for_each_root(root)						\
544
	list_for_each_entry((root), &cgroup_roots, root_list)
545

546 547
/* iterate over child cgrps, lock should be held throughout iteration */
#define cgroup_for_each_live_child(child, cgrp)				\
548
	list_for_each_entry((child), &(cgrp)->self.children, self.sibling) \
T
Tejun Heo 已提交
549
		if (({ lockdep_assert_held(&cgroup_mutex);		\
550 551 552
		       cgroup_is_dead(child); }))			\
			;						\
		else
553

554
static void cgroup_release_agent(struct work_struct *work);
555
static void check_for_release(struct cgroup *cgrp);
556

557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574
/*
 * A cgroup can be associated with multiple css_sets as different tasks may
 * belong to different cgroups on different hierarchies.  In the other
 * direction, a css_set is naturally associated with multiple cgroups.
 * This M:N relationship is represented by the following link structure
 * which exists for each association and allows traversing the associations
 * from both sides.
 */
struct cgrp_cset_link {
	/* the cgroup and css_set this link associates */
	struct cgroup		*cgrp;
	struct css_set		*cset;

	/* list of cgrp_cset_links anchored at cgrp->cset_links */
	struct list_head	cset_link;

	/* list of cgrp_cset_links anchored at css_set->cgrp_links */
	struct list_head	cgrp_link;
575 576
};

577 578
/*
 * The default css_set - used by init and its children prior to any
579 580 581 582 583
 * hierarchies being mounted. It contains a pointer to the root state
 * for each subsystem. Also used to anchor the list of css_sets. Not
 * reference-counted, to improve performance when child cgroups
 * haven't been created.
 */
T
Tejun Heo 已提交
584
struct css_set init_css_set = {
585 586 587 588 589 590
	.refcount		= ATOMIC_INIT(1),
	.cgrp_links		= LIST_HEAD_INIT(init_css_set.cgrp_links),
	.tasks			= LIST_HEAD_INIT(init_css_set.tasks),
	.mg_tasks		= LIST_HEAD_INIT(init_css_set.mg_tasks),
	.mg_preload_node	= LIST_HEAD_INIT(init_css_set.mg_preload_node),
	.mg_node		= LIST_HEAD_INIT(init_css_set.mg_node),
591
	.task_iters		= LIST_HEAD_INIT(init_css_set.task_iters),
592
};
593

594
static int css_set_count	= 1;	/* 1 for init_css_set */
595

596 597 598 599 600 601
/**
 * css_set_populated - does a css_set contain any tasks?
 * @cset: target css_set
 */
static bool css_set_populated(struct css_set *cset)
{
602
	lockdep_assert_held(&css_set_lock);
603 604 605 606

	return !list_empty(&cset->tasks) || !list_empty(&cset->mg_tasks);
}

607 608 609 610 611
/**
 * cgroup_update_populated - updated populated count of a cgroup
 * @cgrp: the target cgroup
 * @populated: inc or dec populated count
 *
612 613 614 615
 * One of the css_sets associated with @cgrp is either getting its first
 * task or losing the last.  Update @cgrp->populated_cnt accordingly.  The
 * count is propagated towards root so that a given cgroup's populated_cnt
 * is zero iff the cgroup and all its descendants don't contain any tasks.
616 617 618 619 620 621 622 623 624
 *
 * @cgrp's interface file "cgroup.populated" is zero if
 * @cgrp->populated_cnt is zero and 1 otherwise.  When @cgrp->populated_cnt
 * changes from or to zero, userland is notified that the content of the
 * interface file has changed.  This can be used to detect when @cgrp and
 * its descendants become populated or empty.
 */
static void cgroup_update_populated(struct cgroup *cgrp, bool populated)
{
625
	lockdep_assert_held(&css_set_lock);
626 627 628 629 630 631 632 633 634 635 636 637

	do {
		bool trigger;

		if (populated)
			trigger = !cgrp->populated_cnt++;
		else
			trigger = !--cgrp->populated_cnt;

		if (!trigger)
			break;

638
		check_for_release(cgrp);
639 640
		cgroup_file_notify(&cgrp->events_file);

T
Tejun Heo 已提交
641
		cgrp = cgroup_parent(cgrp);
642 643 644
	} while (cgrp);
}

645 646 647 648 649 650 651 652 653 654 655 656
/**
 * css_set_update_populated - update populated state of a css_set
 * @cset: target css_set
 * @populated: whether @cset is populated or depopulated
 *
 * @cset is either getting the first task or losing the last.  Update the
 * ->populated_cnt of all associated cgroups accordingly.
 */
static void css_set_update_populated(struct css_set *cset, bool populated)
{
	struct cgrp_cset_link *link;

657
	lockdep_assert_held(&css_set_lock);
658 659 660 661 662

	list_for_each_entry(link, &cset->cgrp_links, cgrp_link)
		cgroup_update_populated(link->cgrp, populated);
}

T
Tejun Heo 已提交
663 664 665 666 667 668 669 670 671 672 673
/**
 * css_set_move_task - move a task from one css_set to another
 * @task: task being moved
 * @from_cset: css_set @task currently belongs to (may be NULL)
 * @to_cset: new css_set @task is being moved to (may be NULL)
 * @use_mg_tasks: move to @to_cset->mg_tasks instead of ->tasks
 *
 * Move @task from @from_cset to @to_cset.  If @task didn't belong to any
 * css_set, @from_cset can be NULL.  If @task is being disassociated
 * instead of moved, @to_cset can be NULL.
 *
674 675 676
 * This function automatically handles populated_cnt updates and
 * css_task_iter adjustments but the caller is responsible for managing
 * @from_cset and @to_cset's reference counts.
T
Tejun Heo 已提交
677 678 679 680 681
 */
static void css_set_move_task(struct task_struct *task,
			      struct css_set *from_cset, struct css_set *to_cset,
			      bool use_mg_tasks)
{
682
	lockdep_assert_held(&css_set_lock);
T
Tejun Heo 已提交
683 684

	if (from_cset) {
685 686
		struct css_task_iter *it, *pos;

T
Tejun Heo 已提交
687
		WARN_ON_ONCE(list_empty(&task->cg_list));
688 689 690 691 692 693 694 695 696 697 698 699 700

		/*
		 * @task is leaving, advance task iterators which are
		 * pointing to it so that they can resume at the next
		 * position.  Advancing an iterator might remove it from
		 * the list, use safe walk.  See css_task_iter_advance*()
		 * for details.
		 */
		list_for_each_entry_safe(it, pos, &from_cset->task_iters,
					 iters_node)
			if (it->task_pos == &task->cg_list)
				css_task_iter_advance(it);

T
Tejun Heo 已提交
701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724
		list_del_init(&task->cg_list);
		if (!css_set_populated(from_cset))
			css_set_update_populated(from_cset, false);
	} else {
		WARN_ON_ONCE(!list_empty(&task->cg_list));
	}

	if (to_cset) {
		/*
		 * We are synchronized through cgroup_threadgroup_rwsem
		 * against PF_EXITING setting such that we can't race
		 * against cgroup_exit() changing the css_set to
		 * init_css_set and dropping the old one.
		 */
		WARN_ON_ONCE(task->flags & PF_EXITING);

		if (!css_set_populated(to_cset))
			css_set_update_populated(to_cset, true);
		rcu_assign_pointer(task->cgroups, to_cset);
		list_add_tail(&task->cg_list, use_mg_tasks ? &to_cset->mg_tasks :
							     &to_cset->tasks);
	}
}

725 726 727 728 729
/*
 * hash table for cgroup groups. This improves the performance to find
 * an existing css_set. This hash doesn't (currently) take into
 * account cgroups in empty hierarchies.
 */
730
#define CSS_SET_HASH_BITS	7
731
static DEFINE_HASHTABLE(css_set_table, CSS_SET_HASH_BITS);
732

733
static unsigned long css_set_hash(struct cgroup_subsys_state *css[])
734
{
735
	unsigned long key = 0UL;
736 737
	struct cgroup_subsys *ss;
	int i;
738

739
	for_each_subsys(ss, i)
740 741
		key += (unsigned long)css[i];
	key = (key >> 16) ^ key;
742

743
	return key;
744 745
}

Z
Zefan Li 已提交
746
static void put_css_set_locked(struct css_set *cset)
747
{
748
	struct cgrp_cset_link *link, *tmp_link;
T
Tejun Heo 已提交
749 750
	struct cgroup_subsys *ss;
	int ssid;
751

752
	lockdep_assert_held(&css_set_lock);
753 754

	if (!atomic_dec_and_test(&cset->refcount))
755
		return;
756

757
	/* This css_set is dead. unlink it and release cgroup refcounts */
T
Tejun Heo 已提交
758 759
	for_each_subsys(ss, ssid)
		list_del(&cset->e_cset_node[ssid]);
760
	hash_del(&cset->hlist);
761 762
	css_set_count--;

763 764 765
	list_for_each_entry_safe(link, tmp_link, &cset->cgrp_links, cgrp_link) {
		list_del(&link->cset_link);
		list_del(&link->cgrp_link);
766 767
		if (cgroup_parent(link->cgrp))
			cgroup_put(link->cgrp);
768
		kfree(link);
769
	}
770

771
	kfree_rcu(cset, rcu_head);
772 773
}

Z
Zefan Li 已提交
774
static void put_css_set(struct css_set *cset)
775 776 777 778 779 780 781 782 783
{
	/*
	 * Ensure that the refcount doesn't hit zero while any readers
	 * can see it. Similar to atomic_dec_and_lock(), but for an
	 * rwlock
	 */
	if (atomic_add_unless(&cset->refcount, -1, 1))
		return;

784
	spin_lock_bh(&css_set_lock);
Z
Zefan Li 已提交
785
	put_css_set_locked(cset);
786
	spin_unlock_bh(&css_set_lock);
787 788
}

789 790 791
/*
 * refcounted get/put for css_set objects
 */
792
static inline void get_css_set(struct css_set *cset)
793
{
794
	atomic_inc(&cset->refcount);
795 796
}

797
/**
798
 * compare_css_sets - helper function for find_existing_css_set().
799 800
 * @cset: candidate css_set being tested
 * @old_cset: existing css_set for a task
801 802 803
 * @new_cgrp: cgroup that's being entered by the task
 * @template: desired set of css pointers in css_set (pre-calculated)
 *
L
Li Zefan 已提交
804
 * Returns true if "cset" matches "old_cset" except for the hierarchy
805 806
 * which "new_cgrp" belongs to, for which it should match "new_cgrp".
 */
807 808
static bool compare_css_sets(struct css_set *cset,
			     struct css_set *old_cset,
809 810 811 812 813
			     struct cgroup *new_cgrp,
			     struct cgroup_subsys_state *template[])
{
	struct list_head *l1, *l2;

814 815 816 817 818 819
	/*
	 * On the default hierarchy, there can be csets which are
	 * associated with the same set of cgroups but different csses.
	 * Let's first ensure that csses match.
	 */
	if (memcmp(template, cset->subsys, sizeof(cset->subsys)))
820 821 822 823
		return false;

	/*
	 * Compare cgroup pointers in order to distinguish between
824 825 826
	 * different cgroups in hierarchies.  As different cgroups may
	 * share the same effective css, this comparison is always
	 * necessary.
827
	 */
828 829
	l1 = &cset->cgrp_links;
	l2 = &old_cset->cgrp_links;
830
	while (1) {
831
		struct cgrp_cset_link *link1, *link2;
832
		struct cgroup *cgrp1, *cgrp2;
833 834 835 836

		l1 = l1->next;
		l2 = l2->next;
		/* See if we reached the end - both lists are equal length. */
837 838
		if (l1 == &cset->cgrp_links) {
			BUG_ON(l2 != &old_cset->cgrp_links);
839 840
			break;
		} else {
841
			BUG_ON(l2 == &old_cset->cgrp_links);
842 843
		}
		/* Locate the cgroups associated with these links. */
844 845 846 847
		link1 = list_entry(l1, struct cgrp_cset_link, cgrp_link);
		link2 = list_entry(l2, struct cgrp_cset_link, cgrp_link);
		cgrp1 = link1->cgrp;
		cgrp2 = link2->cgrp;
848
		/* Hierarchies should be linked in the same order. */
849
		BUG_ON(cgrp1->root != cgrp2->root);
850 851 852 853 854 855 856 857

		/*
		 * If this hierarchy is the hierarchy of the cgroup
		 * that's changing, then we need to check that this
		 * css_set points to the new cgroup; if it's any other
		 * hierarchy, then this css_set should point to the
		 * same cgroup as the old css_set.
		 */
858 859
		if (cgrp1->root == new_cgrp->root) {
			if (cgrp1 != new_cgrp)
860 861
				return false;
		} else {
862
			if (cgrp1 != cgrp2)
863 864 865 866 867 868
				return false;
		}
	}
	return true;
}

869 870 871 872 873
/**
 * find_existing_css_set - init css array and find the matching css_set
 * @old_cset: the css_set that we're using before the cgroup transition
 * @cgrp: the cgroup that we're moving into
 * @template: out param for the new set of csses, should be clear on entry
874
 */
875 876 877
static struct css_set *find_existing_css_set(struct css_set *old_cset,
					struct cgroup *cgrp,
					struct cgroup_subsys_state *template[])
878
{
879
	struct cgroup_root *root = cgrp->root;
880
	struct cgroup_subsys *ss;
881
	struct css_set *cset;
882
	unsigned long key;
883
	int i;
884

B
Ben Blum 已提交
885 886 887 888 889
	/*
	 * Build the set of subsystem state objects that we want to see in the
	 * new css_set. while subsystems can change globally, the entries here
	 * won't change, so no need for locking.
	 */
890
	for_each_subsys(ss, i) {
891
		if (root->subsys_mask & (1UL << i)) {
892 893 894 895 896
			/*
			 * @ss is in this hierarchy, so we want the
			 * effective css from @cgrp.
			 */
			template[i] = cgroup_e_css(cgrp, ss);
897
		} else {
898 899 900 901
			/*
			 * @ss is not in this hierarchy, so we don't want
			 * to change the css.
			 */
902
			template[i] = old_cset->subsys[i];
903 904 905
		}
	}

906
	key = css_set_hash(template);
907 908
	hash_for_each_possible(css_set_table, cset, hlist, key) {
		if (!compare_css_sets(cset, old_cset, cgrp, template))
909 910 911
			continue;

		/* This css_set matches what we need */
912
		return cset;
913
	}
914 915 916 917 918

	/* No existing cgroup group matched */
	return NULL;
}

919
static void free_cgrp_cset_links(struct list_head *links_to_free)
920
{
921
	struct cgrp_cset_link *link, *tmp_link;
922

923 924
	list_for_each_entry_safe(link, tmp_link, links_to_free, cset_link) {
		list_del(&link->cset_link);
925 926 927 928
		kfree(link);
	}
}

929 930 931 932 933 934 935
/**
 * allocate_cgrp_cset_links - allocate cgrp_cset_links
 * @count: the number of links to allocate
 * @tmp_links: list_head the allocated links are put on
 *
 * Allocate @count cgrp_cset_link structures and chain them on @tmp_links
 * through ->cset_link.  Returns 0 on success or -errno.
936
 */
937
static int allocate_cgrp_cset_links(int count, struct list_head *tmp_links)
938
{
939
	struct cgrp_cset_link *link;
940
	int i;
941 942 943

	INIT_LIST_HEAD(tmp_links);

944
	for (i = 0; i < count; i++) {
945
		link = kzalloc(sizeof(*link), GFP_KERNEL);
946
		if (!link) {
947
			free_cgrp_cset_links(tmp_links);
948 949
			return -ENOMEM;
		}
950
		list_add(&link->cset_link, tmp_links);
951 952 953 954
	}
	return 0;
}

955 956
/**
 * link_css_set - a helper function to link a css_set to a cgroup
957
 * @tmp_links: cgrp_cset_link objects allocated by allocate_cgrp_cset_links()
958
 * @cset: the css_set to be linked
959 960
 * @cgrp: the destination cgroup
 */
961 962
static void link_css_set(struct list_head *tmp_links, struct css_set *cset,
			 struct cgroup *cgrp)
963
{
964
	struct cgrp_cset_link *link;
965

966
	BUG_ON(list_empty(tmp_links));
T
Tejun Heo 已提交
967 968 969 970

	if (cgroup_on_dfl(cgrp))
		cset->dfl_cgrp = cgrp;

971 972
	link = list_first_entry(tmp_links, struct cgrp_cset_link, cset_link);
	link->cset = cset;
973
	link->cgrp = cgrp;
974

975
	/*
976 977
	 * Always add links to the tail of the lists so that the lists are
	 * in choronological order.
978
	 */
979
	list_move_tail(&link->cset_link, &cgrp->cset_links);
980
	list_add_tail(&link->cgrp_link, &cset->cgrp_links);
981 982 983

	if (cgroup_parent(cgrp))
		cgroup_get(cgrp);
984 985
}

986 987 988 989 990 991 992
/**
 * find_css_set - return a new css_set with one cgroup updated
 * @old_cset: the baseline css_set
 * @cgrp: the cgroup to be updated
 *
 * Return a new css_set that's equivalent to @old_cset, but with @cgrp
 * substituted into the appropriate hierarchy.
993
 */
994 995
static struct css_set *find_css_set(struct css_set *old_cset,
				    struct cgroup *cgrp)
996
{
997
	struct cgroup_subsys_state *template[CGROUP_SUBSYS_COUNT] = { };
998
	struct css_set *cset;
999 1000
	struct list_head tmp_links;
	struct cgrp_cset_link *link;
T
Tejun Heo 已提交
1001
	struct cgroup_subsys *ss;
1002
	unsigned long key;
T
Tejun Heo 已提交
1003
	int ssid;
1004

1005 1006
	lockdep_assert_held(&cgroup_mutex);

1007 1008
	/* First see if we already have a cgroup group that matches
	 * the desired set */
1009
	spin_lock_bh(&css_set_lock);
1010 1011 1012
	cset = find_existing_css_set(old_cset, cgrp, template);
	if (cset)
		get_css_set(cset);
1013
	spin_unlock_bh(&css_set_lock);
1014

1015 1016
	if (cset)
		return cset;
1017

1018
	cset = kzalloc(sizeof(*cset), GFP_KERNEL);
1019
	if (!cset)
1020 1021
		return NULL;

1022
	/* Allocate all the cgrp_cset_link objects that we'll need */
1023
	if (allocate_cgrp_cset_links(cgroup_root_count, &tmp_links) < 0) {
1024
		kfree(cset);
1025 1026 1027
		return NULL;
	}

1028
	atomic_set(&cset->refcount, 1);
1029
	INIT_LIST_HEAD(&cset->cgrp_links);
1030
	INIT_LIST_HEAD(&cset->tasks);
T
Tejun Heo 已提交
1031
	INIT_LIST_HEAD(&cset->mg_tasks);
1032
	INIT_LIST_HEAD(&cset->mg_preload_node);
1033
	INIT_LIST_HEAD(&cset->mg_node);
1034
	INIT_LIST_HEAD(&cset->task_iters);
1035
	INIT_HLIST_NODE(&cset->hlist);
1036 1037 1038

	/* Copy the set of subsystem state objects generated in
	 * find_existing_css_set() */
1039
	memcpy(cset->subsys, template, sizeof(cset->subsys));
1040

1041
	spin_lock_bh(&css_set_lock);
1042
	/* Add reference counts and links from the new css_set. */
1043
	list_for_each_entry(link, &old_cset->cgrp_links, cgrp_link) {
1044
		struct cgroup *c = link->cgrp;
1045

1046 1047
		if (c->root == cgrp->root)
			c = cgrp;
1048
		link_css_set(&tmp_links, cset, c);
1049
	}
1050

1051
	BUG_ON(!list_empty(&tmp_links));
1052 1053

	css_set_count++;
1054

T
Tejun Heo 已提交
1055
	/* Add @cset to the hash table */
1056 1057
	key = css_set_hash(cset->subsys);
	hash_add(css_set_table, &cset->hlist, key);
1058

T
Tejun Heo 已提交
1059 1060 1061 1062
	for_each_subsys(ss, ssid)
		list_add_tail(&cset->e_cset_node[ssid],
			      &cset->subsys[ssid]->cgroup->e_csets[ssid]);

1063
	spin_unlock_bh(&css_set_lock);
1064

1065
	return cset;
1066 1067
}

1068
static struct cgroup_root *cgroup_root_from_kf(struct kernfs_root *kf_root)
1069
{
1070
	struct cgroup *root_cgrp = kf_root->kn->priv;
T
Tejun Heo 已提交
1071

1072
	return root_cgrp->root;
T
Tejun Heo 已提交
1073 1074
}

1075
static int cgroup_init_root_id(struct cgroup_root *root)
1076 1077 1078 1079 1080
{
	int id;

	lockdep_assert_held(&cgroup_mutex);

1081
	id = idr_alloc_cyclic(&cgroup_hierarchy_idr, root, 0, 0, GFP_KERNEL);
1082 1083 1084 1085 1086 1087 1088
	if (id < 0)
		return id;

	root->hierarchy_id = id;
	return 0;
}

1089
static void cgroup_exit_root_id(struct cgroup_root *root)
1090 1091 1092 1093 1094 1095 1096 1097 1098
{
	lockdep_assert_held(&cgroup_mutex);

	if (root->hierarchy_id) {
		idr_remove(&cgroup_hierarchy_idr, root->hierarchy_id);
		root->hierarchy_id = 0;
	}
}

1099
static void cgroup_free_root(struct cgroup_root *root)
1100 1101
{
	if (root) {
C
Chen Hanxiao 已提交
1102
		/* hierarchy ID should already have been released */
1103 1104 1105 1106 1107 1108 1109
		WARN_ON_ONCE(root->hierarchy_id);

		idr_destroy(&root->cgroup_idr);
		kfree(root);
	}
}

1110
static void cgroup_destroy_root(struct cgroup_root *root)
1111
{
1112
	struct cgroup *cgrp = &root->cgrp;
1113 1114
	struct cgrp_cset_link *link, *tmp_link;

T
Tejun Heo 已提交
1115
	mutex_lock(&cgroup_mutex);
1116

T
Tejun Heo 已提交
1117
	BUG_ON(atomic_read(&root->nr_cgrps));
1118
	BUG_ON(!list_empty(&cgrp->self.children));
1119 1120

	/* Rebind all subsystems back to the default hierarchy */
1121
	rebind_subsystems(&cgrp_dfl_root, root->subsys_mask);
1122 1123

	/*
1124 1125
	 * Release all the links from cset_links to this hierarchy's
	 * root cgroup
1126
	 */
1127
	spin_lock_bh(&css_set_lock);
1128 1129 1130 1131 1132 1133

	list_for_each_entry_safe(link, tmp_link, &cgrp->cset_links, cset_link) {
		list_del(&link->cset_link);
		list_del(&link->cgrp_link);
		kfree(link);
	}
1134 1135

	spin_unlock_bh(&css_set_lock);
1136 1137 1138 1139 1140 1141 1142 1143 1144 1145

	if (!list_empty(&root->root_list)) {
		list_del(&root->root_list);
		cgroup_root_count--;
	}

	cgroup_exit_root_id(root);

	mutex_unlock(&cgroup_mutex);

T
Tejun Heo 已提交
1146
	kernfs_destroy_root(root->kf_root);
1147 1148 1149
	cgroup_free_root(root);
}

1150 1151
/* look up cgroup associated with given css_set on the specified hierarchy */
static struct cgroup *cset_cgroup_from_root(struct css_set *cset,
1152
					    struct cgroup_root *root)
1153 1154 1155
{
	struct cgroup *res = NULL;

1156
	lockdep_assert_held(&cgroup_mutex);
1157
	lockdep_assert_held(&css_set_lock);
1158

1159
	if (cset == &init_css_set) {
1160
		res = &root->cgrp;
1161
	} else {
1162 1163 1164
		struct cgrp_cset_link *link;

		list_for_each_entry(link, &cset->cgrp_links, cgrp_link) {
1165
			struct cgroup *c = link->cgrp;
1166

1167 1168 1169 1170 1171 1172
			if (c->root == root) {
				res = c;
				break;
			}
		}
	}
1173

1174 1175 1176 1177
	BUG_ON(!res);
	return res;
}

1178
/*
1179
 * Return the cgroup for "task" from the given hierarchy. Must be
1180
 * called with cgroup_mutex and css_set_lock held.
1181 1182
 */
static struct cgroup *task_cgroup_from_root(struct task_struct *task,
1183
					    struct cgroup_root *root)
1184 1185 1186 1187 1188 1189 1190 1191 1192
{
	/*
	 * No need to lock the task - since we hold cgroup_mutex the
	 * task can't change groups, so the only thing that can happen
	 * is that it exits and its css is set back to init_css_set.
	 */
	return cset_cgroup_from_root(task_css_set(task), root);
}

1193 1194 1195 1196 1197 1198
/*
 * A task must hold cgroup_mutex to modify cgroups.
 *
 * Any task can increment and decrement the count field without lock.
 * So in general, code holding cgroup_mutex can't rely on the count
 * field not changing.  However, if the count goes to zero, then only
1199
 * cgroup_attach_task() can increment it again.  Because a count of zero
1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210
 * means that no tasks are currently attached, therefore there is no
 * way a task attached to that cgroup can fork (the other way to
 * increment the count).  So code holding cgroup_mutex can safely
 * assume that if the count is zero, it will stay zero. Similarly, if
 * a task holds cgroup_mutex on a cgroup with zero count, it
 * knows that the cgroup won't be removed, as cgroup_rmdir()
 * needs that mutex.
 *
 * A cgroup can only be deleted if both its 'count' of using tasks
 * is zero, and its list of 'children' cgroups is empty.  Since all
 * tasks in the system use _some_ cgroup, and since there is always at
1211
 * least one task in the system (init, pid == 1), therefore, root cgroup
1212
 * always has either children cgroups and/or using tasks.  So we don't
1213
 * need a special hack to ensure that root cgroup cannot be deleted.
1214 1215
 *
 * P.S.  One more locking exception.  RCU is used to guard the
1216
 * update of a tasks cgroup pointer by cgroup_attach_task()
1217 1218
 */

T
Tejun Heo 已提交
1219
static struct kernfs_syscall_ops cgroup_kf_syscall_ops;
1220
static const struct file_operations proc_cgroupstats_operations;
1221

T
Tejun Heo 已提交
1222 1223
static char *cgroup_file_name(struct cgroup *cgrp, const struct cftype *cft,
			      char *buf)
1224
{
1225 1226
	struct cgroup_subsys *ss = cft->ss;

T
Tejun Heo 已提交
1227 1228 1229
	if (cft->ss && !(cft->flags & CFTYPE_NO_PREFIX) &&
	    !(cgrp->root->flags & CGRP_ROOT_NOPREFIX))
		snprintf(buf, CGROUP_FILE_NAME_MAX, "%s.%s",
1230 1231
			 cgroup_on_dfl(cgrp) ? ss->name : ss->legacy_name,
			 cft->name);
T
Tejun Heo 已提交
1232 1233 1234
	else
		strncpy(buf, cft->name, CGROUP_FILE_NAME_MAX);
	return buf;
1235 1236
}

1237 1238 1239 1240
/**
 * cgroup_file_mode - deduce file mode of a control file
 * @cft: the control file in question
 *
1241
 * S_IRUGO for read, S_IWUSR for write.
1242 1243
 */
static umode_t cgroup_file_mode(const struct cftype *cft)
1244
{
1245
	umode_t mode = 0;
1246

1247 1248 1249
	if (cft->read_u64 || cft->read_s64 || cft->seq_show)
		mode |= S_IRUGO;

1250 1251 1252 1253 1254 1255
	if (cft->write_u64 || cft->write_s64 || cft->write) {
		if (cft->flags & CFTYPE_WORLD_WRITABLE)
			mode |= S_IWUGO;
		else
			mode |= S_IWUSR;
	}
1256 1257

	return mode;
1258 1259
}

1260
/**
1261
 * cgroup_calc_child_subsys_mask - calculate child_subsys_mask
1262
 * @cgrp: the target cgroup
1263
 * @subtree_control: the new subtree_control mask to consider
1264 1265 1266 1267 1268
 *
 * On the default hierarchy, a subsystem may request other subsystems to be
 * enabled together through its ->depends_on mask.  In such cases, more
 * subsystems than specified in "cgroup.subtree_control" may be enabled.
 *
1269 1270 1271
 * This function calculates which subsystems need to be enabled if
 * @subtree_control is to be applied to @cgrp.  The returned mask is always
 * a superset of @subtree_control and follows the usual hierarchy rules.
1272
 */
1273 1274
static unsigned long cgroup_calc_child_subsys_mask(struct cgroup *cgrp,
						  unsigned long subtree_control)
1275
{
1276
	struct cgroup *parent = cgroup_parent(cgrp);
1277
	unsigned long cur_ss_mask = subtree_control;
1278 1279 1280 1281 1282
	struct cgroup_subsys *ss;
	int ssid;

	lockdep_assert_held(&cgroup_mutex);

1283 1284
	if (!cgroup_on_dfl(cgrp))
		return cur_ss_mask;
1285 1286

	while (true) {
1287
		unsigned long new_ss_mask = cur_ss_mask;
1288

1289 1290
		for_each_subsys_which(ss, ssid, &cur_ss_mask)
			new_ss_mask |= ss->depends_on;
1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306

		/*
		 * Mask out subsystems which aren't available.  This can
		 * happen only if some depended-upon subsystems were bound
		 * to non-default hierarchies.
		 */
		if (parent)
			new_ss_mask &= parent->child_subsys_mask;
		else
			new_ss_mask &= cgrp->root->subsys_mask;

		if (new_ss_mask == cur_ss_mask)
			break;
		cur_ss_mask = new_ss_mask;
	}

1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320
	return cur_ss_mask;
}

/**
 * cgroup_refresh_child_subsys_mask - update child_subsys_mask
 * @cgrp: the target cgroup
 *
 * Update @cgrp->child_subsys_mask according to the current
 * @cgrp->subtree_control using cgroup_calc_child_subsys_mask().
 */
static void cgroup_refresh_child_subsys_mask(struct cgroup *cgrp)
{
	cgrp->child_subsys_mask =
		cgroup_calc_child_subsys_mask(cgrp, cgrp->subtree_control);
1321 1322
}

1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333
/**
 * cgroup_kn_unlock - unlocking helper for cgroup kernfs methods
 * @kn: the kernfs_node being serviced
 *
 * This helper undoes cgroup_kn_lock_live() and should be invoked before
 * the method finishes if locking succeeded.  Note that once this function
 * returns the cgroup returned by cgroup_kn_lock_live() may become
 * inaccessible any time.  If the caller intends to continue to access the
 * cgroup, it should pin it before invoking this function.
 */
static void cgroup_kn_unlock(struct kernfs_node *kn)
1334
{
1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345
	struct cgroup *cgrp;

	if (kernfs_type(kn) == KERNFS_DIR)
		cgrp = kn->priv;
	else
		cgrp = kn->parent->priv;

	mutex_unlock(&cgroup_mutex);

	kernfs_unbreak_active_protection(kn);
	cgroup_put(cgrp);
1346 1347
}

1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363
/**
 * cgroup_kn_lock_live - locking helper for cgroup kernfs methods
 * @kn: the kernfs_node being serviced
 *
 * This helper is to be used by a cgroup kernfs method currently servicing
 * @kn.  It breaks the active protection, performs cgroup locking and
 * verifies that the associated cgroup is alive.  Returns the cgroup if
 * alive; otherwise, %NULL.  A successful return should be undone by a
 * matching cgroup_kn_unlock() invocation.
 *
 * Any cgroup kernfs method implementation which requires locking the
 * associated cgroup should use this helper.  It avoids nesting cgroup
 * locking under kernfs active protection and allows all kernfs operations
 * including self-removal.
 */
static struct cgroup *cgroup_kn_lock_live(struct kernfs_node *kn)
T
Tejun Heo 已提交
1364
{
1365 1366 1367 1368 1369 1370
	struct cgroup *cgrp;

	if (kernfs_type(kn) == KERNFS_DIR)
		cgrp = kn->priv;
	else
		cgrp = kn->parent->priv;
T
Tejun Heo 已提交
1371

1372
	/*
1373
	 * We're gonna grab cgroup_mutex which nests outside kernfs
1374 1375 1376
	 * active_ref.  cgroup liveliness check alone provides enough
	 * protection against removal.  Ensure @cgrp stays accessible and
	 * break the active_ref protection.
1377
	 */
1378 1379
	if (!cgroup_tryget(cgrp))
		return NULL;
1380 1381
	kernfs_break_active_protection(kn);

T
Tejun Heo 已提交
1382
	mutex_lock(&cgroup_mutex);
T
Tejun Heo 已提交
1383

1384 1385 1386 1387 1388
	if (!cgroup_is_dead(cgrp))
		return cgrp;

	cgroup_kn_unlock(kn);
	return NULL;
1389
}
T
Tejun Heo 已提交
1390

1391
static void cgroup_rm_file(struct cgroup *cgrp, const struct cftype *cft)
T
Tejun Heo 已提交
1392
{
T
Tejun Heo 已提交
1393
	char name[CGROUP_FILE_NAME_MAX];
T
Tejun Heo 已提交
1394

1395
	lockdep_assert_held(&cgroup_mutex);
T
Tejun Heo 已提交
1396
	kernfs_remove_by_name(cgrp->kn, cgroup_file_name(cgrp, cft, name));
T
Tejun Heo 已提交
1397 1398
}

1399
/**
1400 1401 1402
 * css_clear_dir - remove subsys files in a cgroup directory
 * @css: taget css
 * @cgrp_override: specify if target cgroup is different from css->cgroup
1403
 */
1404 1405
static void css_clear_dir(struct cgroup_subsys_state *css,
			  struct cgroup *cgrp_override)
T
Tejun Heo 已提交
1406
{
1407 1408
	struct cgroup *cgrp = cgrp_override ?: css->cgroup;
	struct cftype *cfts;
T
Tejun Heo 已提交
1409

1410 1411
	list_for_each_entry(cfts, &css->ss->cfts, node)
		cgroup_addrm_files(css, cgrp, cfts, false);
1412 1413
}

1414
/**
1415 1416 1417
 * css_populate_dir - create subsys files in a cgroup directory
 * @css: target css
 * @cgrp_overried: specify if target cgroup is different from css->cgroup
1418 1419 1420
 *
 * On failure, no file is added.
 */
1421 1422
static int css_populate_dir(struct cgroup_subsys_state *css,
			    struct cgroup *cgrp_override)
1423
{
1424 1425 1426
	struct cgroup *cgrp = cgrp_override ?: css->cgroup;
	struct cftype *cfts, *failed_cfts;
	int ret;
1427

1428 1429 1430 1431 1432
	if (!css->ss) {
		if (cgroup_on_dfl(cgrp))
			cfts = cgroup_dfl_base_files;
		else
			cfts = cgroup_legacy_base_files;
1433

1434 1435
		return cgroup_addrm_files(&cgrp->self, cgrp, cfts, true);
	}
1436

1437 1438 1439 1440 1441
	list_for_each_entry(cfts, &css->ss->cfts, node) {
		ret = cgroup_addrm_files(css, cgrp, cfts, true);
		if (ret < 0) {
			failed_cfts = cfts;
			goto err;
1442 1443 1444 1445
		}
	}
	return 0;
err:
1446 1447 1448 1449 1450
	list_for_each_entry(cfts, &css->ss->cfts, node) {
		if (cfts == failed_cfts)
			break;
		cgroup_addrm_files(css, cgrp, cfts, false);
	}
1451 1452 1453
	return ret;
}

1454 1455
static int rebind_subsystems(struct cgroup_root *dst_root,
			     unsigned long ss_mask)
1456
{
1457
	struct cgroup *dcgrp = &dst_root->cgrp;
1458
	struct cgroup_subsys *ss;
1459
	unsigned long tmp_ss_mask;
T
Tejun Heo 已提交
1460
	int ssid, i, ret;
1461

T
Tejun Heo 已提交
1462
	lockdep_assert_held(&cgroup_mutex);
1463

1464
	for_each_subsys_which(ss, ssid, &ss_mask) {
1465 1466
		/* if @ss has non-root csses attached to it, can't move */
		if (css_next_child(NULL, cgroup_css(&ss->root->cgrp, ss)))
T
Tejun Heo 已提交
1467
			return -EBUSY;
1468

1469
		/* can't move between two non-dummy roots either */
1470
		if (ss->root != &cgrp_dfl_root && dst_root != &cgrp_dfl_root)
1471
			return -EBUSY;
1472 1473
	}

1474 1475 1476 1477 1478
	/* skip creating root files on dfl_root for inhibited subsystems */
	tmp_ss_mask = ss_mask;
	if (dst_root == &cgrp_dfl_root)
		tmp_ss_mask &= ~cgrp_dfl_root_inhibit_ss_mask;

1479 1480 1481 1482 1483 1484 1485
	for_each_subsys_which(ss, ssid, &tmp_ss_mask) {
		struct cgroup *scgrp = &ss->root->cgrp;
		int tssid;

		ret = css_populate_dir(cgroup_css(scgrp, ss), dcgrp);
		if (!ret)
			continue;
1486

T
Tejun Heo 已提交
1487 1488 1489 1490 1491 1492
		/*
		 * Rebinding back to the default root is not allowed to
		 * fail.  Using both default and non-default roots should
		 * be rare.  Moving subsystems back and forth even more so.
		 * Just warn about it and continue.
		 */
1493 1494 1495 1496 1497 1498 1499
		if (dst_root == &cgrp_dfl_root) {
			if (cgrp_dfl_root_visible) {
				pr_warn("failed to create files (%d) while rebinding 0x%lx to default root\n",
					ret, ss_mask);
				pr_warn("you may retry by moving them to a different hierarchy and unbinding\n");
			}
			continue;
T
Tejun Heo 已提交
1500
		}
1501 1502 1503 1504 1505 1506 1507

		for_each_subsys_which(ss, tssid, &tmp_ss_mask) {
			if (tssid == ssid)
				break;
			css_clear_dir(cgroup_css(scgrp, ss), dcgrp);
		}
		return ret;
1508
	}
1509 1510 1511 1512 1513

	/*
	 * Nothing can fail from this point on.  Remove files for the
	 * removed subsystems and rebind each subsystem.
	 */
1514
	for_each_subsys_which(ss, ssid, &ss_mask) {
1515 1516 1517
		struct cgroup_root *src_root = ss->root;
		struct cgroup *scgrp = &src_root->cgrp;
		struct cgroup_subsys_state *css = cgroup_css(scgrp, ss);
T
Tejun Heo 已提交
1518
		struct css_set *cset;
1519

1520
		WARN_ON(!css || cgroup_css(dcgrp, ss));
1521

1522 1523
		css_clear_dir(css, NULL);

1524 1525
		RCU_INIT_POINTER(scgrp->subsys[ssid], NULL);
		rcu_assign_pointer(dcgrp->subsys[ssid], css);
1526
		ss->root = dst_root;
1527
		css->cgroup = dcgrp;
1528

1529
		spin_lock_bh(&css_set_lock);
T
Tejun Heo 已提交
1530 1531
		hash_for_each(css_set_table, i, cset, hlist)
			list_move_tail(&cset->e_cset_node[ss->id],
1532
				       &dcgrp->e_csets[ss->id]);
1533
		spin_unlock_bh(&css_set_lock);
T
Tejun Heo 已提交
1534

1535
		src_root->subsys_mask &= ~(1 << ssid);
1536 1537
		scgrp->subtree_control &= ~(1 << ssid);
		cgroup_refresh_child_subsys_mask(scgrp);
1538

1539
		/* default hierarchy doesn't enable controllers by default */
1540
		dst_root->subsys_mask |= 1 << ssid;
1541 1542 1543
		if (dst_root == &cgrp_dfl_root) {
			static_branch_enable(cgroup_subsys_on_dfl_key[ssid]);
		} else {
1544 1545
			dcgrp->subtree_control |= 1 << ssid;
			cgroup_refresh_child_subsys_mask(dcgrp);
1546
			static_branch_disable(cgroup_subsys_on_dfl_key[ssid]);
1547
		}
1548

1549 1550
		if (ss->bind)
			ss->bind(css);
1551 1552
	}

1553
	kernfs_activate(dcgrp->kn);
1554 1555 1556
	return 0;
}

T
Tejun Heo 已提交
1557 1558
static int cgroup_show_options(struct seq_file *seq,
			       struct kernfs_root *kf_root)
1559
{
1560
	struct cgroup_root *root = cgroup_root_from_kf(kf_root);
1561
	struct cgroup_subsys *ss;
T
Tejun Heo 已提交
1562
	int ssid;
1563

1564 1565 1566
	if (root != &cgrp_dfl_root)
		for_each_subsys(ss, ssid)
			if (root->subsys_mask & (1 << ssid))
1567
				seq_show_option(seq, ss->legacy_name, NULL);
1568
	if (root->flags & CGRP_ROOT_NOPREFIX)
1569
		seq_puts(seq, ",noprefix");
1570
	if (root->flags & CGRP_ROOT_XATTR)
A
Aristeu Rozanski 已提交
1571
		seq_puts(seq, ",xattr");
1572 1573

	spin_lock(&release_agent_path_lock);
1574
	if (strlen(root->release_agent_path))
1575 1576
		seq_show_option(seq, "release_agent",
				root->release_agent_path);
1577 1578
	spin_unlock(&release_agent_path_lock);

1579
	if (test_bit(CGRP_CPUSET_CLONE_CHILDREN, &root->cgrp.flags))
1580
		seq_puts(seq, ",clone_children");
1581
	if (strlen(root->name))
1582
		seq_show_option(seq, "name", root->name);
1583 1584 1585 1586
	return 0;
}

struct cgroup_sb_opts {
1587
	unsigned long subsys_mask;
1588
	unsigned int flags;
1589
	char *release_agent;
1590
	bool cpuset_clone_children;
1591
	char *name;
1592 1593
	/* User explicitly requested empty subsystem */
	bool none;
1594 1595
};

B
Ben Blum 已提交
1596
static int parse_cgroupfs_options(char *data, struct cgroup_sb_opts *opts)
1597
{
1598 1599
	char *token, *o = data;
	bool all_ss = false, one_ss = false;
1600
	unsigned long mask = -1UL;
1601
	struct cgroup_subsys *ss;
1602
	int nr_opts = 0;
1603
	int i;
1604 1605

#ifdef CONFIG_CPUSETS
1606
	mask = ~(1U << cpuset_cgrp_id);
1607
#endif
1608

1609
	memset(opts, 0, sizeof(*opts));
1610 1611

	while ((token = strsep(&o, ",")) != NULL) {
1612 1613
		nr_opts++;

1614 1615
		if (!*token)
			return -EINVAL;
1616
		if (!strcmp(token, "none")) {
1617 1618
			/* Explicitly have no subsystems */
			opts->none = true;
1619 1620 1621 1622 1623 1624 1625 1626 1627
			continue;
		}
		if (!strcmp(token, "all")) {
			/* Mutually exclusive option 'all' + subsystem name */
			if (one_ss)
				return -EINVAL;
			all_ss = true;
			continue;
		}
1628 1629 1630 1631
		if (!strcmp(token, "__DEVEL__sane_behavior")) {
			opts->flags |= CGRP_ROOT_SANE_BEHAVIOR;
			continue;
		}
1632
		if (!strcmp(token, "noprefix")) {
1633
			opts->flags |= CGRP_ROOT_NOPREFIX;
1634 1635 1636
			continue;
		}
		if (!strcmp(token, "clone_children")) {
1637
			opts->cpuset_clone_children = true;
1638 1639
			continue;
		}
A
Aristeu Rozanski 已提交
1640
		if (!strcmp(token, "xattr")) {
1641
			opts->flags |= CGRP_ROOT_XATTR;
A
Aristeu Rozanski 已提交
1642 1643
			continue;
		}
1644
		if (!strncmp(token, "release_agent=", 14)) {
1645 1646 1647
			/* Specifying two release agents is forbidden */
			if (opts->release_agent)
				return -EINVAL;
1648
			opts->release_agent =
1649
				kstrndup(token + 14, PATH_MAX - 1, GFP_KERNEL);
1650 1651
			if (!opts->release_agent)
				return -ENOMEM;
1652 1653 1654
			continue;
		}
		if (!strncmp(token, "name=", 5)) {
1655 1656 1657 1658 1659 1660 1661 1662 1663 1664 1665 1666 1667 1668 1669 1670 1671
			const char *name = token + 5;
			/* Can't specify an empty name */
			if (!strlen(name))
				return -EINVAL;
			/* Must match [\w.-]+ */
			for (i = 0; i < strlen(name); i++) {
				char c = name[i];
				if (isalnum(c))
					continue;
				if ((c == '.') || (c == '-') || (c == '_'))
					continue;
				return -EINVAL;
			}
			/* Specifying two names is forbidden */
			if (opts->name)
				return -EINVAL;
			opts->name = kstrndup(name,
1672
					      MAX_CGROUP_ROOT_NAMELEN - 1,
1673 1674 1675
					      GFP_KERNEL);
			if (!opts->name)
				return -ENOMEM;
1676 1677 1678 1679

			continue;
		}

1680
		for_each_subsys(ss, i) {
1681
			if (strcmp(token, ss->legacy_name))
1682
				continue;
1683
			if (!cgroup_ssid_enabled(i))
1684 1685 1686 1687 1688
				continue;

			/* Mutually exclusive option 'all' + subsystem name */
			if (all_ss)
				return -EINVAL;
1689
			opts->subsys_mask |= (1 << i);
1690 1691 1692 1693 1694 1695 1696 1697
			one_ss = true;

			break;
		}
		if (i == CGROUP_SUBSYS_COUNT)
			return -ENOENT;
	}

1698
	if (opts->flags & CGRP_ROOT_SANE_BEHAVIOR) {
1699
		pr_warn("sane_behavior: this is still under development and its behaviors will change, proceed at your own risk\n");
1700 1701
		if (nr_opts != 1) {
			pr_err("sane_behavior: no other mount options allowed\n");
1702 1703
			return -EINVAL;
		}
1704
		return 0;
1705 1706
	}

1707 1708 1709 1710 1711 1712 1713
	/*
	 * If the 'all' option was specified select all the subsystems,
	 * otherwise if 'none', 'name=' and a subsystem name options were
	 * not specified, let's default to 'all'
	 */
	if (all_ss || (!one_ss && !opts->none && !opts->name))
		for_each_subsys(ss, i)
1714
			if (cgroup_ssid_enabled(i))
1715 1716 1717 1718 1719 1720 1721 1722 1723
				opts->subsys_mask |= (1 << i);

	/*
	 * We either have to specify by name or by subsystems. (So all
	 * empty hierarchies must have a name).
	 */
	if (!opts->subsys_mask && !opts->name)
		return -EINVAL;

1724 1725 1726 1727 1728
	/*
	 * Option noprefix was introduced just for backward compatibility
	 * with the old cpuset, so we allow noprefix only if mounting just
	 * the cpuset subsystem.
	 */
1729
	if ((opts->flags & CGRP_ROOT_NOPREFIX) && (opts->subsys_mask & mask))
1730 1731
		return -EINVAL;

1732
	/* Can't specify "none" and some subsystems */
1733
	if (opts->subsys_mask && opts->none)
1734 1735
		return -EINVAL;

1736 1737 1738
	return 0;
}

T
Tejun Heo 已提交
1739
static int cgroup_remount(struct kernfs_root *kf_root, int *flags, char *data)
1740 1741
{
	int ret = 0;
1742
	struct cgroup_root *root = cgroup_root_from_kf(kf_root);
1743
	struct cgroup_sb_opts opts;
1744
	unsigned long added_mask, removed_mask;
1745

1746 1747
	if (root == &cgrp_dfl_root) {
		pr_err("remount is not allowed\n");
1748 1749 1750
		return -EINVAL;
	}

1751 1752 1753 1754 1755 1756 1757
	mutex_lock(&cgroup_mutex);

	/* See what subsystems are wanted */
	ret = parse_cgroupfs_options(data, &opts);
	if (ret)
		goto out_unlock;

1758
	if (opts.subsys_mask != root->subsys_mask || opts.release_agent)
1759
		pr_warn("option changes via remount are deprecated (pid=%d comm=%s)\n",
1760
			task_tgid_nr(current), current->comm);
1761

1762 1763
	added_mask = opts.subsys_mask & ~root->subsys_mask;
	removed_mask = root->subsys_mask & ~opts.subsys_mask;
1764

B
Ben Blum 已提交
1765
	/* Don't allow flags or name to change at remount */
T
Tejun Heo 已提交
1766
	if ((opts.flags ^ root->flags) ||
B
Ben Blum 已提交
1767
	    (opts.name && strcmp(opts.name, root->name))) {
1768
		pr_err("option or name mismatch, new: 0x%x \"%s\", old: 0x%x \"%s\"\n",
T
Tejun Heo 已提交
1769
		       opts.flags, opts.name ?: "", root->flags, root->name);
1770 1771 1772 1773
		ret = -EINVAL;
		goto out_unlock;
	}

1774
	/* remounting is not allowed for populated hierarchies */
1775
	if (!list_empty(&root->cgrp.self.children)) {
1776
		ret = -EBUSY;
1777
		goto out_unlock;
B
Ben Blum 已提交
1778
	}
1779

1780
	ret = rebind_subsystems(root, added_mask);
1781
	if (ret)
1782
		goto out_unlock;
1783

1784
	rebind_subsystems(&cgrp_dfl_root, removed_mask);
1785

1786 1787
	if (opts.release_agent) {
		spin_lock(&release_agent_path_lock);
1788
		strcpy(root->release_agent_path, opts.release_agent);
1789 1790
		spin_unlock(&release_agent_path_lock);
	}
1791
 out_unlock:
1792
	kfree(opts.release_agent);
1793
	kfree(opts.name);
1794 1795 1796 1797
	mutex_unlock(&cgroup_mutex);
	return ret;
}

1798 1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809
/*
 * To reduce the fork() overhead for systems that are not actually using
 * their cgroups capability, we don't maintain the lists running through
 * each css_set to its tasks until we see the list actually used - in other
 * words after the first mount.
 */
static bool use_task_css_set_links __read_mostly;

static void cgroup_enable_task_cg_lists(void)
{
	struct task_struct *p, *g;

1810
	spin_lock_bh(&css_set_lock);
1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831 1832

	if (use_task_css_set_links)
		goto out_unlock;

	use_task_css_set_links = true;

	/*
	 * We need tasklist_lock because RCU is not safe against
	 * while_each_thread(). Besides, a forking task that has passed
	 * cgroup_post_fork() without seeing use_task_css_set_links = 1
	 * is not guaranteed to have its child immediately visible in the
	 * tasklist if we walk through it with RCU.
	 */
	read_lock(&tasklist_lock);
	do_each_thread(g, p) {
		WARN_ON_ONCE(!list_empty(&p->cg_list) ||
			     task_css_set(p) != &init_css_set);

		/*
		 * We should check if the process is exiting, otherwise
		 * it will race with cgroup_exit() in that the list
		 * entry won't be deleted though the process has exited.
1833 1834
		 * Do it while holding siglock so that we don't end up
		 * racing against cgroup_exit().
1835
		 */
1836
		spin_lock_irq(&p->sighand->siglock);
1837 1838 1839
		if (!(p->flags & PF_EXITING)) {
			struct css_set *cset = task_css_set(p);

1840 1841
			if (!css_set_populated(cset))
				css_set_update_populated(cset, true);
1842
			list_add_tail(&p->cg_list, &cset->tasks);
1843 1844
			get_css_set(cset);
		}
1845
		spin_unlock_irq(&p->sighand->siglock);
1846 1847 1848
	} while_each_thread(g, p);
	read_unlock(&tasklist_lock);
out_unlock:
1849
	spin_unlock_bh(&css_set_lock);
1850
}
1851

1852 1853
static void init_cgroup_housekeeping(struct cgroup *cgrp)
{
T
Tejun Heo 已提交
1854 1855 1856
	struct cgroup_subsys *ss;
	int ssid;

1857 1858
	INIT_LIST_HEAD(&cgrp->self.sibling);
	INIT_LIST_HEAD(&cgrp->self.children);
1859
	INIT_LIST_HEAD(&cgrp->self.files);
1860
	INIT_LIST_HEAD(&cgrp->cset_links);
1861 1862
	INIT_LIST_HEAD(&cgrp->pidlists);
	mutex_init(&cgrp->pidlist_mutex);
1863
	cgrp->self.cgroup = cgrp;
1864
	cgrp->self.flags |= CSS_ONLINE;
T
Tejun Heo 已提交
1865 1866 1867

	for_each_subsys(ss, ssid)
		INIT_LIST_HEAD(&cgrp->e_csets[ssid]);
1868 1869

	init_waitqueue_head(&cgrp->offline_waitq);
1870
	INIT_WORK(&cgrp->release_agent_work, cgroup_release_agent);
1871
}
1872

1873
static void init_cgroup_root(struct cgroup_root *root,
1874
			     struct cgroup_sb_opts *opts)
1875
{
1876
	struct cgroup *cgrp = &root->cgrp;
1877

1878
	INIT_LIST_HEAD(&root->root_list);
1879
	atomic_set(&root->nr_cgrps, 1);
1880
	cgrp->root = root;
1881
	init_cgroup_housekeeping(cgrp);
1882
	idr_init(&root->cgroup_idr);
1883 1884 1885 1886 1887 1888

	root->flags = opts->flags;
	if (opts->release_agent)
		strcpy(root->release_agent_path, opts->release_agent);
	if (opts->name)
		strcpy(root->name, opts->name);
1889
	if (opts->cpuset_clone_children)
1890
		set_bit(CGRP_CPUSET_CLONE_CHILDREN, &root->cgrp.flags);
1891 1892
}

1893
static int cgroup_setup_root(struct cgroup_root *root, unsigned long ss_mask)
1894
{
1895
	LIST_HEAD(tmp_links);
1896
	struct cgroup *root_cgrp = &root->cgrp;
1897 1898
	struct css_set *cset;
	int i, ret;
1899

1900
	lockdep_assert_held(&cgroup_mutex);
1901

V
Vladimir Davydov 已提交
1902
	ret = cgroup_idr_alloc(&root->cgroup_idr, root_cgrp, 1, 2, GFP_KERNEL);
1903
	if (ret < 0)
T
Tejun Heo 已提交
1904
		goto out;
1905
	root_cgrp->id = ret;
1906

1907 1908
	ret = percpu_ref_init(&root_cgrp->self.refcnt, css_release, 0,
			      GFP_KERNEL);
1909 1910 1911
	if (ret)
		goto out;

1912
	/*
1913
	 * We're accessing css_set_count without locking css_set_lock here,
1914 1915 1916 1917 1918 1919
	 * but that's OK - it can only be increased by someone holding
	 * cgroup_lock, and that's us. The worst that can happen is that we
	 * have some link structures left over
	 */
	ret = allocate_cgrp_cset_links(css_set_count, &tmp_links);
	if (ret)
1920
		goto cancel_ref;
1921

1922
	ret = cgroup_init_root_id(root);
1923
	if (ret)
1924
		goto cancel_ref;
1925

T
Tejun Heo 已提交
1926 1927 1928 1929 1930 1931 1932 1933
	root->kf_root = kernfs_create_root(&cgroup_kf_syscall_ops,
					   KERNFS_ROOT_CREATE_DEACTIVATED,
					   root_cgrp);
	if (IS_ERR(root->kf_root)) {
		ret = PTR_ERR(root->kf_root);
		goto exit_root_id;
	}
	root_cgrp->kn = root->kf_root->kn;
1934

1935
	ret = css_populate_dir(&root_cgrp->self, NULL);
1936
	if (ret)
T
Tejun Heo 已提交
1937
		goto destroy_root;
1938

1939
	ret = rebind_subsystems(root, ss_mask);
1940
	if (ret)
T
Tejun Heo 已提交
1941
		goto destroy_root;
1942

1943 1944 1945 1946 1947 1948 1949
	/*
	 * There must be no failure case after here, since rebinding takes
	 * care of subsystems' refcounts, which are explicitly dropped in
	 * the failure exit path.
	 */
	list_add(&root->root_list, &cgroup_roots);
	cgroup_root_count++;
A
Al Viro 已提交
1950

1951
	/*
1952
	 * Link the root cgroup in this hierarchy into all the css_set
1953 1954
	 * objects.
	 */
1955
	spin_lock_bh(&css_set_lock);
1956
	hash_for_each(css_set_table, i, cset, hlist) {
1957
		link_css_set(&tmp_links, cset, root_cgrp);
1958 1959 1960
		if (css_set_populated(cset))
			cgroup_update_populated(root_cgrp, true);
	}
1961
	spin_unlock_bh(&css_set_lock);
1962

1963
	BUG_ON(!list_empty(&root_cgrp->self.children));
1964
	BUG_ON(atomic_read(&root->nr_cgrps) != 1);
1965

T
Tejun Heo 已提交
1966
	kernfs_activate(root_cgrp->kn);
1967
	ret = 0;
T
Tejun Heo 已提交
1968
	goto out;
1969

T
Tejun Heo 已提交
1970 1971 1972 1973
destroy_root:
	kernfs_destroy_root(root->kf_root);
	root->kf_root = NULL;
exit_root_id:
1974
	cgroup_exit_root_id(root);
1975
cancel_ref:
1976
	percpu_ref_exit(&root_cgrp->self.refcnt);
T
Tejun Heo 已提交
1977
out:
1978 1979
	free_cgrp_cset_links(&tmp_links);
	return ret;
1980 1981
}

A
Al Viro 已提交
1982
static struct dentry *cgroup_mount(struct file_system_type *fs_type,
1983
			 int flags, const char *unused_dev_name,
A
Al Viro 已提交
1984
			 void *data)
1985
{
1986
	struct super_block *pinned_sb = NULL;
1987
	struct cgroup_subsys *ss;
1988
	struct cgroup_root *root;
1989
	struct cgroup_sb_opts opts;
T
Tejun Heo 已提交
1990
	struct dentry *dentry;
1991
	int ret;
1992
	int i;
L
Li Zefan 已提交
1993
	bool new_sb;
1994

1995 1996 1997 1998 1999 2000
	/*
	 * The first time anyone tries to mount a cgroup, enable the list
	 * linking each css_set to its tasks and fix up all existing tasks.
	 */
	if (!use_task_css_set_links)
		cgroup_enable_task_cg_lists();
2001

B
Ben Blum 已提交
2002
	mutex_lock(&cgroup_mutex);
2003 2004

	/* First find the desired set of subsystems */
2005
	ret = parse_cgroupfs_options(data, &opts);
2006
	if (ret)
2007
		goto out_unlock;
2008

T
Tejun Heo 已提交
2009
	/* look for a matching existing root */
2010
	if (opts.flags & CGRP_ROOT_SANE_BEHAVIOR) {
T
Tejun Heo 已提交
2011 2012 2013 2014 2015
		cgrp_dfl_root_visible = true;
		root = &cgrp_dfl_root;
		cgroup_get(&root->cgrp);
		ret = 0;
		goto out_unlock;
2016 2017
	}

2018 2019 2020 2021 2022 2023 2024 2025 2026 2027 2028 2029 2030 2031 2032 2033 2034 2035 2036 2037 2038
	/*
	 * Destruction of cgroup root is asynchronous, so subsystems may
	 * still be dying after the previous unmount.  Let's drain the
	 * dying subsystems.  We just need to ensure that the ones
	 * unmounted previously finish dying and don't care about new ones
	 * starting.  Testing ref liveliness is good enough.
	 */
	for_each_subsys(ss, i) {
		if (!(opts.subsys_mask & (1 << i)) ||
		    ss->root == &cgrp_dfl_root)
			continue;

		if (!percpu_ref_tryget_live(&ss->root->cgrp.self.refcnt)) {
			mutex_unlock(&cgroup_mutex);
			msleep(10);
			ret = restart_syscall();
			goto out_free;
		}
		cgroup_put(&ss->root->cgrp);
	}

2039
	for_each_root(root) {
T
Tejun Heo 已提交
2040
		bool name_match = false;
2041

2042
		if (root == &cgrp_dfl_root)
2043
			continue;
2044

B
Ben Blum 已提交
2045
		/*
T
Tejun Heo 已提交
2046 2047 2048
		 * If we asked for a name then it must match.  Also, if
		 * name matches but sybsys_mask doesn't, we should fail.
		 * Remember whether name matched.
B
Ben Blum 已提交
2049
		 */
T
Tejun Heo 已提交
2050 2051 2052 2053 2054
		if (opts.name) {
			if (strcmp(opts.name, root->name))
				continue;
			name_match = true;
		}
2055

2056
		/*
T
Tejun Heo 已提交
2057 2058
		 * If we asked for subsystems (or explicitly for no
		 * subsystems) then they must match.
2059
		 */
T
Tejun Heo 已提交
2060
		if ((opts.subsys_mask || opts.none) &&
2061
		    (opts.subsys_mask != root->subsys_mask)) {
T
Tejun Heo 已提交
2062 2063 2064 2065 2066
			if (!name_match)
				continue;
			ret = -EBUSY;
			goto out_unlock;
		}
2067

2068 2069
		if (root->flags ^ opts.flags)
			pr_warn("new mount options do not match the existing superblock, will be ignored\n");
2070

T
Tejun Heo 已提交
2071
		/*
2072 2073 2074 2075 2076 2077 2078 2079 2080 2081
		 * We want to reuse @root whose lifetime is governed by its
		 * ->cgrp.  Let's check whether @root is alive and keep it
		 * that way.  As cgroup_kill_sb() can happen anytime, we
		 * want to block it by pinning the sb so that @root doesn't
		 * get killed before mount is complete.
		 *
		 * With the sb pinned, tryget_live can reliably indicate
		 * whether @root can be reused.  If it's being killed,
		 * drain it.  We can use wait_queue for the wait but this
		 * path is super cold.  Let's just sleep a bit and retry.
T
Tejun Heo 已提交
2082
		 */
2083 2084 2085
		pinned_sb = kernfs_pin_sb(root->kf_root, NULL);
		if (IS_ERR(pinned_sb) ||
		    !percpu_ref_tryget_live(&root->cgrp.self.refcnt)) {
T
Tejun Heo 已提交
2086
			mutex_unlock(&cgroup_mutex);
2087 2088
			if (!IS_ERR_OR_NULL(pinned_sb))
				deactivate_super(pinned_sb);
T
Tejun Heo 已提交
2089
			msleep(10);
2090 2091
			ret = restart_syscall();
			goto out_free;
T
Tejun Heo 已提交
2092
		}
2093

T
Tejun Heo 已提交
2094
		ret = 0;
T
Tejun Heo 已提交
2095
		goto out_unlock;
2096 2097
	}

2098
	/*
2099 2100 2101
	 * No such thing, create a new one.  name= matching without subsys
	 * specification is allowed for already existing hierarchies but we
	 * can't create new one without subsys specification.
2102
	 */
2103 2104 2105
	if (!opts.subsys_mask && !opts.none) {
		ret = -EINVAL;
		goto out_unlock;
2106 2107
	}

2108 2109 2110
	root = kzalloc(sizeof(*root), GFP_KERNEL);
	if (!root) {
		ret = -ENOMEM;
T
Tejun Heo 已提交
2111
		goto out_unlock;
2112
	}
2113

2114 2115
	init_cgroup_root(root, &opts);

T
Tejun Heo 已提交
2116
	ret = cgroup_setup_root(root, opts.subsys_mask);
T
Tejun Heo 已提交
2117 2118
	if (ret)
		cgroup_free_root(root);
2119

2120
out_unlock:
2121
	mutex_unlock(&cgroup_mutex);
2122
out_free:
2123 2124
	kfree(opts.release_agent);
	kfree(opts.name);
A
Aristeu Rozanski 已提交
2125

T
Tejun Heo 已提交
2126
	if (ret)
2127
		return ERR_PTR(ret);
T
Tejun Heo 已提交
2128

2129 2130
	dentry = kernfs_mount(fs_type, flags, root->kf_root,
				CGROUP_SUPER_MAGIC, &new_sb);
L
Li Zefan 已提交
2131
	if (IS_ERR(dentry) || !new_sb)
2132
		cgroup_put(&root->cgrp);
2133 2134 2135 2136 2137 2138 2139 2140 2141 2142

	/*
	 * If @pinned_sb, we're reusing an existing root and holding an
	 * extra ref on its sb.  Mount is complete.  Put the extra ref.
	 */
	if (pinned_sb) {
		WARN_ON(new_sb);
		deactivate_super(pinned_sb);
	}

T
Tejun Heo 已提交
2143 2144 2145 2146 2147 2148
	return dentry;
}

static void cgroup_kill_sb(struct super_block *sb)
{
	struct kernfs_root *kf_root = kernfs_root_from_sb(sb);
2149
	struct cgroup_root *root = cgroup_root_from_kf(kf_root);
T
Tejun Heo 已提交
2150

2151 2152 2153 2154
	/*
	 * If @root doesn't have any mounts or children, start killing it.
	 * This prevents new mounts by disabling percpu_ref_tryget_live().
	 * cgroup_mount() may wait for @root's release.
2155 2156
	 *
	 * And don't kill the default root.
2157
	 */
2158
	if (!list_empty(&root->cgrp.self.children) ||
2159
	    root == &cgrp_dfl_root)
2160 2161 2162 2163
		cgroup_put(&root->cgrp);
	else
		percpu_ref_kill(&root->cgrp.self.refcnt);

T
Tejun Heo 已提交
2164
	kernfs_kill_sb(sb);
2165 2166 2167 2168
}

static struct file_system_type cgroup_fs_type = {
	.name = "cgroup",
A
Al Viro 已提交
2169
	.mount = cgroup_mount,
2170 2171 2172
	.kill_sb = cgroup_kill_sb,
};

2173
/**
2174
 * task_cgroup_path - cgroup path of a task in the first cgroup hierarchy
2175 2176 2177 2178
 * @task: target task
 * @buf: the buffer to write the path into
 * @buflen: the length of the buffer
 *
2179 2180 2181 2182 2183
 * Determine @task's cgroup on the first (the one with the lowest non-zero
 * hierarchy_id) cgroup hierarchy and copy its path into @buf.  This
 * function grabs cgroup_mutex and shouldn't be used inside locks used by
 * cgroup controller callbacks.
 *
T
Tejun Heo 已提交
2184
 * Return value is the same as kernfs_path().
2185
 */
T
Tejun Heo 已提交
2186
char *task_cgroup_path(struct task_struct *task, char *buf, size_t buflen)
2187
{
2188
	struct cgroup_root *root;
2189
	struct cgroup *cgrp;
T
Tejun Heo 已提交
2190 2191
	int hierarchy_id = 1;
	char *path = NULL;
2192 2193

	mutex_lock(&cgroup_mutex);
2194
	spin_lock_bh(&css_set_lock);
2195

2196 2197
	root = idr_get_next(&cgroup_hierarchy_idr, &hierarchy_id);

2198 2199
	if (root) {
		cgrp = task_cgroup_from_root(task, root);
T
Tejun Heo 已提交
2200
		path = cgroup_path(cgrp, buf, buflen);
2201 2202
	} else {
		/* if no hierarchy exists, everyone is in "/" */
T
Tejun Heo 已提交
2203 2204
		if (strlcpy(buf, "/", buflen) < buflen)
			path = buf;
2205 2206
	}

2207
	spin_unlock_bh(&css_set_lock);
2208
	mutex_unlock(&cgroup_mutex);
T
Tejun Heo 已提交
2209
	return path;
2210
}
2211
EXPORT_SYMBOL_GPL(task_cgroup_path);
2212

2213
/* used to track tasks and other necessary states during migration */
2214
struct cgroup_taskset {
2215 2216 2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228 2229 2230 2231 2232
	/* the src and dst cset list running through cset->mg_node */
	struct list_head	src_csets;
	struct list_head	dst_csets;

	/*
	 * Fields for cgroup_taskset_*() iteration.
	 *
	 * Before migration is committed, the target migration tasks are on
	 * ->mg_tasks of the csets on ->src_csets.  After, on ->mg_tasks of
	 * the csets on ->dst_csets.  ->csets point to either ->src_csets
	 * or ->dst_csets depending on whether migration is committed.
	 *
	 * ->cur_csets and ->cur_task point to the current task position
	 * during iteration.
	 */
	struct list_head	*csets;
	struct css_set		*cur_cset;
	struct task_struct	*cur_task;
2233 2234
};

2235 2236 2237 2238 2239 2240 2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 2255
#define CGROUP_TASKSET_INIT(tset)	(struct cgroup_taskset){	\
	.src_csets		= LIST_HEAD_INIT(tset.src_csets),	\
	.dst_csets		= LIST_HEAD_INIT(tset.dst_csets),	\
	.csets			= &tset.src_csets,			\
}

/**
 * cgroup_taskset_add - try to add a migration target task to a taskset
 * @task: target task
 * @tset: target taskset
 *
 * Add @task, which is a migration target, to @tset.  This function becomes
 * noop if @task doesn't need to be migrated.  @task's css_set should have
 * been added as a migration source and @task->cg_list will be moved from
 * the css_set's tasks list to mg_tasks one.
 */
static void cgroup_taskset_add(struct task_struct *task,
			       struct cgroup_taskset *tset)
{
	struct css_set *cset;

2256
	lockdep_assert_held(&css_set_lock);
2257 2258 2259 2260 2261 2262 2263 2264 2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277

	/* @task either already exited or can't exit until the end */
	if (task->flags & PF_EXITING)
		return;

	/* leave @task alone if post_fork() hasn't linked it yet */
	if (list_empty(&task->cg_list))
		return;

	cset = task_css_set(task);
	if (!cset->mg_src_cgrp)
		return;

	list_move_tail(&task->cg_list, &cset->mg_tasks);
	if (list_empty(&cset->mg_node))
		list_add_tail(&cset->mg_node, &tset->src_csets);
	if (list_empty(&cset->mg_dst_cset->mg_node))
		list_move_tail(&cset->mg_dst_cset->mg_node,
			       &tset->dst_csets);
}

2278 2279 2280 2281 2282 2283 2284 2285
/**
 * cgroup_taskset_first - reset taskset and return the first task
 * @tset: taskset of interest
 *
 * @tset iteration is initialized and the first task is returned.
 */
struct task_struct *cgroup_taskset_first(struct cgroup_taskset *tset)
{
2286 2287 2288 2289
	tset->cur_cset = list_first_entry(tset->csets, struct css_set, mg_node);
	tset->cur_task = NULL;

	return cgroup_taskset_next(tset);
2290 2291 2292 2293 2294 2295 2296 2297 2298 2299 2300
}

/**
 * cgroup_taskset_next - iterate to the next task in taskset
 * @tset: taskset of interest
 *
 * Return the next task in @tset.  Iteration must have been initialized
 * with cgroup_taskset_first().
 */
struct task_struct *cgroup_taskset_next(struct cgroup_taskset *tset)
{
2301 2302
	struct css_set *cset = tset->cur_cset;
	struct task_struct *task = tset->cur_task;
2303

2304 2305 2306 2307 2308 2309
	while (&cset->mg_node != tset->csets) {
		if (!task)
			task = list_first_entry(&cset->mg_tasks,
						struct task_struct, cg_list);
		else
			task = list_next_entry(task, cg_list);
2310

2311 2312 2313 2314 2315
		if (&task->cg_list != &cset->mg_tasks) {
			tset->cur_cset = cset;
			tset->cur_task = task;
			return task;
		}
2316

2317 2318 2319
		cset = list_next_entry(cset, mg_node);
		task = NULL;
	}
2320

2321
	return NULL;
2322 2323
}

2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335 2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361
/**
 * cgroup_taskset_migrate - migrate a taskset to a cgroup
 * @tset: taget taskset
 * @dst_cgrp: destination cgroup
 *
 * Migrate tasks in @tset to @dst_cgrp.  This function fails iff one of the
 * ->can_attach callbacks fails and guarantees that either all or none of
 * the tasks in @tset are migrated.  @tset is consumed regardless of
 * success.
 */
static int cgroup_taskset_migrate(struct cgroup_taskset *tset,
				  struct cgroup *dst_cgrp)
{
	struct cgroup_subsys_state *css, *failed_css = NULL;
	struct task_struct *task, *tmp_task;
	struct css_set *cset, *tmp_cset;
	int i, ret;

	/* methods shouldn't be called if no task is actually migrating */
	if (list_empty(&tset->src_csets))
		return 0;

	/* check that we can legitimately attach to the cgroup */
	for_each_e_css(css, i, dst_cgrp) {
		if (css->ss->can_attach) {
			ret = css->ss->can_attach(css, tset);
			if (ret) {
				failed_css = css;
				goto out_cancel_attach;
			}
		}
	}

	/*
	 * Now that we're guaranteed success, proceed to move all tasks to
	 * the new cgroup.  There are no failure cases after here, so this
	 * is the commit point.
	 */
2362
	spin_lock_bh(&css_set_lock);
2363
	list_for_each_entry(cset, &tset->src_csets, mg_node) {
T
Tejun Heo 已提交
2364 2365 2366 2367 2368 2369 2370 2371
		list_for_each_entry_safe(task, tmp_task, &cset->mg_tasks, cg_list) {
			struct css_set *from_cset = task_css_set(task);
			struct css_set *to_cset = cset->mg_dst_cset;

			get_css_set(to_cset);
			css_set_move_task(task, from_cset, to_cset, true);
			put_css_set_locked(from_cset);
		}
2372
	}
2373
	spin_unlock_bh(&css_set_lock);
2374 2375 2376 2377 2378 2379 2380 2381 2382 2383 2384 2385 2386 2387 2388 2389 2390 2391 2392 2393 2394 2395 2396

	/*
	 * Migration is committed, all target tasks are now on dst_csets.
	 * Nothing is sensitive to fork() after this point.  Notify
	 * controllers that migration is complete.
	 */
	tset->csets = &tset->dst_csets;

	for_each_e_css(css, i, dst_cgrp)
		if (css->ss->attach)
			css->ss->attach(css, tset);

	ret = 0;
	goto out_release_tset;

out_cancel_attach:
	for_each_e_css(css, i, dst_cgrp) {
		if (css == failed_css)
			break;
		if (css->ss->cancel_attach)
			css->ss->cancel_attach(css, tset);
	}
out_release_tset:
2397
	spin_lock_bh(&css_set_lock);
2398 2399 2400 2401 2402
	list_splice_init(&tset->dst_csets, &tset->src_csets);
	list_for_each_entry_safe(cset, tmp_cset, &tset->src_csets, mg_node) {
		list_splice_tail_init(&cset->mg_tasks, &cset->tasks);
		list_del_init(&cset->mg_node);
	}
2403
	spin_unlock_bh(&css_set_lock);
2404 2405 2406
	return ret;
}

L
Li Zefan 已提交
2407
/**
2408 2409
 * cgroup_migrate_finish - cleanup after attach
 * @preloaded_csets: list of preloaded css_sets
B
Ben Blum 已提交
2410
 *
2411 2412
 * Undo cgroup_migrate_add_src() and cgroup_migrate_prepare_dst().  See
 * those functions for details.
B
Ben Blum 已提交
2413
 */
2414
static void cgroup_migrate_finish(struct list_head *preloaded_csets)
B
Ben Blum 已提交
2415
{
2416
	struct css_set *cset, *tmp_cset;
B
Ben Blum 已提交
2417

2418 2419
	lockdep_assert_held(&cgroup_mutex);

2420
	spin_lock_bh(&css_set_lock);
2421 2422 2423 2424
	list_for_each_entry_safe(cset, tmp_cset, preloaded_csets, mg_preload_node) {
		cset->mg_src_cgrp = NULL;
		cset->mg_dst_cset = NULL;
		list_del_init(&cset->mg_preload_node);
Z
Zefan Li 已提交
2425
		put_css_set_locked(cset);
2426
	}
2427
	spin_unlock_bh(&css_set_lock);
2428 2429 2430 2431 2432 2433 2434 2435 2436 2437 2438 2439
}

/**
 * cgroup_migrate_add_src - add a migration source css_set
 * @src_cset: the source css_set to add
 * @dst_cgrp: the destination cgroup
 * @preloaded_csets: list of preloaded css_sets
 *
 * Tasks belonging to @src_cset are about to be migrated to @dst_cgrp.  Pin
 * @src_cset and add it to @preloaded_csets, which should later be cleaned
 * up by cgroup_migrate_finish().
 *
2440 2441 2442 2443 2444
 * This function may be called without holding cgroup_threadgroup_rwsem
 * even if the target is a process.  Threads may be created and destroyed
 * but as long as cgroup_mutex is not dropped, no new css_set can be put
 * into play and the preloaded css_sets are guaranteed to cover all
 * migrations.
2445 2446 2447 2448 2449 2450 2451 2452
 */
static void cgroup_migrate_add_src(struct css_set *src_cset,
				   struct cgroup *dst_cgrp,
				   struct list_head *preloaded_csets)
{
	struct cgroup *src_cgrp;

	lockdep_assert_held(&cgroup_mutex);
2453
	lockdep_assert_held(&css_set_lock);
2454 2455 2456 2457 2458 2459 2460 2461 2462 2463 2464 2465 2466 2467 2468 2469 2470

	src_cgrp = cset_cgroup_from_root(src_cset, dst_cgrp->root);

	if (!list_empty(&src_cset->mg_preload_node))
		return;

	WARN_ON(src_cset->mg_src_cgrp);
	WARN_ON(!list_empty(&src_cset->mg_tasks));
	WARN_ON(!list_empty(&src_cset->mg_node));

	src_cset->mg_src_cgrp = src_cgrp;
	get_css_set(src_cset);
	list_add(&src_cset->mg_preload_node, preloaded_csets);
}

/**
 * cgroup_migrate_prepare_dst - prepare destination css_sets for migration
2471
 * @dst_cgrp: the destination cgroup (may be %NULL)
2472 2473 2474 2475
 * @preloaded_csets: list of preloaded source css_sets
 *
 * Tasks are about to be moved to @dst_cgrp and all the source css_sets
 * have been preloaded to @preloaded_csets.  This function looks up and
2476 2477 2478
 * pins all destination css_sets, links each to its source, and append them
 * to @preloaded_csets.  If @dst_cgrp is %NULL, the destination of each
 * source css_set is assumed to be its cgroup on the default hierarchy.
2479 2480 2481 2482 2483 2484 2485 2486 2487 2488
 *
 * This function must be called after cgroup_migrate_add_src() has been
 * called on each migration source css_set.  After migration is performed
 * using cgroup_migrate(), cgroup_migrate_finish() must be called on
 * @preloaded_csets.
 */
static int cgroup_migrate_prepare_dst(struct cgroup *dst_cgrp,
				      struct list_head *preloaded_csets)
{
	LIST_HEAD(csets);
2489
	struct css_set *src_cset, *tmp_cset;
2490 2491 2492

	lockdep_assert_held(&cgroup_mutex);

2493 2494 2495 2496
	/*
	 * Except for the root, child_subsys_mask must be zero for a cgroup
	 * with tasks so that child cgroups don't compete against tasks.
	 */
T
Tejun Heo 已提交
2497
	if (dst_cgrp && cgroup_on_dfl(dst_cgrp) && cgroup_parent(dst_cgrp) &&
2498 2499 2500
	    dst_cgrp->child_subsys_mask)
		return -EBUSY;

2501
	/* look up the dst cset for each src cset and link it to src */
2502
	list_for_each_entry_safe(src_cset, tmp_cset, preloaded_csets, mg_preload_node) {
2503 2504
		struct css_set *dst_cset;

2505 2506
		dst_cset = find_css_set(src_cset,
					dst_cgrp ?: src_cset->dfl_cgrp);
2507 2508 2509 2510
		if (!dst_cset)
			goto err;

		WARN_ON_ONCE(src_cset->mg_dst_cset || dst_cset->mg_dst_cset);
2511 2512 2513 2514 2515 2516 2517 2518 2519

		/*
		 * If src cset equals dst, it's noop.  Drop the src.
		 * cgroup_migrate() will skip the cset too.  Note that we
		 * can't handle src == dst as some nodes are used by both.
		 */
		if (src_cset == dst_cset) {
			src_cset->mg_src_cgrp = NULL;
			list_del_init(&src_cset->mg_preload_node);
Z
Zefan Li 已提交
2520 2521
			put_css_set(src_cset);
			put_css_set(dst_cset);
2522 2523 2524
			continue;
		}

2525 2526 2527 2528 2529
		src_cset->mg_dst_cset = dst_cset;

		if (list_empty(&dst_cset->mg_preload_node))
			list_add(&dst_cset->mg_preload_node, &csets);
		else
Z
Zefan Li 已提交
2530
			put_css_set(dst_cset);
2531 2532
	}

2533
	list_splice_tail(&csets, preloaded_csets);
2534 2535 2536 2537 2538 2539 2540 2541 2542 2543
	return 0;
err:
	cgroup_migrate_finish(&csets);
	return -ENOMEM;
}

/**
 * cgroup_migrate - migrate a process or task to a cgroup
 * @leader: the leader of the process or the task to migrate
 * @threadgroup: whether @leader points to the whole process or a single task
2544
 * @cgrp: the destination cgroup
2545 2546
 *
 * Migrate a process or task denoted by @leader to @cgrp.  If migrating a
2547
 * process, the caller must be holding cgroup_threadgroup_rwsem.  The
2548 2549 2550 2551 2552 2553 2554 2555 2556 2557
 * caller is also responsible for invoking cgroup_migrate_add_src() and
 * cgroup_migrate_prepare_dst() on the targets before invoking this
 * function and following up with cgroup_migrate_finish().
 *
 * As long as a controller's ->can_attach() doesn't fail, this function is
 * guaranteed to succeed.  This means that, excluding ->can_attach()
 * failure, when migrating multiple targets, the success or failure can be
 * decided for all targets by invoking group_migrate_prepare_dst() before
 * actually starting migrating.
 */
2558 2559
static int cgroup_migrate(struct task_struct *leader, bool threadgroup,
			  struct cgroup *cgrp)
B
Ben Blum 已提交
2560
{
2561 2562
	struct cgroup_taskset tset = CGROUP_TASKSET_INIT(tset);
	struct task_struct *task;
B
Ben Blum 已提交
2563

2564 2565 2566 2567 2568
	/*
	 * Prevent freeing of tasks while we take a snapshot. Tasks that are
	 * already PF_EXITING could be freed from underneath us unless we
	 * take an rcu_read_lock.
	 */
2569
	spin_lock_bh(&css_set_lock);
2570
	rcu_read_lock();
2571
	task = leader;
B
Ben Blum 已提交
2572
	do {
2573
		cgroup_taskset_add(task, &tset);
2574 2575
		if (!threadgroup)
			break;
2576
	} while_each_thread(leader, task);
2577
	rcu_read_unlock();
2578
	spin_unlock_bh(&css_set_lock);
B
Ben Blum 已提交
2579

2580
	return cgroup_taskset_migrate(&tset, cgrp);
B
Ben Blum 已提交
2581 2582
}

2583 2584 2585 2586 2587 2588
/**
 * cgroup_attach_task - attach a task or a whole threadgroup to a cgroup
 * @dst_cgrp: the cgroup to attach to
 * @leader: the task or the leader of the threadgroup to be attached
 * @threadgroup: attach the whole threadgroup?
 *
2589
 * Call holding cgroup_mutex and cgroup_threadgroup_rwsem.
2590 2591 2592 2593 2594 2595 2596 2597 2598
 */
static int cgroup_attach_task(struct cgroup *dst_cgrp,
			      struct task_struct *leader, bool threadgroup)
{
	LIST_HEAD(preloaded_csets);
	struct task_struct *task;
	int ret;

	/* look up all src csets */
2599
	spin_lock_bh(&css_set_lock);
2600 2601 2602 2603 2604 2605 2606 2607 2608
	rcu_read_lock();
	task = leader;
	do {
		cgroup_migrate_add_src(task_css_set(task), dst_cgrp,
				       &preloaded_csets);
		if (!threadgroup)
			break;
	} while_each_thread(leader, task);
	rcu_read_unlock();
2609
	spin_unlock_bh(&css_set_lock);
2610 2611 2612 2613

	/* prepare dst csets and commit */
	ret = cgroup_migrate_prepare_dst(dst_cgrp, &preloaded_csets);
	if (!ret)
2614
		ret = cgroup_migrate(leader, threadgroup, dst_cgrp);
2615 2616 2617

	cgroup_migrate_finish(&preloaded_csets);
	return ret;
B
Ben Blum 已提交
2618 2619
}

2620 2621 2622
static int cgroup_procs_write_permission(struct task_struct *task,
					 struct cgroup *dst_cgrp,
					 struct kernfs_open_file *of)
2623 2624 2625 2626 2627 2628 2629 2630 2631 2632 2633 2634 2635 2636
{
	const struct cred *cred = current_cred();
	const struct cred *tcred = get_task_cred(task);
	int ret = 0;

	/*
	 * even if we're attaching all tasks in the thread group, we only
	 * need to check permissions on one of them.
	 */
	if (!uid_eq(cred->euid, GLOBAL_ROOT_UID) &&
	    !uid_eq(cred->euid, tcred->uid) &&
	    !uid_eq(cred->euid, tcred->suid))
		ret = -EACCES;

2637 2638 2639 2640 2641
	if (!ret && cgroup_on_dfl(dst_cgrp)) {
		struct super_block *sb = of->file->f_path.dentry->d_sb;
		struct cgroup *cgrp;
		struct inode *inode;

2642
		spin_lock_bh(&css_set_lock);
2643
		cgrp = task_cgroup_from_root(task, &cgrp_dfl_root);
2644
		spin_unlock_bh(&css_set_lock);
2645 2646 2647 2648 2649

		while (!cgroup_is_descendant(dst_cgrp, cgrp))
			cgrp = cgroup_parent(cgrp);

		ret = -ENOMEM;
2650
		inode = kernfs_get_inode(sb, cgrp->procs_file.kn);
2651 2652 2653 2654 2655 2656
		if (inode) {
			ret = inode_permission(inode, MAY_WRITE);
			iput(inode);
		}
	}

2657 2658 2659 2660
	put_cred(tcred);
	return ret;
}

B
Ben Blum 已提交
2661 2662
/*
 * Find the task_struct of the task to attach by vpid and pass it along to the
2663
 * function to attach either it or all tasks in its threadgroup. Will lock
2664
 * cgroup_mutex and threadgroup.
2665
 */
2666 2667
static ssize_t __cgroup_procs_write(struct kernfs_open_file *of, char *buf,
				    size_t nbytes, loff_t off, bool threadgroup)
2668 2669
{
	struct task_struct *tsk;
2670
	struct cgroup *cgrp;
2671
	pid_t pid;
2672 2673
	int ret;

2674 2675 2676
	if (kstrtoint(strstrip(buf), 0, &pid) || pid < 0)
		return -EINVAL;

2677 2678
	cgrp = cgroup_kn_lock_live(of->kn);
	if (!cgrp)
B
Ben Blum 已提交
2679 2680
		return -ENODEV;

T
Tejun Heo 已提交
2681
	percpu_down_write(&cgroup_threadgroup_rwsem);
2682
	rcu_read_lock();
2683
	if (pid) {
2684
		tsk = find_task_by_vpid(pid);
B
Ben Blum 已提交
2685
		if (!tsk) {
S
SeongJae Park 已提交
2686
			ret = -ESRCH;
T
Tejun Heo 已提交
2687
			goto out_unlock_rcu;
2688
		}
2689
	} else {
2690
		tsk = current;
2691
	}
2692 2693

	if (threadgroup)
2694
		tsk = tsk->group_leader;
2695 2696

	/*
2697
	 * Workqueue threads may acquire PF_NO_SETAFFINITY and become
2698 2699 2700
	 * trapped in a cpuset, or RT worker may be born in a cgroup
	 * with no rt_runtime allocated.  Just say no.
	 */
2701
	if (tsk == kthreadd_task || (tsk->flags & PF_NO_SETAFFINITY)) {
2702
		ret = -EINVAL;
T
Tejun Heo 已提交
2703
		goto out_unlock_rcu;
2704 2705
	}

2706 2707 2708
	get_task_struct(tsk);
	rcu_read_unlock();

2709
	ret = cgroup_procs_write_permission(tsk, cgrp, of);
2710 2711
	if (!ret)
		ret = cgroup_attach_task(cgrp, tsk, threadgroup);
2712

2713
	put_task_struct(tsk);
T
Tejun Heo 已提交
2714 2715 2716 2717 2718 2719
	goto out_unlock_threadgroup;

out_unlock_rcu:
	rcu_read_unlock();
out_unlock_threadgroup:
	percpu_up_write(&cgroup_threadgroup_rwsem);
2720
	cgroup_kn_unlock(of->kn);
2721
	return ret ?: nbytes;
2722 2723
}

2724 2725 2726 2727 2728 2729 2730
/**
 * cgroup_attach_task_all - attach task 'tsk' to all cgroups of task 'from'
 * @from: attach to all cgroups of a given task
 * @tsk: the task to be attached
 */
int cgroup_attach_task_all(struct task_struct *from, struct task_struct *tsk)
{
2731
	struct cgroup_root *root;
2732 2733
	int retval = 0;

T
Tejun Heo 已提交
2734
	mutex_lock(&cgroup_mutex);
2735
	for_each_root(root) {
2736 2737
		struct cgroup *from_cgrp;

2738
		if (root == &cgrp_dfl_root)
2739 2740
			continue;

2741
		spin_lock_bh(&css_set_lock);
2742
		from_cgrp = task_cgroup_from_root(from, root);
2743
		spin_unlock_bh(&css_set_lock);
2744

L
Li Zefan 已提交
2745
		retval = cgroup_attach_task(from_cgrp, tsk, false);
2746 2747 2748
		if (retval)
			break;
	}
T
Tejun Heo 已提交
2749
	mutex_unlock(&cgroup_mutex);
2750 2751 2752 2753 2754

	return retval;
}
EXPORT_SYMBOL_GPL(cgroup_attach_task_all);

2755 2756
static ssize_t cgroup_tasks_write(struct kernfs_open_file *of,
				  char *buf, size_t nbytes, loff_t off)
B
Ben Blum 已提交
2757
{
2758
	return __cgroup_procs_write(of, buf, nbytes, off, false);
B
Ben Blum 已提交
2759 2760
}

2761 2762
static ssize_t cgroup_procs_write(struct kernfs_open_file *of,
				  char *buf, size_t nbytes, loff_t off)
2763
{
2764
	return __cgroup_procs_write(of, buf, nbytes, off, true);
2765 2766
}

2767 2768
static ssize_t cgroup_release_agent_write(struct kernfs_open_file *of,
					  char *buf, size_t nbytes, loff_t off)
2769
{
2770
	struct cgroup *cgrp;
2771

2772
	BUILD_BUG_ON(sizeof(cgrp->root->release_agent_path) < PATH_MAX);
2773

2774 2775
	cgrp = cgroup_kn_lock_live(of->kn);
	if (!cgrp)
2776
		return -ENODEV;
2777
	spin_lock(&release_agent_path_lock);
2778 2779
	strlcpy(cgrp->root->release_agent_path, strstrip(buf),
		sizeof(cgrp->root->release_agent_path));
2780
	spin_unlock(&release_agent_path_lock);
2781
	cgroup_kn_unlock(of->kn);
2782
	return nbytes;
2783 2784
}

2785
static int cgroup_release_agent_show(struct seq_file *seq, void *v)
2786
{
2787
	struct cgroup *cgrp = seq_css(seq)->cgroup;
2788

2789
	spin_lock(&release_agent_path_lock);
2790
	seq_puts(seq, cgrp->root->release_agent_path);
2791
	spin_unlock(&release_agent_path_lock);
2792 2793 2794 2795
	seq_putc(seq, '\n');
	return 0;
}

2796
static int cgroup_sane_behavior_show(struct seq_file *seq, void *v)
2797
{
2798
	seq_puts(seq, "0\n");
2799 2800 2801
	return 0;
}

2802
static void cgroup_print_ss_mask(struct seq_file *seq, unsigned long ss_mask)
2803
{
2804 2805 2806
	struct cgroup_subsys *ss;
	bool printed = false;
	int ssid;
2807

2808 2809 2810 2811 2812
	for_each_subsys_which(ss, ssid, &ss_mask) {
		if (printed)
			seq_putc(seq, ' ');
		seq_printf(seq, "%s", ss->name);
		printed = true;
2813
	}
2814 2815
	if (printed)
		seq_putc(seq, '\n');
2816 2817
}

2818 2819
/* show controllers which are currently attached to the default hierarchy */
static int cgroup_root_controllers_show(struct seq_file *seq, void *v)
2820
{
2821 2822
	struct cgroup *cgrp = seq_css(seq)->cgroup;

2823 2824
	cgroup_print_ss_mask(seq, cgrp->root->subsys_mask &
			     ~cgrp_dfl_root_inhibit_ss_mask);
2825
	return 0;
2826 2827
}

2828 2829
/* show controllers which are enabled from the parent */
static int cgroup_controllers_show(struct seq_file *seq, void *v)
2830
{
2831 2832
	struct cgroup *cgrp = seq_css(seq)->cgroup;

2833
	cgroup_print_ss_mask(seq, cgroup_parent(cgrp)->subtree_control);
2834
	return 0;
2835 2836
}

2837 2838
/* show controllers which are enabled for a given cgroup's children */
static int cgroup_subtree_control_show(struct seq_file *seq, void *v)
2839
{
2840 2841
	struct cgroup *cgrp = seq_css(seq)->cgroup;

2842
	cgroup_print_ss_mask(seq, cgrp->subtree_control);
2843 2844 2845 2846 2847 2848 2849 2850 2851 2852 2853 2854 2855 2856 2857
	return 0;
}

/**
 * cgroup_update_dfl_csses - update css assoc of a subtree in default hierarchy
 * @cgrp: root of the subtree to update csses for
 *
 * @cgrp's child_subsys_mask has changed and its subtree's (self excluded)
 * css associations need to be updated accordingly.  This function looks up
 * all css_sets which are attached to the subtree, creates the matching
 * updated css_sets and migrates the tasks to the new ones.
 */
static int cgroup_update_dfl_csses(struct cgroup *cgrp)
{
	LIST_HEAD(preloaded_csets);
2858
	struct cgroup_taskset tset = CGROUP_TASKSET_INIT(tset);
2859 2860 2861 2862 2863 2864
	struct cgroup_subsys_state *css;
	struct css_set *src_cset;
	int ret;

	lockdep_assert_held(&cgroup_mutex);

T
Tejun Heo 已提交
2865 2866
	percpu_down_write(&cgroup_threadgroup_rwsem);

2867
	/* look up all csses currently attached to @cgrp's subtree */
2868
	spin_lock_bh(&css_set_lock);
2869 2870 2871 2872 2873 2874 2875 2876 2877 2878 2879
	css_for_each_descendant_pre(css, cgroup_css(cgrp, NULL)) {
		struct cgrp_cset_link *link;

		/* self is not affected by child_subsys_mask change */
		if (css->cgroup == cgrp)
			continue;

		list_for_each_entry(link, &css->cgroup->cset_links, cset_link)
			cgroup_migrate_add_src(link->cset, cgrp,
					       &preloaded_csets);
	}
2880
	spin_unlock_bh(&css_set_lock);
2881 2882 2883 2884 2885 2886

	/* NULL dst indicates self on default hierarchy */
	ret = cgroup_migrate_prepare_dst(NULL, &preloaded_csets);
	if (ret)
		goto out_finish;

2887
	spin_lock_bh(&css_set_lock);
2888
	list_for_each_entry(src_cset, &preloaded_csets, mg_preload_node) {
2889
		struct task_struct *task, *ntask;
2890 2891 2892 2893 2894

		/* src_csets precede dst_csets, break on the first dst_cset */
		if (!src_cset->mg_src_cgrp)
			break;

2895 2896 2897
		/* all tasks in src_csets need to be migrated */
		list_for_each_entry_safe(task, ntask, &src_cset->tasks, cg_list)
			cgroup_taskset_add(task, &tset);
2898
	}
2899
	spin_unlock_bh(&css_set_lock);
2900

2901
	ret = cgroup_taskset_migrate(&tset, cgrp);
2902 2903
out_finish:
	cgroup_migrate_finish(&preloaded_csets);
T
Tejun Heo 已提交
2904
	percpu_up_write(&cgroup_threadgroup_rwsem);
2905 2906 2907 2908
	return ret;
}

/* change the enabled child controllers for a cgroup in the default hierarchy */
2909 2910 2911
static ssize_t cgroup_subtree_control_write(struct kernfs_open_file *of,
					    char *buf, size_t nbytes,
					    loff_t off)
2912
{
2913 2914
	unsigned long enable = 0, disable = 0;
	unsigned long css_enable, css_disable, old_sc, new_sc, old_ss, new_ss;
2915
	struct cgroup *cgrp, *child;
2916
	struct cgroup_subsys *ss;
2917
	char *tok;
2918 2919 2920
	int ssid, ret;

	/*
2921 2922
	 * Parse input - space separated list of subsystem names prefixed
	 * with either + or -.
2923
	 */
2924 2925
	buf = strstrip(buf);
	while ((tok = strsep(&buf, " "))) {
2926 2927
		unsigned long tmp_ss_mask = ~cgrp_dfl_root_inhibit_ss_mask;

2928 2929
		if (tok[0] == '\0')
			continue;
2930
		for_each_subsys_which(ss, ssid, &tmp_ss_mask) {
2931 2932
			if (!cgroup_ssid_enabled(ssid) ||
			    strcmp(tok + 1, ss->name))
2933 2934 2935
				continue;

			if (*tok == '+') {
2936 2937
				enable |= 1 << ssid;
				disable &= ~(1 << ssid);
2938
			} else if (*tok == '-') {
2939 2940
				disable |= 1 << ssid;
				enable &= ~(1 << ssid);
2941 2942 2943 2944 2945 2946 2947 2948 2949
			} else {
				return -EINVAL;
			}
			break;
		}
		if (ssid == CGROUP_SUBSYS_COUNT)
			return -EINVAL;
	}

2950 2951 2952
	cgrp = cgroup_kn_lock_live(of->kn);
	if (!cgrp)
		return -ENODEV;
2953 2954 2955

	for_each_subsys(ss, ssid) {
		if (enable & (1 << ssid)) {
2956
			if (cgrp->subtree_control & (1 << ssid)) {
2957 2958 2959 2960
				enable &= ~(1 << ssid);
				continue;
			}

2961 2962 2963
			/* unavailable or not enabled on the parent? */
			if (!(cgrp_dfl_root.subsys_mask & (1 << ssid)) ||
			    (cgroup_parent(cgrp) &&
2964
			     !(cgroup_parent(cgrp)->subtree_control & (1 << ssid)))) {
2965 2966 2967
				ret = -ENOENT;
				goto out_unlock;
			}
2968
		} else if (disable & (1 << ssid)) {
2969
			if (!(cgrp->subtree_control & (1 << ssid))) {
2970 2971 2972 2973 2974 2975
				disable &= ~(1 << ssid);
				continue;
			}

			/* a child has it enabled? */
			cgroup_for_each_live_child(child, cgrp) {
2976
				if (child->subtree_control & (1 << ssid)) {
2977
					ret = -EBUSY;
2978
					goto out_unlock;
2979 2980 2981 2982 2983 2984 2985
				}
			}
		}
	}

	if (!enable && !disable) {
		ret = 0;
2986
		goto out_unlock;
2987 2988 2989
	}

	/*
2990
	 * Except for the root, subtree_control must be zero for a cgroup
2991 2992
	 * with tasks so that child cgroups don't compete against tasks.
	 */
T
Tejun Heo 已提交
2993
	if (enable && cgroup_parent(cgrp) && !list_empty(&cgrp->cset_links)) {
2994 2995 2996 2997 2998
		ret = -EBUSY;
		goto out_unlock;
	}

	/*
2999 3000 3001 3002
	 * Update subsys masks and calculate what needs to be done.  More
	 * subsystems than specified may need to be enabled or disabled
	 * depending on subsystem dependencies.
	 */
3003 3004 3005 3006
	old_sc = cgrp->subtree_control;
	old_ss = cgrp->child_subsys_mask;
	new_sc = (old_sc | enable) & ~disable;
	new_ss = cgroup_calc_child_subsys_mask(cgrp, new_sc);
3007

3008 3009
	css_enable = ~old_ss & new_ss;
	css_disable = old_ss & ~new_ss;
3010 3011
	enable |= css_enable;
	disable |= css_disable;
3012

3013 3014 3015 3016 3017 3018
	/*
	 * Because css offlining is asynchronous, userland might try to
	 * re-enable the same controller while the previous instance is
	 * still around.  In such cases, wait till it's gone using
	 * offline_waitq.
	 */
3019
	for_each_subsys_which(ss, ssid, &css_enable) {
3020 3021 3022 3023 3024 3025 3026 3027 3028 3029 3030 3031 3032 3033 3034 3035 3036 3037
		cgroup_for_each_live_child(child, cgrp) {
			DEFINE_WAIT(wait);

			if (!cgroup_css(child, ss))
				continue;

			cgroup_get(child);
			prepare_to_wait(&child->offline_waitq, &wait,
					TASK_UNINTERRUPTIBLE);
			cgroup_kn_unlock(of->kn);
			schedule();
			finish_wait(&child->offline_waitq, &wait);
			cgroup_put(child);

			return restart_syscall();
		}
	}

3038 3039 3040
	cgrp->subtree_control = new_sc;
	cgrp->child_subsys_mask = new_ss;

3041 3042 3043 3044 3045
	/*
	 * Create new csses or make the existing ones visible.  A css is
	 * created invisible if it's being implicitly enabled through
	 * dependency.  An invisible css is made visible when the userland
	 * explicitly enables it.
3046 3047 3048 3049 3050 3051
	 */
	for_each_subsys(ss, ssid) {
		if (!(enable & (1 << ssid)))
			continue;

		cgroup_for_each_live_child(child, cgrp) {
3052 3053 3054 3055
			if (css_enable & (1 << ssid))
				ret = create_css(child, ss,
					cgrp->subtree_control & (1 << ssid));
			else
3056 3057
				ret = css_populate_dir(cgroup_css(child, ss),
						       NULL);
3058 3059 3060 3061 3062
			if (ret)
				goto err_undo_css;
		}
	}

3063 3064 3065 3066 3067
	/*
	 * At this point, cgroup_e_css() results reflect the new csses
	 * making the following cgroup_update_dfl_csses() properly update
	 * css associations of all tasks in the subtree.
	 */
3068 3069 3070 3071
	ret = cgroup_update_dfl_csses(cgrp);
	if (ret)
		goto err_undo_css;

3072 3073 3074
	/*
	 * All tasks are migrated out of disabled csses.  Kill or hide
	 * them.  A css is hidden when the userland requests it to be
3075 3076 3077 3078
	 * disabled while other subsystems are still depending on it.  The
	 * css must not actively control resources and be in the vanilla
	 * state if it's made visible again later.  Controllers which may
	 * be depended upon should provide ->css_reset() for this purpose.
3079
	 */
3080 3081 3082 3083
	for_each_subsys(ss, ssid) {
		if (!(disable & (1 << ssid)))
			continue;

3084
		cgroup_for_each_live_child(child, cgrp) {
3085 3086 3087 3088 3089
			struct cgroup_subsys_state *css = cgroup_css(child, ss);

			if (css_disable & (1 << ssid)) {
				kill_css(css);
			} else {
3090
				css_clear_dir(css, NULL);
3091 3092 3093
				if (ss->css_reset)
					ss->css_reset(css);
			}
3094
		}
3095 3096
	}

3097 3098 3099 3100 3101 3102 3103 3104 3105 3106 3107 3108 3109 3110 3111 3112 3113 3114
	/*
	 * The effective csses of all the descendants (excluding @cgrp) may
	 * have changed.  Subsystems can optionally subscribe to this event
	 * by implementing ->css_e_css_changed() which is invoked if any of
	 * the effective csses seen from the css's cgroup may have changed.
	 */
	for_each_subsys(ss, ssid) {
		struct cgroup_subsys_state *this_css = cgroup_css(cgrp, ss);
		struct cgroup_subsys_state *css;

		if (!ss->css_e_css_changed || !this_css)
			continue;

		css_for_each_descendant_pre(css, this_css)
			if (css != this_css)
				ss->css_e_css_changed(css);
	}

3115 3116 3117
	kernfs_activate(cgrp->kn);
	ret = 0;
out_unlock:
3118
	cgroup_kn_unlock(of->kn);
3119
	return ret ?: nbytes;
3120 3121

err_undo_css:
3122 3123
	cgrp->subtree_control = old_sc;
	cgrp->child_subsys_mask = old_ss;
3124 3125 3126 3127 3128 3129 3130

	for_each_subsys(ss, ssid) {
		if (!(enable & (1 << ssid)))
			continue;

		cgroup_for_each_live_child(child, cgrp) {
			struct cgroup_subsys_state *css = cgroup_css(child, ss);
3131 3132 3133 3134 3135

			if (!css)
				continue;

			if (css_enable & (1 << ssid))
3136
				kill_css(css);
3137
			else
3138
				css_clear_dir(css, NULL);
3139 3140 3141 3142 3143
		}
	}
	goto out_unlock;
}

3144
static int cgroup_events_show(struct seq_file *seq, void *v)
3145
{
3146
	seq_printf(seq, "populated %d\n",
3147
		   cgroup_is_populated(seq_css(seq)->cgroup));
3148 3149 3150
	return 0;
}

T
Tejun Heo 已提交
3151 3152
static ssize_t cgroup_file_write(struct kernfs_open_file *of, char *buf,
				 size_t nbytes, loff_t off)
3153
{
T
Tejun Heo 已提交
3154 3155 3156
	struct cgroup *cgrp = of->kn->parent->priv;
	struct cftype *cft = of->kn->priv;
	struct cgroup_subsys_state *css;
3157
	int ret;
3158

T
Tejun Heo 已提交
3159 3160 3161
	if (cft->write)
		return cft->write(of, buf, nbytes, off);

T
Tejun Heo 已提交
3162 3163 3164 3165 3166 3167 3168 3169 3170
	/*
	 * kernfs guarantees that a file isn't deleted with operations in
	 * flight, which means that the matching css is and stays alive and
	 * doesn't need to be pinned.  The RCU locking is not necessary
	 * either.  It's just for the convenience of using cgroup_css().
	 */
	rcu_read_lock();
	css = cgroup_css(cgrp, cft->ss);
	rcu_read_unlock();
3171

3172
	if (cft->write_u64) {
3173 3174 3175 3176 3177 3178 3179 3180 3181
		unsigned long long v;
		ret = kstrtoull(buf, 0, &v);
		if (!ret)
			ret = cft->write_u64(css, cft, v);
	} else if (cft->write_s64) {
		long long v;
		ret = kstrtoll(buf, 0, &v);
		if (!ret)
			ret = cft->write_s64(css, cft, v);
3182
	} else {
3183
		ret = -EINVAL;
3184
	}
T
Tejun Heo 已提交
3185

3186
	return ret ?: nbytes;
3187 3188
}

3189
static void *cgroup_seqfile_start(struct seq_file *seq, loff_t *ppos)
3190
{
T
Tejun Heo 已提交
3191
	return seq_cft(seq)->seq_start(seq, ppos);
3192 3193
}

3194
static void *cgroup_seqfile_next(struct seq_file *seq, void *v, loff_t *ppos)
3195
{
T
Tejun Heo 已提交
3196
	return seq_cft(seq)->seq_next(seq, v, ppos);
3197 3198
}

3199
static void cgroup_seqfile_stop(struct seq_file *seq, void *v)
3200
{
T
Tejun Heo 已提交
3201
	seq_cft(seq)->seq_stop(seq, v);
3202 3203
}

3204
static int cgroup_seqfile_show(struct seq_file *m, void *arg)
3205
{
3206 3207
	struct cftype *cft = seq_cft(m);
	struct cgroup_subsys_state *css = seq_css(m);
3208

3209 3210
	if (cft->seq_show)
		return cft->seq_show(m, arg);
3211

3212
	if (cft->read_u64)
3213 3214 3215 3216 3217 3218
		seq_printf(m, "%llu\n", cft->read_u64(css, cft));
	else if (cft->read_s64)
		seq_printf(m, "%lld\n", cft->read_s64(css, cft));
	else
		return -EINVAL;
	return 0;
3219 3220
}

T
Tejun Heo 已提交
3221 3222 3223 3224
static struct kernfs_ops cgroup_kf_single_ops = {
	.atomic_write_len	= PAGE_SIZE,
	.write			= cgroup_file_write,
	.seq_show		= cgroup_seqfile_show,
3225 3226
};

T
Tejun Heo 已提交
3227 3228 3229 3230 3231 3232 3233 3234
static struct kernfs_ops cgroup_kf_ops = {
	.atomic_write_len	= PAGE_SIZE,
	.write			= cgroup_file_write,
	.seq_start		= cgroup_seqfile_start,
	.seq_next		= cgroup_seqfile_next,
	.seq_stop		= cgroup_seqfile_stop,
	.seq_show		= cgroup_seqfile_show,
};
3235 3236 3237 3238

/*
 * cgroup_rename - Only allow simple rename of directories in place.
 */
T
Tejun Heo 已提交
3239 3240
static int cgroup_rename(struct kernfs_node *kn, struct kernfs_node *new_parent,
			 const char *new_name_str)
3241
{
T
Tejun Heo 已提交
3242
	struct cgroup *cgrp = kn->priv;
3243 3244
	int ret;

T
Tejun Heo 已提交
3245
	if (kernfs_type(kn) != KERNFS_DIR)
3246
		return -ENOTDIR;
T
Tejun Heo 已提交
3247
	if (kn->parent != new_parent)
3248
		return -EIO;
3249

3250 3251
	/*
	 * This isn't a proper migration and its usefulness is very
3252
	 * limited.  Disallow on the default hierarchy.
3253
	 */
3254
	if (cgroup_on_dfl(cgrp))
3255
		return -EPERM;
L
Li Zefan 已提交
3256

3257
	/*
T
Tejun Heo 已提交
3258
	 * We're gonna grab cgroup_mutex which nests outside kernfs
3259
	 * active_ref.  kernfs_rename() doesn't require active_ref
T
Tejun Heo 已提交
3260
	 * protection.  Break them before grabbing cgroup_mutex.
3261 3262 3263
	 */
	kernfs_break_active_protection(new_parent);
	kernfs_break_active_protection(kn);
L
Li Zefan 已提交
3264

T
Tejun Heo 已提交
3265
	mutex_lock(&cgroup_mutex);
L
Li Zefan 已提交
3266

T
Tejun Heo 已提交
3267
	ret = kernfs_rename(kn, new_parent, new_name_str);
L
Li Zefan 已提交
3268

T
Tejun Heo 已提交
3269
	mutex_unlock(&cgroup_mutex);
3270 3271 3272

	kernfs_unbreak_active_protection(kn);
	kernfs_unbreak_active_protection(new_parent);
T
Tejun Heo 已提交
3273
	return ret;
L
Li Zefan 已提交
3274 3275
}

3276 3277 3278 3279 3280 3281 3282 3283 3284 3285 3286 3287 3288 3289
/* set uid and gid of cgroup dirs and files to that of the creator */
static int cgroup_kn_set_ugid(struct kernfs_node *kn)
{
	struct iattr iattr = { .ia_valid = ATTR_UID | ATTR_GID,
			       .ia_uid = current_fsuid(),
			       .ia_gid = current_fsgid(), };

	if (uid_eq(iattr.ia_uid, GLOBAL_ROOT_UID) &&
	    gid_eq(iattr.ia_gid, GLOBAL_ROOT_GID))
		return 0;

	return kernfs_setattr(kn, &iattr);
}

3290 3291
static int cgroup_add_file(struct cgroup_subsys_state *css, struct cgroup *cgrp,
			   struct cftype *cft)
3292
{
T
Tejun Heo 已提交
3293
	char name[CGROUP_FILE_NAME_MAX];
T
Tejun Heo 已提交
3294 3295
	struct kernfs_node *kn;
	struct lock_class_key *key = NULL;
3296
	int ret;
T
Tejun Heo 已提交
3297

T
Tejun Heo 已提交
3298 3299 3300 3301 3302
#ifdef CONFIG_DEBUG_LOCK_ALLOC
	key = &cft->lockdep_key;
#endif
	kn = __kernfs_create_file(cgrp->kn, cgroup_file_name(cgrp, cft, name),
				  cgroup_file_mode(cft), 0, cft->kf_ops, cft,
T
Tejun Heo 已提交
3303
				  NULL, key);
3304 3305 3306 3307
	if (IS_ERR(kn))
		return PTR_ERR(kn);

	ret = cgroup_kn_set_ugid(kn);
3308
	if (ret) {
3309
		kernfs_remove(kn);
3310 3311 3312
		return ret;
	}

3313 3314 3315 3316 3317 3318 3319 3320
	if (cft->file_offset) {
		struct cgroup_file *cfile = (void *)css + cft->file_offset;

		kernfs_get(kn);
		cfile->kn = kn;
		list_add(&cfile->node, &css->files);
	}

3321
	return 0;
3322 3323
}

3324 3325
/**
 * cgroup_addrm_files - add or remove files to a cgroup directory
3326 3327
 * @css: the target css
 * @cgrp: the target cgroup (usually css->cgroup)
3328 3329 3330 3331
 * @cfts: array of cftypes to be added
 * @is_add: whether to add or remove
 *
 * Depending on @is_add, add or remove files defined by @cfts on @cgrp.
3332
 * For removals, this function never fails.
3333
 */
3334 3335
static int cgroup_addrm_files(struct cgroup_subsys_state *css,
			      struct cgroup *cgrp, struct cftype cfts[],
3336
			      bool is_add)
3337
{
3338
	struct cftype *cft, *cft_end = NULL;
3339 3340
	int ret;

3341
	lockdep_assert_held(&cgroup_mutex);
T
Tejun Heo 已提交
3342

3343 3344
restart:
	for (cft = cfts; cft != cft_end && cft->name[0] != '\0'; cft++) {
3345
		/* does cft->flags tell us to skip this file on @cgrp? */
3346
		if ((cft->flags & __CFTYPE_ONLY_ON_DFL) && !cgroup_on_dfl(cgrp))
T
Tejun Heo 已提交
3347
			continue;
3348
		if ((cft->flags & __CFTYPE_NOT_ON_DFL) && cgroup_on_dfl(cgrp))
3349
			continue;
T
Tejun Heo 已提交
3350
		if ((cft->flags & CFTYPE_NOT_ON_ROOT) && !cgroup_parent(cgrp))
3351
			continue;
T
Tejun Heo 已提交
3352
		if ((cft->flags & CFTYPE_ONLY_ON_ROOT) && cgroup_parent(cgrp))
3353 3354
			continue;

3355
		if (is_add) {
3356
			ret = cgroup_add_file(css, cgrp, cft);
3357
			if (ret) {
3358 3359
				pr_warn("%s: failed to add %s, err=%d\n",
					__func__, cft->name, ret);
3360 3361 3362
				cft_end = cft;
				is_add = false;
				goto restart;
3363
			}
3364 3365
		} else {
			cgroup_rm_file(cgrp, cft);
T
Tejun Heo 已提交
3366
		}
3367
	}
3368
	return 0;
3369 3370
}

3371
static int cgroup_apply_cftypes(struct cftype *cfts, bool is_add)
3372 3373
{
	LIST_HEAD(pending);
3374
	struct cgroup_subsys *ss = cfts[0].ss;
3375
	struct cgroup *root = &ss->root->cgrp;
3376
	struct cgroup_subsys_state *css;
3377
	int ret = 0;
3378

3379
	lockdep_assert_held(&cgroup_mutex);
3380 3381

	/* add/rm files for all cgroups created before */
3382
	css_for_each_descendant_pre(css, cgroup_css(root, ss)) {
3383 3384
		struct cgroup *cgrp = css->cgroup;

3385 3386 3387
		if (cgroup_is_dead(cgrp))
			continue;

3388
		ret = cgroup_addrm_files(css, cgrp, cfts, is_add);
3389 3390
		if (ret)
			break;
3391
	}
3392 3393 3394

	if (is_add && !ret)
		kernfs_activate(root->kn);
3395
	return ret;
3396 3397
}

3398
static void cgroup_exit_cftypes(struct cftype *cfts)
3399
{
3400
	struct cftype *cft;
3401

T
Tejun Heo 已提交
3402 3403 3404 3405 3406
	for (cft = cfts; cft->name[0] != '\0'; cft++) {
		/* free copy for custom atomic_write_len, see init_cftypes() */
		if (cft->max_write_len && cft->max_write_len != PAGE_SIZE)
			kfree(cft->kf_ops);
		cft->kf_ops = NULL;
3407
		cft->ss = NULL;
3408 3409

		/* revert flags set by cgroup core while adding @cfts */
3410
		cft->flags &= ~(__CFTYPE_ONLY_ON_DFL | __CFTYPE_NOT_ON_DFL);
T
Tejun Heo 已提交
3411
	}
3412 3413
}

T
Tejun Heo 已提交
3414
static int cgroup_init_cftypes(struct cgroup_subsys *ss, struct cftype *cfts)
3415 3416 3417
{
	struct cftype *cft;

T
Tejun Heo 已提交
3418 3419 3420
	for (cft = cfts; cft->name[0] != '\0'; cft++) {
		struct kernfs_ops *kf_ops;

T
Tejun Heo 已提交
3421 3422
		WARN_ON(cft->ss || cft->kf_ops);

T
Tejun Heo 已提交
3423 3424 3425 3426 3427 3428 3429 3430 3431 3432 3433 3434 3435 3436 3437 3438 3439
		if (cft->seq_start)
			kf_ops = &cgroup_kf_ops;
		else
			kf_ops = &cgroup_kf_single_ops;

		/*
		 * Ugh... if @cft wants a custom max_write_len, we need to
		 * make a copy of kf_ops to set its atomic_write_len.
		 */
		if (cft->max_write_len && cft->max_write_len != PAGE_SIZE) {
			kf_ops = kmemdup(kf_ops, sizeof(*kf_ops), GFP_KERNEL);
			if (!kf_ops) {
				cgroup_exit_cftypes(cfts);
				return -ENOMEM;
			}
			kf_ops->atomic_write_len = cft->max_write_len;
		}
3440

T
Tejun Heo 已提交
3441
		cft->kf_ops = kf_ops;
3442
		cft->ss = ss;
T
Tejun Heo 已提交
3443
	}
3444

T
Tejun Heo 已提交
3445
	return 0;
3446 3447
}

3448 3449
static int cgroup_rm_cftypes_locked(struct cftype *cfts)
{
3450
	lockdep_assert_held(&cgroup_mutex);
3451 3452 3453 3454 3455 3456 3457 3458

	if (!cfts || !cfts[0].ss)
		return -ENOENT;

	list_del(&cfts->node);
	cgroup_apply_cftypes(cfts, false);
	cgroup_exit_cftypes(cfts);
	return 0;
3459 3460
}

3461 3462 3463 3464
/**
 * cgroup_rm_cftypes - remove an array of cftypes from a subsystem
 * @cfts: zero-length name terminated array of cftypes
 *
3465 3466 3467
 * Unregister @cfts.  Files described by @cfts are removed from all
 * existing cgroups and all future cgroups won't have them either.  This
 * function can be called anytime whether @cfts' subsys is attached or not.
3468 3469
 *
 * Returns 0 on successful unregistration, -ENOENT if @cfts is not
3470
 * registered.
3471
 */
3472
int cgroup_rm_cftypes(struct cftype *cfts)
3473
{
3474
	int ret;
3475

3476
	mutex_lock(&cgroup_mutex);
3477
	ret = cgroup_rm_cftypes_locked(cfts);
3478
	mutex_unlock(&cgroup_mutex);
3479
	return ret;
T
Tejun Heo 已提交
3480 3481
}

3482 3483 3484 3485 3486 3487 3488 3489 3490 3491 3492 3493 3494 3495
/**
 * cgroup_add_cftypes - add an array of cftypes to a subsystem
 * @ss: target cgroup subsystem
 * @cfts: zero-length name terminated array of cftypes
 *
 * Register @cfts to @ss.  Files described by @cfts are created for all
 * existing cgroups to which @ss is attached and all future cgroups will
 * have them too.  This function can be called anytime whether @ss is
 * attached or not.
 *
 * Returns 0 on successful registration, -errno on failure.  Note that this
 * function currently returns 0 as long as @cfts registration is successful
 * even if some file creation attempts on existing cgroups fail.
 */
3496
static int cgroup_add_cftypes(struct cgroup_subsys *ss, struct cftype *cfts)
3497
{
3498
	int ret;
3499

3500
	if (!cgroup_ssid_enabled(ss->id))
3501 3502
		return 0;

3503 3504
	if (!cfts || cfts[0].name[0] == '\0')
		return 0;
3505

T
Tejun Heo 已提交
3506 3507 3508
	ret = cgroup_init_cftypes(ss, cfts);
	if (ret)
		return ret;
3509

3510
	mutex_lock(&cgroup_mutex);
3511

T
Tejun Heo 已提交
3512
	list_add_tail(&cfts->node, &ss->cfts);
3513
	ret = cgroup_apply_cftypes(cfts, true);
3514
	if (ret)
3515
		cgroup_rm_cftypes_locked(cfts);
3516

3517
	mutex_unlock(&cgroup_mutex);
3518
	return ret;
3519 3520
}

3521 3522 3523 3524 3525 3526 3527 3528 3529 3530 3531 3532 3533
/**
 * cgroup_add_dfl_cftypes - add an array of cftypes for default hierarchy
 * @ss: target cgroup subsystem
 * @cfts: zero-length name terminated array of cftypes
 *
 * Similar to cgroup_add_cftypes() but the added files are only used for
 * the default hierarchy.
 */
int cgroup_add_dfl_cftypes(struct cgroup_subsys *ss, struct cftype *cfts)
{
	struct cftype *cft;

	for (cft = cfts; cft && cft->name[0] != '\0'; cft++)
3534
		cft->flags |= __CFTYPE_ONLY_ON_DFL;
3535 3536 3537 3538 3539 3540 3541 3542 3543 3544 3545
	return cgroup_add_cftypes(ss, cfts);
}

/**
 * cgroup_add_legacy_cftypes - add an array of cftypes for legacy hierarchies
 * @ss: target cgroup subsystem
 * @cfts: zero-length name terminated array of cftypes
 *
 * Similar to cgroup_add_cftypes() but the added files are only used for
 * the legacy hierarchies.
 */
3546 3547
int cgroup_add_legacy_cftypes(struct cgroup_subsys *ss, struct cftype *cfts)
{
3548 3549
	struct cftype *cft;

3550 3551
	for (cft = cfts; cft && cft->name[0] != '\0'; cft++)
		cft->flags |= __CFTYPE_NOT_ON_DFL;
3552 3553 3554
	return cgroup_add_cftypes(ss, cfts);
}

L
Li Zefan 已提交
3555 3556 3557 3558 3559 3560
/**
 * cgroup_task_count - count the number of tasks in a cgroup.
 * @cgrp: the cgroup in question
 *
 * Return the number of tasks in the cgroup.
 */
3561
static int cgroup_task_count(const struct cgroup *cgrp)
3562 3563
{
	int count = 0;
3564
	struct cgrp_cset_link *link;
3565

3566
	spin_lock_bh(&css_set_lock);
3567 3568
	list_for_each_entry(link, &cgrp->cset_links, cset_link)
		count += atomic_read(&link->cset->refcount);
3569
	spin_unlock_bh(&css_set_lock);
3570 3571 3572
	return count;
}

3573
/**
3574
 * css_next_child - find the next child of a given css
3575 3576
 * @pos: the current position (%NULL to initiate traversal)
 * @parent: css whose children to walk
3577
 *
3578
 * This function returns the next child of @parent and should be called
3579
 * under either cgroup_mutex or RCU read lock.  The only requirement is
3580 3581 3582 3583 3584 3585 3586 3587 3588
 * that @parent and @pos are accessible.  The next sibling is guaranteed to
 * be returned regardless of their states.
 *
 * If a subsystem synchronizes ->css_online() and the start of iteration, a
 * css which finished ->css_online() is guaranteed to be visible in the
 * future iterations and will stay visible until the last reference is put.
 * A css which hasn't finished ->css_online() or already finished
 * ->css_offline() may show up during traversal.  It's each subsystem's
 * responsibility to synchronize against on/offlining.
3589
 */
3590 3591
struct cgroup_subsys_state *css_next_child(struct cgroup_subsys_state *pos,
					   struct cgroup_subsys_state *parent)
3592
{
3593
	struct cgroup_subsys_state *next;
3594

T
Tejun Heo 已提交
3595
	cgroup_assert_mutex_or_rcu_locked();
3596 3597

	/*
3598 3599 3600 3601 3602 3603 3604 3605 3606 3607
	 * @pos could already have been unlinked from the sibling list.
	 * Once a cgroup is removed, its ->sibling.next is no longer
	 * updated when its next sibling changes.  CSS_RELEASED is set when
	 * @pos is taken off list, at which time its next pointer is valid,
	 * and, as releases are serialized, the one pointed to by the next
	 * pointer is guaranteed to not have started release yet.  This
	 * implies that if we observe !CSS_RELEASED on @pos in this RCU
	 * critical section, the one pointed to by its next pointer is
	 * guaranteed to not have finished its RCU grace period even if we
	 * have dropped rcu_read_lock() inbetween iterations.
3608
	 *
3609 3610 3611 3612 3613 3614 3615
	 * If @pos has CSS_RELEASED set, its next pointer can't be
	 * dereferenced; however, as each css is given a monotonically
	 * increasing unique serial number and always appended to the
	 * sibling list, the next one can be found by walking the parent's
	 * children until the first css with higher serial number than
	 * @pos's.  While this path can be slower, it happens iff iteration
	 * races against release and the race window is very small.
3616
	 */
3617
	if (!pos) {
3618 3619 3620
		next = list_entry_rcu(parent->children.next, struct cgroup_subsys_state, sibling);
	} else if (likely(!(pos->flags & CSS_RELEASED))) {
		next = list_entry_rcu(pos->sibling.next, struct cgroup_subsys_state, sibling);
3621
	} else {
3622
		list_for_each_entry_rcu(next, &parent->children, sibling)
3623 3624
			if (next->serial_nr > pos->serial_nr)
				break;
3625 3626
	}

3627 3628
	/*
	 * @next, if not pointing to the head, can be dereferenced and is
3629
	 * the next sibling.
3630
	 */
3631 3632
	if (&next->sibling != &parent->children)
		return next;
3633
	return NULL;
3634 3635
}

3636
/**
3637
 * css_next_descendant_pre - find the next descendant for pre-order walk
3638
 * @pos: the current position (%NULL to initiate traversal)
3639
 * @root: css whose descendants to walk
3640
 *
3641
 * To be used by css_for_each_descendant_pre().  Find the next descendant
3642 3643
 * to visit for pre-order traversal of @root's descendants.  @root is
 * included in the iteration and the first node to be visited.
3644
 *
3645 3646 3647 3648
 * While this function requires cgroup_mutex or RCU read locking, it
 * doesn't require the whole traversal to be contained in a single critical
 * section.  This function will return the correct next descendant as long
 * as both @pos and @root are accessible and @pos is a descendant of @root.
3649 3650 3651 3652 3653 3654 3655
 *
 * If a subsystem synchronizes ->css_online() and the start of iteration, a
 * css which finished ->css_online() is guaranteed to be visible in the
 * future iterations and will stay visible until the last reference is put.
 * A css which hasn't finished ->css_online() or already finished
 * ->css_offline() may show up during traversal.  It's each subsystem's
 * responsibility to synchronize against on/offlining.
3656
 */
3657 3658 3659
struct cgroup_subsys_state *
css_next_descendant_pre(struct cgroup_subsys_state *pos,
			struct cgroup_subsys_state *root)
3660
{
3661
	struct cgroup_subsys_state *next;
3662

T
Tejun Heo 已提交
3663
	cgroup_assert_mutex_or_rcu_locked();
3664

3665
	/* if first iteration, visit @root */
3666
	if (!pos)
3667
		return root;
3668 3669

	/* visit the first child if exists */
3670
	next = css_next_child(NULL, pos);
3671 3672 3673 3674
	if (next)
		return next;

	/* no child, visit my or the closest ancestor's next sibling */
3675
	while (pos != root) {
T
Tejun Heo 已提交
3676
		next = css_next_child(pos, pos->parent);
3677
		if (next)
3678
			return next;
T
Tejun Heo 已提交
3679
		pos = pos->parent;
3680
	}
3681 3682 3683 3684

	return NULL;
}

3685
/**
3686 3687
 * css_rightmost_descendant - return the rightmost descendant of a css
 * @pos: css of interest
3688
 *
3689 3690
 * Return the rightmost descendant of @pos.  If there's no descendant, @pos
 * is returned.  This can be used during pre-order traversal to skip
3691
 * subtree of @pos.
3692
 *
3693 3694 3695 3696
 * While this function requires cgroup_mutex or RCU read locking, it
 * doesn't require the whole traversal to be contained in a single critical
 * section.  This function will return the correct rightmost descendant as
 * long as @pos is accessible.
3697
 */
3698 3699
struct cgroup_subsys_state *
css_rightmost_descendant(struct cgroup_subsys_state *pos)
3700
{
3701
	struct cgroup_subsys_state *last, *tmp;
3702

T
Tejun Heo 已提交
3703
	cgroup_assert_mutex_or_rcu_locked();
3704 3705 3706 3707 3708

	do {
		last = pos;
		/* ->prev isn't RCU safe, walk ->next till the end */
		pos = NULL;
3709
		css_for_each_child(tmp, last)
3710 3711 3712 3713 3714 3715
			pos = tmp;
	} while (pos);

	return last;
}

3716 3717
static struct cgroup_subsys_state *
css_leftmost_descendant(struct cgroup_subsys_state *pos)
3718
{
3719
	struct cgroup_subsys_state *last;
3720 3721 3722

	do {
		last = pos;
3723
		pos = css_next_child(NULL, pos);
3724 3725 3726 3727 3728 3729
	} while (pos);

	return last;
}

/**
3730
 * css_next_descendant_post - find the next descendant for post-order walk
3731
 * @pos: the current position (%NULL to initiate traversal)
3732
 * @root: css whose descendants to walk
3733
 *
3734
 * To be used by css_for_each_descendant_post().  Find the next descendant
3735 3736
 * to visit for post-order traversal of @root's descendants.  @root is
 * included in the iteration and the last node to be visited.
3737
 *
3738 3739 3740 3741 3742
 * While this function requires cgroup_mutex or RCU read locking, it
 * doesn't require the whole traversal to be contained in a single critical
 * section.  This function will return the correct next descendant as long
 * as both @pos and @cgroup are accessible and @pos is a descendant of
 * @cgroup.
3743 3744 3745 3746 3747 3748 3749
 *
 * If a subsystem synchronizes ->css_online() and the start of iteration, a
 * css which finished ->css_online() is guaranteed to be visible in the
 * future iterations and will stay visible until the last reference is put.
 * A css which hasn't finished ->css_online() or already finished
 * ->css_offline() may show up during traversal.  It's each subsystem's
 * responsibility to synchronize against on/offlining.
3750
 */
3751 3752 3753
struct cgroup_subsys_state *
css_next_descendant_post(struct cgroup_subsys_state *pos,
			 struct cgroup_subsys_state *root)
3754
{
3755
	struct cgroup_subsys_state *next;
3756

T
Tejun Heo 已提交
3757
	cgroup_assert_mutex_or_rcu_locked();
3758

3759 3760 3761
	/* if first iteration, visit leftmost descendant which may be @root */
	if (!pos)
		return css_leftmost_descendant(root);
3762

3763 3764 3765 3766
	/* if we visited @root, we're done */
	if (pos == root)
		return NULL;

3767
	/* if there's an unvisited sibling, visit its leftmost descendant */
T
Tejun Heo 已提交
3768
	next = css_next_child(pos, pos->parent);
3769
	if (next)
3770
		return css_leftmost_descendant(next);
3771 3772

	/* no sibling left, visit parent */
T
Tejun Heo 已提交
3773
	return pos->parent;
3774 3775
}

3776 3777 3778 3779 3780 3781 3782 3783 3784
/**
 * css_has_online_children - does a css have online children
 * @css: the target css
 *
 * Returns %true if @css has any online children; otherwise, %false.  This
 * function can be called from any context but the caller is responsible
 * for synchronizing against on/offlining as necessary.
 */
bool css_has_online_children(struct cgroup_subsys_state *css)
3785
{
3786 3787
	struct cgroup_subsys_state *child;
	bool ret = false;
3788 3789

	rcu_read_lock();
3790
	css_for_each_child(child, css) {
3791
		if (child->flags & CSS_ONLINE) {
3792 3793
			ret = true;
			break;
3794 3795 3796
		}
	}
	rcu_read_unlock();
3797
	return ret;
3798 3799
}

3800
/**
3801
 * css_task_iter_advance_css_set - advance a task itererator to the next css_set
3802 3803 3804
 * @it: the iterator to advance
 *
 * Advance @it to the next css_set to walk.
3805
 */
3806
static void css_task_iter_advance_css_set(struct css_task_iter *it)
3807
{
T
Tejun Heo 已提交
3808
	struct list_head *l = it->cset_pos;
3809 3810 3811
	struct cgrp_cset_link *link;
	struct css_set *cset;

3812
	lockdep_assert_held(&css_set_lock);
3813

3814 3815 3816
	/* Advance to the next non-empty css_set */
	do {
		l = l->next;
T
Tejun Heo 已提交
3817 3818
		if (l == it->cset_head) {
			it->cset_pos = NULL;
3819
			it->task_pos = NULL;
3820 3821
			return;
		}
3822 3823 3824 3825 3826 3827 3828 3829

		if (it->ss) {
			cset = container_of(l, struct css_set,
					    e_cset_node[it->ss->id]);
		} else {
			link = list_entry(l, struct cgrp_cset_link, cset_link);
			cset = link->cset;
		}
3830
	} while (!css_set_populated(cset));
T
Tejun Heo 已提交
3831

T
Tejun Heo 已提交
3832
	it->cset_pos = l;
T
Tejun Heo 已提交
3833 3834

	if (!list_empty(&cset->tasks))
T
Tejun Heo 已提交
3835
		it->task_pos = cset->tasks.next;
T
Tejun Heo 已提交
3836
	else
T
Tejun Heo 已提交
3837 3838 3839 3840
		it->task_pos = cset->mg_tasks.next;

	it->tasks_head = &cset->tasks;
	it->mg_tasks_head = &cset->mg_tasks;
3841 3842 3843 3844 3845 3846 3847 3848 3849 3850 3851 3852 3853 3854 3855 3856 3857 3858 3859 3860 3861 3862 3863

	/*
	 * We don't keep css_sets locked across iteration steps and thus
	 * need to take steps to ensure that iteration can be resumed after
	 * the lock is re-acquired.  Iteration is performed at two levels -
	 * css_sets and tasks in them.
	 *
	 * Once created, a css_set never leaves its cgroup lists, so a
	 * pinned css_set is guaranteed to stay put and we can resume
	 * iteration afterwards.
	 *
	 * Tasks may leave @cset across iteration steps.  This is resolved
	 * by registering each iterator with the css_set currently being
	 * walked and making css_set_move_task() advance iterators whose
	 * next task is leaving.
	 */
	if (it->cur_cset) {
		list_del(&it->iters_node);
		put_css_set_locked(it->cur_cset);
	}
	get_css_set(cset);
	it->cur_cset = cset;
	list_add(&it->iters_node, &cset->task_iters);
3864 3865
}

3866 3867 3868 3869
static void css_task_iter_advance(struct css_task_iter *it)
{
	struct list_head *l = it->task_pos;

3870
	lockdep_assert_held(&css_set_lock);
3871 3872 3873 3874 3875 3876 3877 3878 3879 3880 3881 3882 3883 3884 3885 3886 3887 3888
	WARN_ON_ONCE(!l);

	/*
	 * Advance iterator to find next entry.  cset->tasks is consumed
	 * first and then ->mg_tasks.  After ->mg_tasks, we move onto the
	 * next cset.
	 */
	l = l->next;

	if (l == it->tasks_head)
		l = it->mg_tasks_head->next;

	if (l == it->mg_tasks_head)
		css_task_iter_advance_css_set(it);
	else
		it->task_pos = l;
}

3889
/**
3890 3891
 * css_task_iter_start - initiate task iteration
 * @css: the css to walk tasks of
3892 3893
 * @it: the task iterator to use
 *
3894 3895 3896 3897
 * Initiate iteration through the tasks of @css.  The caller can call
 * css_task_iter_next() to walk through the tasks until the function
 * returns NULL.  On completion of iteration, css_task_iter_end() must be
 * called.
3898
 */
3899 3900
void css_task_iter_start(struct cgroup_subsys_state *css,
			 struct css_task_iter *it)
3901
{
3902 3903
	/* no one should try to iterate before mounting cgroups */
	WARN_ON_ONCE(!use_task_css_set_links);
3904

3905 3906
	memset(it, 0, sizeof(*it));

3907
	spin_lock_bh(&css_set_lock);
3908

3909 3910 3911 3912 3913 3914 3915
	it->ss = css->ss;

	if (it->ss)
		it->cset_pos = &css->cgroup->e_csets[css->ss->id];
	else
		it->cset_pos = &css->cgroup->cset_links;

T
Tejun Heo 已提交
3916
	it->cset_head = it->cset_pos;
3917

3918
	css_task_iter_advance_css_set(it);
3919

3920
	spin_unlock_bh(&css_set_lock);
3921 3922
}

3923
/**
3924
 * css_task_iter_next - return the next task for the iterator
3925 3926 3927
 * @it: the task iterator being iterated
 *
 * The "next" function for task iteration.  @it should have been
3928 3929
 * initialized via css_task_iter_start().  Returns NULL when the iteration
 * reaches the end.
3930
 */
3931
struct task_struct *css_task_iter_next(struct css_task_iter *it)
3932
{
3933
	if (it->cur_task) {
3934
		put_task_struct(it->cur_task);
3935 3936
		it->cur_task = NULL;
	}
3937

3938
	spin_lock_bh(&css_set_lock);
3939

3940 3941 3942 3943 3944 3945
	if (it->task_pos) {
		it->cur_task = list_entry(it->task_pos, struct task_struct,
					  cg_list);
		get_task_struct(it->cur_task);
		css_task_iter_advance(it);
	}
3946

3947
	spin_unlock_bh(&css_set_lock);
3948 3949

	return it->cur_task;
3950 3951
}

3952
/**
3953
 * css_task_iter_end - finish task iteration
3954 3955
 * @it: the task iterator to finish
 *
3956
 * Finish task iteration started by css_task_iter_start().
3957
 */
3958
void css_task_iter_end(struct css_task_iter *it)
3959
{
3960
	if (it->cur_cset) {
3961
		spin_lock_bh(&css_set_lock);
3962 3963
		list_del(&it->iters_node);
		put_css_set_locked(it->cur_cset);
3964
		spin_unlock_bh(&css_set_lock);
3965 3966 3967 3968
	}

	if (it->cur_task)
		put_task_struct(it->cur_task);
3969 3970 3971
}

/**
3972 3973 3974
 * cgroup_trasnsfer_tasks - move tasks from one cgroup to another
 * @to: cgroup to which the tasks will be moved
 * @from: cgroup in which the tasks currently reside
3975
 *
3976 3977 3978 3979 3980
 * Locking rules between cgroup_post_fork() and the migration path
 * guarantee that, if a task is forking while being migrated, the new child
 * is guaranteed to be either visible in the source cgroup after the
 * parent's migration is complete or put into the target cgroup.  No task
 * can slip out of migration through forking.
3981
 */
3982
int cgroup_transfer_tasks(struct cgroup *to, struct cgroup *from)
3983
{
3984 3985
	LIST_HEAD(preloaded_csets);
	struct cgrp_cset_link *link;
3986
	struct css_task_iter it;
3987
	struct task_struct *task;
3988
	int ret;
3989

3990
	mutex_lock(&cgroup_mutex);
3991

3992
	/* all tasks in @from are being moved, all csets are source */
3993
	spin_lock_bh(&css_set_lock);
3994 3995
	list_for_each_entry(link, &from->cset_links, cset_link)
		cgroup_migrate_add_src(link->cset, to, &preloaded_csets);
3996
	spin_unlock_bh(&css_set_lock);
3997

3998 3999 4000
	ret = cgroup_migrate_prepare_dst(to, &preloaded_csets);
	if (ret)
		goto out_err;
4001

4002 4003 4004 4005
	/*
	 * Migrate tasks one-by-one until @form is empty.  This fails iff
	 * ->can_attach() fails.
	 */
4006
	do {
4007
		css_task_iter_start(&from->self, &it);
4008 4009 4010 4011 4012 4013
		task = css_task_iter_next(&it);
		if (task)
			get_task_struct(task);
		css_task_iter_end(&it);

		if (task) {
4014
			ret = cgroup_migrate(task, false, to);
4015 4016 4017
			put_task_struct(task);
		}
	} while (task && !ret);
4018 4019
out_err:
	cgroup_migrate_finish(&preloaded_csets);
T
Tejun Heo 已提交
4020
	mutex_unlock(&cgroup_mutex);
4021
	return ret;
4022 4023
}

4024
/*
4025
 * Stuff for reading the 'tasks'/'procs' files.
4026 4027 4028 4029 4030 4031 4032 4033
 *
 * Reading this file can return large amounts of data if a cgroup has
 * *lots* of attached tasks. So it may need several calls to read(),
 * but we cannot guarantee that the information we produce is correct
 * unless we produce it entirely atomically.
 *
 */

4034 4035 4036 4037 4038 4039 4040 4041 4042 4043 4044 4045 4046 4047 4048 4049 4050 4051 4052 4053 4054 4055 4056 4057 4058 4059
/* which pidlist file are we talking about? */
enum cgroup_filetype {
	CGROUP_FILE_PROCS,
	CGROUP_FILE_TASKS,
};

/*
 * A pidlist is a list of pids that virtually represents the contents of one
 * of the cgroup files ("procs" or "tasks"). We keep a list of such pidlists,
 * a pair (one each for procs, tasks) for each pid namespace that's relevant
 * to the cgroup.
 */
struct cgroup_pidlist {
	/*
	 * used to find which pidlist is wanted. doesn't change as long as
	 * this particular list stays in the list.
	*/
	struct { enum cgroup_filetype type; struct pid_namespace *ns; } key;
	/* array of xids */
	pid_t *list;
	/* how many elements the above list has */
	int length;
	/* each of these stored in a list by its cgroup */
	struct list_head links;
	/* pointer to the cgroup we belong to, for list removal purposes */
	struct cgroup *owner;
4060 4061
	/* for delayed destruction */
	struct delayed_work destroy_dwork;
4062 4063
};

4064 4065 4066 4067 4068 4069 4070 4071 4072 4073 4074 4075 4076
/*
 * The following two functions "fix" the issue where there are more pids
 * than kmalloc will give memory for; in such cases, we use vmalloc/vfree.
 * TODO: replace with a kernel-wide solution to this problem
 */
#define PIDLIST_TOO_LARGE(c) ((c) * sizeof(pid_t) > (PAGE_SIZE * 2))
static void *pidlist_allocate(int count)
{
	if (PIDLIST_TOO_LARGE(count))
		return vmalloc(count * sizeof(pid_t));
	else
		return kmalloc(count * sizeof(pid_t), GFP_KERNEL);
}
4077

4078 4079
static void pidlist_free(void *p)
{
4080
	kvfree(p);
4081 4082
}

4083 4084 4085 4086 4087 4088 4089 4090 4091 4092 4093 4094 4095 4096 4097 4098 4099 4100 4101 4102 4103 4104 4105 4106 4107 4108 4109
/*
 * Used to destroy all pidlists lingering waiting for destroy timer.  None
 * should be left afterwards.
 */
static void cgroup_pidlist_destroy_all(struct cgroup *cgrp)
{
	struct cgroup_pidlist *l, *tmp_l;

	mutex_lock(&cgrp->pidlist_mutex);
	list_for_each_entry_safe(l, tmp_l, &cgrp->pidlists, links)
		mod_delayed_work(cgroup_pidlist_destroy_wq, &l->destroy_dwork, 0);
	mutex_unlock(&cgrp->pidlist_mutex);

	flush_workqueue(cgroup_pidlist_destroy_wq);
	BUG_ON(!list_empty(&cgrp->pidlists));
}

static void cgroup_pidlist_destroy_work_fn(struct work_struct *work)
{
	struct delayed_work *dwork = to_delayed_work(work);
	struct cgroup_pidlist *l = container_of(dwork, struct cgroup_pidlist,
						destroy_dwork);
	struct cgroup_pidlist *tofree = NULL;

	mutex_lock(&l->owner->pidlist_mutex);

	/*
4110 4111
	 * Destroy iff we didn't get queued again.  The state won't change
	 * as destroy_dwork can only be queued while locked.
4112
	 */
4113
	if (!delayed_work_pending(dwork)) {
4114 4115 4116 4117 4118 4119 4120 4121 4122 4123
		list_del(&l->links);
		pidlist_free(l->list);
		put_pid_ns(l->key.ns);
		tofree = l;
	}

	mutex_unlock(&l->owner->pidlist_mutex);
	kfree(tofree);
}

4124
/*
4125
 * pidlist_uniq - given a kmalloc()ed list, strip out all duplicate entries
4126
 * Returns the number of unique elements.
4127
 */
4128
static int pidlist_uniq(pid_t *list, int length)
4129
{
4130 4131 4132 4133 4134 4135 4136 4137 4138 4139 4140 4141 4142 4143 4144 4145 4146 4147 4148 4149 4150 4151 4152 4153
	int src, dest = 1;

	/*
	 * we presume the 0th element is unique, so i starts at 1. trivial
	 * edge cases first; no work needs to be done for either
	 */
	if (length == 0 || length == 1)
		return length;
	/* src and dest walk down the list; dest counts unique elements */
	for (src = 1; src < length; src++) {
		/* find next unique element */
		while (list[src] == list[src-1]) {
			src++;
			if (src == length)
				goto after;
		}
		/* dest always points to where the next unique element goes */
		list[dest] = list[src];
		dest++;
	}
after:
	return dest;
}

4154 4155 4156 4157 4158 4159 4160 4161 4162 4163 4164
/*
 * The two pid files - task and cgroup.procs - guaranteed that the result
 * is sorted, which forced this whole pidlist fiasco.  As pid order is
 * different per namespace, each namespace needs differently sorted list,
 * making it impossible to use, for example, single rbtree of member tasks
 * sorted by task pointer.  As pidlists can be fairly large, allocating one
 * per open file is dangerous, so cgroup had to implement shared pool of
 * pidlists keyed by cgroup and namespace.
 *
 * All this extra complexity was caused by the original implementation
 * committing to an entirely unnecessary property.  In the long term, we
4165 4166 4167
 * want to do away with it.  Explicitly scramble sort order if on the
 * default hierarchy so that no such expectation exists in the new
 * interface.
4168 4169 4170 4171 4172 4173 4174 4175 4176 4177 4178 4179 4180 4181
 *
 * Scrambling is done by swapping every two consecutive bits, which is
 * non-identity one-to-one mapping which disturbs sort order sufficiently.
 */
static pid_t pid_fry(pid_t pid)
{
	unsigned a = pid & 0x55555555;
	unsigned b = pid & 0xAAAAAAAA;

	return (a << 1) | (b >> 1);
}

static pid_t cgroup_pid_fry(struct cgroup *cgrp, pid_t pid)
{
4182
	if (cgroup_on_dfl(cgrp))
4183 4184 4185 4186 4187
		return pid_fry(pid);
	else
		return pid;
}

4188 4189 4190 4191 4192
static int cmppid(const void *a, const void *b)
{
	return *(pid_t *)a - *(pid_t *)b;
}

4193 4194 4195 4196 4197
static int fried_cmppid(const void *a, const void *b)
{
	return pid_fry(*(pid_t *)a) - pid_fry(*(pid_t *)b);
}

T
Tejun Heo 已提交
4198 4199 4200 4201 4202 4203 4204 4205 4206 4207 4208 4209 4210 4211 4212
static struct cgroup_pidlist *cgroup_pidlist_find(struct cgroup *cgrp,
						  enum cgroup_filetype type)
{
	struct cgroup_pidlist *l;
	/* don't need task_nsproxy() if we're looking at ourself */
	struct pid_namespace *ns = task_active_pid_ns(current);

	lockdep_assert_held(&cgrp->pidlist_mutex);

	list_for_each_entry(l, &cgrp->pidlists, links)
		if (l->key.type == type && l->key.ns == ns)
			return l;
	return NULL;
}

4213 4214 4215 4216 4217 4218
/*
 * find the appropriate pidlist for our purpose (given procs vs tasks)
 * returns with the lock on that pidlist already held, and takes care
 * of the use count, or returns NULL with no locks held if we're out of
 * memory.
 */
T
Tejun Heo 已提交
4219 4220
static struct cgroup_pidlist *cgroup_pidlist_find_create(struct cgroup *cgrp,
						enum cgroup_filetype type)
4221 4222
{
	struct cgroup_pidlist *l;
4223

T
Tejun Heo 已提交
4224 4225 4226 4227 4228 4229
	lockdep_assert_held(&cgrp->pidlist_mutex);

	l = cgroup_pidlist_find(cgrp, type);
	if (l)
		return l;

4230
	/* entry not found; create a new one */
4231
	l = kzalloc(sizeof(struct cgroup_pidlist), GFP_KERNEL);
T
Tejun Heo 已提交
4232
	if (!l)
4233
		return l;
T
Tejun Heo 已提交
4234

4235
	INIT_DELAYED_WORK(&l->destroy_dwork, cgroup_pidlist_destroy_work_fn);
4236
	l->key.type = type;
T
Tejun Heo 已提交
4237 4238
	/* don't need task_nsproxy() if we're looking at ourself */
	l->key.ns = get_pid_ns(task_active_pid_ns(current));
4239 4240 4241 4242 4243
	l->owner = cgrp;
	list_add(&l->links, &cgrp->pidlists);
	return l;
}

4244 4245 4246
/*
 * Load a cgroup's pidarray with either procs' tgids or tasks' pids
 */
4247 4248
static int pidlist_array_load(struct cgroup *cgrp, enum cgroup_filetype type,
			      struct cgroup_pidlist **lp)
4249 4250 4251 4252
{
	pid_t *array;
	int length;
	int pid, n = 0; /* used for populating the array */
4253
	struct css_task_iter it;
4254
	struct task_struct *tsk;
4255 4256
	struct cgroup_pidlist *l;

4257 4258
	lockdep_assert_held(&cgrp->pidlist_mutex);

4259 4260 4261 4262 4263 4264 4265
	/*
	 * If cgroup gets more users after we read count, we won't have
	 * enough space - tough.  This race is indistinguishable to the
	 * caller from the case that the additional cgroup users didn't
	 * show up until sometime later on.
	 */
	length = cgroup_task_count(cgrp);
4266
	array = pidlist_allocate(length);
4267 4268 4269
	if (!array)
		return -ENOMEM;
	/* now, populate the array */
4270
	css_task_iter_start(&cgrp->self, &it);
4271
	while ((tsk = css_task_iter_next(&it))) {
4272
		if (unlikely(n == length))
4273
			break;
4274
		/* get tgid or pid for procs or tasks file respectively */
4275 4276 4277 4278
		if (type == CGROUP_FILE_PROCS)
			pid = task_tgid_vnr(tsk);
		else
			pid = task_pid_vnr(tsk);
4279 4280
		if (pid > 0) /* make sure to only use valid results */
			array[n++] = pid;
4281
	}
4282
	css_task_iter_end(&it);
4283 4284
	length = n;
	/* now sort & (if procs) strip out duplicates */
4285
	if (cgroup_on_dfl(cgrp))
4286 4287 4288
		sort(array, length, sizeof(pid_t), fried_cmppid, NULL);
	else
		sort(array, length, sizeof(pid_t), cmppid, NULL);
4289
	if (type == CGROUP_FILE_PROCS)
4290
		length = pidlist_uniq(array, length);
T
Tejun Heo 已提交
4291 4292

	l = cgroup_pidlist_find_create(cgrp, type);
4293
	if (!l) {
4294
		pidlist_free(array);
4295
		return -ENOMEM;
4296
	}
T
Tejun Heo 已提交
4297 4298

	/* store array, freeing old if necessary */
4299
	pidlist_free(l->list);
4300 4301
	l->list = array;
	l->length = length;
4302
	*lp = l;
4303
	return 0;
4304 4305
}

B
Balbir Singh 已提交
4306
/**
L
Li Zefan 已提交
4307
 * cgroupstats_build - build and fill cgroupstats
B
Balbir Singh 已提交
4308 4309 4310
 * @stats: cgroupstats to fill information into
 * @dentry: A dentry entry belonging to the cgroup for which stats have
 * been requested.
L
Li Zefan 已提交
4311 4312 4313
 *
 * Build and fill cgroupstats so that taskstats can export it to user
 * space.
B
Balbir Singh 已提交
4314 4315 4316
 */
int cgroupstats_build(struct cgroupstats *stats, struct dentry *dentry)
{
T
Tejun Heo 已提交
4317
	struct kernfs_node *kn = kernfs_node_from_dentry(dentry);
4318
	struct cgroup *cgrp;
4319
	struct css_task_iter it;
B
Balbir Singh 已提交
4320
	struct task_struct *tsk;
4321

T
Tejun Heo 已提交
4322 4323 4324 4325 4326
	/* it should be kernfs_node belonging to cgroupfs and is a directory */
	if (dentry->d_sb->s_type != &cgroup_fs_type || !kn ||
	    kernfs_type(kn) != KERNFS_DIR)
		return -EINVAL;

4327 4328
	mutex_lock(&cgroup_mutex);

B
Balbir Singh 已提交
4329
	/*
T
Tejun Heo 已提交
4330
	 * We aren't being called from kernfs and there's no guarantee on
4331
	 * @kn->priv's validity.  For this and css_tryget_online_from_dir(),
T
Tejun Heo 已提交
4332
	 * @kn->priv is RCU safe.  Let's do the RCU dancing.
B
Balbir Singh 已提交
4333
	 */
T
Tejun Heo 已提交
4334 4335
	rcu_read_lock();
	cgrp = rcu_dereference(kn->priv);
4336
	if (!cgrp || cgroup_is_dead(cgrp)) {
T
Tejun Heo 已提交
4337
		rcu_read_unlock();
4338
		mutex_unlock(&cgroup_mutex);
T
Tejun Heo 已提交
4339 4340
		return -ENOENT;
	}
4341
	rcu_read_unlock();
B
Balbir Singh 已提交
4342

4343
	css_task_iter_start(&cgrp->self, &it);
4344
	while ((tsk = css_task_iter_next(&it))) {
B
Balbir Singh 已提交
4345 4346 4347 4348 4349 4350 4351 4352 4353 4354 4355 4356 4357 4358 4359 4360 4361 4362 4363
		switch (tsk->state) {
		case TASK_RUNNING:
			stats->nr_running++;
			break;
		case TASK_INTERRUPTIBLE:
			stats->nr_sleeping++;
			break;
		case TASK_UNINTERRUPTIBLE:
			stats->nr_uninterruptible++;
			break;
		case TASK_STOPPED:
			stats->nr_stopped++;
			break;
		default:
			if (delayacct_is_task_waiting_on_io(tsk))
				stats->nr_io_wait++;
			break;
		}
	}
4364
	css_task_iter_end(&it);
B
Balbir Singh 已提交
4365

4366
	mutex_unlock(&cgroup_mutex);
T
Tejun Heo 已提交
4367
	return 0;
B
Balbir Singh 已提交
4368 4369
}

4370

4371
/*
4372
 * seq_file methods for the tasks/procs files. The seq_file position is the
4373
 * next pid to display; the seq_file iterator is a pointer to the pid
4374
 * in the cgroup->l->list array.
4375
 */
4376

4377
static void *cgroup_pidlist_start(struct seq_file *s, loff_t *pos)
4378
{
4379 4380 4381 4382 4383 4384
	/*
	 * Initially we receive a position value that corresponds to
	 * one more than the last pid shown (or 0 on the first call or
	 * after a seek to the start). Use a binary-search to find the
	 * next pid to display, if any
	 */
T
Tejun Heo 已提交
4385
	struct kernfs_open_file *of = s->private;
4386
	struct cgroup *cgrp = seq_css(s)->cgroup;
4387
	struct cgroup_pidlist *l;
4388
	enum cgroup_filetype type = seq_cft(s)->private;
4389
	int index = 0, pid = *pos;
4390 4391 4392 4393 4394
	int *iter, ret;

	mutex_lock(&cgrp->pidlist_mutex);

	/*
4395
	 * !NULL @of->priv indicates that this isn't the first start()
4396
	 * after open.  If the matching pidlist is around, we can use that.
4397
	 * Look for it.  Note that @of->priv can't be used directly.  It
4398 4399
	 * could already have been destroyed.
	 */
4400 4401
	if (of->priv)
		of->priv = cgroup_pidlist_find(cgrp, type);
4402 4403 4404 4405 4406

	/*
	 * Either this is the first start() after open or the matching
	 * pidlist has been destroyed inbetween.  Create a new one.
	 */
4407 4408 4409
	if (!of->priv) {
		ret = pidlist_array_load(cgrp, type,
					 (struct cgroup_pidlist **)&of->priv);
4410 4411 4412
		if (ret)
			return ERR_PTR(ret);
	}
4413
	l = of->priv;
4414 4415

	if (pid) {
4416
		int end = l->length;
S
Stephen Rothwell 已提交
4417

4418 4419
		while (index < end) {
			int mid = (index + end) / 2;
4420
			if (cgroup_pid_fry(cgrp, l->list[mid]) == pid) {
4421 4422
				index = mid;
				break;
4423
			} else if (cgroup_pid_fry(cgrp, l->list[mid]) <= pid)
4424 4425 4426 4427 4428 4429
				index = mid + 1;
			else
				end = mid;
		}
	}
	/* If we're off the end of the array, we're done */
4430
	if (index >= l->length)
4431 4432
		return NULL;
	/* Update the abstract position to be the actual pid that we found */
4433
	iter = l->list + index;
4434
	*pos = cgroup_pid_fry(cgrp, *iter);
4435 4436 4437
	return iter;
}

4438
static void cgroup_pidlist_stop(struct seq_file *s, void *v)
4439
{
T
Tejun Heo 已提交
4440
	struct kernfs_open_file *of = s->private;
4441
	struct cgroup_pidlist *l = of->priv;
4442

4443 4444
	if (l)
		mod_delayed_work(cgroup_pidlist_destroy_wq, &l->destroy_dwork,
4445
				 CGROUP_PIDLIST_DESTROY_DELAY);
4446
	mutex_unlock(&seq_css(s)->cgroup->pidlist_mutex);
4447 4448
}

4449
static void *cgroup_pidlist_next(struct seq_file *s, void *v, loff_t *pos)
4450
{
T
Tejun Heo 已提交
4451
	struct kernfs_open_file *of = s->private;
4452
	struct cgroup_pidlist *l = of->priv;
4453 4454
	pid_t *p = v;
	pid_t *end = l->list + l->length;
4455 4456 4457 4458 4459 4460 4461 4462
	/*
	 * Advance to the next pid in the array. If this goes off the
	 * end, we're done
	 */
	p++;
	if (p >= end) {
		return NULL;
	} else {
4463
		*pos = cgroup_pid_fry(seq_css(s)->cgroup, *p);
4464 4465 4466 4467
		return p;
	}
}

4468
static int cgroup_pidlist_show(struct seq_file *s, void *v)
4469
{
4470 4471 4472
	seq_printf(s, "%d\n", *(int *)v);

	return 0;
4473
}
4474

4475 4476
static u64 cgroup_read_notify_on_release(struct cgroup_subsys_state *css,
					 struct cftype *cft)
4477
{
4478
	return notify_on_release(css->cgroup);
4479 4480
}

4481 4482
static int cgroup_write_notify_on_release(struct cgroup_subsys_state *css,
					  struct cftype *cft, u64 val)
4483 4484
{
	if (val)
4485
		set_bit(CGRP_NOTIFY_ON_RELEASE, &css->cgroup->flags);
4486
	else
4487
		clear_bit(CGRP_NOTIFY_ON_RELEASE, &css->cgroup->flags);
4488 4489 4490
	return 0;
}

4491 4492
static u64 cgroup_clone_children_read(struct cgroup_subsys_state *css,
				      struct cftype *cft)
4493
{
4494
	return test_bit(CGRP_CPUSET_CLONE_CHILDREN, &css->cgroup->flags);
4495 4496
}

4497 4498
static int cgroup_clone_children_write(struct cgroup_subsys_state *css,
				       struct cftype *cft, u64 val)
4499 4500
{
	if (val)
4501
		set_bit(CGRP_CPUSET_CLONE_CHILDREN, &css->cgroup->flags);
4502
	else
4503
		clear_bit(CGRP_CPUSET_CLONE_CHILDREN, &css->cgroup->flags);
4504 4505 4506
	return 0;
}

4507 4508
/* cgroup core interface files for the default hierarchy */
static struct cftype cgroup_dfl_base_files[] = {
4509
	{
4510
		.name = "cgroup.procs",
4511
		.file_offset = offsetof(struct cgroup, procs_file),
4512 4513 4514 4515
		.seq_start = cgroup_pidlist_start,
		.seq_next = cgroup_pidlist_next,
		.seq_stop = cgroup_pidlist_stop,
		.seq_show = cgroup_pidlist_show,
4516
		.private = CGROUP_FILE_PROCS,
4517
		.write = cgroup_procs_write,
4518
	},
4519 4520
	{
		.name = "cgroup.controllers",
4521
		.flags = CFTYPE_ONLY_ON_ROOT,
4522 4523 4524 4525
		.seq_show = cgroup_root_controllers_show,
	},
	{
		.name = "cgroup.controllers",
4526
		.flags = CFTYPE_NOT_ON_ROOT,
4527 4528 4529 4530 4531
		.seq_show = cgroup_controllers_show,
	},
	{
		.name = "cgroup.subtree_control",
		.seq_show = cgroup_subtree_control_show,
4532
		.write = cgroup_subtree_control_write,
4533
	},
4534
	{
4535
		.name = "cgroup.events",
4536
		.flags = CFTYPE_NOT_ON_ROOT,
4537
		.file_offset = offsetof(struct cgroup, events_file),
4538
		.seq_show = cgroup_events_show,
4539
	},
4540 4541
	{ }	/* terminate */
};
4542

4543 4544 4545 4546 4547 4548 4549 4550 4551 4552 4553 4554 4555 4556 4557 4558 4559 4560 4561 4562 4563
/* cgroup core interface files for the legacy hierarchies */
static struct cftype cgroup_legacy_base_files[] = {
	{
		.name = "cgroup.procs",
		.seq_start = cgroup_pidlist_start,
		.seq_next = cgroup_pidlist_next,
		.seq_stop = cgroup_pidlist_stop,
		.seq_show = cgroup_pidlist_show,
		.private = CGROUP_FILE_PROCS,
		.write = cgroup_procs_write,
	},
	{
		.name = "cgroup.clone_children",
		.read_u64 = cgroup_clone_children_read,
		.write_u64 = cgroup_clone_children_write,
	},
	{
		.name = "cgroup.sane_behavior",
		.flags = CFTYPE_ONLY_ON_ROOT,
		.seq_show = cgroup_sane_behavior_show,
	},
4564 4565
	{
		.name = "tasks",
4566 4567 4568 4569
		.seq_start = cgroup_pidlist_start,
		.seq_next = cgroup_pidlist_next,
		.seq_stop = cgroup_pidlist_stop,
		.seq_show = cgroup_pidlist_show,
4570
		.private = CGROUP_FILE_TASKS,
4571
		.write = cgroup_tasks_write,
4572 4573 4574 4575 4576 4577
	},
	{
		.name = "notify_on_release",
		.read_u64 = cgroup_read_notify_on_release,
		.write_u64 = cgroup_write_notify_on_release,
	},
4578 4579
	{
		.name = "release_agent",
4580
		.flags = CFTYPE_ONLY_ON_ROOT,
4581
		.seq_show = cgroup_release_agent_show,
4582
		.write = cgroup_release_agent_write,
4583
		.max_write_len = PATH_MAX - 1,
4584
	},
T
Tejun Heo 已提交
4585
	{ }	/* terminate */
4586 4587
};

4588 4589 4590 4591 4592 4593 4594
/*
 * css destruction is four-stage process.
 *
 * 1. Destruction starts.  Killing of the percpu_ref is initiated.
 *    Implemented in kill_css().
 *
 * 2. When the percpu_ref is confirmed to be visible as killed on all CPUs
4595 4596 4597
 *    and thus css_tryget_online() is guaranteed to fail, the css can be
 *    offlined by invoking offline_css().  After offlining, the base ref is
 *    put.  Implemented in css_killed_work_fn().
4598 4599 4600 4601 4602 4603 4604 4605 4606 4607 4608 4609
 *
 * 3. When the percpu_ref reaches zero, the only possible remaining
 *    accessors are inside RCU read sections.  css_release() schedules the
 *    RCU callback.
 *
 * 4. After the grace period, the css can be freed.  Implemented in
 *    css_free_work_fn().
 *
 * It is actually hairier because both step 2 and 4 require process context
 * and thus involve punting to css->destroy_work adding two additional
 * steps to the already complex sequence.
 */
4610
static void css_free_work_fn(struct work_struct *work)
4611 4612
{
	struct cgroup_subsys_state *css =
4613
		container_of(work, struct cgroup_subsys_state, destroy_work);
4614
	struct cgroup_subsys *ss = css->ss;
4615
	struct cgroup *cgrp = css->cgroup;
4616
	struct cgroup_file *cfile;
4617

4618 4619
	percpu_ref_exit(&css->refcnt);

4620 4621 4622
	list_for_each_entry(cfile, &css->files, node)
		kernfs_put(cfile->kn);

4623
	if (ss) {
4624
		/* css free path */
4625 4626
		int id = css->id;

4627 4628
		if (css->parent)
			css_put(css->parent);
4629

4630 4631
		ss->css_free(css);
		cgroup_idr_remove(&ss->css_idr, id);
4632 4633 4634 4635 4636
		cgroup_put(cgrp);
	} else {
		/* cgroup free path */
		atomic_dec(&cgrp->root->nr_cgrps);
		cgroup_pidlist_destroy_all(cgrp);
4637
		cancel_work_sync(&cgrp->release_agent_work);
4638

T
Tejun Heo 已提交
4639
		if (cgroup_parent(cgrp)) {
4640 4641 4642 4643 4644 4645
			/*
			 * We get a ref to the parent, and put the ref when
			 * this cgroup is being freed, so it's guaranteed
			 * that the parent won't be destroyed before its
			 * children.
			 */
T
Tejun Heo 已提交
4646
			cgroup_put(cgroup_parent(cgrp));
4647 4648 4649 4650 4651 4652 4653 4654 4655 4656 4657
			kernfs_put(cgrp->kn);
			kfree(cgrp);
		} else {
			/*
			 * This is root cgroup's refcnt reaching zero,
			 * which indicates that the root should be
			 * released.
			 */
			cgroup_destroy_root(cgrp->root);
		}
	}
4658 4659
}

4660
static void css_free_rcu_fn(struct rcu_head *rcu_head)
4661 4662
{
	struct cgroup_subsys_state *css =
4663
		container_of(rcu_head, struct cgroup_subsys_state, rcu_head);
4664

4665
	INIT_WORK(&css->destroy_work, css_free_work_fn);
4666
	queue_work(cgroup_destroy_wq, &css->destroy_work);
4667 4668
}

4669
static void css_release_work_fn(struct work_struct *work)
4670 4671
{
	struct cgroup_subsys_state *css =
4672
		container_of(work, struct cgroup_subsys_state, destroy_work);
4673
	struct cgroup_subsys *ss = css->ss;
4674
	struct cgroup *cgrp = css->cgroup;
4675

4676 4677
	mutex_lock(&cgroup_mutex);

4678
	css->flags |= CSS_RELEASED;
4679 4680
	list_del_rcu(&css->sibling);

4681 4682
	if (ss) {
		/* css release path */
4683
		cgroup_idr_replace(&ss->css_idr, NULL, css->id);
4684 4685
		if (ss->css_released)
			ss->css_released(css);
4686 4687 4688 4689
	} else {
		/* cgroup release path */
		cgroup_idr_remove(&cgrp->root->cgroup_idr, cgrp->id);
		cgrp->id = -1;
4690 4691 4692 4693 4694 4695 4696 4697 4698

		/*
		 * There are two control paths which try to determine
		 * cgroup from dentry without going through kernfs -
		 * cgroupstats_build() and css_tryget_online_from_dir().
		 * Those are supported by RCU protecting clearing of
		 * cgrp->kn->priv backpointer.
		 */
		RCU_INIT_POINTER(*(void __rcu __force **)&cgrp->kn->priv, NULL);
4699
	}
4700

4701 4702
	mutex_unlock(&cgroup_mutex);

4703
	call_rcu(&css->rcu_head, css_free_rcu_fn);
4704 4705 4706 4707 4708 4709 4710
}

static void css_release(struct percpu_ref *ref)
{
	struct cgroup_subsys_state *css =
		container_of(ref, struct cgroup_subsys_state, refcnt);

4711 4712
	INIT_WORK(&css->destroy_work, css_release_work_fn);
	queue_work(cgroup_destroy_wq, &css->destroy_work);
4713 4714
}

4715 4716
static void init_and_link_css(struct cgroup_subsys_state *css,
			      struct cgroup_subsys *ss, struct cgroup *cgrp)
4717
{
4718 4719
	lockdep_assert_held(&cgroup_mutex);

4720 4721
	cgroup_get(cgrp);

4722
	memset(css, 0, sizeof(*css));
4723
	css->cgroup = cgrp;
4724
	css->ss = ss;
4725 4726
	INIT_LIST_HEAD(&css->sibling);
	INIT_LIST_HEAD(&css->children);
4727
	INIT_LIST_HEAD(&css->files);
4728
	css->serial_nr = css_serial_nr_next++;
4729

T
Tejun Heo 已提交
4730 4731
	if (cgroup_parent(cgrp)) {
		css->parent = cgroup_css(cgroup_parent(cgrp), ss);
4732 4733
		css_get(css->parent);
	}
4734

4735
	BUG_ON(cgroup_css(cgrp, ss));
4736 4737
}

4738
/* invoke ->css_online() on a new CSS and mark it online if successful */
4739
static int online_css(struct cgroup_subsys_state *css)
4740
{
4741
	struct cgroup_subsys *ss = css->ss;
T
Tejun Heo 已提交
4742 4743
	int ret = 0;

4744 4745
	lockdep_assert_held(&cgroup_mutex);

4746
	if (ss->css_online)
4747
		ret = ss->css_online(css);
4748
	if (!ret) {
4749
		css->flags |= CSS_ONLINE;
4750
		rcu_assign_pointer(css->cgroup->subsys[ss->id], css);
4751
	}
T
Tejun Heo 已提交
4752
	return ret;
4753 4754
}

4755
/* if the CSS is online, invoke ->css_offline() on it and mark it offline */
4756
static void offline_css(struct cgroup_subsys_state *css)
4757
{
4758
	struct cgroup_subsys *ss = css->ss;
4759 4760 4761 4762 4763 4764

	lockdep_assert_held(&cgroup_mutex);

	if (!(css->flags & CSS_ONLINE))
		return;

4765
	if (ss->css_offline)
4766
		ss->css_offline(css);
4767

4768
	css->flags &= ~CSS_ONLINE;
4769
	RCU_INIT_POINTER(css->cgroup->subsys[ss->id], NULL);
4770 4771

	wake_up_all(&css->cgroup->offline_waitq);
4772 4773
}

4774 4775 4776 4777
/**
 * create_css - create a cgroup_subsys_state
 * @cgrp: the cgroup new css will be associated with
 * @ss: the subsys of new css
4778
 * @visible: whether to create control knobs for the new css or not
4779 4780
 *
 * Create a new css associated with @cgrp - @ss pair.  On success, the new
4781 4782
 * css is online and installed in @cgrp with all interface files created if
 * @visible.  Returns 0 on success, -errno on failure.
4783
 */
4784 4785
static int create_css(struct cgroup *cgrp, struct cgroup_subsys *ss,
		      bool visible)
4786
{
T
Tejun Heo 已提交
4787
	struct cgroup *parent = cgroup_parent(cgrp);
4788
	struct cgroup_subsys_state *parent_css = cgroup_css(parent, ss);
4789 4790 4791 4792 4793
	struct cgroup_subsys_state *css;
	int err;

	lockdep_assert_held(&cgroup_mutex);

4794
	css = ss->css_alloc(parent_css);
4795 4796 4797
	if (IS_ERR(css))
		return PTR_ERR(css);

4798
	init_and_link_css(css, ss, cgrp);
4799

4800
	err = percpu_ref_init(&css->refcnt, css_release, 0, GFP_KERNEL);
4801
	if (err)
4802
		goto err_free_css;
4803

V
Vladimir Davydov 已提交
4804
	err = cgroup_idr_alloc(&ss->css_idr, NULL, 2, 0, GFP_KERNEL);
4805 4806 4807
	if (err < 0)
		goto err_free_percpu_ref;
	css->id = err;
4808

4809
	if (visible) {
4810
		err = css_populate_dir(css, NULL);
4811 4812 4813
		if (err)
			goto err_free_id;
	}
4814 4815

	/* @css is ready to be brought online now, make it visible */
4816
	list_add_tail_rcu(&css->sibling, &parent_css->children);
4817
	cgroup_idr_replace(&ss->css_idr, css, css->id);
4818 4819 4820

	err = online_css(css);
	if (err)
4821
		goto err_list_del;
4822

4823
	if (ss->broken_hierarchy && !ss->warned_broken_hierarchy &&
T
Tejun Heo 已提交
4824
	    cgroup_parent(parent)) {
4825
		pr_warn("%s (%d) created nested cgroup for controller \"%s\" which has incomplete hierarchy support. Nested cgroups may change behavior in the future.\n",
4826
			current->comm, current->pid, ss->name);
4827
		if (!strcmp(ss->name, "memory"))
4828
			pr_warn("\"memory\" requires setting use_hierarchy to 1 on the root\n");
4829 4830 4831 4832 4833
		ss->warned_broken_hierarchy = true;
	}

	return 0;

4834 4835
err_list_del:
	list_del_rcu(&css->sibling);
4836
	css_clear_dir(css, NULL);
4837 4838
err_free_id:
	cgroup_idr_remove(&ss->css_idr, css->id);
4839
err_free_percpu_ref:
4840
	percpu_ref_exit(&css->refcnt);
4841
err_free_css:
4842
	call_rcu(&css->rcu_head, css_free_rcu_fn);
4843 4844 4845
	return err;
}

4846 4847
static int cgroup_mkdir(struct kernfs_node *parent_kn, const char *name,
			umode_t mode)
4848
{
4849 4850
	struct cgroup *parent, *cgrp;
	struct cgroup_root *root;
4851
	struct cgroup_subsys *ss;
T
Tejun Heo 已提交
4852
	struct kernfs_node *kn;
4853
	int ssid, ret;
4854

4855 4856 4857 4858 4859
	/* Do not accept '\n' to prevent making /proc/<pid>/cgroup unparsable.
	 */
	if (strchr(name, '\n'))
		return -EINVAL;

4860 4861 4862 4863
	parent = cgroup_kn_lock_live(parent_kn);
	if (!parent)
		return -ENODEV;
	root = parent->root;
4864

T
Tejun Heo 已提交
4865
	/* allocate the cgroup and its ID, 0 is reserved for the root */
4866
	cgrp = kzalloc(sizeof(*cgrp), GFP_KERNEL);
T
Tejun Heo 已提交
4867 4868 4869
	if (!cgrp) {
		ret = -ENOMEM;
		goto out_unlock;
4870 4871
	}

4872
	ret = percpu_ref_init(&cgrp->self.refcnt, css_release, 0, GFP_KERNEL);
4873 4874 4875
	if (ret)
		goto out_free_cgrp;

4876 4877 4878 4879
	/*
	 * Temporarily set the pointer to NULL, so idr_find() won't return
	 * a half-baked cgroup.
	 */
V
Vladimir Davydov 已提交
4880
	cgrp->id = cgroup_idr_alloc(&root->cgroup_idr, NULL, 2, 0, GFP_KERNEL);
4881
	if (cgrp->id < 0) {
T
Tejun Heo 已提交
4882
		ret = -ENOMEM;
4883
		goto out_cancel_ref;
4884 4885
	}

4886
	init_cgroup_housekeeping(cgrp);
4887

4888
	cgrp->self.parent = &parent->self;
T
Tejun Heo 已提交
4889
	cgrp->root = root;
4890

4891 4892 4893
	if (notify_on_release(parent))
		set_bit(CGRP_NOTIFY_ON_RELEASE, &cgrp->flags);

4894 4895
	if (test_bit(CGRP_CPUSET_CLONE_CHILDREN, &parent->flags))
		set_bit(CGRP_CPUSET_CLONE_CHILDREN, &cgrp->flags);
4896

T
Tejun Heo 已提交
4897
	/* create the directory */
T
Tejun Heo 已提交
4898
	kn = kernfs_create_dir(parent->kn, name, mode, cgrp);
T
Tejun Heo 已提交
4899
	if (IS_ERR(kn)) {
T
Tejun Heo 已提交
4900 4901
		ret = PTR_ERR(kn);
		goto out_free_id;
T
Tejun Heo 已提交
4902 4903
	}
	cgrp->kn = kn;
4904

4905
	/*
4906 4907
	 * This extra ref will be put in cgroup_free_fn() and guarantees
	 * that @cgrp->kn is always accessible.
4908
	 */
4909
	kernfs_get(kn);
4910

4911
	cgrp->self.serial_nr = css_serial_nr_next++;
4912

4913
	/* allocation complete, commit to creation */
4914
	list_add_tail_rcu(&cgrp->self.sibling, &cgroup_parent(cgrp)->self.children);
4915
	atomic_inc(&root->nr_cgrps);
4916
	cgroup_get(parent);
4917

4918 4919 4920 4921
	/*
	 * @cgrp is now fully operational.  If something fails after this
	 * point, it'll be released via the normal destruction path.
	 */
4922
	cgroup_idr_replace(&root->cgroup_idr, cgrp, cgrp->id);
4923

T
Tejun Heo 已提交
4924 4925 4926
	ret = cgroup_kn_set_ugid(kn);
	if (ret)
		goto out_destroy;
4927

4928
	ret = css_populate_dir(&cgrp->self, NULL);
T
Tejun Heo 已提交
4929 4930
	if (ret)
		goto out_destroy;
4931

4932
	/* let's create and online css's */
T
Tejun Heo 已提交
4933
	for_each_subsys(ss, ssid) {
4934
		if (parent->child_subsys_mask & (1 << ssid)) {
4935 4936
			ret = create_css(cgrp, ss,
					 parent->subtree_control & (1 << ssid));
T
Tejun Heo 已提交
4937 4938
			if (ret)
				goto out_destroy;
T
Tejun Heo 已提交
4939
		}
4940
	}
4941

4942 4943
	/*
	 * On the default hierarchy, a child doesn't automatically inherit
4944
	 * subtree_control from the parent.  Each is configured manually.
4945
	 */
4946 4947 4948 4949
	if (!cgroup_on_dfl(cgrp)) {
		cgrp->subtree_control = parent->subtree_control;
		cgroup_refresh_child_subsys_mask(cgrp);
	}
T
Tejun Heo 已提交
4950 4951

	kernfs_activate(kn);
4952

T
Tejun Heo 已提交
4953 4954
	ret = 0;
	goto out_unlock;
4955

T
Tejun Heo 已提交
4956
out_free_id:
4957
	cgroup_idr_remove(&root->cgroup_idr, cgrp->id);
4958
out_cancel_ref:
4959
	percpu_ref_exit(&cgrp->self.refcnt);
T
Tejun Heo 已提交
4960
out_free_cgrp:
4961
	kfree(cgrp);
T
Tejun Heo 已提交
4962
out_unlock:
4963
	cgroup_kn_unlock(parent_kn);
T
Tejun Heo 已提交
4964
	return ret;
4965

T
Tejun Heo 已提交
4966
out_destroy:
4967
	cgroup_destroy_locked(cgrp);
T
Tejun Heo 已提交
4968
	goto out_unlock;
4969 4970
}

4971 4972
/*
 * This is called when the refcnt of a css is confirmed to be killed.
4973 4974
 * css_tryget_online() is now guaranteed to fail.  Tell the subsystem to
 * initate destruction and put the css ref from kill_css().
4975 4976
 */
static void css_killed_work_fn(struct work_struct *work)
4977
{
4978 4979
	struct cgroup_subsys_state *css =
		container_of(work, struct cgroup_subsys_state, destroy_work);
4980

4981
	mutex_lock(&cgroup_mutex);
4982
	offline_css(css);
4983
	mutex_unlock(&cgroup_mutex);
4984 4985

	css_put(css);
4986 4987
}

4988 4989
/* css kill confirmation processing requires process context, bounce */
static void css_killed_ref_fn(struct percpu_ref *ref)
4990 4991 4992 4993
{
	struct cgroup_subsys_state *css =
		container_of(ref, struct cgroup_subsys_state, refcnt);

4994
	INIT_WORK(&css->destroy_work, css_killed_work_fn);
4995
	queue_work(cgroup_destroy_wq, &css->destroy_work);
4996 4997
}

4998 4999 5000 5001 5002 5003
/**
 * kill_css - destroy a css
 * @css: css to destroy
 *
 * This function initiates destruction of @css by removing cgroup interface
 * files and putting its base reference.  ->css_offline() will be invoked
5004 5005
 * asynchronously once css_tryget_online() is guaranteed to fail and when
 * the reference count reaches zero, @css will be released.
5006 5007
 */
static void kill_css(struct cgroup_subsys_state *css)
T
Tejun Heo 已提交
5008
{
5009
	lockdep_assert_held(&cgroup_mutex);
5010

T
Tejun Heo 已提交
5011 5012 5013 5014
	/*
	 * This must happen before css is disassociated with its cgroup.
	 * See seq_css() for details.
	 */
5015
	css_clear_dir(css, NULL);
5016

T
Tejun Heo 已提交
5017 5018 5019 5020 5021 5022 5023 5024 5025
	/*
	 * Killing would put the base ref, but we need to keep it alive
	 * until after ->css_offline().
	 */
	css_get(css);

	/*
	 * cgroup core guarantees that, by the time ->css_offline() is
	 * invoked, no new css reference will be given out via
5026
	 * css_tryget_online().  We can't simply call percpu_ref_kill() and
T
Tejun Heo 已提交
5027 5028 5029 5030 5031 5032 5033
	 * proceed to offlining css's because percpu_ref_kill() doesn't
	 * guarantee that the ref is seen as killed on all CPUs on return.
	 *
	 * Use percpu_ref_kill_and_confirm() to get notifications as each
	 * css is confirmed to be seen as killed on all CPUs.
	 */
	percpu_ref_kill_and_confirm(&css->refcnt, css_killed_ref_fn);
5034 5035 5036 5037 5038 5039 5040 5041
}

/**
 * cgroup_destroy_locked - the first stage of cgroup destruction
 * @cgrp: cgroup to be destroyed
 *
 * css's make use of percpu refcnts whose killing latency shouldn't be
 * exposed to userland and are RCU protected.  Also, cgroup core needs to
5042 5043 5044
 * guarantee that css_tryget_online() won't succeed by the time
 * ->css_offline() is invoked.  To satisfy all the requirements,
 * destruction is implemented in the following two steps.
5045 5046 5047 5048 5049 5050 5051 5052 5053 5054 5055 5056 5057 5058 5059
 *
 * s1. Verify @cgrp can be destroyed and mark it dying.  Remove all
 *     userland visible parts and start killing the percpu refcnts of
 *     css's.  Set up so that the next stage will be kicked off once all
 *     the percpu refcnts are confirmed to be killed.
 *
 * s2. Invoke ->css_offline(), mark the cgroup dead and proceed with the
 *     rest of destruction.  Once all cgroup references are gone, the
 *     cgroup is RCU-freed.
 *
 * This function implements s1.  After this step, @cgrp is gone as far as
 * the userland is concerned and a new cgroup with the same name may be
 * created.  As cgroup doesn't care about the names internally, this
 * doesn't cause any problem.
 */
5060 5061
static int cgroup_destroy_locked(struct cgroup *cgrp)
	__releases(&cgroup_mutex) __acquires(&cgroup_mutex)
5062
{
T
Tejun Heo 已提交
5063
	struct cgroup_subsys_state *css;
T
Tejun Heo 已提交
5064
	int ssid;
5065

5066 5067
	lockdep_assert_held(&cgroup_mutex);

5068 5069 5070 5071 5072
	/*
	 * Only migration can raise populated from zero and we're already
	 * holding cgroup_mutex.
	 */
	if (cgroup_is_populated(cgrp))
5073
		return -EBUSY;
L
Li Zefan 已提交
5074

5075
	/*
5076 5077 5078
	 * Make sure there's no live children.  We can't test emptiness of
	 * ->self.children as dead children linger on it while being
	 * drained; otherwise, "rmdir parent/child parent" may fail.
5079
	 */
5080
	if (css_has_online_children(&cgrp->self))
5081 5082
		return -EBUSY;

5083 5084
	/*
	 * Mark @cgrp dead.  This prevents further task migration and child
5085
	 * creation by disabling cgroup_lock_live_group().
5086
	 */
5087
	cgrp->self.flags &= ~CSS_ONLINE;
5088

5089
	/* initiate massacre of all css's */
T
Tejun Heo 已提交
5090 5091
	for_each_css(css, ssid, cgrp)
		kill_css(css);
5092 5093

	/*
5094 5095
	 * Remove @cgrp directory along with the base files.  @cgrp has an
	 * extra ref on its kn.
5096
	 */
5097
	kernfs_remove(cgrp->kn);
5098

T
Tejun Heo 已提交
5099
	check_for_release(cgroup_parent(cgrp));
T
Tejun Heo 已提交
5100

5101
	/* put the base reference */
5102
	percpu_ref_kill(&cgrp->self.refcnt);
5103

5104 5105 5106
	return 0;
};

T
Tejun Heo 已提交
5107
static int cgroup_rmdir(struct kernfs_node *kn)
5108
{
5109
	struct cgroup *cgrp;
T
Tejun Heo 已提交
5110
	int ret = 0;
5111

5112 5113 5114
	cgrp = cgroup_kn_lock_live(kn);
	if (!cgrp)
		return 0;
5115

5116
	ret = cgroup_destroy_locked(cgrp);
5117

5118
	cgroup_kn_unlock(kn);
5119
	return ret;
5120 5121
}

T
Tejun Heo 已提交
5122 5123 5124 5125 5126 5127 5128 5129
static struct kernfs_syscall_ops cgroup_kf_syscall_ops = {
	.remount_fs		= cgroup_remount,
	.show_options		= cgroup_show_options,
	.mkdir			= cgroup_mkdir,
	.rmdir			= cgroup_rmdir,
	.rename			= cgroup_rename,
};

5130
static void __init cgroup_init_subsys(struct cgroup_subsys *ss, bool early)
5131 5132
{
	struct cgroup_subsys_state *css;
D
Diego Calleja 已提交
5133 5134

	printk(KERN_INFO "Initializing cgroup subsys %s\n", ss->name);
5135

5136 5137
	mutex_lock(&cgroup_mutex);

5138
	idr_init(&ss->css_idr);
T
Tejun Heo 已提交
5139
	INIT_LIST_HEAD(&ss->cfts);
5140

5141 5142 5143
	/* Create the root cgroup state for this subsystem */
	ss->root = &cgrp_dfl_root;
	css = ss->css_alloc(cgroup_css(&cgrp_dfl_root.cgrp, ss));
5144 5145
	/* We don't handle early failures gracefully */
	BUG_ON(IS_ERR(css));
5146
	init_and_link_css(css, ss, &cgrp_dfl_root.cgrp);
5147 5148 5149 5150 5151 5152 5153

	/*
	 * Root csses are never destroyed and we can't initialize
	 * percpu_ref during early init.  Disable refcnting.
	 */
	css->flags |= CSS_NO_REF;

5154
	if (early) {
5155
		/* allocation can't be done safely during early init */
5156 5157 5158 5159 5160
		css->id = 1;
	} else {
		css->id = cgroup_idr_alloc(&ss->css_idr, css, 1, 2, GFP_KERNEL);
		BUG_ON(css->id < 0);
	}
5161

L
Li Zefan 已提交
5162
	/* Update the init_css_set to contain a subsys
5163
	 * pointer to this state - since the subsystem is
L
Li Zefan 已提交
5164
	 * newly registered, all tasks and hence the
5165
	 * init_css_set is in the subsystem's root cgroup. */
5166
	init_css_set.subsys[ss->id] = css;
5167

5168 5169
	have_fork_callback |= (bool)ss->fork << ss->id;
	have_exit_callback |= (bool)ss->exit << ss->id;
5170
	have_free_callback |= (bool)ss->free << ss->id;
5171
	have_canfork_callback |= (bool)ss->can_fork << ss->id;
5172

L
Li Zefan 已提交
5173 5174 5175 5176 5177
	/* At system boot, before all subsystems have been
	 * registered, no tasks have been forked, so we don't
	 * need to invoke fork callbacks here. */
	BUG_ON(!list_empty(&init_task.tasks));

5178
	BUG_ON(online_css(css));
5179

B
Ben Blum 已提交
5180 5181 5182
	mutex_unlock(&cgroup_mutex);
}

5183
/**
L
Li Zefan 已提交
5184 5185 5186 5187
 * cgroup_init_early - cgroup initialization at system boot
 *
 * Initialize cgroups at system boot, and initialize any
 * subsystems that request early init.
5188 5189 5190
 */
int __init cgroup_init_early(void)
{
5191
	static struct cgroup_sb_opts __initdata opts;
5192
	struct cgroup_subsys *ss;
5193
	int i;
5194

5195
	init_cgroup_root(&cgrp_dfl_root, &opts);
5196 5197
	cgrp_dfl_root.cgrp.self.flags |= CSS_NO_REF;

5198
	RCU_INIT_POINTER(init_task.cgroups, &init_css_set);
5199

T
Tejun Heo 已提交
5200
	for_each_subsys(ss, i) {
5201
		WARN(!ss->css_alloc || !ss->css_free || ss->name || ss->id,
5202 5203
		     "invalid cgroup_subsys %d:%s css_alloc=%p css_free=%p name:id=%d:%s\n",
		     i, cgroup_subsys_name[i], ss->css_alloc, ss->css_free,
5204
		     ss->id, ss->name);
5205 5206 5207
		WARN(strlen(cgroup_subsys_name[i]) > MAX_CGROUP_TYPE_NAMELEN,
		     "cgroup_subsys_name %s too long\n", cgroup_subsys_name[i]);

5208
		ss->id = i;
5209
		ss->name = cgroup_subsys_name[i];
5210 5211
		if (!ss->legacy_name)
			ss->legacy_name = cgroup_subsys_name[i];
5212 5213

		if (ss->early_init)
5214
			cgroup_init_subsys(ss, true);
5215 5216 5217 5218
	}
	return 0;
}

5219 5220
static unsigned long cgroup_disable_mask __initdata;

5221
/**
L
Li Zefan 已提交
5222 5223 5224 5225
 * cgroup_init - cgroup initialization
 *
 * Register cgroup filesystem and /proc file, and initialize
 * any subsystems that didn't request early init.
5226 5227 5228
 */
int __init cgroup_init(void)
{
5229
	struct cgroup_subsys *ss;
5230
	unsigned long key;
5231
	int ssid;
5232

5233
	BUG_ON(percpu_init_rwsem(&cgroup_threadgroup_rwsem));
5234 5235
	BUG_ON(cgroup_init_cftypes(NULL, cgroup_dfl_base_files));
	BUG_ON(cgroup_init_cftypes(NULL, cgroup_legacy_base_files));
5236

T
Tejun Heo 已提交
5237 5238
	mutex_lock(&cgroup_mutex);

5239 5240 5241 5242
	/* Add init_css_set to the hash table */
	key = css_set_hash(init_css_set.subsys);
	hash_add(css_set_table, &init_css_set.hlist, key);

5243
	BUG_ON(cgroup_setup_root(&cgrp_dfl_root, 0));
5244

T
Tejun Heo 已提交
5245 5246
	mutex_unlock(&cgroup_mutex);

5247
	for_each_subsys(ss, ssid) {
5248 5249 5250 5251 5252 5253 5254 5255 5256 5257
		if (ss->early_init) {
			struct cgroup_subsys_state *css =
				init_css_set.subsys[ss->id];

			css->id = cgroup_idr_alloc(&ss->css_idr, css, 1, 2,
						   GFP_KERNEL);
			BUG_ON(css->id < 0);
		} else {
			cgroup_init_subsys(ss, false);
		}
5258

T
Tejun Heo 已提交
5259 5260
		list_add_tail(&init_css_set.e_cset_node[ssid],
			      &cgrp_dfl_root.cgrp.e_csets[ssid]);
5261 5262

		/*
5263 5264 5265
		 * Setting dfl_root subsys_mask needs to consider the
		 * disabled flag and cftype registration needs kmalloc,
		 * both of which aren't available during early_init.
5266
		 */
5267 5268 5269 5270
		if (cgroup_disable_mask & (1 << ssid)) {
			static_branch_disable(cgroup_subsys_enabled_key[ssid]);
			printk(KERN_INFO "Disabling %s control group subsystem\n",
			       ss->name);
5271
			continue;
5272
		}
5273 5274 5275

		cgrp_dfl_root.subsys_mask |= 1 << ss->id;

5276 5277 5278
		if (!ss->dfl_cftypes)
			cgrp_dfl_root_inhibit_ss_mask |= 1 << ss->id;

5279 5280 5281 5282 5283
		if (ss->dfl_cftypes == ss->legacy_cftypes) {
			WARN_ON(cgroup_add_cftypes(ss, ss->dfl_cftypes));
		} else {
			WARN_ON(cgroup_add_dfl_cftypes(ss, ss->dfl_cftypes));
			WARN_ON(cgroup_add_legacy_cftypes(ss, ss->legacy_cftypes));
5284
		}
5285 5286 5287

		if (ss->bind)
			ss->bind(init_css_set.subsys[ssid]);
5288 5289
	}

5290 5291 5292
	WARN_ON(sysfs_create_mount_point(fs_kobj, "cgroup"));
	WARN_ON(register_filesystem(&cgroup_fs_type));
	WARN_ON(!proc_create("cgroups", 0, NULL, &proc_cgroupstats_operations));
5293

T
Tejun Heo 已提交
5294
	return 0;
5295
}
5296

5297 5298 5299 5300 5301
static int __init cgroup_wq_init(void)
{
	/*
	 * There isn't much point in executing destruction path in
	 * parallel.  Good chunk is serialized with cgroup_mutex anyway.
5302
	 * Use 1 for @max_active.
5303 5304 5305 5306
	 *
	 * We would prefer to do this in cgroup_init() above, but that
	 * is called before init_workqueues(): so leave this until after.
	 */
5307
	cgroup_destroy_wq = alloc_workqueue("cgroup_destroy", 0, 1);
5308
	BUG_ON(!cgroup_destroy_wq);
5309 5310 5311 5312 5313 5314 5315 5316 5317

	/*
	 * Used to destroy pidlists and separate to serve as flush domain.
	 * Cap @max_active to 1 too.
	 */
	cgroup_pidlist_destroy_wq = alloc_workqueue("cgroup_pidlist_destroy",
						    0, 1);
	BUG_ON(!cgroup_pidlist_destroy_wq);

5318 5319 5320 5321
	return 0;
}
core_initcall(cgroup_wq_init);

5322 5323 5324 5325 5326
/*
 * proc_cgroup_show()
 *  - Print task's cgroup paths into seq_file, one line for each hierarchy
 *  - Used for /proc/<pid>/cgroup.
 */
Z
Zefan Li 已提交
5327 5328
int proc_cgroup_show(struct seq_file *m, struct pid_namespace *ns,
		     struct pid *pid, struct task_struct *tsk)
5329
{
T
Tejun Heo 已提交
5330
	char *buf, *path;
5331
	int retval;
5332
	struct cgroup_root *root;
5333 5334

	retval = -ENOMEM;
T
Tejun Heo 已提交
5335
	buf = kmalloc(PATH_MAX, GFP_KERNEL);
5336 5337 5338 5339
	if (!buf)
		goto out;

	mutex_lock(&cgroup_mutex);
5340
	spin_lock_bh(&css_set_lock);
5341

5342
	for_each_root(root) {
5343
		struct cgroup_subsys *ss;
5344
		struct cgroup *cgrp;
T
Tejun Heo 已提交
5345
		int ssid, count = 0;
5346

T
Tejun Heo 已提交
5347
		if (root == &cgrp_dfl_root && !cgrp_dfl_root_visible)
5348 5349
			continue;

5350
		seq_printf(m, "%d:", root->hierarchy_id);
5351 5352 5353 5354
		if (root != &cgrp_dfl_root)
			for_each_subsys(ss, ssid)
				if (root->subsys_mask & (1 << ssid))
					seq_printf(m, "%s%s", count++ ? "," : "",
5355
						   ss->legacy_name);
5356 5357 5358
		if (strlen(root->name))
			seq_printf(m, "%sname=%s", count ? "," : "",
				   root->name);
5359
		seq_putc(m, ':');
5360

5361
		cgrp = task_cgroup_from_root(tsk, root);
5362 5363 5364 5365 5366 5367 5368 5369 5370 5371 5372 5373 5374 5375 5376 5377 5378 5379

		/*
		 * On traditional hierarchies, all zombie tasks show up as
		 * belonging to the root cgroup.  On the default hierarchy,
		 * while a zombie doesn't show up in "cgroup.procs" and
		 * thus can't be migrated, its /proc/PID/cgroup keeps
		 * reporting the cgroup it belonged to before exiting.  If
		 * the cgroup is removed before the zombie is reaped,
		 * " (deleted)" is appended to the cgroup path.
		 */
		if (cgroup_on_dfl(cgrp) || !(tsk->flags & PF_EXITING)) {
			path = cgroup_path(cgrp, buf, PATH_MAX);
			if (!path) {
				retval = -ENAMETOOLONG;
				goto out_unlock;
			}
		} else {
			path = "/";
T
Tejun Heo 已提交
5380
		}
5381

T
Tejun Heo 已提交
5382
		seq_puts(m, path);
5383 5384 5385 5386 5387

		if (cgroup_on_dfl(cgrp) && cgroup_is_dead(cgrp))
			seq_puts(m, " (deleted)\n");
		else
			seq_putc(m, '\n');
5388 5389
	}

Z
Zefan Li 已提交
5390
	retval = 0;
5391
out_unlock:
5392
	spin_unlock_bh(&css_set_lock);
5393 5394 5395 5396 5397 5398 5399 5400 5401
	mutex_unlock(&cgroup_mutex);
	kfree(buf);
out:
	return retval;
}

/* Display information about each subsystem and each hierarchy */
static int proc_cgroupstats_show(struct seq_file *m, void *v)
{
5402
	struct cgroup_subsys *ss;
5403 5404
	int i;

5405
	seq_puts(m, "#subsys_name\thierarchy\tnum_cgroups\tenabled\n");
B
Ben Blum 已提交
5406 5407 5408 5409 5410
	/*
	 * ideally we don't want subsystems moving around while we do this.
	 * cgroup_mutex is also necessary to guarantee an atomic snapshot of
	 * subsys/hierarchy state.
	 */
5411
	mutex_lock(&cgroup_mutex);
5412 5413

	for_each_subsys(ss, i)
5414
		seq_printf(m, "%s\t%d\t%d\t%d\n",
5415
			   ss->legacy_name, ss->root->hierarchy_id,
5416 5417
			   atomic_read(&ss->root->nr_cgrps),
			   cgroup_ssid_enabled(i));
5418

5419 5420 5421 5422 5423 5424
	mutex_unlock(&cgroup_mutex);
	return 0;
}

static int cgroupstats_open(struct inode *inode, struct file *file)
{
A
Al Viro 已提交
5425
	return single_open(file, proc_cgroupstats_show, NULL);
5426 5427
}

5428
static const struct file_operations proc_cgroupstats_operations = {
5429 5430 5431 5432 5433 5434
	.open = cgroupstats_open,
	.read = seq_read,
	.llseek = seq_lseek,
	.release = single_release,
};

5435 5436 5437 5438 5439 5440 5441 5442 5443 5444 5445 5446 5447
static void **subsys_canfork_priv_p(void *ss_priv[CGROUP_CANFORK_COUNT], int i)
{
	if (CGROUP_CANFORK_START <= i && i < CGROUP_CANFORK_END)
		return &ss_priv[i - CGROUP_CANFORK_START];
	return NULL;
}

static void *subsys_canfork_priv(void *ss_priv[CGROUP_CANFORK_COUNT], int i)
{
	void **private = subsys_canfork_priv_p(ss_priv, i);
	return private ? *private : NULL;
}

5448
/**
5449
 * cgroup_fork - initialize cgroup related fields during copy_process()
L
Li Zefan 已提交
5450
 * @child: pointer to task_struct of forking parent process.
5451
 *
5452 5453 5454
 * A task is associated with the init_css_set until cgroup_post_fork()
 * attaches it to the parent's css_set.  Empty cg_list indicates that
 * @child isn't holding reference to its css_set.
5455 5456 5457
 */
void cgroup_fork(struct task_struct *child)
{
5458
	RCU_INIT_POINTER(child->cgroups, &init_css_set);
5459
	INIT_LIST_HEAD(&child->cg_list);
5460 5461
}

5462 5463 5464 5465 5466 5467 5468 5469 5470 5471 5472 5473 5474 5475 5476 5477 5478 5479 5480 5481 5482 5483 5484 5485 5486 5487 5488 5489 5490 5491 5492 5493 5494 5495 5496 5497 5498 5499 5500 5501 5502 5503 5504 5505 5506 5507 5508 5509 5510 5511 5512
/**
 * cgroup_can_fork - called on a new task before the process is exposed
 * @child: the task in question.
 *
 * This calls the subsystem can_fork() callbacks. If the can_fork() callback
 * returns an error, the fork aborts with that error code. This allows for
 * a cgroup subsystem to conditionally allow or deny new forks.
 */
int cgroup_can_fork(struct task_struct *child,
		    void *ss_priv[CGROUP_CANFORK_COUNT])
{
	struct cgroup_subsys *ss;
	int i, j, ret;

	for_each_subsys_which(ss, i, &have_canfork_callback) {
		ret = ss->can_fork(child, subsys_canfork_priv_p(ss_priv, i));
		if (ret)
			goto out_revert;
	}

	return 0;

out_revert:
	for_each_subsys(ss, j) {
		if (j >= i)
			break;
		if (ss->cancel_fork)
			ss->cancel_fork(child, subsys_canfork_priv(ss_priv, j));
	}

	return ret;
}

/**
 * cgroup_cancel_fork - called if a fork failed after cgroup_can_fork()
 * @child: the task in question
 *
 * This calls the cancel_fork() callbacks if a fork failed *after*
 * cgroup_can_fork() succeded.
 */
void cgroup_cancel_fork(struct task_struct *child,
			void *ss_priv[CGROUP_CANFORK_COUNT])
{
	struct cgroup_subsys *ss;
	int i;

	for_each_subsys(ss, i)
		if (ss->cancel_fork)
			ss->cancel_fork(child, subsys_canfork_priv(ss_priv, i));
}

5513
/**
L
Li Zefan 已提交
5514 5515 5516
 * cgroup_post_fork - called on a new task after adding it to the task list
 * @child: the task in question
 *
5517 5518 5519
 * Adds the task to the list running through its css_set if necessary and
 * call the subsystem fork() callbacks.  Has to be after the task is
 * visible on the task list in case we race with the first call to
5520
 * cgroup_task_iter_start() - to guarantee that the new task ends up on its
5521
 * list.
L
Li Zefan 已提交
5522
 */
5523 5524
void cgroup_post_fork(struct task_struct *child,
		      void *old_ss_priv[CGROUP_CANFORK_COUNT])
5525
{
5526
	struct cgroup_subsys *ss;
5527 5528
	int i;

5529
	/*
D
Dongsheng Yang 已提交
5530
	 * This may race against cgroup_enable_task_cg_lists().  As that
5531 5532 5533 5534 5535 5536 5537
	 * function sets use_task_css_set_links before grabbing
	 * tasklist_lock and we just went through tasklist_lock to add
	 * @child, it's guaranteed that either we see the set
	 * use_task_css_set_links or cgroup_enable_task_cg_lists() sees
	 * @child during its iteration.
	 *
	 * If we won the race, @child is associated with %current's
5538
	 * css_set.  Grabbing css_set_lock guarantees both that the
5539 5540 5541 5542 5543 5544
	 * association is stable, and, on completion of the parent's
	 * migration, @child is visible in the source of migration or
	 * already in the destination cgroup.  This guarantee is necessary
	 * when implementing operations which need to migrate all tasks of
	 * a cgroup to another.
	 *
D
Dongsheng Yang 已提交
5545
	 * Note that if we lose to cgroup_enable_task_cg_lists(), @child
5546 5547 5548
	 * will remain in init_css_set.  This is safe because all tasks are
	 * in the init_css_set before cg_links is enabled and there's no
	 * operation which transfers all tasks out of init_css_set.
5549
	 */
5550
	if (use_task_css_set_links) {
5551 5552
		struct css_set *cset;

5553
		spin_lock_bh(&css_set_lock);
5554
		cset = task_css_set(current);
5555 5556
		if (list_empty(&child->cg_list)) {
			get_css_set(cset);
T
Tejun Heo 已提交
5557
			css_set_move_task(child, NULL, cset, false);
5558
		}
5559
		spin_unlock_bh(&css_set_lock);
5560
	}
5561 5562 5563 5564 5565 5566

	/*
	 * Call ss->fork().  This must happen after @child is linked on
	 * css_set; otherwise, @child might change state between ->fork()
	 * and addition to css_set.
	 */
5567
	for_each_subsys_which(ss, i, &have_fork_callback)
5568
		ss->fork(child, subsys_canfork_priv(old_ss_priv, i));
5569
}
5570

5571 5572 5573 5574 5575 5576 5577 5578 5579 5580 5581 5582
/**
 * cgroup_exit - detach cgroup from exiting task
 * @tsk: pointer to task_struct of exiting process
 *
 * Description: Detach cgroup from @tsk and release it.
 *
 * Note that cgroups marked notify_on_release force every task in
 * them to take the global cgroup_mutex mutex when exiting.
 * This could impact scaling on very large systems.  Be reluctant to
 * use notify_on_release cgroups where very high task exit scaling
 * is required on large systems.
 *
5583 5584 5585 5586 5587
 * We set the exiting tasks cgroup to the root cgroup (top_cgroup).  We
 * call cgroup_exit() while the task is still competent to handle
 * notify_on_release(), then leave the task attached to the root cgroup in
 * each hierarchy for the remainder of its exit.  No need to bother with
 * init_css_set refcnting.  init_css_set never goes away and we can't race
5588
 * with migration path - PF_EXITING is visible to migration path.
5589
 */
5590
void cgroup_exit(struct task_struct *tsk)
5591
{
5592
	struct cgroup_subsys *ss;
5593
	struct css_set *cset;
5594
	int i;
5595 5596

	/*
5597
	 * Unlink from @tsk from its css_set.  As migration path can't race
5598
	 * with us, we can check css_set and cg_list without synchronization.
5599
	 */
5600 5601
	cset = task_css_set(tsk);

5602
	if (!list_empty(&tsk->cg_list)) {
5603
		spin_lock_bh(&css_set_lock);
T
Tejun Heo 已提交
5604
		css_set_move_task(tsk, cset, NULL, false);
5605
		spin_unlock_bh(&css_set_lock);
5606 5607
	} else {
		get_css_set(cset);
5608 5609
	}

5610
	/* see cgroup_post_fork() for details */
5611 5612 5613
	for_each_subsys_which(ss, i, &have_exit_callback)
		ss->exit(tsk);
}
5614

5615 5616 5617
void cgroup_free(struct task_struct *task)
{
	struct css_set *cset = task_css_set(task);
5618 5619 5620 5621 5622
	struct cgroup_subsys *ss;
	int ssid;

	for_each_subsys_which(ss, ssid, &have_free_callback)
		ss->free(task);
5623

5624
	put_css_set(cset);
5625
}
5626

5627
static void check_for_release(struct cgroup *cgrp)
5628
{
5629
	if (notify_on_release(cgrp) && !cgroup_is_populated(cgrp) &&
5630 5631
	    !css_has_online_children(&cgrp->self) && !cgroup_is_dead(cgrp))
		schedule_work(&cgrp->release_agent_work);
5632 5633 5634 5635 5636 5637 5638 5639 5640 5641 5642 5643 5644 5645 5646 5647 5648 5649 5650 5651 5652 5653 5654 5655 5656 5657 5658
}

/*
 * Notify userspace when a cgroup is released, by running the
 * configured release agent with the name of the cgroup (path
 * relative to the root of cgroup file system) as the argument.
 *
 * Most likely, this user command will try to rmdir this cgroup.
 *
 * This races with the possibility that some other task will be
 * attached to this cgroup before it is removed, or that some other
 * user task will 'mkdir' a child cgroup of this cgroup.  That's ok.
 * The presumed 'rmdir' will fail quietly if this cgroup is no longer
 * unused, and this cgroup will be reprieved from its death sentence,
 * to continue to serve a useful existence.  Next time it's released,
 * we will get notified again, if it still has 'notify_on_release' set.
 *
 * The final arg to call_usermodehelper() is UMH_WAIT_EXEC, which
 * means only wait until the task is successfully execve()'d.  The
 * separate release agent task is forked by call_usermodehelper(),
 * then control in this thread returns here, without waiting for the
 * release agent task.  We don't bother to wait because the caller of
 * this routine has no use for the exit status of the release agent
 * task, so no sense holding our caller up for that.
 */
static void cgroup_release_agent(struct work_struct *work)
{
5659 5660 5661 5662 5663
	struct cgroup *cgrp =
		container_of(work, struct cgroup, release_agent_work);
	char *pathbuf = NULL, *agentbuf = NULL, *path;
	char *argv[3], *envp[3];

5664
	mutex_lock(&cgroup_mutex);
5665 5666 5667 5668 5669 5670 5671 5672 5673 5674 5675 5676 5677 5678 5679 5680 5681 5682 5683

	pathbuf = kmalloc(PATH_MAX, GFP_KERNEL);
	agentbuf = kstrdup(cgrp->root->release_agent_path, GFP_KERNEL);
	if (!pathbuf || !agentbuf)
		goto out;

	path = cgroup_path(cgrp, pathbuf, PATH_MAX);
	if (!path)
		goto out;

	argv[0] = agentbuf;
	argv[1] = path;
	argv[2] = NULL;

	/* minimal command environment */
	envp[0] = "HOME=/";
	envp[1] = "PATH=/sbin:/bin:/usr/sbin:/usr/bin";
	envp[2] = NULL;

5684
	mutex_unlock(&cgroup_mutex);
5685
	call_usermodehelper(argv[0], argv, envp, UMH_WAIT_EXEC);
5686
	goto out_free;
5687
out:
5688
	mutex_unlock(&cgroup_mutex);
5689
out_free:
5690 5691
	kfree(agentbuf);
	kfree(pathbuf);
5692
}
5693 5694 5695

static int __init cgroup_disable(char *str)
{
5696
	struct cgroup_subsys *ss;
5697
	char *token;
5698
	int i;
5699 5700 5701 5702

	while ((token = strsep(&str, ",")) != NULL) {
		if (!*token)
			continue;
5703

T
Tejun Heo 已提交
5704
		for_each_subsys(ss, i) {
5705 5706 5707
			if (strcmp(token, ss->name) &&
			    strcmp(token, ss->legacy_name))
				continue;
5708
			cgroup_disable_mask |= 1 << i;
5709 5710 5711 5712 5713
		}
	}
	return 1;
}
__setup("cgroup_disable=", cgroup_disable);
K
KAMEZAWA Hiroyuki 已提交
5714

5715
/**
5716
 * css_tryget_online_from_dir - get corresponding css from a cgroup dentry
5717 5718
 * @dentry: directory dentry of interest
 * @ss: subsystem of interest
5719
 *
5720 5721 5722
 * If @dentry is a directory for a cgroup which has @ss enabled on it, try
 * to get the corresponding css and return it.  If such css doesn't exist
 * or can't be pinned, an ERR_PTR value is returned.
S
Stephane Eranian 已提交
5723
 */
5724 5725
struct cgroup_subsys_state *css_tryget_online_from_dir(struct dentry *dentry,
						       struct cgroup_subsys *ss)
S
Stephane Eranian 已提交
5726
{
T
Tejun Heo 已提交
5727 5728
	struct kernfs_node *kn = kernfs_node_from_dentry(dentry);
	struct cgroup_subsys_state *css = NULL;
S
Stephane Eranian 已提交
5729 5730
	struct cgroup *cgrp;

5731
	/* is @dentry a cgroup dir? */
T
Tejun Heo 已提交
5732 5733
	if (dentry->d_sb->s_type != &cgroup_fs_type || !kn ||
	    kernfs_type(kn) != KERNFS_DIR)
S
Stephane Eranian 已提交
5734 5735
		return ERR_PTR(-EBADF);

5736 5737
	rcu_read_lock();

T
Tejun Heo 已提交
5738 5739 5740
	/*
	 * This path doesn't originate from kernfs and @kn could already
	 * have been or be removed at any point.  @kn->priv is RCU
5741
	 * protected for this access.  See css_release_work_fn() for details.
T
Tejun Heo 已提交
5742 5743 5744 5745
	 */
	cgrp = rcu_dereference(kn->priv);
	if (cgrp)
		css = cgroup_css(cgrp, ss);
5746

5747
	if (!css || !css_tryget_online(css))
5748 5749 5750 5751
		css = ERR_PTR(-ENOENT);

	rcu_read_unlock();
	return css;
S
Stephane Eranian 已提交
5752 5753
}

5754 5755 5756 5757 5758 5759 5760 5761 5762 5763
/**
 * css_from_id - lookup css by id
 * @id: the cgroup id
 * @ss: cgroup subsys to be looked into
 *
 * Returns the css if there's valid one with @id, otherwise returns NULL.
 * Should be called under rcu_read_lock().
 */
struct cgroup_subsys_state *css_from_id(int id, struct cgroup_subsys *ss)
{
5764
	WARN_ON_ONCE(!rcu_read_lock_held());
5765
	return id > 0 ? idr_find(&ss->css_idr, id) : NULL;
S
Stephane Eranian 已提交
5766 5767
}

5768
#ifdef CONFIG_CGROUP_DEBUG
5769 5770
static struct cgroup_subsys_state *
debug_css_alloc(struct cgroup_subsys_state *parent_css)
5771 5772 5773 5774 5775 5776 5777 5778 5779
{
	struct cgroup_subsys_state *css = kzalloc(sizeof(*css), GFP_KERNEL);

	if (!css)
		return ERR_PTR(-ENOMEM);

	return css;
}

5780
static void debug_css_free(struct cgroup_subsys_state *css)
5781
{
5782
	kfree(css);
5783 5784
}

5785 5786
static u64 debug_taskcount_read(struct cgroup_subsys_state *css,
				struct cftype *cft)
5787
{
5788
	return cgroup_task_count(css->cgroup);
5789 5790
}

5791 5792
static u64 current_css_set_read(struct cgroup_subsys_state *css,
				struct cftype *cft)
5793 5794 5795 5796
{
	return (u64)(unsigned long)current->cgroups;
}

5797
static u64 current_css_set_refcount_read(struct cgroup_subsys_state *css,
L
Li Zefan 已提交
5798
					 struct cftype *cft)
5799 5800 5801 5802
{
	u64 count;

	rcu_read_lock();
5803
	count = atomic_read(&task_css_set(current)->refcount);
5804 5805 5806 5807
	rcu_read_unlock();
	return count;
}

5808
static int current_css_set_cg_links_read(struct seq_file *seq, void *v)
5809
{
5810
	struct cgrp_cset_link *link;
5811
	struct css_set *cset;
T
Tejun Heo 已提交
5812 5813 5814 5815 5816
	char *name_buf;

	name_buf = kmalloc(NAME_MAX + 1, GFP_KERNEL);
	if (!name_buf)
		return -ENOMEM;
5817

5818
	spin_lock_bh(&css_set_lock);
5819
	rcu_read_lock();
5820
	cset = rcu_dereference(current->cgroups);
5821
	list_for_each_entry(link, &cset->cgrp_links, cgrp_link) {
5822 5823
		struct cgroup *c = link->cgrp;

T
Tejun Heo 已提交
5824
		cgroup_name(c, name_buf, NAME_MAX + 1);
5825
		seq_printf(seq, "Root %d group %s\n",
T
Tejun Heo 已提交
5826
			   c->root->hierarchy_id, name_buf);
5827 5828
	}
	rcu_read_unlock();
5829
	spin_unlock_bh(&css_set_lock);
T
Tejun Heo 已提交
5830
	kfree(name_buf);
5831 5832 5833 5834
	return 0;
}

#define MAX_TASKS_SHOWN_PER_CSS 25
5835
static int cgroup_css_links_read(struct seq_file *seq, void *v)
5836
{
5837
	struct cgroup_subsys_state *css = seq_css(seq);
5838
	struct cgrp_cset_link *link;
5839

5840
	spin_lock_bh(&css_set_lock);
5841
	list_for_each_entry(link, &css->cgroup->cset_links, cset_link) {
5842
		struct css_set *cset = link->cset;
5843 5844
		struct task_struct *task;
		int count = 0;
T
Tejun Heo 已提交
5845

5846
		seq_printf(seq, "css_set %p\n", cset);
T
Tejun Heo 已提交
5847

5848
		list_for_each_entry(task, &cset->tasks, cg_list) {
T
Tejun Heo 已提交
5849 5850 5851 5852 5853 5854 5855 5856 5857
			if (count++ > MAX_TASKS_SHOWN_PER_CSS)
				goto overflow;
			seq_printf(seq, "  task %d\n", task_pid_vnr(task));
		}

		list_for_each_entry(task, &cset->mg_tasks, cg_list) {
			if (count++ > MAX_TASKS_SHOWN_PER_CSS)
				goto overflow;
			seq_printf(seq, "  task %d\n", task_pid_vnr(task));
5858
		}
T
Tejun Heo 已提交
5859 5860 5861
		continue;
	overflow:
		seq_puts(seq, "  ...\n");
5862
	}
5863
	spin_unlock_bh(&css_set_lock);
5864 5865 5866
	return 0;
}

5867
static u64 releasable_read(struct cgroup_subsys_state *css, struct cftype *cft)
5868
{
5869
	return (!cgroup_is_populated(css->cgroup) &&
Z
Zefan Li 已提交
5870
		!css_has_online_children(&css->cgroup->self));
5871 5872 5873 5874 5875 5876 5877 5878 5879 5880 5881 5882 5883 5884 5885 5886 5887 5888
}

static struct cftype debug_files[] =  {
	{
		.name = "taskcount",
		.read_u64 = debug_taskcount_read,
	},

	{
		.name = "current_css_set",
		.read_u64 = current_css_set_read,
	},

	{
		.name = "current_css_set_refcount",
		.read_u64 = current_css_set_refcount_read,
	},

5889 5890
	{
		.name = "current_css_set_cg_links",
5891
		.seq_show = current_css_set_cg_links_read,
5892 5893 5894 5895
	},

	{
		.name = "cgroup_css_links",
5896
		.seq_show = cgroup_css_links_read,
5897 5898
	},

5899 5900 5901 5902 5903
	{
		.name = "releasable",
		.read_u64 = releasable_read,
	},

5904 5905
	{ }	/* terminate */
};
5906

5907
struct cgroup_subsys debug_cgrp_subsys = {
5908 5909
	.css_alloc = debug_css_alloc,
	.css_free = debug_css_free,
5910
	.legacy_cftypes = debug_files,
5911 5912
};
#endif /* CONFIG_CGROUP_DEBUG */