stop threads when condition is reached, gracefully deal with status text

3 files changed, 17 insertions, 13 deletions

diff --git a/src/qt/mainwindow.cpp b/src/qt/mainwindow.cpp
index 5bf013d..84d6ee9 100644
--- a/src/qt/mainwindow.cpp
+++ b/src/qt/mainwindow.cpp
@@ -98,6 +98,8 @@ void MainWindow::workerResult(const enum Worker::Results_t& result)
 
         case Worker::RESULT_IS_INSTALLED:
             installed = true;
+            ui->mainButton->setText("Play");
+            ui->statusLabel->setText("Checking for updates...");
             workerOperate(Worker::TASK_IS_UPTODATE);
             break;
 
@@ -108,7 +110,6 @@ void MainWindow::workerResult(const enum Worker::Results_t& result)
 
         case Worker::RESULT_IS_UPTODATE:
             uptodate = true;
-            ui->mainButton->setText("Play");
             ui->statusLabel->setText("Up to Date");
             break;
 
diff --git a/src/qt/workers.cpp b/src/qt/workers.cpp
index e4faa74..a54509f 100644
--- a/src/qt/workers.cpp
+++ b/src/qt/workers.cpp
@@ -23,7 +23,10 @@ struct thread_object_info {
 static void* thread_download(void* pinfo)
 {
     struct thread_object_info* info = (struct thread_object_info*)pinfo;
-    if (info)
+    Worker* worker = info->worker;
+    int* do_work = &worker->do_work;
+
+    if (info && *do_work)
     {
         char* of_dir = info->of_dir;
         char* remote = info->remote;
@@ -31,10 +34,10 @@ static void* thread_download(void* pinfo)
         size_t i = info->index;
 
         struct file_info* file = &rev->files[i];
-        if (file->type == TYPE_WRITE)
+        if (file->type == TYPE_WRITE && *do_work)
         {
             info->infoText = QString("Verifying %1").arg(file->object);
-            if (verifyFileHash(of_dir, file))
+            if (verifyFileHash(of_dir, file) && *do_work)
             {
                 info->infoText = QString("Downloading %1").arg(file->object);
                 downloadObject(of_dir, remote, file);
@@ -42,17 +45,17 @@ static void* thread_download(void* pinfo)
         }
 
         QString* threadString = &info->infoText;
-        if (!threadString->isEmpty())
+        if (!threadString->isEmpty() && *do_work)
         {
-            pthread_mutex_lock(&info->worker->textMutex);
+            pthread_mutex_lock(&worker->textMutex);
             // allow the main thread to clear the string before we continue
-            while (!info->worker->infoText.isEmpty()) {};
+            while (!worker->infoText.isEmpty() && *do_work) {};
 
-            info->worker->progress = (int)(((info->index * 100) + 1) / rev->file_count);
+            worker->progress = (int)(((info->index * 100) + 1) / rev->file_count);
 
-            info->worker->infoText = *threadString;
-            emit info->worker->resultReady(Worker::RESULT_UPDATE_TEXT);
-            pthread_mutex_unlock(&info->worker->textMutex);
+            worker->infoText = *threadString;
+            emit worker->resultReady(Worker::RESULT_UPDATE_TEXT);
+            pthread_mutex_unlock(&worker->textMutex);
         }
     }
     return NULL;
@@ -123,7 +126,7 @@ bool Worker::isOutdated()
 
 void Worker::stop_work()
 {
-    do_work = false;
+    do_work = 0;
 }
 
 int Worker::update_setup(int local_rev, int remote_rev)
diff --git a/src/qt/workers.hpp b/src/qt/workers.hpp
index 8e2a274..19d83f5 100644
--- a/src/qt/workers.hpp
+++ b/src/qt/workers.hpp
@@ -21,12 +21,12 @@ private:
     char* remote;
     size_t remote_len;
 
-    int do_work = 1;
     bool update_in_progress = false;
 
     QSettings settings;
 
 public:
+    int do_work = 1;
     int progress = -1;
     QString infoText;
     pthread_mutex_t textMutex;