home *** CD-ROM | disk | FTP | other *** search
/ PC Welt 2006 November (DVD) / PCWELT_11_2006.ISO / casper / filesystem.squashfs / usr / src / linux-headers-2.6.17-6 / include / linux / workqueue.h < prev    next >
Encoding:
C/C++ Source or Header  |  2006-08-11  |  2.7 KB  |  100 lines
  1. /*
  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.  
  12. struct workqueue_struct;
  13.  
  14. struct 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.  
  23. struct execute_work {
  24.     struct work_struct work;
  25. };
  26.  
  27. #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.  
  57. extern 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.  
  62. extern void destroy_workqueue(struct workqueue_struct *wq);
  63.  
  64. extern int FASTCALL(queue_work(struct workqueue_struct *wq, struct work_struct *work));
  65. extern int FASTCALL(queue_delayed_work(struct workqueue_struct *wq, struct work_struct *work, unsigned long delay));
  66. extern void FASTCALL(flush_workqueue(struct workqueue_struct *wq));
  67.  
  68. extern int FASTCALL(schedule_work(struct work_struct *work));
  69. extern int FASTCALL(schedule_delayed_work(struct work_struct *work, unsigned long delay));
  70.  
  71. extern int schedule_delayed_work_on(int cpu, struct work_struct *work, unsigned long delay);
  72. extern int schedule_on_each_cpu(void (*func)(void *info), void *info);
  73. extern void flush_scheduled_work(void);
  74. extern int current_is_keventd(void);
  75. extern int keventd_up(void);
  76.  
  77. extern void init_workqueues(void);
  78. void cancel_rearming_delayed_work(struct work_struct *work);
  79. void cancel_rearming_delayed_workqueue(struct workqueue_struct *,
  80.                        struct work_struct *);
  81. int execute_in_process_context(void (*fn)(void *), void *,
  82.                    struct execute_work *);
  83.  
  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.  */
  89. static 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
  100.