Changeset 24 for trunk/gtk

Timestamp:

Jan 12, 2006, 7:04:05 PM (17 years ago)

Author:

root

Message:

Update 2006-01-03

Location:

trunk/gtk

Files:

• conf.c (modified) (1 diff)
• main.c (modified) (18 diffs)
• util.c (modified) (6 diffs)
• util.h (modified) (3 diffs)

trunk/gtk/conf.c

@@ -450 +450 @@
   for(ii = 0; ii < count; ii++) {
     /* XXX need a better way to query running/stopped state */
-    paused = (TR_STATUS_STOPPING == torrents[ii].status ||
-              TR_STATUS_STOPPED == torrents[ii].status ||
-              TR_STATUS_PAUSE == torrents[ii].status);
+    paused = ((TR_STATUS_STOPPING | TR_STATUS_PAUSE) & torrents[ii].status);
     torrentfile = g_strescape(torrents[ii].info.torrent, "");
     torrentdir = g_strescape(torrents[ii].folder, "");

trunk/gtk/main.c

@@ -77 +77 @@
 gboolean
 exitcheck(gpointer gdata);
+void
+stoptransmission(void *tr);
 GtkWidget *
 makewind_toolbar(struct cbdata *data);
@@ -105 +107 @@
 void
 actionclick(GtkWidget *widget, gpointer gdata);
+gint
+intrevcmp(gconstpointer a, gconstpointer b);
 void
 doubleclick(GtkWidget *widget, GtkTreePath *path, GtkTreeViewColumn *col,
@@ -169 +173 @@
   tr = tr_init();
 
+  setuphandlers(stoptransmission, tr);
+
   if(cf_init(tr_getPrefsDirectory(), &err)) {
     if(cf_lock(&err)) {
@@ -202 +208 @@
         gtk_widget_show_all(stateerr);
     } else {
-      gtk_widget_show(errmsg_full(NULL, (errfunc_t)gtk_main_quit,
+      gtk_widget_show(errmsg_full(NULL, (callbackfunc_t)gtk_main_quit,
                                   NULL, "%s", err));
       g_free(err);
     }
   } else {
-    gtk_widget_show(errmsg_full(NULL, (errfunc_t)gtk_main_quit,
+    gtk_widget_show(errmsg_full(NULL, (callbackfunc_t)gtk_main_quit,
                                 NULL, "%s", err));
     g_free(err);
@@ -309 +315 @@
   data->timer = -1;
 
+  blocksigs();
+
   for(ii = tr_torrentStat(data->tr, &st); 0 < ii; ii--) {
     if(TR_TORRENT_NEEDS_STOP(st[ii-1].status)) {
@@ -320 +328 @@
   free(st);
 
+  unblocksigs();
+
   /* XXX should disable widgets or something */
 
@@ -340 +350 @@
   int ii;
 
+  blocksigs();
+
   for(ii = tr_torrentStat(data->cbdata->tr, &st); 0 < ii; ii--) {
-    if(TR_STATUS_PAUSE == st[ii-1].status) {
+    if(TR_STATUS_PAUSE & st[ii-1].status) {
       /*fprintf(stderr, "quit: closing %i %s\n", ii, st[ii-1].info.name);*/
       tr_torrentClose(data->cbdata->tr, ii - 1);
@@ -354 +366 @@
      time(NULL) - data->started < TRACKER_EXIT_TIMEOUT) {
     updatemodel(data->cbdata);
+    unblocksigs();
     return TRUE;
   }
-
-  /*fprintf(stderr, "quit: giving up on %i torrents\n",
-    tr_torrentCount(data->cbdata->tr));*/
-
-  for(ii = tr_torrentCount(data->cbdata->tr); 0 < ii; ii--)
-    tr_torrentClose(data->cbdata->tr, ii - 1);
 
   /* exit otherwise */
@@ -369 +376 @@
   data->timer = -1;
 
+  /*fprintf(stderr, "quit: giving up on %i torrents\n",
+    tr_torrentCount(data->cbdata->tr));*/
+  stoptransmission(data->cbdata->tr);
+  clearhandlers();
+  unblocksigs();
+
   gtk_widget_destroy(GTK_WIDGET(data->cbdata->wind));
-  tr_close(data->cbdata->tr);
   g_free(data->cbdata);
   g_free(data);
@@ -376 +388 @@
 
   return FALSE;
+}
+
+void
+stoptransmission(void *tr) {
+  while(0 < tr_torrentCount(tr))
+    tr_torrentClose(tr, 0);
+  tr_close(tr);
 }
 
@@ -590 +609 @@
   char *upstr, *downstr, *str;
 
+  blocksigs();
+
   max = tr_torrentStat(data->tr, &st);
   for(ii = 0; ii < max; ii++) {
@@ -626 +647 @@
   /* the status of the selected item may have changed, so update the buttons */
   fixbuttons(NULL, data);
+
+  unblocksigs();
 
   return TRUE;
@@ -791 +814 @@
   assert(actindex < ALEN(actionitems));
 
+  blocksigs();
   updatesave = FALSE;
   count = tr_torrentStat(data->tr, &sb);
 
-  for(ii = g_list_first(ids); NULL != ii; ii = ii->next) {
+  for(ii = g_list_sort(ids, intrevcmp); NULL != ii; ii = ii->next) {
     index = GPOINTER_TO_INT(ii->data);
     if(index >= count) {
@@ -820 +844 @@
         tr_torrentClose(data->tr, index);
         updatesave = TRUE;
+        /* XXX should only unselect deleted rows */
+        gtk_tree_selection_unselect_all(gtk_tree_view_get_selection(data->view));
         break;
       case ACT_INFO:
@@ -836 +862 @@
   }
 
+  unblocksigs();
+
   if(FROM_BUTTON == from)
     g_list_free(ids);
+}
+
+gint
+intrevcmp(gconstpointer a, gconstpointer b) {
+  int aint = GPOINTER_TO_INT(a);
+  int bint = GPOINTER_TO_INT(b);
+
+  if(bint > aint)
+    return 1;
+  else if(bint < aint)
+    return -1;
+  else
+    return 0;
 }
 
@@ -867 +908 @@
   }
 
+  blocksigs();
+
   if(0 != tr_torrentInit(tr, torrent)) {
+    unblocksigs();
     /* XXX would be nice to have errno strings, are they printed to stdout? */
     errmsg(parentwind, "Failed to open torrent file %s", torrent);
@@ -887 +931 @@
   if(!paused)
     tr_torrentStart(tr, tr_torrentCount(tr) - 1);
+
+  unblocksigs();
+
   return TRUE;
 }
@@ -909 +956 @@
     ret = cf_savestate(count, stat, &errstr);
   else {
+    blocksigs();
     count = tr_torrentStat(tr, &st);
+    unblocksigs();
     ret = cf_savestate(count, st, &errstr);
     free(st);

trunk/gtk/util.c

@@ -28 +28 @@
 #include <sys/stat.h>
 #include <errno.h>
+#include <signal.h>
 #include <stdarg.h>
 #include <string.h>
@@ -35 +36 @@
 #include "util.h"
 
+static void
+sigexithandler(int sig);
 static void
 errcb(GtkWidget *wind, int resp, gpointer data);
@@ -99 +102 @@
 }
 
+static int exit_sigs[] = {SIGHUP, SIGINT, SIGQUIT, SIGTERM, SIGUSR1, SIGUSR2};
+static callbackfunc_t exit_func = NULL;
+static void *exit_data = NULL;
+static int exit_block_level = 0;
+
+void
+setuphandlers(callbackfunc_t func, void *data) {
+  struct sigaction sa;
+  unsigned int ii;
+
+  exit_data = data;
+  exit_func = func;
+
+  bzero(&sa, sizeof(sa));
+  sa.sa_handler = sigexithandler;
+  for(ii = 0; ii < ALEN(exit_sigs); ii++)
+    sigaction(exit_sigs[ii], &sa, NULL);
+}
+
+void
+clearhandlers(void) {
+  struct sigaction sa;
+  unsigned int ii;
+
+  bzero(&sa, sizeof(sa));
+  sa.sa_handler = SIG_DFL;
+  for(ii = 0; ii < ALEN(exit_sigs); ii++)
+    sigaction(exit_sigs[ii], &sa, NULL);
+}
+
+static void
+sigexithandler(int sig) {
+  exit_func(exit_data);
+  clearhandlers();
+  raise(sig);
+}
+
+void
+blocksigs(void) {
+  sigset_t mask;
+  unsigned int ii;
+
+  if(0 < (exit_block_level++))
+    return;
+
+  sigemptyset(&mask);
+  for(ii = 0; ii < ALEN(exit_sigs); ii++)
+    sigaddset(&mask, exit_sigs[ii]);
+  sigprocmask(SIG_BLOCK, &mask, NULL);
+}
+
+void
+unblocksigs(void) {
+  sigset_t mask;
+  unsigned int ii;
+
+  if(0 < (--exit_block_level))
+    return;
+
+  sigemptyset(&mask);
+  for(ii = 0; ii < ALEN(exit_sigs); ii++)
+    sigaddset(&mask, exit_sigs[ii]);
+  sigprocmask(SIG_UNBLOCK, &mask, NULL);
+}
+
 GtkWidget *
 errmsg(GtkWindow *wind, const char *format, ...) {
@@ -112 +180 @@
 
 GtkWidget *
-errmsg_full(GtkWindow *wind, errfunc_t func, void *data,
+errmsg_full(GtkWindow *wind, callbackfunc_t func, void *data,
             const char *format, ...) {
   GtkWidget *dialog;
@@ -125 +193 @@
 
 GtkWidget *
-verrmsg(GtkWindow *wind, errfunc_t func, void *data,
+verrmsg(GtkWindow *wind, callbackfunc_t func, void *data,
         const char *format, va_list ap) {
   GtkWidget *dialog;
@@ -156 +224 @@
 errcb(GtkWidget *widget, int resp SHUTUP, gpointer data) {
   GList *funcdata;
-  errfunc_t func;
+  callbackfunc_t func;
 
   if(NULL != data) {

trunk/gtk/util.h

@@ -41 +41 @@
 #define ALEN(a)                 (sizeof(a) / sizeof((a)[0]))
 
+/* used for a callback function with a data parameter */
+typedef void (*callbackfunc_t)(void*);
+
+/* try to interpret a string as a textual representation of a boolean */
 gboolean
 strbool(const char *str);
 
+/* return a human-readable string for the size given in bytes with the
+   requested number of decimal places.  the string must be g_free()d */
 char *
 readablesize(guint64 size, int decimals);
 
+/* create a directory and any missing parent directories */
 gboolean
 mkdir_p(const char *name, mode_t mode);
 
-typedef void (*errfunc_t)(void*);
+/* set up a handler for various fatal signals */
+void
+setuphandlers(callbackfunc_t func, void *data);
+
+/* clear the handlers for fatal signals */
+void
+clearhandlers(void);
+
+/* blocks and unblocks delivery of fatal signals. calls to these
+   functions can be nested as long as unblocksigs() is called exactly
+   as many times as blocksigs().  only the first blocksigs() will
+   block signals and only the last unblocksigs() will unblock them. */
+void
+blocksigs(void);
+void
+unblocksigs(void);
 
 /* if wind is NULL then you must call gtk_widget_show on the returned widget */
@@ -62 +84 @@
 
 GtkWidget *
-errmsg_full(GtkWindow *wind, errfunc_t func, void *data,
+errmsg_full(GtkWindow *wind, callbackfunc_t func, void *data,
             const char *format, ...)
 #ifdef __GNUC__
@@ -70 +92 @@
 
 GtkWidget *
-verrmsg(GtkWindow *wind, errfunc_t func, void *data,
+verrmsg(GtkWindow *wind, callbackfunc_t func, void *data,
         const char *format, va_list ap);