summaryrefslogtreecommitdiff
path: root/libguile/fdes-finalizers.c
diff options
context:
space:
mode:
Diffstat (limited to 'libguile/fdes-finalizers.c')
-rw-r--r--libguile/fdes-finalizers.c129
1 files changed, 129 insertions, 0 deletions
diff --git a/libguile/fdes-finalizers.c b/libguile/fdes-finalizers.c
new file mode 100644
index 000000000..fd4689e13
--- /dev/null
+++ b/libguile/fdes-finalizers.c
@@ -0,0 +1,129 @@
+/* Copyright (C) 2016 Free Software Foundation, Inc.
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public License
+ * as published by the Free Software Foundation; either version 3 of
+ * the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
+ * 02110-1301 USA
+ */
+
+
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include "libguile/_scm.h"
+#include "libguile/hashtab.h"
+#include "libguile/numbers.h"
+#include "libguile/fdes-finalizers.h"
+
+
+
+/* Table of fdes finalizers and associated lock. */
+static scm_i_pthread_mutex_t fdes_finalizers_lock =
+ SCM_I_PTHREAD_MUTEX_INITIALIZER;
+static SCM fdes_finalizers;
+
+SCM_DEFINE (scm_add_fdes_finalizer_x, "add-fdes-finalizer!", 2, 0, 0,
+ (SCM fd, SCM finalizer),
+ "Add a finalizer that will be called when @var{fd} is closed.")
+#define FUNC_NAME s_scm_add_fdes_finalizer_x
+{
+ SCM h;
+
+ /* Check type. */
+ scm_to_uint (fd);
+
+ scm_i_pthread_mutex_lock (&fdes_finalizers_lock);
+ h = scm_hashv_create_handle_x (fdes_finalizers, fd, SCM_EOL);
+ scm_set_cdr_x (h, scm_cons (finalizer, scm_cdr (h)));
+ scm_i_pthread_mutex_unlock (&fdes_finalizers_lock);
+
+ return SCM_UNSPECIFIED;
+}
+#undef FUNC_NAME
+
+SCM_DEFINE (scm_remove_fdes_finalizer_x, "remove-fdes-finalizer!", 2, 0, 0,
+ (SCM fd, SCM finalizer),
+ "Remove a finalizer that was previously added to the file\n"
+ "descriptor @var{fd}.")
+#define FUNC_NAME s_scm_remove_fdes_finalizer_x
+{
+ SCM h;
+
+ /* Check type. */
+ scm_to_uint (fd);
+
+ scm_i_pthread_mutex_lock (&fdes_finalizers_lock);
+ h = scm_hashv_get_handle (fdes_finalizers, fd);
+ if (scm_is_true (h))
+ scm_set_cdr_x (h, scm_delq1_x (finalizer, scm_cdr (h)));
+ scm_i_pthread_mutex_unlock (&fdes_finalizers_lock);
+
+ return SCM_UNSPECIFIED;
+}
+#undef FUNC_NAME
+
+struct fdes_finalizer_data
+{
+ SCM finalizer;
+ SCM fd;
+};
+
+static SCM
+do_run_finalizer (void *data)
+{
+ struct fdes_finalizer_data *fdata = data;
+ return scm_call_1 (fdata->finalizer, fdata->fd);
+}
+
+void
+scm_run_fdes_finalizers (int fd)
+{
+ SCM finalizers;
+ struct fdes_finalizer_data data;
+
+ data.fd = scm_from_int (fd);
+
+ scm_i_pthread_mutex_lock (&fdes_finalizers_lock);
+ finalizers = scm_hashv_ref (fdes_finalizers, data.fd, SCM_EOL);
+ if (!scm_is_null (finalizers))
+ scm_hashv_remove_x (fdes_finalizers, data.fd);
+ scm_i_pthread_mutex_unlock (&fdes_finalizers_lock);
+
+ for (; !scm_is_null (finalizers); finalizers = scm_cdr (finalizers))
+ {
+ data.finalizer = scm_car (finalizers);
+ scm_internal_catch (SCM_BOOL_T, do_run_finalizer, &data,
+ scm_handle_by_message_noexit, NULL);
+ }
+}
+
+
+
+
+static void
+scm_init_fdes_finalizers (void)
+{
+#include "libguile/fdes-finalizers.x"
+}
+
+void
+scm_register_fdes_finalizers ()
+{
+ fdes_finalizers = scm_c_make_hash_table (0);
+
+ scm_c_register_extension ("libguile-" SCM_EFFECTIVE_VERSION,
+ "scm_init_fdes_finalizers",
+ (scm_t_extension_init_func) scm_init_fdes_finalizers,
+ NULL);
+}