include/minix/mthread.h

   1 #ifndef _MTHREAD_H
   2 #define _MTHREAD_H
   3
   4 #include <minix/config.h>       /* MUST be first */
   5 #include <minix/const.h>
   6 #include <sys/types.h>
   7 #include <stdio.h>
   8 #include <ucontext.h>
   9 #include <errno.h>
  10 #include <stdlib.h>
  11 #include <limits.h>
  12 #include <sys/signal.h>
  13
  14 typedef int mthread_thread_t;
  15 typedef int mthread_once_t;
  16 typedef int mthread_key_t;
  17 typedef void * mthread_condattr_t;
  18 typedef void * mthread_mutexattr_t;
  19
  20 struct __mthread_tcb;
  21 typedef struct {
  22   struct __mthread_tcb *mq_head;
  23   struct __mthread_tcb *mq_tail;
  24 } mthread_queue_t;
  25
  26 struct __mthread_mutex {
  27   mthread_queue_t mm_queue;     /* Queue of threads blocked on this mutex */
  28   mthread_thread_t mm_owner;    /* Thread ID that currently owns mutex */
  29 #ifdef MTHREAD_STRICT
  30   struct __mthread_mutex *mm_prev;
  31   struct __mthread_mutex *mm_next;
  32 #endif
  33   unsigned int mm_magic;
  34 };
  35 typedef struct __mthread_mutex *mthread_mutex_t;
  36
  37 struct __mthread_cond {
  38   struct __mthread_mutex *mc_mutex;     /* Associate mutex with condition */
  39 #ifdef MTHREAD_STRICT
  40   struct __mthread_cond *mc_prev;
  41   struct __mthread_cond *mc_next;
  42 #endif
  43   unsigned int mc_magic;
  44 };
  45 typedef struct __mthread_cond *mthread_cond_t;
  46
  47 struct __mthread_attr {
  48   size_t ma_stacksize;
  49   char *ma_stackaddr;
  50   int ma_detachstate;
  51   struct __mthread_attr *ma_prev;
  52   struct __mthread_attr *ma_next;
  53 };
  54 typedef struct __mthread_attr *mthread_attr_t;
  55
  56 typedef struct {
  57   mthread_mutex_t mutex;
  58   mthread_cond_t cond;
  59 } mthread_event_t;
  60
  61 typedef struct {
  62   unsigned int readers;
  63   mthread_thread_t writer;
  64   mthread_mutex_t queue;
  65   mthread_event_t drain;
  66 } mthread_rwlock_t;
  67
  68 #define MTHREAD_CREATE_JOINABLE 001
  69 #define MTHREAD_CREATE_DETACHED 002
  70 #define MTHREAD_ONCE_INIT 0
  71 #define MTHREAD_STACK_MIN MINSIGSTKSZ
  72 #define MTHREAD_KEYS_MAX 128
  73
  74 /* allocate.c */
  75 int mthread_create(mthread_thread_t *thread, mthread_attr_t *tattr, void
  76         *(*proc)(void *), void *arg);
  77 int mthread_detach(mthread_thread_t thread);
  78 int mthread_equal(mthread_thread_t l, mthread_thread_t r);
  79 void mthread_exit(void *value);
  80 int mthread_join(mthread_thread_t thread, void **value);
  81 int mthread_once(mthread_once_t *once, void (*proc)(void));
  82 mthread_thread_t mthread_self(void);
  83
  84 /* attribute.c */
  85 int mthread_attr_destroy(mthread_attr_t *tattr);
  86 int mthread_attr_getdetachstate(mthread_attr_t *tattr, int
  87         *detachstate);
  88 int mthread_attr_getstack(mthread_attr_t *tattr, void **stackaddr,
  89         size_t *stacksize);
  90 int mthread_attr_getstacksize(mthread_attr_t *tattr, size_t *stacksize);
  91 int mthread_attr_init(mthread_attr_t *tattr);
  92 int mthread_attr_setdetachstate(mthread_attr_t *tattr, int detachstate);
  93 int mthread_attr_setstack(mthread_attr_t *tattr, void *stackaddr, size_t
  94         stacksize);
  95 int mthread_attr_setstacksize(mthread_attr_t *tattr, size_t stacksize);
  96
  97
  98 /* condition.c */
  99 int mthread_cond_broadcast(mthread_cond_t *cond);
 100 int mthread_cond_destroy(mthread_cond_t *cond);
 101 int mthread_cond_init(mthread_cond_t *cond, mthread_condattr_t *cattr);
 102 int mthread_cond_signal(mthread_cond_t *cond);
 103 int mthread_cond_wait(mthread_cond_t *cond, mthread_mutex_t *mutex);
 104
 105 /* key.c */
 106 int mthread_key_create(mthread_key_t *key, void (*destructor)(void *));
 107 int mthread_key_delete(mthread_key_t key);
 108 void *mthread_getspecific(mthread_key_t key);
 109 int mthread_setspecific(mthread_key_t key, void *value);
 110
 111 /* misc.c */
 112 void mthread_stats(void);
 113 void mthread_verify_f(char *f, int l);
 114 #define mthread_verify() mthread_verify_f(__FILE__, __LINE__)
 115 void mthread_stacktrace(mthread_thread_t t);
 116 void mthread_stacktraces(void);
 117
 118 /* mutex.c */
 119 int mthread_mutex_destroy(mthread_mutex_t *mutex);
 120 int mthread_mutex_init(mthread_mutex_t *mutex, mthread_mutexattr_t
 121         *mattr);
 122 int mthread_mutex_lock(mthread_mutex_t *mutex);
 123 int mthread_mutex_trylock(mthread_mutex_t *mutex);
 124 int mthread_mutex_unlock(mthread_mutex_t *mutex);
 125
 126 /* event.c */
 127 int mthread_event_destroy(mthread_event_t *event);
 128 int mthread_event_init(mthread_event_t *event);
 129 int mthread_event_wait(mthread_event_t *event);
 130 int mthread_event_fire(mthread_event_t *event);
 131 int mthread_event_fire_all(mthread_event_t *event);
 132
 133 /* rwlock.c */
 134 int mthread_rwlock_destroy(mthread_rwlock_t *rwlock);
 135 int mthread_rwlock_init(mthread_rwlock_t *rwlock);
 136 int mthread_rwlock_rdlock(mthread_rwlock_t *rwlock);
 137 int mthread_rwlock_wrlock(mthread_rwlock_t *rwlock);
 138 int mthread_rwlock_unlock(mthread_rwlock_t *rwlock);
 139
 140 /* schedule.c */
 141 void mthread_init(void);
 142 int mthread_yield(void);
 143 void mthread_yield_all(void);
 144
 145 #endif