iolog: cleanup data wait

Signed-off-by: Jens Axboe <axboe@fb.com>

diff --git a/iolog.c b/iolog.c
index 9c59acd8653b491a08c6a8aa4ab12584599e9910..0d4d26a599ab6c493af2efdd9096e087c8963d2b 100644 (file)
--- a/iolog.c
+++ b/iolog.c
@@ -1163,14 +1163,13 @@ int iolog_flush(struct io_log *log, int wait)
        data->nr_samples = log->nr_samples;
        log->nr_samples = 0;
 
        data->nr_samples = log->nr_samples;
        log->nr_samples = 0;
 

-       if (wait) {
+       data->wait = wait;
+       if (data->wait) {

                pthread_mutex_init(&data->lock, NULL);
                pthread_cond_init(&data->cv, NULL);
                data->done = 0;
                pthread_mutex_init(&data->lock, NULL);
                pthread_cond_init(&data->cv, NULL);
                data->done = 0;

-               data->wait = 1;

                data->refs = 2;
                data->refs = 2;

-       } else
-               data->wait = 0;
+       }

 
        workqueue_enqueue(&log->td->log_compress_wq, &data->work);
 
 
        workqueue_enqueue(&log->td->log_compress_wq, &data->work);