summaryrefslogtreecommitdiff
path: root/libguile/null-threads.c
diff options
context:
space:
mode:
authorMarius Vollmer <mvo@zagadka.de>2002-10-16 15:54:23 +0000
committerMarius Vollmer <mvo@zagadka.de>2002-10-16 15:54:23 +0000
commit3d527b275536d99effe4e25e6f6edabf38c89581 (patch)
tree2ab0a1c98eb409a3bfa95cc072c7f2cb6987cf27 /libguile/null-threads.c
parentf77420343729541d9d959ae887bcf3d5af168d27 (diff)
downloadguile-3d527b275536d99effe4e25e6f6edabf38c89581.tar.gz
New files.
Diffstat (limited to 'libguile/null-threads.c')
-rw-r--r--libguile/null-threads.c318
1 files changed, 318 insertions, 0 deletions
diff --git a/libguile/null-threads.c b/libguile/null-threads.c
new file mode 100644
index 000000000..ac1a135e1
--- /dev/null
+++ b/libguile/null-threads.c
@@ -0,0 +1,318 @@
+/* Copyright (C) 2002 Free Software Foundation, Inc.
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2, or (at your option)
+ * any later version.
+ *
+ * This program 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this software; see the file COPYING. If not, write to
+ * the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
+ * Boston, MA 02111-1307 USA
+ *
+ * As a special exception, the Free Software Foundation gives permission
+ * for additional uses of the text contained in its release of GUILE.
+ *
+ * The exception is that, if you link the GUILE library with other files
+ * to produce an executable, this does not by itself cause the
+ * resulting executable to be covered by the GNU General Public License.
+ * Your use of that executable is in no way restricted on account of
+ * linking the GUILE library code into it.
+ *
+ * This exception does not however invalidate any other reasons why
+ * the executable file might be covered by the GNU General Public License.
+ *
+ * This exception applies only to the code released by the
+ * Free Software Foundation under the name GUILE. If you copy
+ * code from other Free Software Foundation releases into a copy of
+ * GUILE, as the General Public License permits, the exception does
+ * not apply to the code that you add in this way. To avoid misleading
+ * anyone as to the status of such modified files, you must delete
+ * this exception notice from them.
+ *
+ * If you write modifications of your own for GUILE, it is your choice
+ * whether to permit this exception to apply to your modifications.
+ * If you do not wish that, delete this exception notice. */
+
+
+
+
+#include "libguile/validate.h"
+#include "libguile/root.h"
+#include "libguile/stackchk.h"
+#include "libguile/async.h"
+#include "sys/time.h"
+#include "sys/types.h"
+
+void *scm_null_threads_data;
+
+static SCM main_thread;
+
+void
+scm_threads_init (SCM_STACKITEM *i)
+{
+ main_thread = scm_permanent_object (scm_cell (scm_tc16_thread, 0));
+ scm_null_threads_data = NULL;
+}
+
+#ifdef __ia64__
+# define SCM_MARK_BACKING_STORE() do { \
+ ucontext_t ctx; \
+ SCM_STACKITEM * top, * bot; \
+ getcontext (&ctx); \
+ scm_mark_locations ((SCM_STACKITEM *) &ctx.uc_mcontext, \
+ ((size_t) (sizeof (SCM_STACKITEM) - 1 + sizeof ctx.uc_mcontext) \
+ / sizeof (SCM_STACKITEM))); \
+ bot = (SCM_STACKITEM *) __libc_ia64_register_backing_store_base; \
+ top = (SCM_STACKITEM *) ctx.uc_mcontext.sc_ar_bsp; \
+ scm_mark_locations (bot, top - bot); } while (0)
+#else
+# define SCM_MARK_BACKING_STORE()
+#endif
+
+void
+scm_threads_mark_stacks (void)
+{
+ /* Mark objects on the C stack. */
+ SCM_FLUSH_REGISTER_WINDOWS;
+ /* This assumes that all registers are saved into the jmp_buf */
+ setjmp (scm_save_regs_gc_mark);
+ scm_mark_locations ((SCM_STACKITEM *) scm_save_regs_gc_mark,
+ ( (size_t) (sizeof (SCM_STACKITEM) - 1 +
+ sizeof scm_save_regs_gc_mark)
+ / sizeof (SCM_STACKITEM)));
+
+ {
+ unsigned long stack_len = scm_stack_size (scm_stack_base);
+#ifdef SCM_STACK_GROWS_UP
+ scm_mark_locations (scm_stack_base, stack_len);
+#else
+ scm_mark_locations (scm_stack_base - stack_len, stack_len);
+#endif
+ }
+ SCM_MARK_BACKING_STORE();
+}
+
+SCM
+scm_call_with_new_thread (SCM argl)
+#define FUNC_NAME s_call_with_new_thread
+{
+ SCM_MISC_ERROR ("threads are not supported in this version of Guile",
+ SCM_EOL);
+ return SCM_BOOL_F;
+}
+#undef FUNC_NAME
+
+SCM
+scm_spawn_thread (scm_t_catch_body body, void *body_data,
+ scm_t_catch_handler handler, void *handler_data)
+{
+ scm_misc_error ("scm_spawn_thread",
+ "threads are not supported in this version of Guile",
+ SCM_EOL);
+ return SCM_BOOL_F;
+}
+
+SCM
+scm_current_thread (void)
+{
+ return main_thread;
+}
+
+SCM
+scm_all_threads (void)
+{
+ return scm_list_1 (main_thread);
+}
+
+scm_root_state *
+scm_i_thread_root (SCM thread)
+{
+ return (scm_root_state *)scm_null_threads_data;
+}
+
+SCM
+scm_join_thread (SCM thread)
+#define FUNC_NAME s_join_thread
+{
+ SCM_MISC_ERROR ("threads are not supported in this version of Guile",
+ SCM_EOL);
+ return SCM_BOOL_F;
+}
+#undef FUNC_NAME
+
+SCM
+scm_yield (void)
+{
+ return SCM_BOOL_T;
+}
+
+/* Block until a new async might have been queued.
+ */
+static void
+block ()
+{
+ select (0, NULL, NULL, NULL, NULL);
+}
+
+int
+scm_null_mutex_init (scm_null_mutex *m)
+{
+ m->locked = 0;
+ return 0;
+}
+
+int
+scm_null_mutex_lock (scm_null_mutex *m)
+{
+ while (m->locked)
+ {
+ block ();
+ SCM_ASYNC_TICK;
+ }
+ m->locked = 1;
+ return 1;
+}
+
+int
+scm_null_mutex_unlock (scm_null_mutex *m)
+{
+ if (m->locked == 0)
+ return 0;
+ m->locked = 0;
+ return 1;
+}
+
+int
+scm_null_mutex_destroy (scm_null_mutex *m)
+{
+ return 1;
+}
+
+SCM
+scm_make_mutex (void)
+{
+ SCM m = scm_make_smob (scm_tc16_mutex);
+ scm_null_mutex_init (SCM_MUTEX_DATA(m));
+ return m;
+}
+
+SCM
+scm_lock_mutex (SCM m)
+{
+ SCM_ASSERT (SCM_MUTEXP (m), m, SCM_ARG1, s_lock_mutex);
+ scm_null_mutex_lock (SCM_MUTEX_DATA(m));
+ return SCM_BOOL_T;
+}
+
+SCM
+scm_unlock_mutex (SCM m)
+{
+ SCM_ASSERT (SCM_MUTEXP (m), m, SCM_ARG1, s_unlock_mutex);
+ if (!scm_null_mutex_unlock (SCM_MUTEX_DATA(m)))
+ scm_misc_error (s_unlock_mutex, "mutex is not locked", SCM_EOL);
+ return SCM_BOOL_T;
+}
+
+int
+scm_null_condvar_init (scm_null_condvar *c)
+{
+ c->signalled = 0;
+ return 0;
+}
+
+int
+scm_null_condvar_wait (scm_null_condvar *c, scm_null_mutex *m)
+{
+ scm_null_mutex_unlock (m);
+ while (!c->signalled)
+ {
+ block ();
+ SCM_ASYNC_TICK;
+ }
+ scm_null_mutex_lock (m);
+ c->signalled = 0;
+ return 0;
+}
+
+int
+scm_null_condvar_signal (scm_null_condvar *c)
+{
+ c->signalled = 1;
+ return 0;
+}
+
+int
+scm_null_condvar_destroy (scm_null_condvar *c)
+{
+ return 1;
+}
+
+SCM
+scm_make_condition_variable (void)
+{
+ SCM c = scm_make_smob (scm_tc16_condvar);
+ scm_null_condvar_init (SCM_CONDVAR_DATA (c));
+ return c;
+}
+
+SCM
+scm_wait_condition_variable (SCM c, SCM m)
+{
+ SCM_ASSERT (SCM_CONDVARP (c),
+ c,
+ SCM_ARG1,
+ s_wait_condition_variable);
+ SCM_ASSERT (SCM_MUTEXP (m),
+ m,
+ SCM_ARG2,
+ s_wait_condition_variable);
+ scm_null_condvar_wait (SCM_CONDVAR_DATA (c), SCM_MUTEX_DATA (m));
+ return SCM_BOOL_T;
+}
+
+SCM
+scm_signal_condition_variable (SCM c)
+{
+ SCM_ASSERT (SCM_CONDVARP (c),
+ c,
+ SCM_ARG1,
+ s_signal_condition_variable);
+ scm_null_condvar_signal (SCM_CONDVAR_DATA (c));
+ return SCM_BOOL_T;
+}
+
+unsigned long
+scm_thread_usleep (unsigned long usec)
+{
+ struct timeval timeout;
+ timeout.tv_sec = 0;
+ timeout.tv_usec = usec;
+ select (0, NULL, NULL, NULL, &timeout);
+ return 0; /* Maybe we should calculate actual time slept,
+ but this is faster... :) */
+}
+
+unsigned long
+scm_thread_sleep (unsigned long sec)
+{
+ time_t now = time (NULL);
+ struct timeval timeout;
+ unsigned long slept;
+ timeout.tv_sec = sec;
+ timeout.tv_usec = 0;
+ select (0, NULL, NULL, NULL, &timeout);
+ slept = time (NULL) - now;
+ return slept > sec ? 0 : sec - slept;
+}
+
+/*
+ Local Variables:
+ c-file-style: "gnu"
+ End:
+*/