2008-01-24 15:52:45 +08:00
|
|
|
#ifndef IOCONTEXT_H
|
|
|
|
#define IOCONTEXT_H
|
|
|
|
|
2008-01-24 15:44:49 +08:00
|
|
|
#include <linux/radix-tree.h>
|
2008-04-02 20:31:02 +08:00
|
|
|
#include <linux/rcupdate.h>
|
2008-01-24 15:44:49 +08:00
|
|
|
|
2008-01-24 15:52:45 +08:00
|
|
|
struct cfq_queue;
|
|
|
|
struct cfq_io_context {
|
|
|
|
void *key;
|
2008-01-24 15:44:49 +08:00
|
|
|
unsigned long dead_key;
|
2008-01-24 15:52:45 +08:00
|
|
|
|
|
|
|
struct cfq_queue *cfqq[2];
|
|
|
|
|
|
|
|
struct io_context *ioc;
|
|
|
|
|
|
|
|
unsigned long last_end_request;
|
|
|
|
|
|
|
|
unsigned long ttime_total;
|
|
|
|
unsigned long ttime_samples;
|
|
|
|
unsigned long ttime_mean;
|
|
|
|
|
|
|
|
struct list_head queue_list;
|
2008-02-19 17:02:29 +08:00
|
|
|
struct hlist_node cic_list;
|
2008-01-24 15:52:45 +08:00
|
|
|
|
|
|
|
void (*dtor)(struct io_context *); /* destructor */
|
|
|
|
void (*exit)(struct io_context *); /* called on task exit */
|
2008-04-02 20:31:02 +08:00
|
|
|
|
|
|
|
struct rcu_head rcu_head;
|
2008-01-24 15:52:45 +08:00
|
|
|
};
|
|
|
|
|
|
|
|
/*
|
2008-01-24 15:53:35 +08:00
|
|
|
* I/O subsystem state of the associated processes. It is refcounted
|
|
|
|
* and kmalloc'ed. These could be shared between processes.
|
2008-01-24 15:52:45 +08:00
|
|
|
*/
|
|
|
|
struct io_context {
|
2009-06-11 03:57:06 +08:00
|
|
|
atomic_long_t refcount;
|
2008-01-24 15:53:35 +08:00
|
|
|
atomic_t nr_tasks;
|
|
|
|
|
|
|
|
/* all the fields below are protected by this lock */
|
|
|
|
spinlock_t lock;
|
2008-01-24 15:52:45 +08:00
|
|
|
|
|
|
|
unsigned short ioprio;
|
|
|
|
unsigned short ioprio_changed;
|
|
|
|
|
2010-03-11 07:22:11 +08:00
|
|
|
#if defined(CONFIG_BLK_CGROUP) || defined(CONFIG_BLK_CGROUP_MODULE)
|
2009-12-04 01:59:42 +08:00
|
|
|
unsigned short cgroup_changed;
|
|
|
|
#endif
|
|
|
|
|
2008-01-24 15:52:45 +08:00
|
|
|
/*
|
|
|
|
* For request batching
|
|
|
|
*/
|
|
|
|
int nr_batch_requests; /* Number of requests left in the batch */
|
2010-02-26 21:00:43 +08:00
|
|
|
unsigned long last_waited; /* Time last woken after wait for request */
|
2008-01-24 15:52:45 +08:00
|
|
|
|
2008-01-24 15:44:49 +08:00
|
|
|
struct radix_tree_root radix_root;
|
2008-02-19 17:02:29 +08:00
|
|
|
struct hlist_head cic_list;
|
2008-01-24 15:52:45 +08:00
|
|
|
void *ioc_data;
|
|
|
|
};
|
|
|
|
|
2008-01-24 15:53:35 +08:00
|
|
|
static inline struct io_context *ioc_task_link(struct io_context *ioc)
|
|
|
|
{
|
|
|
|
/*
|
|
|
|
* if ref count is zero, don't allow sharing (ioc is going away, it's
|
|
|
|
* a race).
|
|
|
|
*/
|
2009-06-11 03:57:06 +08:00
|
|
|
if (ioc && atomic_long_inc_not_zero(&ioc->refcount)) {
|
2009-07-31 14:55:48 +08:00
|
|
|
atomic_inc(&ioc->nr_tasks);
|
2008-01-24 15:53:35 +08:00
|
|
|
return ioc;
|
2008-04-15 15:25:33 +08:00
|
|
|
}
|
2008-01-24 15:53:35 +08:00
|
|
|
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
2009-12-04 21:52:42 +08:00
|
|
|
struct task_struct;
|
2008-07-01 02:42:08 +08:00
|
|
|
#ifdef CONFIG_BLOCK
|
|
|
|
int put_io_context(struct io_context *ioc);
|
2009-12-04 21:52:42 +08:00
|
|
|
void exit_io_context(struct task_struct *task);
|
2008-07-01 02:42:08 +08:00
|
|
|
struct io_context *get_io_context(gfp_t gfp_flags, int node);
|
|
|
|
struct io_context *alloc_io_context(gfp_t gfp_flags, int node);
|
|
|
|
void copy_io_context(struct io_context **pdst, struct io_context **psrc);
|
|
|
|
#else
|
2009-12-04 21:52:42 +08:00
|
|
|
static inline void exit_io_context(struct task_struct *task)
|
2008-07-01 02:42:08 +08:00
|
|
|
{
|
|
|
|
}
|
|
|
|
|
|
|
|
struct io_context;
|
|
|
|
static inline int put_io_context(struct io_context *ioc)
|
|
|
|
{
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
#endif
|
|
|
|
|
2008-01-24 15:52:45 +08:00
|
|
|
#endif
|