[95ec05]: implement.h Maximize Restore History

Download this file

implement.h    375 lines (310 with data), 10.6 kB

  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
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
/*
* implement.h
*
* Definitions that don't need to be public.
*
* Keeps all the internals out of pthread.h
*
* Pthreads-win32 - POSIX Threads Library for Win32
* Copyright (C) 1998
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Library General Public License for more details.
*
* You should have received a copy of the GNU Library General Public
* License along with this library; if not, write to the Free
* Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
* MA 02111-1307, USA
*/
#ifndef _IMPLEMENT_H
#define _IMPLEMENT_H
/* changed include from <semaphore.h> to use local file during development */
#include "semaphore.h"
typedef enum {
/*
* This enumeration represents the state of the thread;
* The thread is still "alive" if the numeric value of the
* state is greater or equal "PThreadStateRunning".
*/
PThreadStateInitial = 0, /* Thread not running */
PThreadStateRunning, /* Thread alive & kicking */
PThreadStateSuspended, /* Thread alive but suspended */
PThreadStateCanceling, /* Thread alive but and is */
/* in the process of terminating */
/* due to a cancellation request */
PThreadStateException, /* Thread alive but exiting */
/* due to an exception */
PThreadStateLast
}
PThreadState;
typedef enum {
/*
* This enumeration represents the reason why a thread has
* terminated/is terminating.
*/
PThreadDemisePeaceful = 0, /* Death due natural causes */
PThreadDemiseCancelled, /* Death due to user cancel */
PThreadDemiseException, /* Death due to unhandled */
/* exception */
PThreadDemiseNotDead /* I'm not dead! */
}
PThreadDemise;
struct pthread_t_ {
DWORD thread;
HANDLE threadH;
PThreadState state;
PThreadDemise demise;
void *exitStatus;
void *parms;
int ptErrno;
int detachState;
int cancelState;
int cancelType;
HANDLE cancelEvent;
#if HAVE_SIGSET_T
sigset_t sigmask;
#endif /* HAVE_SIGSET_T */
int implicit:1;
void *keys;
};
/*
* Special value to mark attribute objects as valid.
*/
#define _PTHREAD_ATTR_VALID ((unsigned long) 0xC4C0FFEE)
struct pthread_attr_t_ {
unsigned long valid;
void *stackaddr;
size_t stacksize;
int detachstate;
int priority;
#if HAVE_SIGSET_T
sigset_t sigmask;
#endif /* HAVE_SIGSET_T */
};
/*
* ====================
* ====================
* Mutexes and Condition Variables
* ====================
* ====================
*/
#define _PTHREAD_OBJECT_AUTO_INIT ((void *) -1)
#define _PTHREAD_OBJECT_INVALID NULL
struct pthread_mutex_t_ {
HANDLE mutex;
CRITICAL_SECTION cs;
};
struct pthread_mutexattr_t_ {
int pshared;
int forcecs;
};
struct pthread_key_t_ {
DWORD key;
void (*destructor) (void *);
pthread_mutex_t threadsLock;
void *threads;
};
typedef struct ThreadParms ThreadParms;
typedef struct ThreadKeyAssoc ThreadKeyAssoc;
struct ThreadParms {
pthread_t tid;
void *(*start) (void *);
void *arg;
};
struct pthread_cond_t_ {
long waiters; /* # waiting threads */
pthread_mutex_t waitersLock; /* Mutex that guards access to
waiter count */
sem_t sema; /* Queue up threads waiting for the
condition to become signaled */
HANDLE waitersDone; /* An auto reset event used by the
broadcast/signal thread to wait
for the waiting thread(s) to wake
up and get a chance at the
semaphore */
int wasBroadcast; /* keeps track if we are signaling
or broadcasting */
};
struct pthread_condattr_t_ {
int pshared;
};
struct ThreadKeyAssoc {
/*
* Purpose:
* This structure creates an association between a
* thread and a key.
* It is used to implement the implicit invocation
* of a user defined destroy routine for thread
* specific data registered by a user upon exiting a
* thread.
*
* Attributes:
* lock
* protects access to the rest of the structure
*
* thread
* reference to the thread that owns the association.
* As long as this is not NULL, the association remains
* referenced by the pthread_t.
*
* key
* reference to the key that owns the association.
* As long as this is not NULL, the association remains
* referenced by the pthread_key_t.
*
* nextKey
* The pthread_t->keys attribute is the head of a
* chain of associations that runs through the nextKey
* link. This chain provides the 1 to many relationship
* between a pthread_t and all pthread_key_t on which
* it called pthread_setspecific.
*
* nextThread
* The pthread_key_t->threads attribute is the head of
* a chain of assoctiations that runs through the
* nextThreads link. This chain provides the 1 to many
* relationship between a pthread_key_t and all the
* PThreads that have called pthread_setspecific for
* this pthread_key_t.
*
*
* Notes:
* 1) As long as one of the attributes, thread or key, is
* not NULL, the association is being referenced; once
* both are NULL, the association must be released.
*
* 2) Under WIN32, an association is only created by
* pthread_setspecific if the user provided a
* destroyRoutine when they created the key.
*
*
*/
pthread_mutex_t lock;
pthread_t thread;
pthread_key_t key;
ThreadKeyAssoc *nextKey;
ThreadKeyAssoc *nextThread;
};
#ifdef _MSC_VER
/*
* --------------------------------------------------------------
* MAKE_SOFTWARE_EXCEPTION
* This macro constructs a software exception code following
* the same format as the standard Win32 error codes as defined
* in WINERROR.H
* Values are 32 bit values layed out as follows:
*
* 1 0 9 8 7 6 5 4 3 2 1 0 9 8 7 6 5 4 3 2 1 0 9 8 7 6 5 4 3 2 1 0
* +---+-+-+-----------------------+-------------------------------+
* |Sev|C|R| Facility | Code |
* +---+-+-+-----------------------+-------------------------------+
*
* Severity Values:
*/
#define SE_SUCCESS 0x00
#define SE_INFORMATION 0x01
#define SE_WARNING 0x02
#define SE_ERROR 0x03
#define MAKE_SOFTWARE_EXCEPTION( _severity, _facility, _exception ) \
( (DWORD) ( ( (_severity) << 30 ) | /* Severity code */ \
( 1 << 29 ) | /* MS=0, User=1 */ \
( 0 << 28 ) | /* Reserved */ \
( (_facility) << 16 ) | /* Facility Code */ \
( (_exception) << 0 ) /* Exception Code */ \
) )
/*
* We choose one specific Facility/Error code combination to
* identify our software exceptions vs. WIN32 exceptions.
* We store our actual component and error code within
* the optional information array.
*/
#define EXCEPTION_PTHREAD_SERVICES \
MAKE_SOFTWARE_EXCEPTION( SE_ERROR, \
PTHREAD_SERVICES_FACILITY, \
PTHREAD_SERVICES_ERROR )
#define PTHREAD_SERVICES_FACILITY 0xBAD
#define PTHREAD_SERVICES_ERROR 0xDEED
#else
#ifdef __cplusplus
class Pthread_exception {};
#else /* __cplusplus */
#warning File __FILE__, Line __LINE__: Cancellation not supported under C.
#endif /* __cplusplus */
#endif /* _MSC_VER */
/* Function pointer to TryEnterCriticalSection if it exists; otherwise NULL */
extern BOOL (WINAPI *_pthread_try_enter_critical_section)(LPCRITICAL_SECTION);
/* Declared in global.c */
extern int _pthread_processInitialized;
extern pthread_key_t _pthread_selfThreadKey;
extern pthread_key_t _pthread_cleanupKey;
extern CRITICAL_SECTION _pthread_mutex_test_init_lock;
extern CRITICAL_SECTION _pthread_cond_test_init_lock;
/* Declared in misc.c */
#ifdef NEED_CALLOC
#define calloc(n, s) _pthread_calloc(n, s)
void *_pthread_calloc(size_t n, size_t s);
#endif
#ifdef __cplusplus
extern "C" {
#endif /* __cplusplus */
/*
* =====================
* =====================
* Forward Declarations
* =====================
* =====================
*/
int _pthread_processInitialize (void);
void _pthread_processTerminate (void);
void _pthread_threadDestroy (pthread_t tid);
void _pthread_cleanupStack (void);
void *_pthread_threadStart (ThreadParms * threadParms);
void _pthread_callUserDestroyRoutines (pthread_t thread);
int _pthread_tkAssocCreate (ThreadKeyAssoc ** assocP,
pthread_t thread,
pthread_key_t key);
void _pthread_tkAssocDestroy (ThreadKeyAssoc * assoc);
int _pthread_sem_timedwait (sem_t * sem,
const struct timespec * abstime);
#ifdef NEED_SEM
void _pthread_decrease_semaphore(sem_t * sem);
BOOL _pthread_increase_semaphore(sem_t * sem,
unsigned int n);
#endif /* NEED_SEM */
#ifdef __cplusplus
}
#endif /* __cplusplus */
/*
* Check for old and new versions of cygwin. See the FAQ file:
*
* Question 1 - How do I get pthreads-win32 to link under Cygwin or Mingw32?
*
* Patch by Anders Norlander <anorland@hem2.passagen.se>
*/
#if defined(__CYGWIN32__) || defined(__CYGWIN__) || defined(_PTHREAD_CREATETHREAD)
/*
* Macro uses args so we can cast start_proc to LPTHREAD_START_ROUTINE
* in order to avoid warnings because of return type
*/
#define _beginthreadex(security, \
stack_size, \
start_proc, \
arg, \
flags, \
pid) \
CreateThread(security, \
stack_size, \
(LPTHREAD_START_ROUTINE) start_proc, \
arg, \
flags, \
pid)
#define _endthreadex ExitThread
#endif /* __CYGWIN32__ || __CYGWIN__ */
#endif /* _IMPLEMENT_H */