|
@@ -3572,8 +3572,10 @@ static int pktgen_thread_worker(void *arg)
|
|
pktgen_rem_thread(t);
|
|
pktgen_rem_thread(t);
|
|
|
|
|
|
/* Wait for kthread_stop */
|
|
/* Wait for kthread_stop */
|
|
- while (!kthread_should_stop()) {
|
|
|
|
|
|
+ for (;;) {
|
|
set_current_state(TASK_INTERRUPTIBLE);
|
|
set_current_state(TASK_INTERRUPTIBLE);
|
|
|
|
+ if (kthread_should_stop())
|
|
|
|
+ break;
|
|
schedule();
|
|
schedule();
|
|
}
|
|
}
|
|
__set_current_state(TASK_RUNNING);
|
|
__set_current_state(TASK_RUNNING);
|