blk-cgroup.h 4.3 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
#ifndef _BLK_CGROUP_H
#define _BLK_CGROUP_H
/*
 * 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/cgroup.h>

B
Ben Blum 已提交
18 19 20 21 22 23 24
#if defined(CONFIG_BLK_CGROUP) || defined(CONFIG_BLK_CGROUP_MODULE)

#ifndef CONFIG_BLK_CGROUP
/* When blk-cgroup is a module, its subsys_id isn't a compile-time constant */
extern struct cgroup_subsys blkio_subsys;
#define blkio_subsys_id blkio_subsys.subsys_id
#endif
25

26 27 28 29 30 31 32 33
enum io_type {
	IO_READ = 0,
	IO_WRITE,
	IO_SYNC,
	IO_ASYNC,
	IO_TYPE_MAX
};

34 35 36 37 38 39 40
struct blkio_cgroup {
	struct cgroup_subsys_state css;
	unsigned int weight;
	spinlock_t lock;
	struct hlist_head blkg_list;
};

41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57
struct blkio_group_stats {
	/* total disk time and nr sectors dispatched by this group */
	uint64_t time;
	uint64_t sectors;
	/* Total disk time used by IOs in ns */
	uint64_t io_service_time[IO_TYPE_MAX];
	uint64_t io_service_bytes[IO_TYPE_MAX]; /* Total bytes transferred */
	/* Total IOs serviced, post merge */
	uint64_t io_serviced[IO_TYPE_MAX];
	/* Total time spent waiting in scheduler queue in ns */
	uint64_t io_wait_time[IO_TYPE_MAX];
#ifdef CONFIG_DEBUG_BLK_CGROUP
	/* How many times this group has been removed from service tree */
	unsigned long dequeue;
#endif
};

58 59 60 61
struct blkio_group {
	/* An rcu protected unique identifier for the group */
	void *key;
	struct hlist_node blkcg_node;
62
	unsigned short blkcg_id;
V
Vivek Goyal 已提交
63 64 65 66
#ifdef CONFIG_DEBUG_BLK_CGROUP
	/* Store cgroup path */
	char path[128];
#endif
67 68 69
	/* The device MKDEV(major, minor), this group has been created for */
	dev_t   dev;

70 71 72
	/* Need to serialize the stats in the case of reset/update */
	spinlock_t stats_lock;
	struct blkio_group_stats stats;
73 74
};

75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92
typedef void (blkio_unlink_group_fn) (void *key, struct blkio_group *blkg);
typedef void (blkio_update_group_weight_fn) (struct blkio_group *blkg,
						unsigned int weight);

struct blkio_policy_ops {
	blkio_unlink_group_fn *blkio_unlink_group_fn;
	blkio_update_group_weight_fn *blkio_update_group_weight_fn;
};

struct blkio_policy_type {
	struct list_head list;
	struct blkio_policy_ops ops;
};

/* Blkio controller policy registration */
extern void blkio_policy_register(struct blkio_policy_type *);
extern void blkio_policy_unregister(struct blkio_policy_type *);

93 94 95 96 97
#else

struct blkio_group {
};

98 99 100 101 102 103
struct blkio_policy_type {
};

static inline void blkio_policy_register(struct blkio_policy_type *blkiop) { }
static inline void blkio_policy_unregister(struct blkio_policy_type *blkiop) { }

104 105
#endif

106 107 108 109
#define BLKIO_WEIGHT_MIN	100
#define BLKIO_WEIGHT_MAX	1000
#define BLKIO_WEIGHT_DEFAULT	500

V
Vivek Goyal 已提交
110 111 112 113 114
#ifdef CONFIG_DEBUG_BLK_CGROUP
static inline char *blkg_path(struct blkio_group *blkg)
{
	return blkg->path;
}
115 116
void blkiocg_update_blkio_group_dequeue_stats(struct blkio_group *blkg,
				unsigned long dequeue);
V
Vivek Goyal 已提交
117 118
#else
static inline char *blkg_path(struct blkio_group *blkg) { return NULL; }
119 120
static inline void blkiocg_update_blkio_group_dequeue_stats(
			struct blkio_group *blkg, unsigned long dequeue) {}
V
Vivek Goyal 已提交
121 122
#endif

B
Ben Blum 已提交
123
#if defined(CONFIG_BLK_CGROUP) || defined(CONFIG_BLK_CGROUP_MODULE)
124 125 126
extern struct blkio_cgroup blkio_root_cgroup;
extern struct blkio_cgroup *cgroup_to_blkio_cgroup(struct cgroup *cgroup);
extern void blkiocg_add_blkio_group(struct blkio_cgroup *blkcg,
127
			struct blkio_group *blkg, void *key, dev_t dev);
128 129 130
extern int blkiocg_del_blkio_group(struct blkio_group *blkg);
extern struct blkio_group *blkiocg_lookup_group(struct blkio_cgroup *blkcg,
						void *key);
131 132
void blkiocg_update_timeslice_used(struct blkio_group *blkg,
					unsigned long time);
133
#else
134
struct cgroup;
135 136 137 138
static inline struct blkio_cgroup *
cgroup_to_blkio_cgroup(struct cgroup *cgroup) { return NULL; }

static inline void blkiocg_add_blkio_group(struct blkio_cgroup *blkcg,
139
			struct blkio_group *blkg, void *key, dev_t dev)
140 141 142 143 144 145 146 147
{
}

static inline int
blkiocg_del_blkio_group(struct blkio_group *blkg) { return 0; }

static inline struct blkio_group *
blkiocg_lookup_group(struct blkio_cgroup *blkcg, void *key) { return NULL; }
148
static inline void blkiocg_update_timeslice_used(struct blkio_group *blkg,
149
						unsigned long time) {}
150 151
#endif
#endif /* _BLK_CGROUP_H */