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: +*/ diff --git a/libguile/null-threads.h b/libguile/null-threads.h new file mode 100644 index 000000000..92efcad8f --- /dev/null +++ b/libguile/null-threads.h @@ -0,0 +1,98 @@ +/* classes: h_files */ + +#ifndef SCM_NULL_DEFS_H +#define SCM_NULL_DEFS_H + +/* 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. */ + + + +/* The null-threads implementation. We provide the standard API, but + no new threads can be created. +*/ + +#define SCM_CRITICAL_SECTION_START +#define SCM_CRITICAL_SECTION_END +#define SCM_THREAD_SWITCHING_CODE + +typedef struct scm_null_mutex { + int locked; +} scm_null_mutex; + +SCM_API int scm_null_mutex_init (scm_null_mutex *); +SCM_API int scm_null_mutex_lock (scm_null_mutex *); +SCM_API int scm_null_mutex_unlock (scm_null_mutex *); +SCM_API int scm_null_mutex_destroy (scm_null_mutex *); + +typedef scm_null_mutex scm_t_mutex; +#define scm_mutex_init scm_null_mutex_init +#define scm_mutex_lock scm_null_mutex_lock +#define scm_mutex_unlock scm_null_mutex_unlock + +typedef struct scm_null_condvar { + int signalled; +} scm_null_condvar; + +SCM_API int scm_null_condvar_init (scm_null_condvar *); +SCM_API int scm_null_condvar_wait (scm_null_condvar *, scm_null_mutex *); +SCM_API int scm_null_condvar_signal (scm_null_condvar *); +SCM_API int scm_null_condvar_destroy (scm_null_condvar *); + +typedef scm_null_condvar scm_t_condvar; +#define scm_cond_init scm_null_condvar_init +#define scm_cond_wait scm_null_condvar_wait +#define scm_cond_signal scm_null_condvar_signal +#define scm_cond_broadcast scm_null_condvar_signal /* yes */ +#define scm_cond_destroy scm_null_condvar_destroy + +SCM_API void *scm_null_threads_data; + +#define SCM_THREAD_LOCAL_DATA (scm_null_threads_data) +#define SCM_SET_THREAD_LOCAL_DATA(ptr) (scm_null_threads_data = (ptr)) + +#endif /* SCM_NULL_DEFS_H */ + +/* + Local Variables: + c-file-style: "gnu" + End: +*/