* by counting up threads starting at 3, we seem to get what top shows in the LWPID...

[citadel.git] / citadel / threads.h

diff --git a/citadel/threads.h b/citadel/threads.h
index cbffc273eabaab41c325566e903186c8c5478428..4103466f5b861d3222b8b2d620c451f705e12024 100644 (file)
--- a/citadel/threads.h
+++ b/citadel/threads.h
@@ -1,4 +1,4 @@
-/* $Id:$ */
+/* $Id$ */
 
 #ifndef THREADS_H
 #define THREADS_H
@@ -21,6 +21,49 @@
 #endif
 
 #include "server.h"
+#include "sysdep_decls.h"
+
+#ifndef timerclear
+#define timerclear(tvp)         ((tvp)->tv_sec = (tvp)->tv_usec = 0)
+#endif
+
+#ifndef timerisset
+#define timerisset(tvp)         ((tvp)->tv_sec || (tvp)->tv_usec)
+#endif
+
+#ifndef timercmp
+#define timercmp(tvp, uvp, cmp) \
+ (((tvp)->tv_sec == (uvp)->tv_sec) ? \
+     ((tvp)->tv_usec cmp (uvp)->tv_usec) : \
+     ((tvp)->tv_sec cmp (uvp)->tv_sec))
+#endif
+
+#ifndef timeradd
+#define timeradd(tvp, uvp, vvp) \
+ do { \
+  (vvp)->tv_sec = (tvp)->tv_sec + (uvp)->tv_sec; \
+  (vvp)->tv_usec = (tvp)->tv_usec + (uvp)->tv_usec; \
+  if ((vvp)->tv_usec >= 1000000) { \
+   (vvp)->tv_sec++; \
+   (vvp)->tv_usec -= 1000000; \
+  } \
+ } while (0)
+#endif
+
+#ifndef timersub
+#define timersub(tvp, uvp, vvp) \
+ do { \
+  (vvp)->tv_sec = (tvp)->tv_sec - (uvp)->tv_sec; \
+  (vvp)->tv_usec = (tvp)->tv_usec - (uvp)->tv_usec; \
+  if ((vvp)->tv_usec < 0) { \
+   (vvp)->tv_sec--; \
+   (vvp)->tv_usec += 1000000; \
+  } \
+ } while (0)
+#endif
+ 
+
+// #define THREADS_USESIGNALS
 
 /*
  * Thread stuff
@@ -42,8 +85,9 @@ enum CtdlThreadState {
 typedef struct CtdlThreadNode CtdlThreadNode;
 
 struct CtdlThreadNode{
-       pthread_t tid;                          /* id as returned by pthread_create() */
+       citthread_t tid;                                /* id as returned by citthread_create() */
        pid_t pid;                              /* pid, as best the OS will let us determine */
+       long reltid;                            /* counting from start... */
        time_t when;                            /* When to start a scheduled thread */
        struct CitContext *Context;             /* The session context that this thread mught be working on or NULL if none */
        long number;                            /* A unigue number for this thread (not implimented yet) */
@@ -55,11 +99,12 @@ struct CtdlThreadNode{
        void *user_args;                        /* Arguments passed to this threads work function */
        long flags;                             /* Flags that describe this thread */
        enum CtdlThreadState state;             /* Flag to show state of this thread */
-       pthread_mutex_t ThreadMutex;            /* A mutex to sync this thread to others if this thread allows (also used for sleeping) */
-       pthread_cond_t ThreadCond;              /* A condition variable to sync this thread with others */
-       pthread_mutex_t SleepMutex;             /* A mutex for sleeping */
-       pthread_cond_t SleepCond;               /* A condition variable for sleeping */
-       pthread_attr_t attr;                    /* Attributes of this thread */
+       time_t stop_ticker;                     /* A counter to determine how long it has taken for this thread to exit */
+       citthread_mutex_t ThreadMutex;          /* A mutex to sync this thread to others if this thread allows (also used for sleeping) */
+       citthread_cond_t ThreadCond;            /* A condition variable to sync this thread with others */
+       citthread_mutex_t SleepMutex;           /* A mutex for sleeping */
+       citthread_cond_t SleepCond;             /* A condition variable for sleeping */
+       citthread_attr_t attr;                  /* Attributes of this thread */
        struct timeval start_time;              /* Time this thread was started */
        struct timeval last_state_change;       /* Time when this thread last changed state */
        double avg_sleeping;                    /* Average sleeping time */
@@ -82,7 +127,8 @@ struct ThreadTSD {
 
 extern double CtdlThreadLoadAvg;
 extern double CtdlThreadWorkerAvg;
-extern pthread_key_t ThreadKey;
+extern long statcount;         /* are we doing a stats check? */
+extern citthread_key_t ThreadKey;
 
 void ctdl_thread_internal_init_tsd(void);
 void ctdl_internal_thread_gc (void);
@@ -92,6 +138,7 @@ void ctdl_thread_internal_calc_loadavg(void);
 void ctdl_thread_internal_free_tsd(void);
 CtdlThreadNode *ctdl_internal_create_thread(char *name, long flags, void *(*thread_func) (void *arg), void *args);
 void ctdl_thread_internal_check_scheduled(void);
+void ctdl_thread_internal_change_state (CtdlThreadNode *this_thread, enum CtdlThreadState new_state);
 
 void InitialiseSemaphores(void);
 int try_critical_section (int which_one);