pthread_internals.h [plain text]
#ifndef _POSIX_PTHREAD_INTERNALS_H
#define _POSIX_PTHREAD_INTERNALS_H
#include <assert.h>
#include <mach/port.h>
#include <mach/mach_error.h>
#include <mach/message.h>
#include <mach/machine/vm_types.h>
#include <mach/std_types.h>
#include <mach/policy.h>
#include <mach/sync.h>
#include <mach/sync_policy.h>
#include <mach/mach_traps.h>
#include <mach/thread_switch.h>
#include <mach/mach_host.h>
#include <mach/mach.h>
#ifndef __POSIX_LIB__
#define __POSIX_LIB__
#endif
#include "posix_sched.h"
#include "pthread_machdep.h"
extern kern_return_t syscall_thread_switch(mach_port_name_t, int, mach_msg_timeout_t);
#undef _POSIX_THREAD_KEYS_MAX
#define _POSIX_THREAD_KEYS_MAX 128
typedef struct _pthread
{
long sig;
struct _pthread_handler_rec *cleanup_stack;
pthread_lock_t lock;
int detached;
int inherit;
int policy;
struct sched_param param;
struct _pthread_mutex *mutexes;
struct _pthread *joiner;
int pad1;
void *exit_value;
semaphore_t death;
mach_port_t kernel_thread;
void *(*fun)(void*);
void *arg;
int cancel_state;
int err_no;
void *tsd[_POSIX_THREAD_KEYS_MAX];
void *stackaddr;
size_t stacksize;
mach_port_t reply_port;
void *cthread_self;
boolean_t freeStackOnExit;
} *pthread_t;
typedef struct
{
long sig;
pthread_lock_t lock;
int detached;
int inherit;
int policy;
struct sched_param param;
void *stackaddr;
size_t stacksize;
boolean_t freeStackOnExit;
} pthread_attr_t;
typedef struct
{
long sig;
int prioceiling;
u_int32_t protocol:2,
type:2,
rfu:28;
} pthread_mutexattr_t;
typedef struct _pthread_mutex
{
long sig;
pthread_lock_t lock;
int waiters:30,
def:1,
cond_lock:1;
pthread_t owner;
mach_port_t sem;
u_int32_t protocol:2,
type:2,
rfu:12,
lock_count:16;
struct _pthread_mutex *next, *prev;
struct _pthread_cond *busy;
int prioceiling;
int priority;
} pthread_mutex_t;
typedef struct
{
long sig;
int unsupported;
} pthread_condattr_t;
typedef struct _pthread_cond
{
long sig;
pthread_lock_t lock;
mach_port_t sem;
struct _pthread_cond *next, *prev;
struct _pthread_mutex *busy;
int waiters:16,
sigspending:16;
} pthread_cond_t;
typedef struct
{
long sig;
pthread_lock_t lock;
} pthread_once_t;
typedef struct {
long sig;
int pshared;
int rfu[2];
} pthread_rwlockattr_t;
typedef struct {
long sig;
pthread_mutex_t lock;
int state;
pthread_cond_t read_signal;
pthread_cond_t write_signal;
int blocked_writers;
int pshared;
int rfu[3];
} pthread_rwlock_t;
#include "pthread.h"
#define _PTHREAD_DEFAULT_INHERITSCHED PTHREAD_INHERIT_SCHED
#define _PTHREAD_DEFAULT_PROTOCOL PTHREAD_PRIO_NONE
#define _PTHREAD_DEFAULT_PRIOCEILING 0
#define _PTHREAD_DEFAULT_POLICY SCHED_OTHER
#define _PTHREAD_DEFAULT_STACKSIZE 0x80000
#define _PTHREAD_NO_SIG 0x00000000
#define _PTHREAD_MUTEX_ATTR_SIG 0x4D545841
#define _PTHREAD_MUTEX_SIG 0x4D555458
#define _PTHREAD_MUTEX_SIG_init 0x32AAABA7
#define _PTHREAD_COND_ATTR_SIG 0x434E4441
#define _PTHREAD_COND_SIG 0x434F4E44
#define _PTHREAD_COND_SIG_init 0x3CB0B1BB
#define _PTHREAD_ATTR_SIG 0x54484441
#define _PTHREAD_ONCE_SIG 0x4F4E4345
#define _PTHREAD_ONCE_SIG_init 0x30B1BCBA
#define _PTHREAD_SIG 0x54485244
#define _PTHREAD_RWLOCK_ATTR_SIG 0x52574C41
#define _PTHREAD_RWLOCK_SIG 0x52574C4B
#define _PTHREAD_RWLOCK_SIG_init 0x2DA8B3B4
#define _PTHREAD_CREATE_PARENT 4
#define _PTHREAD_EXITED 8
#define _PTHREAD_CANCEL_STATE_MASK 0xFE
#define _PTHREAD_CANCEL_TYPE_MASK 0xFD
#define _PTHREAD_CANCEL_PENDING 0x10
extern boolean_t swtch_pri(int);
#define MP_SPIN_TRIES 1000
extern int _spin_tries;
extern int __is_threaded;
extern int _cpu_has_altivec;
#define TRY_LOCK(v) (!__is_threaded || _spin_lock_try((pthread_lock_t *)&(v)))
#define LOCK(v) \
do { \
if (__is_threaded) { \
int tries = _spin_tries; \
\
while (!_spin_lock_try((pthread_lock_t *)&(v))) { \
if (tries-- > 0) \
continue; \
\
syscall_thread_switch(THREAD_NULL, SWITCH_OPTION_DEPRESS, 1); \
tries = _spin_tries; \
} \
} \
} while (0)
#define UNLOCK(v) \
do { \
if (__is_threaded) \
_spin_unlock((pthread_lock_t *)&(v)); \
} while (0)
#ifndef ESUCCESS
#define ESUCCESS 0
#endif
#ifndef PTHREAD_MACH_CALL
#define PTHREAD_MACH_CALL(expr, ret) (ret) = (expr)
#endif
extern vm_address_t _sp(void);
extern vm_address_t _adjust_sp(vm_address_t sp);
extern void _spin_lock(pthread_lock_t *lockp);
extern int _spin_lock_try(pthread_lock_t *lockp);
extern void _spin_unlock(pthread_lock_t *lockp);
extern void _pthread_setup(pthread_t th, void (*f)(pthread_t), void *sp, int suspended, int needresume);
extern void _pthread_tsd_cleanup(pthread_t self);
__private_extern__ semaphore_t new_sem_from_pool(void);
__private_extern__ void restore_sem_to_pool(semaphore_t);
#endif