blob: 957c21c16d62370a9e158336a5981682d6f7625f [file] [log] [blame]
Linus Torvalds1da177e2005-04-16 15:20:36 -07001/*
2 * workqueue.h --- work queue handling for Linux.
3 */
4
5#ifndef _LINUX_WORKQUEUE_H
6#define _LINUX_WORKQUEUE_H
7
8#include <linux/timer.h>
9#include <linux/linkage.h>
10#include <linux/bitops.h>
11
12struct workqueue_struct;
13
14struct work_struct {
15 unsigned long pending;
16 struct list_head entry;
17 void (*func)(void *);
18 void *data;
19 void *wq_data;
20 struct timer_list timer;
21};
22
James Bottomley1fa44ec2006-02-23 12:43:43 -060023struct execute_work {
24 struct work_struct work;
25};
26
Linus Torvalds1da177e2005-04-16 15:20:36 -070027#define __WORK_INITIALIZER(n, f, d) { \
28 .entry = { &(n).entry, &(n).entry }, \
29 .func = (f), \
30 .data = (d), \
31 .timer = TIMER_INITIALIZER(NULL, 0, 0), \
32 }
33
34#define DECLARE_WORK(n, f, d) \
35 struct work_struct n = __WORK_INITIALIZER(n, f, d)
36
37/*
38 * initialize a work-struct's func and data pointers:
39 */
40#define PREPARE_WORK(_work, _func, _data) \
41 do { \
42 (_work)->func = _func; \
43 (_work)->data = _data; \
44 } while (0)
45
46/*
47 * initialize all of a work-struct:
48 */
49#define INIT_WORK(_work, _func, _data) \
50 do { \
51 INIT_LIST_HEAD(&(_work)->entry); \
52 (_work)->pending = 0; \
53 PREPARE_WORK((_work), (_func), (_data)); \
54 init_timer(&(_work)->timer); \
55 } while (0)
56
57extern struct workqueue_struct *__create_workqueue(const char *name,
58 int singlethread);
59#define create_workqueue(name) __create_workqueue((name), 0)
60#define create_singlethread_workqueue(name) __create_workqueue((name), 1)
61
62extern void destroy_workqueue(struct workqueue_struct *wq);
63
64extern int FASTCALL(queue_work(struct workqueue_struct *wq, struct work_struct *work));
65extern int FASTCALL(queue_delayed_work(struct workqueue_struct *wq, struct work_struct *work, unsigned long delay));
66extern void FASTCALL(flush_workqueue(struct workqueue_struct *wq));
67
68extern int FASTCALL(schedule_work(struct work_struct *work));
69extern int FASTCALL(schedule_delayed_work(struct work_struct *work, unsigned long delay));
70
71extern int schedule_delayed_work_on(int cpu, struct work_struct *work, unsigned long delay);
Christoph Lameter15316ba2006-01-08 01:00:43 -080072extern int schedule_on_each_cpu(void (*func)(void *info), void *info);
Linus Torvalds1da177e2005-04-16 15:20:36 -070073extern void flush_scheduled_work(void);
74extern int current_is_keventd(void);
75extern int keventd_up(void);
76
77extern void init_workqueues(void);
78void cancel_rearming_delayed_work(struct work_struct *work);
James Bottomley81ddef72005-04-16 15:23:59 -070079void cancel_rearming_delayed_workqueue(struct workqueue_struct *,
80 struct work_struct *);
James Bottomley1fa44ec2006-02-23 12:43:43 -060081int execute_in_process_context(void (*fn)(void *), void *,
82 struct execute_work *);
Linus Torvalds1da177e2005-04-16 15:20:36 -070083
84/*
85 * Kill off a pending schedule_delayed_work(). Note that the work callback
86 * function may still be running on return from cancel_delayed_work(). Run
87 * flush_scheduled_work() to wait on it.
88 */
89static inline int cancel_delayed_work(struct work_struct *work)
90{
91 int ret;
92
93 ret = del_timer_sync(&work->timer);
94 if (ret)
95 clear_bit(0, &work->pending);
96 return ret;
97}
98
99#endif