Add fatal error handlers

Add Rast__unopen_all()
Invoke Rast__unopen_all() on fatal errors


git-svn-id: https://svn.osgeo.org/grass/grass/trunk@40463 15284696-431f-4ddb-bdfa-cd5b030d7da7

include/gisdefs.h

@@ -281,6 +281,11 @@ void G__no_gisinit(const char *);
 void G__check_gisinit(void);
 void G_init_all(void);
 
+/* handler.c */
+void G_add_error_handler(void (*)(void *), void *);
+void G_remove_error_handler(void (*)(void *), void *);
+void G__call_error_handlers(void);
+
 /* home.c */
 const char *G_home(void);
 const char *G__home(void);

include/rasterdefs.h

@@ -84,6 +84,7 @@ int Rast_cell_stats_histo_eq(struct Cell_stats *, CELL, CELL, CELL, CELL, int,
 /* closecell.c */
 void Rast_close(int);
 void Rast_unopen(int);
+void Rast__unopen_all(void);
 
 /* color_compat.c */
 void Rast_make_ryg_colors(struct Colors *, CELL, CELL);
@@ -344,6 +345,7 @@ void Rast_init(void);
 void Rast__check_init(void);
 void Rast_init_all(void);
 void Rast__init(void);
+void Rast__error_handler(void *);
 
 /* interp.c */
 DCELL Rast_interp_linear(double, DCELL, DCELL);

lib/gis/error.c

@@ -152,6 +152,8 @@ void G_fatal_error(const char *msg, ...)
     vfprint_error(ERR, msg, ap);
     va_end(ap);
 
+    G__call_error_handlers();
+
     exit(EXIT_FAILURE);
 }
 

lib/gis/handler.c

@@ -0,0 +1,65 @@
+
+#include <stddef.h>
+#include <grass/gis.h>
+
+struct handler {
+    void (*func)(void *);
+    void *closure;
+};
+
+static struct handler *handlers;
+
+static int num_handlers;
+static int max_handlers;
+
+static struct handler *alloc_handler(void)
+{
+    int i;
+
+    for (i = 0; i < num_handlers; i++) {
+	struct handler *h = &handlers[i];
+	if (!h->func)
+	    return h;
+    }
+
+    if (num_handlers >= max_handlers) {
+	max_handlers += 10;
+	handlers = G_realloc(handlers, max_handlers * sizeof(struct handler));
+    }
+
+    return &handlers[num_handlers++];
+}
+
+void G_add_error_handler(void (*func)(void *), void *closure)
+{
+    struct handler *h = alloc_handler();
+
+    h->func = func;
+    h->closure = closure;
+}
+
+void G_remove_error_handler(void (*func)(void *), void *closure)
+{
+    int i;
+
+    for (i = 0; i < num_handlers; i++) {
+	struct handler *h = &handlers[i];
+
+	if (h->func == func && h->closure == closure) {
+	    h->func = NULL;
+	    h->closure = NULL;
+	}
+    }
+}
+
+void G__call_error_handlers(void)
+{
+    int i;
+
+    for (i = 0; i < num_handlers; i++) {
+	struct handler *h = &handlers[i];
+	if (h->func)
+	    (*h->func)(h->closure);
+    }
+}
+

lib/raster/closecell.c

@@ -64,8 +64,7 @@ static int write_fp_format(int fd);
  *
  * \param fd file descriptor
  *
- * \return -1 on error
- * \return 1 on success
+ * \return void
  */
 void Rast_close(int fd)
 {
@@ -98,8 +97,7 @@ void Rast_close(int fd)
  *
  * \param fd file descriptor
  *
- * \return -1 on error
- * \return 1 on success
+ * \return void
  */
 void Rast_unopen(int fd)
 {
@@ -114,6 +112,30 @@ void Rast_unopen(int fd)
 	close_new(fd, 0);
 }
 
+/*!
+ * \brief Unopen all raster maps
+ *
+ * Unopen all raster maps opened for write. Memory allocated for
+ * raster processing is freed, and the temporary file created when the
+ * raster map was opened is removed (see \ref
+ * Creating_and_Opening_New_Raster_Files). This routine is useful when
+ * errors are detected and it is desired to remove temporary files.
+ *
+ * \return void
+ */
+void Rast__unopen_all(void)
+{
+    int i;
+
+    for (i = 0; i < R__.fileinfo_count; i++) {
+	struct fileinfo *fcb = &R__.fileinfo[i];
+
+	if (fcb->open_mode == OPEN_NEW_COMPRESSED ||
+	    fcb->open_mode == OPEN_NEW_UNCOMPRESSED)
+	    close_new(i, 0);
+    }
+}
+
 static int close_old(int fd)
 {
     struct fileinfo *fcb = &R__.fileinfo[fd];

lib/raster/init.c

@@ -71,6 +71,11 @@ void Rast__init(void)
     G_initialize_done(&initialized);
 }
 
+void Rast__error_handler(void *p)
+{
+    Rast__unopen_all();
+}
+
 static int init(void)
 {
     G__init_window();
@@ -88,6 +93,8 @@ static int init(void)
     R__.nbytes = sizeof(CELL);
     R__.compression_type = getenv("GRASS_INT_ZLIB") ? 2 : 1;
 
+    G_add_error_handler(Rast__error_handler, NULL);
+
     initialized = 1;
 
     return 0;