diff options
Diffstat (limited to 'kernel/workqueue_internal.h')
| -rw-r--r-- | kernel/workqueue_internal.h | 65 |
1 files changed, 65 insertions, 0 deletions
diff --git a/kernel/workqueue_internal.h b/kernel/workqueue_internal.h new file mode 100644 index 000000000000..07650264ec15 --- /dev/null +++ b/kernel/workqueue_internal.h | |||
| @@ -0,0 +1,65 @@ | |||
| 1 | /* | ||
| 2 | * kernel/workqueue_internal.h | ||
| 3 | * | ||
| 4 | * Workqueue internal header file. Only to be included by workqueue and | ||
| 5 | * core kernel subsystems. | ||
| 6 | */ | ||
| 7 | #ifndef _KERNEL_WORKQUEUE_INTERNAL_H | ||
| 8 | #define _KERNEL_WORKQUEUE_INTERNAL_H | ||
| 9 | |||
| 10 | #include <linux/workqueue.h> | ||
| 11 | #include <linux/kthread.h> | ||
| 12 | |||
| 13 | struct worker_pool; | ||
| 14 | |||
| 15 | /* | ||
| 16 | * The poor guys doing the actual heavy lifting. All on-duty workers are | ||
| 17 | * either serving the manager role, on idle list or on busy hash. For | ||
| 18 | * details on the locking annotation (L, I, X...), refer to workqueue.c. | ||
| 19 | * | ||
| 20 | * Only to be used in workqueue and async. | ||
| 21 | */ | ||
| 22 | struct worker { | ||
| 23 | /* on idle list while idle, on busy hash table while busy */ | ||
| 24 | union { | ||
| 25 | struct list_head entry; /* L: while idle */ | ||
| 26 | struct hlist_node hentry; /* L: while busy */ | ||
| 27 | }; | ||
| 28 | |||
| 29 | struct work_struct *current_work; /* L: work being processed */ | ||
| 30 | work_func_t current_func; /* L: current_work's fn */ | ||
| 31 | struct pool_workqueue *current_pwq; /* L: current_work's pwq */ | ||
| 32 | struct list_head scheduled; /* L: scheduled works */ | ||
| 33 | struct task_struct *task; /* I: worker task */ | ||
| 34 | struct worker_pool *pool; /* I: the associated pool */ | ||
| 35 | /* 64 bytes boundary on 64bit, 32 on 32bit */ | ||
| 36 | unsigned long last_active; /* L: last active timestamp */ | ||
| 37 | unsigned int flags; /* X: flags */ | ||
| 38 | int id; /* I: worker id */ | ||
| 39 | |||
| 40 | /* for rebinding worker to CPU */ | ||
| 41 | struct work_struct rebind_work; /* L: for busy worker */ | ||
| 42 | |||
| 43 | /* used only by rescuers to point to the target workqueue */ | ||
| 44 | struct workqueue_struct *rescue_wq; /* I: the workqueue to rescue */ | ||
| 45 | }; | ||
| 46 | |||
| 47 | /** | ||
| 48 | * current_wq_worker - return struct worker if %current is a workqueue worker | ||
| 49 | */ | ||
| 50 | static inline struct worker *current_wq_worker(void) | ||
| 51 | { | ||
| 52 | if (current->flags & PF_WQ_WORKER) | ||
| 53 | return kthread_data(current); | ||
| 54 | return NULL; | ||
| 55 | } | ||
| 56 | |||
| 57 | /* | ||
| 58 | * Scheduler hooks for concurrency managed workqueue. Only to be used from | ||
| 59 | * sched.c and workqueue.c. | ||
| 60 | */ | ||
| 61 | void wq_worker_waking_up(struct task_struct *task, unsigned int cpu); | ||
| 62 | struct task_struct *wq_worker_sleeping(struct task_struct *task, | ||
| 63 | unsigned int cpu); | ||
| 64 | |||
| 65 | #endif /* _KERNEL_WORKQUEUE_INTERNAL_H */ | ||
