Changeset 3272 in orxonox.OLD for orxonox/branches/updater/src

Timestamp:

Dec 24, 2004, 8:41:18 PM (20 years ago)

Author:

bensch

Message:

orxonox/branches/updater: using pthread as Threader.

Location:

orxonox/branches/updater/src/gui

Files:

• orxonox_gui_update.cc (modified) (4 diffs)
• orxonox_gui_update.h (modified) (3 diffs)

orxonox/branches/updater/src/gui/orxonox_gui_update.cc

@@ -201 +201 @@
 
 CURL* OrxonoxGuiUpdate::curlHandle = NULL;
-GThread* OrxonoxGuiUpdate::downloadThreadID = NULL;
+pthread_t* OrxonoxGuiUpdate::downloadThreadID = new pthread_t;
+bool OrxonoxGuiUpdate::isDownloading = false;
 
 void* OrxonoxGuiUpdate::download (void* fileInfo)
@@ -209 +210 @@
   FileInfo* info = (FileInfo*)fileInfo;
   CURLcode res;
-  FILE* outfile;
   curlHandle = curl_easy_init();
   char* fileOnNet = new char [strlen(info->webRoot)+strlen(info->fileName)+1];
@@ -217 +217 @@
   strcpy (fileOnDisk, info->localRoot);
   strcat (fileOnDisk, info->fileName);
-
+  pthread_t test;
   if(curlHandle)
     {
       
-      outfile = fopen(fileOnDisk, "w");
+      info->fileHandle = fopen(fileOnDisk, "w");
 
       curl_easy_setopt(curlHandle, CURLOPT_URL, fileOnNet);
-      curl_easy_setopt(curlHandle, CURLOPT_WRITEDATA, outfile);
+      curl_easy_setopt(curlHandle, CURLOPT_WRITEDATA, info->fileHandle);
       curl_easy_setopt(curlHandle, CURLOPT_WRITEFUNCTION, curlWriteFunc);
       curl_easy_setopt(curlHandle, CURLOPT_READFUNCTION, curlReadFunc);
@@ -231 +231 @@
       curl_easy_setopt(curlHandle, CURLOPT_PROGRESSDATA, info->Bar);
 
-      if (!downloadThreadID)
+      if (!isDownloading)
         {
           //! \todo check if threads really were created.
-          downloadThreadID = g_thread_create(&downloadThread, info, TRUE, NULL);
-
-          g_thread_create(&downloadThreadFinished, outfile, TRUE, NULL);
+          pthread_create(downloadThreadID, NULL, downloadThread, info);
+          //      else 
+          //    PRINTF(1)("thread already in use\n");
+          //      res = curl_easy_perform(curlHandle);
+          
+          //      fclose(outfile);
         }
-      else 
-        PRINTF(1)("thread already in use\n");
-      //      res = curl_easy_perform(curlHandle);
-      
-      //      fclose(outfile);
     }
-  //  downloadThreadID = NULL;
   return NULL;
 }
 void* OrxonoxGuiUpdate::downloadThread(void* fileInfo)
 {
-  //  gdk_threads_enter();
+  isDownloading = true;
+
+  FileInfo* info = (FileInfo*)fileInfo;
   curl_easy_perform(curlHandle);
   if (curlHandle)
     curl_easy_cleanup(curlHandle);
-  gdk_threads_leave();
-  downloadThreadID = NULL;
-  //  g_thread_exit (NULL);
-}
-
-void* OrxonoxGuiUpdate::downloadThreadFinished(void* outfile)
-{
-  g_thread_join(downloadThreadID);
+
+  pthread_join(*downloadThreadID, NULL);
   PRINTF(3)("Closing the downloaded file.\n");
-  fclose((FILE*)outfile);
-}
+  fclose(info->fileHandle);
+
+  isDownloading = false;
+}
+
 
 #ifdef HAVE_GTK2

orxonox/branches/updater/src/gui/orxonox_gui_update.h

@@ -14 +14 @@
 #include <curl/easy.h>
 #endif /* HAVE_CURL */
+#include <pthread.h>
 using namespace std;
 
@@ -50 +51 @@
     char* webRoot;        //!< The Root of the File on The Web
     char* localRoot;      //!< The Root directory to put the files on the local disk.
+    FILE* fileHandle;     //!< A fileHandler.
 
     ProgressBar* Bar;     //!< The ProgressBar, that sould be updated.
@@ -62 +64 @@
   static gint cancelDownload(GtkWidget* w, GdkEventKey* event, void* bar);
 #endif /* HAVE_GTK2 */  
-  static GThread* downloadThreadID;
+  static pthread_t* downloadThreadID;
+  static bool isDownloading;
+
   static void* download (void* fileInfo);
   static void* downloadThread (void* fileInfo);