diff options
| -rw-r--r-- | extra/mariabackup/ds_compress.cc | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/extra/mariabackup/ds_compress.cc b/extra/mariabackup/ds_compress.cc index 39a72cdca34..549fa35cad0 100644 --- a/extra/mariabackup/ds_compress.cc +++ b/extra/mariabackup/ds_compress.cc @@ -410,6 +410,9 @@ compress_worker_thread_func(void *arg) pthread_mutex_lock(&thd->data_mutex); while (1) { + thd->data_avail = FALSE; + pthread_cond_signal(&thd->data_cond); + while (!thd->data_avail && !thd->cancelled) { pthread_cond_wait(&thd->data_cond, &thd->data_mutex); } |