stream = adap->channel.stream->stream;
 
        for (;;) {
-               if (adap->feed_thread_stop) break;
                if (kthread_should_stop()) break;
 
                /* Not sure about this... */
                ret = wait_event_interruptible(
                    adap->buffer_wait_data,
                    (pvr2_stream_get_ready_count(stream) > 0) ||
-                   adap->feed_thread_stop);
+                   kthread_should_stop());
                if (ret < 0) break;
        }
 
        struct pvr2_stream *stream;
 
        if (adap->thread) {
-               adap->feed_thread_stop = !0;
-               pvr2_dvb_notify(adap);
                kthread_stop(adap->thread);
                adap->thread = NULL;
        }
                if (ret < 0) return ret;
        }
 
-       adap->feed_thread_stop = 0;
        adap->thread = kthread_run(pvr2_dvb_feed_thread, adap, "pvrusb2-dvb");
 
        if (IS_ERR(adap->thread)) {