[linux-2.6-block.git] / fs / io-wq.h

#ifndef INTERNAL_IO_WQ_H
#define INTERNAL_IO_WQ_H

struct io_wq;

enum {
	IO_WQ_WORK_CANCEL	= 1,
	IO_WQ_WORK_HAS_MM	= 2,
	IO_WQ_WORK_HASHED	= 4,
	IO_WQ_WORK_NEEDS_USER	= 8,
	IO_WQ_WORK_NEEDS_FILES	= 16,
	IO_WQ_WORK_UNBOUND	= 32,
	IO_WQ_WORK_INTERNAL	= 64,
	IO_WQ_WORK_CB		= 128,

	IO_WQ_HASH_SHIFT	= 24,	/* upper 8 bits are used for hash key */
};

enum io_wq_cancel {
	IO_WQ_CANCEL_OK,	/* cancelled before started */
	IO_WQ_CANCEL_RUNNING,	/* found, running, and attempted cancelled */
	IO_WQ_CANCEL_NOTFOUND,	/* work not found */
};

struct io_wq_work_node {
	struct io_wq_work_node *next;
};

struct io_wq_work_list {
	struct io_wq_work_node *first;
	struct io_wq_work_node *last;
};

static inline void wq_list_add_tail(struct io_wq_work_node *node,
				    struct io_wq_work_list *list)
{
	if (!list->first) {
		list->first = list->last = node;
	} else {
		list->last->next = node;
		list->last = node;
	}
}

static inline void wq_node_del(struct io_wq_work_list *list,
			       struct io_wq_work_node *node,
			       struct io_wq_work_node *prev)
{
	if (node == list->first)
		list->first = node->next;
	if (node == list->last)
		list->last = prev;
	if (prev)
		prev->next = node->next;
	node->next = NULL;
}

#define wq_list_for_each(pos, prv, head)			\
	for (pos = (head)->first, prv = NULL; pos; prv = pos, pos = (pos)->next)

#define wq_list_empty(list)	((list)->first == NULL)
#define INIT_WQ_LIST(list)	do {				\
	(list)->first = NULL;					\
	(list)->last = NULL;					\
} while (0)

struct io_wq_work {
	union {
		struct io_wq_work_node list;
		void *data;
	};
	void (*func)(struct io_wq_work **);
	struct files_struct *files;
	unsigned flags;
};

#define INIT_IO_WORK(work, _func)			\
	do {						\
		(work)->list.next = NULL;		\
		(work)->func = _func;			\
		(work)->flags = 0;			\
		(work)->files = NULL;			\
	} while (0)					\

typedef void (get_work_fn)(struct io_wq_work *);
typedef void (put_work_fn)(struct io_wq_work *);

struct io_wq_data {
	struct mm_struct *mm;
	struct user_struct *user;
	const struct cred *creds;

	get_work_fn *get_work;
	put_work_fn *put_work;
};

struct io_wq *io_wq_create(unsigned bounded, struct io_wq_data *data);
void io_wq_destroy(struct io_wq *wq);

void io_wq_enqueue(struct io_wq *wq, struct io_wq_work *work);
void io_wq_enqueue_hashed(struct io_wq *wq, struct io_wq_work *work, void *val);
void io_wq_flush(struct io_wq *wq);

void io_wq_cancel_all(struct io_wq *wq);
enum io_wq_cancel io_wq_cancel_work(struct io_wq *wq, struct io_wq_work *cwork);

typedef bool (work_cancel_fn)(struct io_wq_work *, void *);

enum io_wq_cancel io_wq_cancel_cb(struct io_wq *wq, work_cancel_fn *cancel,
					void *data);

#if defined(CONFIG_IO_WQ)
extern void io_wq_worker_sleeping(struct task_struct *);
extern void io_wq_worker_running(struct task_struct *);
#else
static inline void io_wq_worker_sleeping(struct task_struct *tsk)
{
}
static inline void io_wq_worker_running(struct task_struct *tsk)
{
}
#endif /* CONFIG_IO_WQ */

#endif /* INTERNAL_IO_WQ_H */
Commit	Line	Data
771b53d0 JA	1	#ifndef INTERNAL_IO_WQ_H
	2	#define INTERNAL_IO_WQ_H
	3
	4	struct io_wq;
	5
	6	enum {
	7	IO_WQ_WORK_CANCEL = 1,
	8	IO_WQ_WORK_HAS_MM = 2,
	9	IO_WQ_WORK_HASHED = 4,
	10	IO_WQ_WORK_NEEDS_USER = 8,
fcb323cc	11	IO_WQ_WORK_NEEDS_FILES = 16,
c5def4ab	12	IO_WQ_WORK_UNBOUND = 32,
7d723065	13	IO_WQ_WORK_INTERNAL = 64,
b76da70f	14	IO_WQ_WORK_CB = 128,
771b53d0 JA	15
	16	IO_WQ_HASH_SHIFT = 24, /* upper 8 bits are used for hash key */
	17	};
	18
	19	enum io_wq_cancel {
	20	IO_WQ_CANCEL_OK, /* cancelled before started */
	21	IO_WQ_CANCEL_RUNNING, /* found, running, and attempted cancelled */
	22	IO_WQ_CANCEL_NOTFOUND, /* work not found */
	23	};
	24
6206f0e1 JA	25	struct io_wq_work_node {
	26	struct io_wq_work_node *next;
	27	};
	28
	29	struct io_wq_work_list {
	30	struct io_wq_work_node *first;
	31	struct io_wq_work_node *last;
	32	};
	33
	34	static inline void wq_list_add_tail(struct io_wq_work_node *node,
	35	struct io_wq_work_list *list)
	36	{
	37	if (!list->first) {
	38	list->first = list->last = node;
	39	} else {
	40	list->last->next = node;
	41	list->last = node;
	42	}
	43	}
	44
	45	static inline void wq_node_del(struct io_wq_work_list *list,
	46	struct io_wq_work_node *node,
	47	struct io_wq_work_node *prev)
	48	{
	49	if (node == list->first)
	50	list->first = node->next;
	51	if (node == list->last)
	52	list->last = prev;
	53	if (prev)
	54	prev->next = node->next;
08bdcc35	55	node->next = NULL;
6206f0e1 JA	56	}
	57
	58	#define wq_list_for_each(pos, prv, head) \
	59	for (pos = (head)->first, prv = NULL; pos; prv = pos, pos = (pos)->next)
	60
	61	#define wq_list_empty(list) ((list)->first == NULL)
	62	#define INIT_WQ_LIST(list) do { \
	63	(list)->first = NULL; \
	64	(list)->last = NULL; \
	65	} while (0)
	66
771b53d0	67	struct io_wq_work {
b76da70f	68	union {
6206f0e1	69	struct io_wq_work_node list;
b76da70f JA	70	void *data;
b76da70f JA	71	};
771b53d0	72	void (func)(struct io_wq_work *);
fcb323cc	73	struct files_struct *files;
6206f0e1	74	unsigned flags;
771b53d0 JA	75	};
	76
	77	#define INIT_IO_WORK(work, _func) \
	78	do { \
6206f0e1	79	(work)->list.next = NULL; \
771b53d0 JA	80	(work)->func = _func; \
771b53d0 JA	81	(work)->flags = 0; \
fcb323cc	82	(work)->files = NULL; \
771b53d0 JA	83	} while (0) \
771b53d0 JA	84
7d723065 JA	85	typedef void (get_work_fn)(struct io_wq_work *);
	86	typedef void (put_work_fn)(struct io_wq_work *);
	87
576a347b JA	88	struct io_wq_data {
	89	struct mm_struct *mm;
	90	struct user_struct *user;
0b8c0ec7	91	const struct cred *creds;
576a347b JA	92
	93	get_work_fn *get_work;
	94	put_work_fn *put_work;
	95	};
	96
	97	struct io_wq io_wq_create(unsigned bounded, struct io_wq_data data);
771b53d0 JA	98	void io_wq_destroy(struct io_wq *wq);
	99
	100	void io_wq_enqueue(struct io_wq wq, struct io_wq_work work);
	101	void io_wq_enqueue_hashed(struct io_wq wq, struct io_wq_work work, void *val);
	102	void io_wq_flush(struct io_wq *wq);
	103
	104	void io_wq_cancel_all(struct io_wq *wq);
	105	enum io_wq_cancel io_wq_cancel_work(struct io_wq wq, struct io_wq_work cwork);
	106
62755e35 JA	107	typedef bool (work_cancel_fn)(struct io_wq_work , void );
	108
	109	enum io_wq_cancel io_wq_cancel_cb(struct io_wq wq, work_cancel_fn cancel,
	110	void *data);
	111
771b53d0 JA	112	#if defined(CONFIG_IO_WQ)
	113	extern void io_wq_worker_sleeping(struct task_struct *);
	114	extern void io_wq_worker_running(struct task_struct *);
	115	#else
	116	static inline void io_wq_worker_sleeping(struct task_struct *tsk)
	117	{
	118	}
	119	static inline void io_wq_worker_running(struct task_struct *tsk)
	120	{
	121	}
8cdda87a	122	#endif /* CONFIG_IO_WQ */
771b53d0	123
8cdda87a	124	#endif /* INTERNAL_IO_WQ_H */