static inline void debug_work_deactivate(struct work_struct *work) { }
#endif
+#ifdef CONFIG_MTK_WQ_DEBUG
+extern void mttrace_workqueue_execute_work(struct work_struct *work);
+extern void mttrace_workqueue_activate_work(struct work_struct *work);
+extern void mttrace_workqueue_queue_work(unsigned int req_cpu, struct work_struct *work);
+extern void mttrace_workqueue_execute_end(struct work_struct *work);
+#endif //CONFIG_MTK_WQ_DEBUG
+
/* allocate ID and assign it to @pool */
static int worker_pool_assign_id(struct worker_pool *pool)
{
struct pool_workqueue *pwq = get_work_pwq(work);
trace_workqueue_activate_work(work);
+#ifdef CONFIG_MTK_WQ_DEBUG
+ mttrace_workqueue_activate_work(work);
+#endif //CONFIG_MTK_WQ_DEBUG
move_linked_works(work, &pwq->pool->worklist, NULL);
__clear_bit(WORK_STRUCT_DELAYED_BIT, work_data_bits(work));
pwq->nr_active++;
/* pwq determined, queue */
trace_workqueue_queue_work(req_cpu, pwq, work);
+#ifdef CONFIG_MTK_WQ_DEBUG
+ mttrace_workqueue_queue_work(cpu, work);
+#endif //CONFIG_MTK_WQ_DEBUG
if (WARN_ON(!list_empty(&work->entry))) {
spin_unlock(&pwq->pool->lock);
if (likely(pwq->nr_active < pwq->max_active)) {
trace_workqueue_activate_work(work);
+#ifdef CONFIG_MTK_WQ_DEBUG
+ mttrace_workqueue_activate_work(work);
+#endif //CONFIG_MTK_WQ_DEBUG
pwq->nr_active++;
worklist = &pwq->pool->worklist;
} else {
bool cpu_intensive = pwq->wq->flags & WQ_CPU_INTENSIVE;
int work_color;
struct worker *collision;
+ unsigned long long exec_start;
+ char func[128];
+
#ifdef CONFIG_LOCKDEP
/*
* It is permissible to free the struct work_struct from
lock_map_acquire_read(&pwq->wq->lockdep_map);
lock_map_acquire(&lockdep_map);
+
+ exec_start = sched_clock();
+ sprintf(func, "%pf", work->func);
+
trace_workqueue_execute_start(work);
+#ifdef CONFIG_MTK_WQ_DEBUG
+ mttrace_workqueue_execute_work(work);
+#endif //CONFIG_MTK_WQ_DEBUG
+
worker->current_func(work);
+
/*
* While we must be careful to not use "work" after this, the trace
* point will only record its address.
*/
trace_workqueue_execute_end(work);
+#ifdef CONFIG_MTK_WQ_DEBUG
+ mttrace_workqueue_execute_end(work);
+#endif //CONFIG_MTK_WQ_DEBUG
+
+ if ((sched_clock() - exec_start)> 1000000000) // dump log if execute more than 1 sec
+ pr_warning("WQ warning! work (%s, %p) execute more than 1 sec, time: %llu ns\n", func, work, sched_clock() - exec_start);
+
lock_map_release(&lockdep_map);
lock_map_release(&pwq->wq->lockdep_map);