Changeset 3263 in orxonox.OLD for orxonox/branches/updater/src/gui/orxonox_gui_update.cc

Timestamp:

Dec 24, 2004, 1:15:38 PM (19 years ago)

Author:

bensch

Message:

orxonox/branches/updater: now the Data-bar downloads something, and the Progress is displayed. (not very nice, but it works).

NOT THREAD SAVE <<

File:

• orxonox/branches/updater/src/gui/orxonox_gui_update.cc (modified) (4 diffs)

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

@@ -30 +30 @@
 #include "orxonox_gui.h"
 #include <stdio.h>
+#include <curl/curl.h>
+#include <curl/types.h>
+#include <curl/easy.h> /* new for v7 */
 using namespace std;
 
@@ -79 +82 @@
   updateDataBar = new ProgressBar ();
   updateDataBox->fill(updateDataBar);
+
+  updateDataBegin = new Button ("begin Download");
+  updateDataBegin->connectSignal ("button_press_event", updateDataBar, updateDataFunc);
+  updateDataBox->fill(updateDataBegin);
+
   updateDataWindow->fill (updateDataBox);
 
@@ -139 +147 @@
    \param button The Button, that triggered this event.
 */
-gint OrxonoxGuiUpdate::updateDataFunc(GtkWidget* w, GdkEventKey* event, void* button)
-{
-
+gint OrxonoxGuiUpdate::updateDataFunc(GtkWidget* w, GdkEventKey* event, void* bar)
+{
+  FileInfo* info = new FileInfo;
+
+  info->fileOnDisk = new char [5];
+  strcpy (info->fileOnDisk, "test");
+  info->fileOnNet = new char [100];
+  strcpy(info->fileOnNet, "http://www.orxonox.ethz.ch/files/taskHorizon.at.bermuda-funk.ogg");
+  info->Bar = (ProgressBar*)bar;
+  PRINTF(3)("Preparing to download file %s.\n", info->fileOnNet);
+  //downloadThread (info);
+
+  if (!g_thread_create(&downloadThread, info, FALSE, NULL) != 0)
+    PRINTF(1)("can't create the thread"); 
 }
 
@@ -156 +175 @@
   tmpBar->setProgress(tmpBar->getProgress()+1);
 }
-
-#endif /* HAVE_GTK2 */
+#endif /* HAVE_GTK2 */
+
+#ifdef HAVE_CURL
+size_t OrxonoxGuiUpdate::curlWriteFunc (void* ptr, size_t size, size_t nmemb, FILE* stream)
+{
+  return fwrite(ptr, size, nmemb, stream);
+}
+
+size_t OrxonoxGuiUpdate::curlReadFunc (void* ptr, size_t size, size_t nmemb, FILE* stream)
+{
+  return fread(ptr, size, nmemb, stream);
+}
+
+
+int OrxonoxGuiUpdate::curlProgressFunc (ProgressBar* Bar, double totalSize, double progress, double upTotal, double upProgress)
+{
+  //  gdk_threads_enter();
+  Bar->setProgress(progress);
+  Bar->setTotalSize(totalSize);
+  //  gdk_threads_leave();
+  return 0;
+
+}
+
+void* OrxonoxGuiUpdate::downloadThread (void* fileInfo)
+{
+  PRINTF(3)("Downloading.\n");
+  FileInfo* info = (FileInfo*)fileInfo;
+  CURL* curl;
+  CURLcode res;
+  FILE* outfile;
+  curl = curl_easy_init();
+
+  if(curl)
+    {
+      outfile = fopen(info->fileOnDisk, "w");
+      
+      curl_easy_setopt(curl, CURLOPT_URL, info->fileOnNet);
+      curl_easy_setopt(curl, CURLOPT_WRITEDATA, outfile);
+      curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, curlWriteFunc);
+      curl_easy_setopt(curl, CURLOPT_READFUNCTION, curlReadFunc);
+      curl_easy_setopt(curl, CURLOPT_NOPROGRESS, FALSE);
+      curl_easy_setopt(curl, CURLOPT_PROGRESSFUNCTION, curlProgressFunc);
+      curl_easy_setopt(curl, CURLOPT_PROGRESSDATA, info->Bar);
+      
+      res = curl_easy_perform(curl);
+      
+      fclose(outfile);
+      curl_easy_cleanup(curl);
+    }
+  return NULL;
+}
+
+#endif /* HAVE_CURL */
+
+
+/*
+ int main(int argc, char **argv)
+ {
+   GtkWidget *Window, *Frame, *Frame2;
+   GtkAdjustment *adj;
+   
+   // Init thread 
+   g_thread_init(NULL);
+   gtk_init(&argc, &argv);
+   Window = gtk_window_new(GTK_WINDOW_TOPLEVEL);
+   Frame = gtk_frame_new(NULL);
+   gtk_frame_set_shadow_type(GTK_FRAME(Frame), GTK_SHADOW_OUT);
+   gtk_container_add(GTK_CONTAINER(Window), Frame);
+   Frame2 = gtk_frame_new(NULL);
+   gtk_frame_set_shadow_type(GTK_FRAME(Frame2), GTK_SHADOW_IN);
+   gtk_container_add(GTK_CONTAINER(Frame), Frame2);
+   gtk_container_set_border_width(GTK_CONTAINER(Frame2), 5);
+   adj = (GtkAdjustment*)gtk_adjustment_new(0, 0, 100, 0, 0, 0);
+   Bar = gtk_progress_bar_new_with_adjustment(adj);
+   gtk_container_add(GTK_CONTAINER(Frame2), Bar);
+   gtk_widget_show_all(Window);
+ 
+   if (!g_thread_create(&my_thread, argv[1], FALSE, NULL) != 0)
+     g_warning("can't create the thread");
+ 
+ 
+   gdk_threads_enter();
+   gtk_main();
+  gdk_threads_leave();
+   return 0;
+ }
+
+
+
+
+
+size_t writeFunc(void *ptr, size_t size, size_t nmemb, FILE *stream)
+ {
+   return fwrite(ptr, size, nmemb, stream);
+ }
+ 
+ size_t my_read_func(void *ptr, size_t size, size_t nmemb, FILE *stream)
+ {
+   return fread(ptr, size, nmemb, stream);
+ }
+ 
+ int my_progress_func(GtkWidget *Bar,
+                      double t, // dltotal 
+                      double d, // dlnow 
+                      double ultotal,
+                      double ulnow)
+ {
+   gdk_threads_enter();
+   gtk_progress_set_value(GTK_PROGRESS(Bar), d*100.0/t);
+   gdk_threads_leave();
+   return 0;
+ }
+
+ void *my_thread(void *ptr)
+ {
+   CURL *curl;
+   CURLcode res;
+   FILE *outfile;
+   gchar *url = ptr;
+ 
+   curl = curl_easy_init();
+   if(curl)
+   {
+     outfile = fopen("test.curl", "w");
+ 
+     curl_easy_setopt(curl, CURLOPT_URL, url);
+     curl_easy_setopt(curl, CURLOPT_WRITEDATA, outfile);
+     curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, my_write_func);
+     curl_easy_setopt(curl, CURLOPT_READFUNCTION, my_read_func);
+     curl_easy_setopt(curl, CURLOPT_NOPROGRESS, FALSE);
+     curl_easy_setopt(curl, CURLOPT_PROGRESSFUNCTION, my_progress_func);
+     curl_easy_setopt(curl, CURLOPT_PROGRESSDATA, Bar);
+ 
+     res = curl_easy_perform(curl);
+ 
+     fclose(outfile);
+     curl_easy_cleanup(curl);
+   }
+ 
+   return NULL;
+ }
+ 
+*/
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+