Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
rename xbt_thread, xbt_mutex and xbt_thcond to xbt_os_thread, xbt_os_mutex and xbt_os...
[simgrid.git] / src / xbt / context_private.h
index f0450fd..2cf2a2e 100644 (file)
 #include "xbt/context.h"
 #include "xbt/ex.h"
 
-#ifdef USE_PTHREADS
-#  include <pthread.h>
-#elif defined(USE_WIN_THREADS)
-#  include "win_thread.h"
+#ifdef CONTEXT_THREADS
+#  include "xbt/xbt_os_thread.h"
 #else
+#  include <ucontext.h>
 #  define STACK_SIZE 128*1024 /* Lower this if you want to reduce the memory consumption */
-#endif     /* USE_PTHREADS */
+#endif     /* not CONTEXT_THREADS */
 
 
-typedef struct s_xbt_context 
-{
+typedef struct s_xbt_context {
        s_xbt_swag_hookup_t hookup;
-       #ifdef USE_PTHREADS
-       pthread_cond_t cond;
-       pthread_mutex_t mutex;
-       pthread_t *thread;                              /* the thread that execute the code     */
-       #elif defined(USE_WIN_THREADS)
-       win_thread_cond_t cond;
-       win_thread_mutex_t mutex;
-       win_thread_t thread;                    /* the thread that execute the code     */ 
-       #else
-       ucontext_t uc;                                  /* the thread that execute the code     */
+
+       /* Declaration of the thread running the process */
+#ifdef JAVA_SIMGRID /* come first because other ones are defined too */
+       jobject jprocess;  /* the java process instance                 */
+       JNIEnv* jenv;      /* jni interface pointer for this thread     */
+#else   
+# ifdef CONTEXT_THREADS
+       xbt_os_thread_t thread; /* a plain dumb thread (portable to posix or windows) */
+else
+       ucontext_t uc;       /* the thread that execute the code */
        char stack[STACK_SIZE];
        struct s_xbt_context *save;
-       #endif /* USE_PTHREADS || USE_WIN_THREADS */
-       xbt_context_function_t code;    /* the scheduler fonction                       */
+# endif /* CONTEXT_THREADS */
+#endif /* JAVA_SIMGRID */
+   
+       /* What we need to synchronize the process */        
+#if defined(JAVA_SIMGRID) || defined(CONTEXT_THREADS)
+       xbt_os_cond_t cond;             /* the condition used to synchronize the process        */
+       xbt_os_mutex_t mutex;           /* the mutex used to synchronize the process            */
+#endif
+
+       /* What to run */
+       xbt_context_function_t code;    /* the scheduled fonction           */
        int argc;
        char **argv;
+   
+       /* Init/exit functions */   
        void_f_pvoid_t *startup_func;
        void *startup_arg;
        void_f_pvoid_t *cleanup_func;
        void *cleanup_arg;
-       ex_ctx_t *exception;                    /* exception                                            */
+
+       ex_ctx_t *exception;            /* exception container    */
+       int iwannadie;                  /* Set to true by the context when it wants to commit suicide */
+
+   
 } s_xbt_context_t;