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
|
/* $OpenBSD: rf_threadid.h,v 1.1 1999/01/11 14:29:53 niklas Exp $ */
/* $NetBSD: rf_threadid.h,v 1.1 1998/11/13 04:20:35 oster Exp $ */
/*
* Copyright (c) 1995 Carnegie-Mellon University.
* All rights reserved.
*
* Author: Daniel Stodolsky, Mark Holland
*
* Permission to use, copy, modify and distribute this software and
* its documentation is hereby granted, provided that both the copyright
* notice and this permission notice appear in all copies of the
* software, derivative works or modified versions, and any portions
* thereof, and that both notices appear in supporting documentation.
*
* CARNEGIE MELLON ALLOWS FREE USE OF THIS SOFTWARE IN ITS "AS IS"
* CONDITION. CARNEGIE MELLON DISCLAIMS ANY LIABILITY OF ANY KIND
* FOR ANY DAMAGES WHATSOEVER RESULTING FROM THE USE OF THIS SOFTWARE.
*
* Carnegie Mellon requests users of this software to return to
*
* Software Distribution Coordinator or Software.Distribution@CS.CMU.EDU
* School of Computer Science
* Carnegie Mellon University
* Pittsburgh PA 15213-3890
*
* any improvements or extensions that they make and grant Carnegie the
* rights to redistribute these changes.
*/
/* rf_threadid.h
*
* simple macros to register and lookup integer identifiers for threads.
* must include pthread.h before including this
*
* This is one of two places where the pthreads package is used explicitly.
* The other is in threadstuff.h
*
* none of this is used in the kernel, so it all gets compiled out if KERNEL is defined
*/
/* :
* Log: rf_threadid.h,v
* Revision 1.17 1996/08/12 20:11:17 jimz
* fix up for AIX4
*
* Revision 1.16 1996/06/05 18:06:02 jimz
* Major code cleanup. The Great Renaming is now done.
* Better modularity. Better typing. Fixed a bunch of
* synchronization bugs. Made a lot of global stuff
* per-desc or per-array. Removed dead code.
*
* Revision 1.15 1996/06/03 23:28:26 jimz
* more bugfixes
* check in tree to sync for IPDS runs with current bugfixes
* there still may be a problem with threads in the script test
* getting I/Os stuck- not trivially reproducible (runs ~50 times
* in a row without getting stuck)
*
* Revision 1.14 1996/05/30 11:29:41 jimz
* Numerous bug fixes. Stripe lock release code disagreed with the taking code
* about when stripes should be locked (I made it consistent: no parity, no lock)
* There was a lot of extra serialization of I/Os which I've removed- a lot of
* it was to calculate values for the cache code, which is no longer with us.
* More types, function, macro cleanup. Added code to properly quiesce the array
* on shutdown. Made a lot of stuff array-specific which was (bogusly) general
* before. Fixed memory allocation, freeing bugs.
*
* Revision 1.13 1996/05/24 22:17:04 jimz
* continue code + namespace cleanup
* typed a bunch of flags
*
* Revision 1.12 1996/05/23 21:46:35 jimz
* checkpoint in code cleanup (release prep)
* lots of types, function names have been fixed
*
* Revision 1.11 1996/05/20 16:13:46 jimz
* switch to rf_{mutex,cond}_{init,destroy}
*
* Revision 1.10 1996/05/18 19:51:34 jimz
* major code cleanup- fix syntax, make some types consistent,
* add prototypes, clean out dead code, et cetera
*
* Revision 1.9 1996/05/17 13:29:06 jimz
* did a dance on get_threadid such that it will do the pthread_attr_t -> int
* assignment without warnings, even on really anal compilers
*
* Revision 1.8 1995/12/06 15:15:00 root
* added copyright info
*
*/
#ifndef _RF__RF_THREADID_H_
#define _RF__RF_THREADID_H_
#ifdef _KERNEL
#define KERNEL
#endif
#ifndef SIMULATE
#ifndef KERNEL
/*
* User
*/
#include "rf_threadstuff.h"
extern int rf_numThrsRegistered;
extern pthread_key_t rf_thread_id_key;
RF_DECLARE_EXTERN_MUTEX(rf_threadid_mutex)
#define RF_THREAD_MAX 200
/* these should be global since a function is declared. Should be invoked at only one place in code */
#define RF_DECLARE_GLOBAL_THREADID \
int rf_numThrsRegistered = 0; \
pthread_key_t rf_thread_id_key; \
RF_DECLARE_MUTEX(rf_threadid_mutex) \
RF_Thread_t rf_regdThrs[RF_THREAD_MAX]; \
void rf_ThreadIdEmptyFunc() {}
/* setup must be called exactly once, i.e. it can't be called by each thread */
#ifdef AIX
typedef void (*pthread_destructor_t)(void *);
#endif /* AIX */
#ifdef __osf__
#define rf_setup_threadid() { \
extern void rf_ThreadIdEmptyFunc(); \
pthread_keycreate(&rf_thread_id_key, (pthread_destructor_t) rf_ThreadIdEmptyFunc); \
rf_mutex_init(&rf_threadid_mutex); /* XXX check return val */ \
rf_numThrsRegistered = 0; \
}
#endif /* __osf__ */
#ifdef AIX
#define rf_setup_threadid() { \
extern void rf_ThreadIdEmptyFunc(); \
pthread_key_create(&rf_thread_id_key, (pthread_destructor_t) rf_ThreadIdEmptyFunc); \
rf_mutex_init(&rf_threadid_mutex); /* XXX check return val */ \
rf_numThrsRegistered = 0; \
}
#endif /* AIX */
#define rf_shutdown_threadid() { \
rf_mutex_destroy(&rf_threadid_mutex); \
}
#ifdef __osf__
typedef pthread_addr_t RF_THID_cast_t;
#endif /* __osf__ */
#ifdef AIX
typedef void *RF_THID_cast_t;
#endif /* AIX */
#define rf_assign_threadid() {RF_LOCK_MUTEX(rf_threadid_mutex); \
if (pthread_setspecific(rf_thread_id_key, (RF_THID_cast_t) ((unsigned long)(rf_numThrsRegistered++)))) { RF_PANIC(); } \
RF_UNLOCK_MUTEX(rf_threadid_mutex);}
#ifdef __osf__
#define rf_get_threadid(_id_) { \
RF_THID_cast_t _val; \
unsigned long _val2; \
if (pthread_getspecific(rf_thread_id_key, &_val)) \
RF_PANIC(); \
(_val2) = (unsigned long)_val; \
(_id_) = (int)_val2; \
}
#endif /* __osf__ */
#ifdef AIX
#define rf_get_threadid(_id_) { \
RF_THID_cast_t _val; \
unsigned long _val2; \
_val = pthread_getspecific(rf_thread_id_key); \
(_val2) = (unsigned long)_val; \
(_id_) = (int)_val2; \
}
#endif /* AIX */
#else /* KERNEL */
/*
* Kernel
*/
#if !defined(__NetBSD__) && !defined(__OpenBSD__)
#include <kern/task.h>
#include <kern/thread.h>
#include <mach/machine/vm_param.h>
#endif
#define RF_DECLARE_GLOBAL_THREADID
#define rf_setup_threadid()
#define rf_shutdown_threadid()
#define rf_assign_threadid()
#if defined(__NetBSD__) || defined(__OpenBSD__)
#define rf_get_threadid(_id_) _id_ = 0;
#else
#define rf_get_threadid(_id_) { \
thread_t thread = current_thread(); \
_id_ = (int)(((thread->thread_self)>>(8*sizeof(int *)))&0x0fffffff); \
}
#endif /* __NetBSD__ || __OpenBSD__ */
#endif /* KERNEL */
#else /* SIMULATE */
/*
* Simulator
*/
#include "rf_diskevent.h"
#define RF_DECLARE_GLOBAL_THREADID
#define rf_setup_threadid()
#define rf_shutdown_threadid()
#define rf_assign_threadid()
#define rf_get_threadid(_id_) _id_ = rf_GetCurrentOwner()
#endif /* SIMULATE */
#endif /* !_RF__RF_THREADID_H_ */
|
