.. | .. |
---|
625 | 625 | static int |
---|
626 | 626 | ref_scale_shutdown(void *arg) |
---|
627 | 627 | { |
---|
628 | | - wait_event(shutdown_wq, shutdown_start); |
---|
| 628 | + wait_event_idle(shutdown_wq, shutdown_start); |
---|
629 | 629 | |
---|
630 | 630 | smp_mb(); // Wake before output. |
---|
631 | 631 | ref_scale_cleanup(); |
---|
.. | .. |
---|
692 | 692 | VERBOSE_SCALEOUT("Starting %d reader threads\n", nreaders); |
---|
693 | 693 | |
---|
694 | 694 | for (i = 0; i < nreaders; i++) { |
---|
| 695 | + init_waitqueue_head(&reader_tasks[i].wq); |
---|
695 | 696 | firsterr = torture_create_kthread(ref_scale_reader, (void *)i, |
---|
696 | 697 | reader_tasks[i].task); |
---|
697 | 698 | if (firsterr) |
---|
698 | 699 | goto unwind; |
---|
699 | | - |
---|
700 | | - init_waitqueue_head(&(reader_tasks[i].wq)); |
---|
701 | 700 | } |
---|
702 | 701 | |
---|
703 | 702 | // Main Task |
---|