/* src/threads/native/threads.h - native threads header Copyright (C) 1996-2005, 2006, 2007 R. Grafl, A. Krall, C. Kruegel, C. Oates, R. Obermaisser, M. Platter, M. Probst, S. Ring, E. Steiner, C. Thalinger, D. Thuernbeck, P. Tomsich, C. Ullrich, J. Wenninger, Institut f. Computersprachen - TU Wien This file is part of CACAO. 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 program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. $Id: threads.h 7766 2007-04-19 13:24:48Z michi $ */ #ifndef _THREADS_H #define _THREADS_H /* forward typedefs ***********************************************************/ typedef struct threadobject threadobject; typedef union threads_table_entry_t threads_table_entry_t; typedef struct threads_table_t threads_table_t; #include "config.h" #include #include #include "vm/types.h" #include "mm/memory.h" #include "native/jni.h" #include "native/include/java_lang_Thread.h" #include "threads/native/lock.h" #include "vm/global.h" #if defined(ENABLE_GC_CACAO) # include "vm/jit/replace.h" #endif #include "vm/jit/stacktrace.h" #if defined(ENABLE_INTRP) #include "vm/jit/intrp/intrp.h" #endif #if defined(__DARWIN__) # include typedef struct { pthread_mutex_t mutex; pthread_cond_t cond; int value; } sem_t; #else # include #endif /* current threadobject *******************************************************/ #if defined(HAVE___THREAD) #define THREADSPECIFIC __thread #define THREADOBJECT threads_current_threadobject extern __thread threadobject *threads_current_threadobject; #else /* defined(HAVE___THREAD) */ #define THREADSPECIFIC #define THREADOBJECT \ ((threadobject *) pthread_getspecific(threads_current_threadobject_key)) extern pthread_key_t threads_current_threadobject_key; #endif /* defined(HAVE___THREAD) */ /* threads_table_entry_t ******************************************************* An entry in the global threads table. *******************************************************************************/ union threads_table_entry_t { threadobject *thread; /* an existing thread */ ptrint nextfree; /* next free index */ }; /* threads_table_t ************************************************************* Struct for the global threads table. *******************************************************************************/ struct threads_table_t { threads_table_entry_t *table; /* the table, threads[0] is the head */ /* of the free list. Real entries */ /* start at threads[1]. */ s4 size; /* current size of the table */ }; /* threadobject **************************************************************** Struct holding thread local variables. *******************************************************************************/ #define THREAD_FLAG_JAVA 0x01 /* a normal Java thread */ #define THREAD_FLAG_INTERNAL 0x02 /* CACAO internal thread */ #define THREAD_FLAG_DAEMON 0x04 /* daemon thread */ #define THREAD_FLAG_IN_NATIVE 0x08 /* currently executing native code */ #define SUSPEND_REASON_JNI 1 /* suspended from JNI */ #define SUSPEND_REASON_STOPWORLD 2 /* suspended from stop-thw-world */ struct threadobject { java_lang_Thread *object; /* link to java.lang.Thread object */ lock_execution_env_t ee; /* data for the lock implementation */ threadobject *next; /* next thread in list, or self */ threadobject *prev; /* prev thread in list, or self */ ptrint thinlock; /* pre-computed thin lock value */ s4 index; /* thread index, starting with 1 */ u4 flags; /* flag field */ u4 state; /* state field */ pthread_t tid; /* pthread id */ #if defined(__DARWIN__) mach_port_t mach_thread; /* Darwin thread id */ #endif /* these are used for the wait/notify implementation */ pthread_mutex_t waitmutex; pthread_cond_t waitcond; pthread_mutex_t suspendmutex; /* lock before suspending this thread */ pthread_cond_t suspendcond; /* notify to resume this thread */ bool interrupted; bool signaled; bool sleeping; bool suspended; /* is this thread suspended? */ s4 suspend_reason; /* reason for suspending */ u1 *pc; /* current PC (used for profiling) */ java_objectheader *_exceptionptr; /* current exception */ stackframeinfo *_stackframeinfo; /* current native stackframeinfo */ localref_table *_localref_table; /* JNI local references */ #if defined(ENABLE_INTRP) Cell *_global_sp; /* stack pointer for interpreter */ #endif #if defined(ENABLE_GC_CACAO) bool gc_critical; /* indicates a critical section */ sourcestate_t *ss; executionstate_t *es; #endif dumpinfo_t dumpinfo; /* dump memory info structure */ }; /* exception pointer **********************************************************/ #define exceptionptr (&(THREADOBJECT->_exceptionptr)) /* stackframeinfo *************************************************************/ #define STACKFRAMEINFO (THREADOBJECT->_stackframeinfo) /* variables ******************************************************************/ extern threadobject *mainthreadobj; /* functions ******************************************************************/ void threads_sem_init(sem_t *sem, bool shared, int value); void threads_sem_wait(sem_t *sem); void threads_sem_post(sem_t *sem); threadobject *threads_get_current_threadobject(void); void threads_preinit(void); bool threads_init(void); void threads_start_thread(threadobject *thread, functionptr function); void threads_set_thread_priority(pthread_t tid, int priority); bool threads_attach_current_thread(JavaVMAttachArgs *vm_aargs, bool isdaemon); bool threads_detach_thread(threadobject *thread); bool threads_suspend_thread(threadobject *thread, s4 reason); void threads_suspend_ack(u1* pc, u1* sp); bool threads_resume_thread(threadobject *thread); void threads_join_all_threads(void); void threads_sleep(s8 millis, s4 nanos); void threads_yield(void); bool threads_wait_with_timeout_relative(threadobject *t, s8 millis, s4 nanos); void threads_thread_interrupt(threadobject *thread); bool threads_check_if_interrupted_and_reset(void); bool threads_thread_has_been_interrupted(threadobject *thread); #if !defined(DISABLE_GC) void threads_stopworld(void); void threads_startworld(void); #endif #endif /* _THREADS_H */ /* * These are local overrides for various environment variables in Emacs. * Please do not remove this and leave it at the end of the file, where * Emacs will automagically detect them. * --------------------------------------------------------------------- * Local variables: * mode: c * indent-tabs-mode: t * c-basic-offset: 4 * tab-width: 4 * End: * vim:noexpandtab:sw=4:ts=4: */