blk-cgroup.c 29.4 KB
Newer Older
1
2
3
4
5
6
7
8
9
10
11
12
13
/*
 * Common Block IO controller cgroup interface
 *
 * Based on ideas and code from CFQ, CFS and BFQ:
 * Copyright (C) 2003 Jens Axboe <axboe@kernel.dk>
 *
 * Copyright (C) 2008 Fabio Checconi <fabio@gandalf.sssup.it>
 *		      Paolo Valente <paolo.valente@unimore.it>
 *
 * Copyright (C) 2009 Vivek Goyal <vgoyal@redhat.com>
 * 	              Nauman Rafique <nauman@google.com>
 */
#include <linux/ioprio.h>
14
#include <linux/kdev_t.h>
15
#include <linux/module.h>
16
#include <linux/err.h>
17
#include <linux/blkdev.h>
18
#include <linux/slab.h>
19
#include <linux/genhd.h>
20
#include <linux/delay.h>
Tejun Heo's avatar
Tejun Heo committed
21
#include <linux/atomic.h>
22
#include "blk-cgroup.h"
23
#include "blk.h"
24

25
26
#define MAX_KEY_LEN 100

27
static DEFINE_MUTEX(blkcg_pol_mutex);
28

Tejun Heo's avatar
Tejun Heo committed
29
30
struct blkcg blkcg_root = { .cfq_weight = 2 * CFQ_WEIGHT_DEFAULT,
			    .cfq_leaf_weight = 2 * CFQ_WEIGHT_DEFAULT, };
Tejun Heo's avatar
Tejun Heo committed
31
EXPORT_SYMBOL_GPL(blkcg_root);
32

Tejun Heo's avatar
Tejun Heo committed
33
static struct blkcg_policy *blkcg_policy[BLKCG_MAX_POLS];
34

35
static bool blkcg_policy_enabled(struct request_queue *q,
Tejun Heo's avatar
Tejun Heo committed
36
				 const struct blkcg_policy *pol)
37
38
39
40
{
	return pol && test_bit(pol->plid, q->blkcg_pols);
}

41
42
43
44
45
46
/**
 * blkg_free - free a blkg
 * @blkg: blkg to free
 *
 * Free @blkg which may be partially allocated.
 */
Tejun Heo's avatar
Tejun Heo committed
47
static void blkg_free(struct blkcg_gq *blkg)
48
{
49
	int i;
50
51
52
53

	if (!blkg)
		return;

54
55
	for (i = 0; i < BLKCG_MAX_POLS; i++)
		kfree(blkg->pd[i]);
56

57
	blk_exit_rl(&blkg->rl);
58
	kfree(blkg);
59
60
61
62
63
64
}

/**
 * blkg_alloc - allocate a blkg
 * @blkcg: block cgroup the new blkg is associated with
 * @q: request_queue the new blkg is associated with
65
 * @gfp_mask: allocation mask to use
66
 *
67
 * Allocate a new blkg assocating @blkcg and @q.
68
 */
69
70
static struct blkcg_gq *blkg_alloc(struct blkcg *blkcg, struct request_queue *q,
				   gfp_t gfp_mask)
71
{
Tejun Heo's avatar
Tejun Heo committed
72
	struct blkcg_gq *blkg;
73
	int i;
74
75

	/* alloc and init base part */
76
	blkg = kzalloc_node(sizeof(*blkg), gfp_mask, q->node);
77
78
79
	if (!blkg)
		return NULL;

80
	blkg->q = q;
81
	INIT_LIST_HEAD(&blkg->q_node);
82
	blkg->blkcg = blkcg;
Tejun Heo's avatar
Tejun Heo committed
83
	blkg->refcnt = 1;
84

85
86
87
88
89
90
91
	/* root blkg uses @q->root_rl, init rl only for !root blkgs */
	if (blkcg != &blkcg_root) {
		if (blk_init_rl(&blkg->rl, q, gfp_mask))
			goto err_free;
		blkg->rl.blkg = blkg;
	}

92
	for (i = 0; i < BLKCG_MAX_POLS; i++) {
Tejun Heo's avatar
Tejun Heo committed
93
		struct blkcg_policy *pol = blkcg_policy[i];
94
		struct blkg_policy_data *pd;
95

96
		if (!blkcg_policy_enabled(q, pol))
97
98
99
			continue;

		/* alloc per-policy data and attach it to blkg */
100
		pd = kzalloc_node(pol->pd_size, gfp_mask, q->node);
101
102
		if (!pd)
			goto err_free;
103

104
105
		blkg->pd[i] = pd;
		pd->blkg = blkg;
Tejun Heo's avatar
Tejun Heo committed
106
		pd->plid = i;
107
108
	}

109
	return blkg;
110
111
112
113

err_free:
	blkg_free(blkg);
	return NULL;
114
115
}

116
117
118
119
120
121
122
123
124
125
126
/**
 * __blkg_lookup - internal version of blkg_lookup()
 * @blkcg: blkcg of interest
 * @q: request_queue of interest
 * @update_hint: whether to update lookup hint with the result or not
 *
 * This is internal version and shouldn't be used by policy
 * implementations.  Looks up blkgs for the @blkcg - @q pair regardless of
 * @q's bypass state.  If @update_hint is %true, the caller should be
 * holding @q->queue_lock and lookup hint is updated on success.
 */
127
128
struct blkcg_gq *__blkg_lookup(struct blkcg *blkcg, struct request_queue *q,
			       bool update_hint)
129
{
Tejun Heo's avatar
Tejun Heo committed
130
	struct blkcg_gq *blkg;
131

132
133
134
135
136
	blkg = rcu_dereference(blkcg->blkg_hint);
	if (blkg && blkg->q == q)
		return blkg;

	/*
137
138
139
140
	 * Hint didn't match.  Look up from the radix tree.  Note that the
	 * hint can only be updated under queue_lock as otherwise @blkg
	 * could have already been removed from blkg_tree.  The caller is
	 * responsible for grabbing queue_lock if @update_hint.
141
142
	 */
	blkg = radix_tree_lookup(&blkcg->blkg_tree, q->id);
143
144
145
146
147
	if (blkg && blkg->q == q) {
		if (update_hint) {
			lockdep_assert_held(q->queue_lock);
			rcu_assign_pointer(blkcg->blkg_hint, blkg);
		}
148
		return blkg;
149
	}
150

151
152
153
154
155
156
157
158
159
160
161
162
	return NULL;
}

/**
 * blkg_lookup - lookup blkg for the specified blkcg - q pair
 * @blkcg: blkcg of interest
 * @q: request_queue of interest
 *
 * Lookup blkg for the @blkcg - @q pair.  This function should be called
 * under RCU read lock and is guaranteed to return %NULL if @q is bypassing
 * - see blk_queue_bypass_start() for details.
 */
Tejun Heo's avatar
Tejun Heo committed
163
struct blkcg_gq *blkg_lookup(struct blkcg *blkcg, struct request_queue *q)
164
165
166
167
168
{
	WARN_ON_ONCE(!rcu_read_lock_held());

	if (unlikely(blk_queue_bypass(q)))
		return NULL;
169
	return __blkg_lookup(blkcg, q, false);
170
171
172
}
EXPORT_SYMBOL_GPL(blkg_lookup);

173
174
175
176
/*
 * If @new_blkg is %NULL, this function tries to allocate a new one as
 * necessary using %GFP_ATOMIC.  @new_blkg is always consumed on return.
 */
177
178
179
static struct blkcg_gq *blkg_create(struct blkcg *blkcg,
				    struct request_queue *q,
				    struct blkcg_gq *new_blkg)
180
{
Tejun Heo's avatar
Tejun Heo committed
181
	struct blkcg_gq *blkg;
182
	int i, ret;
183

184
185
186
	WARN_ON_ONCE(!rcu_read_lock_held());
	lockdep_assert_held(q->queue_lock);

187
	/* blkg holds a reference to blkcg */
188
	if (!css_tryget_online(&blkcg->css)) {
189
190
		ret = -EINVAL;
		goto err_free_blkg;
191
	}
192

193
	/* allocate */
194
195
196
	if (!new_blkg) {
		new_blkg = blkg_alloc(blkcg, q, GFP_ATOMIC);
		if (unlikely(!new_blkg)) {
197
198
			ret = -ENOMEM;
			goto err_put_css;
199
200
201
		}
	}
	blkg = new_blkg;
202

203
	/* link parent */
204
205
206
	if (blkcg_parent(blkcg)) {
		blkg->parent = __blkg_lookup(blkcg_parent(blkcg), q, false);
		if (WARN_ON_ONCE(!blkg->parent)) {
207
			ret = -EINVAL;
208
209
210
211
212
			goto err_put_css;
		}
		blkg_get(blkg->parent);
	}

213
214
215
216
217
218
219
220
221
	/* invoke per-policy init */
	for (i = 0; i < BLKCG_MAX_POLS; i++) {
		struct blkcg_policy *pol = blkcg_policy[i];

		if (blkg->pd[i] && pol->pd_init_fn)
			pol->pd_init_fn(blkg);
	}

	/* insert */
222
	spin_lock(&blkcg->lock);
223
224
225
226
	ret = radix_tree_insert(&blkcg->blkg_tree, q->id, blkg);
	if (likely(!ret)) {
		hlist_add_head_rcu(&blkg->blkcg_node, &blkcg->blkg_list);
		list_add(&blkg->q_node, &q->blkg_list);
227
228
229
230
231
232
233

		for (i = 0; i < BLKCG_MAX_POLS; i++) {
			struct blkcg_policy *pol = blkcg_policy[i];

			if (blkg->pd[i] && pol->pd_online_fn)
				pol->pd_online_fn(blkg);
		}
234
	}
235
	blkg->online = true;
236
	spin_unlock(&blkcg->lock);
237

238
239
240
241
242
	if (!ret) {
		if (blkcg == &blkcg_root) {
			q->root_blkg = blkg;
			q->root_rl.blkg = blkg;
		}
243
		return blkg;
244
	}
245

246
247
248
249
	/* @blkg failed fully initialized, use the usual release path */
	blkg_put(blkg);
	return ERR_PTR(ret);

250
err_put_css:
251
	css_put(&blkcg->css);
252
err_free_blkg:
253
	blkg_free(new_blkg);
254
	return ERR_PTR(ret);
255
}
256

257
258
259
260
261
262
/**
 * blkg_lookup_create - lookup blkg, try to create one if not there
 * @blkcg: blkcg of interest
 * @q: request_queue of interest
 *
 * Lookup blkg for the @blkcg - @q pair.  If it doesn't exist, try to
263
264
265
 * create one.  blkg creation is performed recursively from blkcg_root such
 * that all non-root blkg's have access to the parent blkg.  This function
 * should be called under RCU read lock and @q->queue_lock.
266
267
268
269
270
 *
 * Returns pointer to the looked up or created blkg on success, ERR_PTR()
 * value on error.  If @q is dead, returns ERR_PTR(-EINVAL).  If @q is not
 * dead and bypassing, returns ERR_PTR(-EBUSY).
 */
Tejun Heo's avatar
Tejun Heo committed
271
272
struct blkcg_gq *blkg_lookup_create(struct blkcg *blkcg,
				    struct request_queue *q)
273
{
274
275
276
277
278
	struct blkcg_gq *blkg;

	WARN_ON_ONCE(!rcu_read_lock_held());
	lockdep_assert_held(q->queue_lock);

279
280
281
282
283
	/*
	 * This could be the first entry point of blkcg implementation and
	 * we shouldn't allow anything to go through for a bypassing queue.
	 */
	if (unlikely(blk_queue_bypass(q)))
284
		return ERR_PTR(blk_queue_dying(q) ? -EINVAL : -EBUSY);
285
286
287
288
289

	blkg = __blkg_lookup(blkcg, q, true);
	if (blkg)
		return blkg;

290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
	/*
	 * Create blkgs walking down from blkcg_root to @blkcg, so that all
	 * non-root blkgs have access to their parents.
	 */
	while (true) {
		struct blkcg *pos = blkcg;
		struct blkcg *parent = blkcg_parent(blkcg);

		while (parent && !__blkg_lookup(parent, q, false)) {
			pos = parent;
			parent = blkcg_parent(parent);
		}

		blkg = blkg_create(pos, q, NULL);
		if (pos == blkcg || IS_ERR(blkg))
			return blkg;
	}
307
}
308
EXPORT_SYMBOL_GPL(blkg_lookup_create);
309

Tejun Heo's avatar
Tejun Heo committed
310
static void blkg_destroy(struct blkcg_gq *blkg)
311
{
Tejun Heo's avatar
Tejun Heo committed
312
	struct blkcg *blkcg = blkg->blkcg;
313
	int i;
314

315
	lockdep_assert_held(blkg->q->queue_lock);
316
	lockdep_assert_held(&blkcg->lock);
317
318

	/* Something wrong if we are trying to remove same group twice */
319
	WARN_ON_ONCE(list_empty(&blkg->q_node));
320
	WARN_ON_ONCE(hlist_unhashed(&blkg->blkcg_node));
321

322
323
324
325
326
327
328
329
	for (i = 0; i < BLKCG_MAX_POLS; i++) {
		struct blkcg_policy *pol = blkcg_policy[i];

		if (blkg->pd[i] && pol->pd_offline_fn)
			pol->pd_offline_fn(blkg);
	}
	blkg->online = false;

330
	radix_tree_delete(&blkcg->blkg_tree, blkg->q->id);
331
	list_del_init(&blkg->q_node);
332
	hlist_del_init_rcu(&blkg->blkcg_node);
333

334
335
336
337
338
	/*
	 * Both setting lookup hint to and clearing it from @blkg are done
	 * under queue_lock.  If it's not pointing to @blkg now, it never
	 * will.  Hint assignment itself can race safely.
	 */
339
	if (rcu_access_pointer(blkcg->blkg_hint) == blkg)
340
341
		rcu_assign_pointer(blkcg->blkg_hint, NULL);

342
343
344
345
346
347
348
349
350
	/*
	 * If root blkg is destroyed.  Just clear the pointer since root_rl
	 * does not take reference on root blkg.
	 */
	if (blkcg == &blkcg_root) {
		blkg->q->root_blkg = NULL;
		blkg->q->root_rl.blkg = NULL;
	}

351
352
353
354
355
356
357
	/*
	 * Put the reference taken at the time of creation so that when all
	 * queues are gone, group can be destroyed.
	 */
	blkg_put(blkg);
}

358
359
360
361
/**
 * blkg_destroy_all - destroy all blkgs associated with a request_queue
 * @q: request_queue of interest
 *
362
 * Destroy all blkgs associated with @q.
363
 */
364
static void blkg_destroy_all(struct request_queue *q)
365
{
Tejun Heo's avatar
Tejun Heo committed
366
	struct blkcg_gq *blkg, *n;
367

368
	lockdep_assert_held(q->queue_lock);
369

370
	list_for_each_entry_safe(blkg, n, &q->blkg_list, q_node) {
Tejun Heo's avatar
Tejun Heo committed
371
		struct blkcg *blkcg = blkg->blkcg;
372

373
374
375
		spin_lock(&blkcg->lock);
		blkg_destroy(blkg);
		spin_unlock(&blkcg->lock);
376
377
378
	}
}

379
380
381
382
383
384
385
386
387
/*
 * A group is RCU protected, but having an rcu lock does not mean that one
 * can access all the fields of blkg and assume these are valid.  For
 * example, don't try to follow throtl_data and request queue links.
 *
 * Having a reference to blkg under an rcu allows accesses to only values
 * local to groups like group stats and group rate limits.
 */
void __blkg_release_rcu(struct rcu_head *rcu_head)
Tejun Heo's avatar
Tejun Heo committed
388
{
389
	struct blkcg_gq *blkg = container_of(rcu_head, struct blkcg_gq, rcu_head);
390
391
392
393
394
395
396
397
398
399
	int i;

	/* tell policies that this one is being freed */
	for (i = 0; i < BLKCG_MAX_POLS; i++) {
		struct blkcg_policy *pol = blkcg_policy[i];

		if (blkg->pd[i] && pol->pd_exit_fn)
			pol->pd_exit_fn(blkg);
	}

400
	/* release the blkcg and parent blkg refs this blkg has been holding */
Tejun Heo's avatar
Tejun Heo committed
401
	css_put(&blkg->blkcg->css);
402
403
	if (blkg->parent) {
		spin_lock_irq(blkg->q->queue_lock);
404
		blkg_put(blkg->parent);
405
406
		spin_unlock_irq(blkg->q->queue_lock);
	}
Tejun Heo's avatar
Tejun Heo committed
407

408
	blkg_free(blkg);
Tejun Heo's avatar
Tejun Heo committed
409
}
410
EXPORT_SYMBOL_GPL(__blkg_release_rcu);
Tejun Heo's avatar
Tejun Heo committed
411

412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
/*
 * The next function used by blk_queue_for_each_rl().  It's a bit tricky
 * because the root blkg uses @q->root_rl instead of its own rl.
 */
struct request_list *__blk_queue_next_rl(struct request_list *rl,
					 struct request_queue *q)
{
	struct list_head *ent;
	struct blkcg_gq *blkg;

	/*
	 * Determine the current blkg list_head.  The first entry is
	 * root_rl which is off @q->blkg_list and mapped to the head.
	 */
	if (rl == &q->root_rl) {
		ent = &q->blkg_list;
428
429
430
		/* There are no more block groups, hence no request lists */
		if (list_empty(ent))
			return NULL;
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
	} else {
		blkg = container_of(rl, struct blkcg_gq, rl);
		ent = &blkg->q_node;
	}

	/* walk to the next list_head, skip root blkcg */
	ent = ent->next;
	if (ent == &q->root_blkg->q_node)
		ent = ent->next;
	if (ent == &q->blkg_list)
		return NULL;

	blkg = container_of(ent, struct blkcg_gq, q_node);
	return &blkg->rl;
}

447
448
static int blkcg_reset_stats(struct cgroup_subsys_state *css,
			     struct cftype *cftype, u64 val)
449
{
450
	struct blkcg *blkcg = css_to_blkcg(css);
Tejun Heo's avatar
Tejun Heo committed
451
	struct blkcg_gq *blkg;
452
	int i;
453

454
455
456
457
458
459
460
461
462
463
464
465
466
467
	/*
	 * XXX: We invoke cgroup_add/rm_cftypes() under blkcg_pol_mutex
	 * which ends up putting cgroup's internal cgroup_tree_mutex under
	 * it; however, cgroup_tree_mutex is nested above cgroup file
	 * active protection and grabbing blkcg_pol_mutex from a cgroup
	 * file operation creates a possible circular dependency.  cgroup
	 * internal locking is planned to go through further simplification
	 * and this issue should go away soon.  For now, let's trylock
	 * blkcg_pol_mutex and restart the write on failure.
	 *
	 * http://lkml.kernel.org/g/5363C04B.4010400@oracle.com
	 */
	if (!mutex_trylock(&blkcg_pol_mutex))
		return restart_syscall();
468
	spin_lock_irq(&blkcg->lock);
Tejun Heo's avatar
Tejun Heo committed
469
470
471
472
473
474

	/*
	 * Note that stat reset is racy - it doesn't synchronize against
	 * stat updates.  This is a debug feature which shouldn't exist
	 * anyway.  If you get hit by a race, retry.
	 */
475
	hlist_for_each_entry(blkg, &blkcg->blkg_list, blkcg_node) {
476
		for (i = 0; i < BLKCG_MAX_POLS; i++) {
Tejun Heo's avatar
Tejun Heo committed
477
			struct blkcg_policy *pol = blkcg_policy[i];
478

479
			if (blkcg_policy_enabled(blkg->q, pol) &&
480
481
			    pol->pd_reset_stats_fn)
				pol->pd_reset_stats_fn(blkg);
482
		}
483
	}
484

485
	spin_unlock_irq(&blkcg->lock);
486
	mutex_unlock(&blkcg_pol_mutex);
487
488
489
	return 0;
}

Tejun Heo's avatar
Tejun Heo committed
490
static const char *blkg_dev_name(struct blkcg_gq *blkg)
491
{
492
493
494
495
	/* some drivers (floppy) instantiate a queue w/o disk registered */
	if (blkg->q->backing_dev_info.dev)
		return dev_name(blkg->q->backing_dev_info.dev);
	return NULL;
496
497
}

498
499
500
501
502
503
504
505
506
507
508
/**
 * blkcg_print_blkgs - helper for printing per-blkg data
 * @sf: seq_file to print to
 * @blkcg: blkcg of interest
 * @prfill: fill function to print out a blkg
 * @pol: policy in question
 * @data: data to be passed to @prfill
 * @show_total: to print out sum of prfill return values or not
 *
 * This function invokes @prfill on each blkg of @blkcg if pd for the
 * policy specified by @pol exists.  @prfill is invoked with @sf, the
509
510
511
 * policy data and @data and the matching queue lock held.  If @show_total
 * is %true, the sum of the return values from @prfill is printed with
 * "Total" label at the end.
512
513
514
515
 *
 * This is to be used to construct print functions for
 * cftype->read_seq_string method.
 */
Tejun Heo's avatar
Tejun Heo committed
516
void blkcg_print_blkgs(struct seq_file *sf, struct blkcg *blkcg,
517
518
		       u64 (*prfill)(struct seq_file *,
				     struct blkg_policy_data *, int),
Tejun Heo's avatar
Tejun Heo committed
519
		       const struct blkcg_policy *pol, int data,
520
		       bool show_total)
521
{
Tejun Heo's avatar
Tejun Heo committed
522
	struct blkcg_gq *blkg;
523
	u64 total = 0;
524

525
	rcu_read_lock();
526
	hlist_for_each_entry_rcu(blkg, &blkcg->blkg_list, blkcg_node) {
527
		spin_lock_irq(blkg->q->queue_lock);
528
		if (blkcg_policy_enabled(blkg->q, pol))
529
			total += prfill(sf, blkg->pd[pol->plid], data);
530
531
532
		spin_unlock_irq(blkg->q->queue_lock);
	}
	rcu_read_unlock();
533
534
535
536

	if (show_total)
		seq_printf(sf, "Total %llu\n", (unsigned long long)total);
}
537
EXPORT_SYMBOL_GPL(blkcg_print_blkgs);
538
539
540
541

/**
 * __blkg_prfill_u64 - prfill helper for a single u64 value
 * @sf: seq_file to print to
542
 * @pd: policy private data of interest
543
544
 * @v: value to print
 *
545
 * Print @v to @sf for the device assocaited with @pd.
546
 */
547
u64 __blkg_prfill_u64(struct seq_file *sf, struct blkg_policy_data *pd, u64 v)
548
{
549
	const char *dname = blkg_dev_name(pd->blkg);
550
551
552
553
554
555
556

	if (!dname)
		return 0;

	seq_printf(sf, "%s %llu\n", dname, (unsigned long long)v);
	return v;
}
557
EXPORT_SYMBOL_GPL(__blkg_prfill_u64);
558
559
560
561

/**
 * __blkg_prfill_rwstat - prfill helper for a blkg_rwstat
 * @sf: seq_file to print to
562
 * @pd: policy private data of interest
563
564
 * @rwstat: rwstat to print
 *
565
 * Print @rwstat to @sf for the device assocaited with @pd.
566
 */
567
u64 __blkg_prfill_rwstat(struct seq_file *sf, struct blkg_policy_data *pd,
568
			 const struct blkg_rwstat *rwstat)
569
570
571
572
573
574
575
{
	static const char *rwstr[] = {
		[BLKG_RWSTAT_READ]	= "Read",
		[BLKG_RWSTAT_WRITE]	= "Write",
		[BLKG_RWSTAT_SYNC]	= "Sync",
		[BLKG_RWSTAT_ASYNC]	= "Async",
	};
576
	const char *dname = blkg_dev_name(pd->blkg);
577
578
579
580
581
582
583
584
585
586
587
588
589
590
	u64 v;
	int i;

	if (!dname)
		return 0;

	for (i = 0; i < BLKG_RWSTAT_NR; i++)
		seq_printf(sf, "%s %s %llu\n", dname, rwstr[i],
			   (unsigned long long)rwstat->cnt[i]);

	v = rwstat->cnt[BLKG_RWSTAT_READ] + rwstat->cnt[BLKG_RWSTAT_WRITE];
	seq_printf(sf, "%s Total %llu\n", dname, (unsigned long long)v);
	return v;
}
591
EXPORT_SYMBOL_GPL(__blkg_prfill_rwstat);
592

593
594
595
/**
 * blkg_prfill_stat - prfill callback for blkg_stat
 * @sf: seq_file to print to
596
597
 * @pd: policy private data of interest
 * @off: offset to the blkg_stat in @pd
598
599
600
 *
 * prfill callback for printing a blkg_stat.
 */
601
u64 blkg_prfill_stat(struct seq_file *sf, struct blkg_policy_data *pd, int off)
602
{
603
	return __blkg_prfill_u64(sf, pd, blkg_stat_read((void *)pd + off));
604
}
605
EXPORT_SYMBOL_GPL(blkg_prfill_stat);
606

607
608
609
/**
 * blkg_prfill_rwstat - prfill callback for blkg_rwstat
 * @sf: seq_file to print to
610
611
 * @pd: policy private data of interest
 * @off: offset to the blkg_rwstat in @pd
612
613
614
 *
 * prfill callback for printing a blkg_rwstat.
 */
615
616
u64 blkg_prfill_rwstat(struct seq_file *sf, struct blkg_policy_data *pd,
		       int off)
617
{
618
	struct blkg_rwstat rwstat = blkg_rwstat_read((void *)pd + off);
619

620
	return __blkg_prfill_rwstat(sf, pd, &rwstat);
621
}
622
EXPORT_SYMBOL_GPL(blkg_prfill_rwstat);
623

624
625
626
627
628
629
630
631
632
633
634
635
636
/**
 * blkg_stat_recursive_sum - collect hierarchical blkg_stat
 * @pd: policy private data of interest
 * @off: offset to the blkg_stat in @pd
 *
 * Collect the blkg_stat specified by @off from @pd and all its online
 * descendants and return the sum.  The caller must be holding the queue
 * lock for online tests.
 */
u64 blkg_stat_recursive_sum(struct blkg_policy_data *pd, int off)
{
	struct blkcg_policy *pol = blkcg_policy[pd->plid];
	struct blkcg_gq *pos_blkg;
637
	struct cgroup_subsys_state *pos_css;
638
	u64 sum = 0;
639
640
641
642

	lockdep_assert_held(pd->blkg->q->queue_lock);

	rcu_read_lock();
643
	blkg_for_each_descendant_pre(pos_blkg, pos_css, pd_to_blkg(pd)) {
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
		struct blkg_policy_data *pos_pd = blkg_to_pd(pos_blkg, pol);
		struct blkg_stat *stat = (void *)pos_pd + off;

		if (pos_blkg->online)
			sum += blkg_stat_read(stat);
	}
	rcu_read_unlock();

	return sum;
}
EXPORT_SYMBOL_GPL(blkg_stat_recursive_sum);

/**
 * blkg_rwstat_recursive_sum - collect hierarchical blkg_rwstat
 * @pd: policy private data of interest
 * @off: offset to the blkg_stat in @pd
 *
 * Collect the blkg_rwstat specified by @off from @pd and all its online
 * descendants and return the sum.  The caller must be holding the queue
 * lock for online tests.
 */
struct blkg_rwstat blkg_rwstat_recursive_sum(struct blkg_policy_data *pd,
					     int off)
{
	struct blkcg_policy *pol = blkcg_policy[pd->plid];
	struct blkcg_gq *pos_blkg;
670
	struct cgroup_subsys_state *pos_css;
671
	struct blkg_rwstat sum = { };
672
673
674
675
676
	int i;

	lockdep_assert_held(pd->blkg->q->queue_lock);

	rcu_read_lock();
677
	blkg_for_each_descendant_pre(pos_blkg, pos_css, pd_to_blkg(pd)) {
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
		struct blkg_policy_data *pos_pd = blkg_to_pd(pos_blkg, pol);
		struct blkg_rwstat *rwstat = (void *)pos_pd + off;
		struct blkg_rwstat tmp;

		if (!pos_blkg->online)
			continue;

		tmp = blkg_rwstat_read(rwstat);

		for (i = 0; i < BLKG_RWSTAT_NR; i++)
			sum.cnt[i] += tmp.cnt[i];
	}
	rcu_read_unlock();

	return sum;
}
EXPORT_SYMBOL_GPL(blkg_rwstat_recursive_sum);

696
697
698
/**
 * blkg_conf_prep - parse and prepare for per-blkg config update
 * @blkcg: target block cgroup
699
 * @pol: target policy
700
701
702
703
704
 * @input: input string
 * @ctx: blkg_conf_ctx to be filled
 *
 * Parse per-blkg config update from @input and initialize @ctx with the
 * result.  @ctx->blkg points to the blkg to be updated and @ctx->v the new
705
706
 * value.  This function returns with RCU read lock and queue lock held and
 * must be paired with blkg_conf_finish().
707
 */
Tejun Heo's avatar
Tejun Heo committed
708
709
int blkg_conf_prep(struct blkcg *blkcg, const struct blkcg_policy *pol,
		   const char *input, struct blkg_conf_ctx *ctx)
710
	__acquires(rcu) __acquires(disk->queue->queue_lock)
711
{
712
	struct gendisk *disk;
Tejun Heo's avatar
Tejun Heo committed
713
	struct blkcg_gq *blkg;
Tejun Heo's avatar
Tejun Heo committed
714
715
716
	unsigned int major, minor;
	unsigned long long v;
	int part, ret;
717

Tejun Heo's avatar
Tejun Heo committed
718
719
	if (sscanf(input, "%u:%u %llu", &major, &minor, &v) != 3)
		return -EINVAL;
720

Tejun Heo's avatar
Tejun Heo committed
721
	disk = get_gendisk(MKDEV(major, minor), &part);
Tejun Heo's avatar
Tejun Heo committed
722
	if (!disk || part)
Tejun Heo's avatar
Tejun Heo committed
723
		return -EINVAL;
724
725

	rcu_read_lock();
Tejun Heo's avatar
Tejun Heo committed
726
	spin_lock_irq(disk->queue->queue_lock);
727

728
	if (blkcg_policy_enabled(disk->queue, pol))
729
		blkg = blkg_lookup_create(blkcg, disk->queue);
730
731
	else
		blkg = ERR_PTR(-EINVAL);
732

Tejun Heo's avatar
Tejun Heo committed
733
734
	if (IS_ERR(blkg)) {
		ret = PTR_ERR(blkg);
735
		rcu_read_unlock();
736
		spin_unlock_irq(disk->queue->queue_lock);
737
738
739
740
741
742
743
744
745
746
		put_disk(disk);
		/*
		 * If queue was bypassing, we should retry.  Do so after a
		 * short msleep().  It isn't strictly necessary but queue
		 * can be bypassing for some time and it's always nice to
		 * avoid busy looping.
		 */
		if (ret == -EBUSY) {
			msleep(10);
			ret = restart_syscall();
747
		}
Tejun Heo's avatar
Tejun Heo committed
748
		return ret;
749
	}
750
751
752

	ctx->disk = disk;
	ctx->blkg = blkg;
Tejun Heo's avatar
Tejun Heo committed
753
754
	ctx->v = v;
	return 0;
755
}
756
EXPORT_SYMBOL_GPL(blkg_conf_prep);
757

758
759
760
761
762
763
764
/**
 * blkg_conf_finish - finish up per-blkg config update
 * @ctx: blkg_conf_ctx intiailized by blkg_conf_prep()
 *
 * Finish up after per-blkg config update.  This function must be paired
 * with blkg_conf_prep().
 */
765
void blkg_conf_finish(struct blkg_conf_ctx *ctx)
766
	__releases(ctx->disk->queue->queue_lock) __releases(rcu)
767
{
768
	spin_unlock_irq(ctx->disk->queue->queue_lock);
769
770
	rcu_read_unlock();
	put_disk(ctx->disk);
771
}
772
EXPORT_SYMBOL_GPL(blkg_conf_finish);
773

Tejun Heo's avatar
Tejun Heo committed
774
struct cftype blkcg_files[] = {
775
776
	{
		.name = "reset_stats",
Tejun Heo's avatar
Tejun Heo committed
777
		.write_u64 = blkcg_reset_stats,
778
	},
779
	{ }	/* terminate */
780
781
};

782
/**
783
 * blkcg_css_offline - cgroup css_offline callback
784
 * @css: css of interest
785
 *
786
787
 * This function is called when @css is about to go away and responsible
 * for shooting down all blkgs associated with @css.  blkgs should be
788
789
790
791
792
 * removed while holding both q and blkcg locks.  As blkcg lock is nested
 * inside q lock, this function performs reverse double lock dancing.
 *
 * This is the blkcg counterpart of ioc_release_fn().
 */
793
static void blkcg_css_offline(struct cgroup_subsys_state *css)
794
{
795
	struct blkcg *blkcg = css_to_blkcg(css);
796

797
	spin_lock_irq(&blkcg->lock);
798

799
	while (!hlist_empty(&blkcg->blkg_list)) {
Tejun Heo's avatar
Tejun Heo committed
800
801
		struct blkcg_gq *blkg = hlist_entry(blkcg->blkg_list.first,
						struct blkcg_gq, blkcg_node);
802
		struct request_queue *q = blkg->q;
803

804
805
806
807
808
809
		if (spin_trylock(q->queue_lock)) {
			blkg_destroy(blkg);
			spin_unlock(q->queue_lock);
		} else {
			spin_unlock_irq(&blkcg->lock);
			cpu_relax();
810
			spin_lock_irq(&blkcg->lock);
811
		}
812
	}
813

814
	spin_unlock_irq(&blkcg->lock);
815
816
}

817
static void blkcg_css_free(struct cgroup_subsys_state *css)
818
{
819
	struct blkcg *blkcg = css_to_blkcg(css);
820

Tejun Heo's avatar
Tejun Heo committed
821
	if (blkcg != &blkcg_root)
Ben Blum's avatar
Ben Blum committed
822
		kfree(blkcg);
823
824
}

825
826
static struct cgroup_subsys_state *
blkcg_css_alloc(struct cgroup_subsys_state *parent_css)
827
{
Tejun Heo's avatar
Tejun Heo committed
828
	static atomic64_t id_seq = ATOMIC64_INIT(0);
Tejun Heo's avatar
Tejun Heo committed
829
	struct blkcg *blkcg;
830

831
	if (!parent_css) {
Tejun Heo's avatar
Tejun Heo committed
832
		blkcg = &blkcg_root;
833
834
835
836
837
838
839
		goto done;
	}

	blkcg = kzalloc(sizeof(*blkcg), GFP_KERNEL);
	if (!blkcg)
		return ERR_PTR(-ENOMEM);

840
	blkcg->cfq_weight = CFQ_WEIGHT_DEFAULT;
Tejun Heo's avatar
Tejun Heo committed
841
	blkcg->cfq_leaf_weight = CFQ_WEIGHT_DEFAULT;
Tejun Heo's avatar
Tejun Heo committed
842
	blkcg->id = atomic64_inc_return(&id_seq); /* root is 0, start from 1 */
843
844
done:
	spin_lock_init(&blkcg->lock);
845
	INIT_RADIX_TREE(&blkcg->blkg_tree, GFP_ATOMIC);
846
847
848
849
850
	INIT_HLIST_HEAD(&blkcg->blkg_list);

	return &blkcg->css;
}

851
852
853
854
855
856
857
858
859
860
861
862
863
864
/**
 * blkcg_init_queue - initialize blkcg part of request queue
 * @q: request_queue to initialize
 *
 * Called from blk_alloc_queue_node(). Responsible for initializing blkcg
 * part of new request_queue @q.
 *
 * RETURNS:
 * 0 on success, -errno on failure.
 */
int blkcg_init_queue(struct request_queue *q)
{
	might_sleep();

865
	return blk_throtl_init(q);
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
}

/**
 * blkcg_drain_queue - drain blkcg part of request_queue
 * @q: request_queue to drain
 *
 * Called from blk_drain_queue().  Responsible for draining blkcg part.
 */
void blkcg_drain_queue(struct request_queue *q)
{
	lockdep_assert_held(q->queue_lock);

	blk_throtl_drain(q);
}

/**
 * blkcg_exit_queue - exit and release blkcg part of request_queue
 * @q: request_queue being released
 *
 * Called from blk_release_queue().  Responsible for exiting blkcg part.
 */
void blkcg_exit_queue(struct request_queue *q)
{
889
	spin_lock_irq(q->queue_lock);
890
	blkg_destroy_all(q);
891
892
	spin_unlock_irq(q->queue_lock);

893
894
895
	blk_throtl_exit(q);
}

896
897
898
899
900
901
/*
 * We cannot support shared io contexts, as we have no mean to support
 * two tasks with the same ioc in two different groups without major rework
 * of the main cic data structures.  For now we allow a task to change
 * its cgroup only if it's the only owner of its ioc.
 */
902
903
static int blkcg_can_attach(struct cgroup_subsys_state *css,
			    struct cgroup_taskset *tset)
904
{
905
	struct task_struct *task;
906
907
908
909
	struct io_context *ioc;
	int ret = 0;

	/* task_lock() is needed to avoid races with exit_io_context() */
910
	cgroup_taskset_for_each(task, tset) {
911
912
913
914
915
916
917
918
		task_lock(task);
		ioc = task->io_context;
		if (ioc && atomic_read(&ioc->nr_tasks) > 1)
			ret = -EINVAL;
		task_unlock(task);
		if (ret)
			break;
	}
919
920
921
	return ret;
}

922
struct cgroup_subsys blkio_cgrp_subsys = {
923
924
925
	.css_alloc = blkcg_css_alloc,
	.css_offline = blkcg_css_offline,
	.css_free = blkcg_css_free,
Tejun Heo's avatar
Tejun Heo committed
926
927
	.can_attach = blkcg_can_attach,
	.base_cftypes = blkcg_files,
928
};
929
EXPORT_SYMBOL_GPL(blkio_cgrp_subsys);
930

931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
/**
 * blkcg_activate_policy - activate a blkcg policy on a request_queue
 * @q: request_queue of interest
 * @pol: blkcg policy to activate
 *
 * Activate @pol on @q.  Requires %GFP_KERNEL context.  @q goes through
 * bypass mode to populate its blkgs with policy_data for @pol.
 *
 * Activation happens with @q bypassed, so nobody would be accessing blkgs
 * from IO path.  Update of each blkg is protected by both queue and blkcg
 * locks so that holding either lock and testing blkcg_policy_enabled() is
 * always enough for dereferencing policy data.
 *
 * The caller is responsible for synchronizing [de]activations and policy
 * [un]registerations.  Returns 0 on success, -errno on failure.
 */
int blkcg_activate_policy(struct request_queue *q,
Tejun Heo's avatar
Tejun Heo committed
948
			  const struct blkcg_policy *pol)
949
950
{
	LIST_HEAD(pds);
951
	struct blkcg_gq *blkg, *new_blkg;
952
953
	struct blkg_policy_data *pd, *n;
	int cnt = 0, ret;
954
	bool preloaded;
955
956
957
958

	if (blkcg_policy_enabled(q, pol))
		return 0;

959
	/* preallocations for root blkg */
960
961
	new_blkg = blkg_alloc(&blkcg_root, q, GFP_KERNEL);
	if (!new_blkg)
962
963
		return -ENOMEM;

964
965
	blk_queue_bypass_start(q);

966
967
	preloaded = !radix_tree_preload(GFP_KERNEL);

968
969
970
971
972
	/*
	 * Make sure the root blkg exists and count the existing blkgs.  As
	 * @q is bypassing at this point, blkg_lookup_create() can't be
	 * used.  Open code it.
	 */
973
974
975
	spin_lock_irq(q->queue_lock);

	rcu_read_lock();
976
977
978
979
980
	blkg = __blkg_lookup(&blkcg_root, q, false);
	if (blkg)
		blkg_free(new_blkg);
	else
		blkg = blkg_create(&blkcg_root, q, new_blkg);
981
982
	rcu_read_unlock();

983
984
985
	if (preloaded)
		radix_tree_preload_end();

986
987
988
989
990
991
992
993
994
995
996
997
	if (IS_ERR(blkg)) {
		ret = PTR_ERR(blkg);
		goto out_unlock;
	}

	list_for_each_entry(blkg, &q->blkg_list, q_node)
		cnt++;

	spin_unlock_irq(q->queue_lock);

	/* allocate policy_data for all existing blkgs */
	while (cnt--) {
998
		pd = kzalloc_node(pol->pd_size, GFP_KERNEL, q->node);
999
1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
1024
1025
		if (!pd) {
			ret = -ENOMEM;
			goto out_free;
		}
		list_add_tail(&pd->alloc_node, &pds);
	}

	/*
	 * Install the allocated pds.  With @q bypassing, no new blkg
	 * should have been created while the queue lock was dropped.
	 */
	spin_lock_irq(q->queue_lock);

	list_for_each_entry(blkg, &q->blkg_list, q_node) {
		if (WARN_ON(list_empty(&pds))) {
			/* umm... this shouldn't happen, just abort */
			ret = -ENOMEM;
			goto out_unlock;
		}
		pd = list_first_entry(&pds, struct blkg_policy_data, alloc_node);
		list_del_init(&pd->alloc_node);

		/* grab blkcg lock too while installing @pd on @blkg */
		spin_lock(&blkg->blkcg->lock);

		blkg->pd[pol->plid] = pd;
		pd->blkg = blkg;
Tejun Heo's avatar
Tejun Heo committed
1026
		pd->plid = pol->plid;
1027
		pol->pd_init_fn(blkg);
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037
1038
1039
1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
1052

		spin_unlock(&blkg->blkcg->lock);
	}

	__set_bit(pol->plid, q->blkcg_pols);
	ret = 0;
out_unlock:
	spin_unlock_irq(q->queue_lock);
out_free:
	blk_queue_bypass_end(q);
	list_for_each_entry_safe(pd, n, &pds, alloc_node)
		kfree(pd);
	return ret;
}
EXPORT_SYMBOL_GPL(blkcg_activate_policy);

/**
 * blkcg_deactivate_policy - deactivate a blkcg policy on a request_queue
 * @q: request_queue of interest
 * @pol: blkcg policy to deactivate
 *
 * Deactivate @pol on @q.  Follows the same synchronization rules as
 * blkcg_activate_policy().
 */
void blkcg_deactivate_policy(struct request_queue *q,
Tejun Heo's avatar
Tejun Heo committed
1053
			     const struct blkcg_policy *pol)
1054
{
Tejun Heo's avatar
Tejun Heo committed
1055
	struct blkcg_gq *blkg;
1056
1057
1058
1059
1060
1061
1062
1063
1064

	if (!blkcg_policy_enabled(q, pol))
		return;

	blk_queue_bypass_start(q);
	spin_lock_irq(q->queue_lock);

	__clear_bit(pol->plid, q->blkcg_pols);

1065
1066
1067
1068
	/* if no policy is left, no need for blkgs - shoot them down */
	if (bitmap_empty(q->blkcg_pols, BLKCG_MAX_POLS))
		blkg_destroy_all(q);

1069
1070
1071
1072
	list_for_each_entry(blkg, &q->blkg_list, q_node) {
		/* grab blkcg lock too while removing @pd from @blkg */
		spin_lock(&blkg->blkcg->lock);

1073
1074
		if (pol->pd_offline_fn)
			pol->pd_offline_fn(blkg);
1075
1076
		if (pol->pd_exit_fn)
			pol->pd_exit_fn(blkg);
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088

		kfree(blkg->pd[pol->plid]);
		blkg->pd[pol->plid] = NULL;

		spin_unlock(&blkg->blkcg->lock);
	}

	spin_unlock_irq(q->queue_lock);
	blk_queue_bypass_end(q);
}
EXPORT_SYMBOL_GPL(blkcg_deactivate_policy);

1089
/**
Tejun Heo's avatar
Tejun Heo committed
1090
1091
 * blkcg_policy_register - register a blkcg policy
 * @pol: blkcg policy to register
1092
 *