| .. | .. |
|---|
| 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 |
|---|