blob: f13267454cefd7813b089209acdb3b66e8d0a567 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
/*
* implement.h
*
* Implementation specific (non API) stuff.
*/
#ifndef _IMPLEMENT_H
#define _IMPLEMENT_H
#define _PTHREAD_HASH_INDEX(x) (((ULONG) x) % PTHREAD_THREADS_MAX)
enum {
_PTHREAD_NEW,
_PTHREAD_INUSE,
_PTHREAD_EXITED,
_PTHREAD_REUSE
};
#define _PTHREAD_VALID(T) \
((T) != NULL \
&& ((T)->ptstatus == _PTHREAD_NEW \
|| (T)->ptstatus == _PTHREAD_INUSE))
/* Handler execution flags. */
#define _PTHREAD_HANDLER_NOEXECUTE 0
#define _PTHREAD_HANDLER_EXECUTE 1
/* Special value to mark attribute objects as valid. */
#define _PTHREAD_ATTR_VALID 0xC0FFEE
/* General description of a handler function on a stack. */
typedef struct _pthread_handler_node _pthread_handler_node_t;
struct _pthread_handler_node {
_pthread_handler_node_t * next;
void (* routine)(void *);
void * arg;
};
/* Stores a thread call routine and argument. */
typedef struct {
unsigned (*routine)(void *);
void * arg;
} _pthread_call_t;
/* Macro to compute the address of a given handler stack. */
#define _PTHREAD_STACK(stack) \
((_pthread_handler_node_t *) &(pthread_self())->cleanupstack + stack);
/* Macro to compute the table index of a thread entry from it's entry
address. */
#define _PTHREAD_THREADS_TABLE_INDEX(this) \
((_pthread_threads_table_t *) this - \
(_pthread_threads_table_t *) _pthread_threads_threads_table)
/* Macro to compute the address of a per-thread mutex lock. */
#define _PTHREAD_THREAD_MUTEX(this) \
(&_pthread_threads_mutex_table[_PTHREAD_THREADS_TABLE_INDEX(this)])
/* An element in the thread table. */
typedef struct _pthread _pthread_t;
/* Keep the old typedef until we've updated all source files. */
typedef struct _pthread _pthread_threads_thread_t;
/* Related constants */
struct _pthread {
HANDLE win32handle;
int ptstatus; /* _PTHREAD_EXITED
_PTHREAD_REUSABLE */
pthread_attr_t attr;
_pthread_call_t call;
int cancel_pending;
int cancelstate; /* PTHREAD_CANCEL_DISABLE
PTHREAD_CANCEL_ENABLE */
int canceltype; /* PTHREAD_CANCEL_ASYNCHRONOUS
PTHREAD_CANCEL_DEFERRED */
void ** joinvalueptr;
int join_count;
/* These must be kept in this order and together. */
_pthread_handler_node_t * cleanupstack;
_pthread_handler_node_t * destructorstack;
_pthread_handler_node_t * forkpreparestack;
_pthread_handler_node_t * forkparentstack;
_pthread_handler_node_t * forkchildstack;
};
#ifdef __cplusplus
extern "C" {
#endif /* __cplusplus */
/* Generic handler push and pop routines. */
int _pthread_handler_push(int stack,
int poporder,
void (*routine)(void *),
void *arg);
void _pthread_handler_pop(int stack,
int execute);
void _pthread_handler_pop_all(int stack,
int execute);
int _pthread_destructor_push(void (*routine)(void *),
pthread_key_t key);
void _pthread_destructor_pop_all();
/* Primitives to manage threads table entries. */
int _pthread_new_thread(pthread_t * thread);
int _pthread_delete_thread(pthread_t thread);
/* Thread cleanup. */
void _pthread_vacuum(void);
void _pthread_exit(pthread_t thread, void * value, int return_code);
#ifdef __cplusplus
}
#endif /* __cplusplus */
/* Global declared dll.c */
extern DWORD _pthread_threadID_TlsIndex;
/* Global data declared in global.c */
extern pthread_mutex_t _pthread_table_mutex;
extern DWORD _pthread_threads_count;
extern _pthread_t * _pthread_virgins;
extern int _pthread_virgin_next;
extern pthread_t * _pthread_reuse;
extern int _pthread_reuse_top;
extern pthread_t * _pthread_win32handle_map;
/* Per thread mutex locks. */
extern pthread_mutex_t * _pthread_threads_mutex_table;
#endif /* _IMPLEMENT_H */
|
