Mercurial > cgi-bin > hgwebdir.cgi > VMS > VMS_Implementations > Vthread_impls > Vthread_MC_shared_impl

view VPThread.h @ 6:ce4ad44fcc23

find changesets by author, revision, files, or words in the commit message
make hardware independent and port to 64bit
author Merten Sach <msach@mailbox.tu-berlin.de>
date Thu, 16 Jun 2011 14:39:38 +0200
parents 505d3c674ce8
children bbcb6fadb60f f593241c2db9
line source
1 /*
2 * Copyright 2009 OpenSourceStewardshipFoundation.org
3 * Licensed under GNU General Public License version 2
4 *
5 * Author: seanhalle@yahoo.com
6 *
7 */
8
9 #ifndef _VPThread_H
10 #define _VPThread_H
11
12 #include "VMS/VMS.h"
13 #include "VMS/Queue_impl/PrivateQueue.h"
14 #include "VMS/DynArray/DynArray.h"
15
16
17 /*This header defines everything specific to the VPThread semantic plug-in
18 */
19
20
21 //===========================================================================
22 #define INIT_NUM_MUTEX 10000
23 #define INIT_NUM_COND 10000
24
25 #define NUM_STRUCS_IN_SEM_ENV 1000
26 //===========================================================================
27
28 //===========================================================================
29 typedef struct _VPThreadSemReq VPThdSemReq;
30 typedef void (*PtrToAtomicFn ) ( void * ); //executed atomically in master
31 //===========================================================================
32
33
34 /*WARNING: assembly hard-codes position of endInstrAddr as first field
35 */
36 typedef struct
37 {
38 void *endInstrAddr;
39 int32 hasBeenStarted;
40 int32 hasFinished;
41 PrivQueueStruc *waitQ;
42 }
43 VPThdSingleton;
44
45 /*Semantic layer-specific data sent inside a request from lib called in app
46 * to request handler called in MasterLoop
47 */
48 enum VPThreadReqType
49 {
50 make_mutex = 1,
51 mutex_lock,
52 mutex_unlock,
53 make_cond,
54 cond_wait,
55 cond_signal,
56 make_procr,
57 malloc_req,
58 free_req,
59 singleton_fn_start,
60 singleton_fn_end,
61 singleton_data_start,
62 singleton_data_end,
63 atomic,
64 trans_start,
65 trans_end
66 };
67
68 struct _VPThreadSemReq
69 { enum VPThreadReqType reqType;
70 VirtProcr *requestingPr;
71 int32 mutexIdx;
72 int32 condIdx;
73
74 void *initData;
75 VirtProcrFnPtr fnPtr;
76 int32 coreToScheduleOnto;
77
78 size_t sizeToMalloc;
79 void *ptrToFree;
80
81 int32 singletonID;
82 VPThdSingleton **singletonPtrAddr;
83
84 PtrToAtomicFn fnToExecInMaster;
85 void *dataForFn;
86
87 int32 transID;
88 }
89 /* VPThreadSemReq */;
90
91
92 typedef struct
93 {
94 VirtProcr *VPCurrentlyExecuting;
95 PrivQueueStruc *waitingVPQ;
96 }
97 VPThdTrans;
98
99
100 typedef struct
101 {
102 int32 mutexIdx;
103 VirtProcr *holderOfLock;
104 PrivQueueStruc *waitingQueue;
105 }
106 VPThdMutex;
107
108
109 typedef struct
110 {
111 int32 condIdx;
112 PrivQueueStruc *waitingQueue;
113 VPThdMutex *partnerMutex;
114 }
115 VPThdCond;
116
117 typedef struct _TransListElem TransListElem;
118 struct _TransListElem
119 {
120 int32 transID;
121 TransListElem *nextTrans;
122 };
123 //TransListElem
124
125 typedef struct
126 {
127 int32 highestTransEntered;
128 TransListElem *lastTransEntered;
129 }
130 VPThdSemData;
131
132
133 typedef struct
134 {
135 //Standard stuff will be in most every semantic env
136 PrivQueueStruc **readyVPQs;
137 int32 numVirtPr;
138 int32 nextCoreToGetNewPr;
139 int32 primitiveStartTime;
140
141 //Specific to this semantic layer
142 VPThdMutex **mutexDynArray;
143 PrivDynArrayInfo *mutexDynArrayInfo;
144
145 VPThdCond **condDynArray;
146 PrivDynArrayInfo *condDynArrayInfo;
147
148 void *applicationGlobals;
149
150 //fix limit on num with dynArray
151 VPThdSingleton fnSingletons[NUM_STRUCS_IN_SEM_ENV];
152
153 VPThdTrans transactionStrucs[NUM_STRUCS_IN_SEM_ENV];
154 }
155 VPThdSemEnv;
156
157
158 //===========================================================================
159
160 inline void
161 VPThread__create_seed_procr_and_do_work( VirtProcrFnPtr fn, void *initData );
162
163 //=======================
164
165 inline VirtProcr *
166 VPThread__create_thread( VirtProcrFnPtr fnPtr, void *initData,
167 VirtProcr *creatingPr );
168
169 inline VirtProcr *
170 VPThread__create_thread_with_affinity( VirtProcrFnPtr fnPtr, void *initData,
171 VirtProcr *creatingPr, int32 coreToScheduleOnto );
172
173 inline void
174 VPThread__dissipate_thread( VirtProcr *procrToDissipate );
175
176 //=======================
177 inline void
178 VPThread__set_globals_to( void *globals );
179
180 inline void *
181 VPThread__give_globals();
182
183 //=======================
184 inline int32
185 VPThread__make_mutex( VirtProcr *animPr );
186
187 inline void
188 VPThread__mutex_lock( int32 mutexIdx, VirtProcr *acquiringPr );
189
190 inline void
191 VPThread__mutex_unlock( int32 mutexIdx, VirtProcr *releasingPr );
192
193
194 //=======================
195 inline int32
196 VPThread__make_cond( int32 ownedMutexIdx, VirtProcr *animPr);
197
198 inline void
199 VPThread__cond_wait( int32 condIdx, VirtProcr *waitingPr);
200
201 inline void *
202 VPThread__cond_signal( int32 condIdx, VirtProcr *signallingPr );
203
204
205 //=======================
206 void
207 VPThread__start_fn_singleton( int32 singletonID, VirtProcr *animPr );
208
209 void
210 VPThread__end_fn_singleton( int32 singletonID, VirtProcr *animPr );
211
212 void
213 VPThread__start_data_singleton( VPThdSingleton **singeltonAddr, VirtProcr *animPr );
214
215 void
216 VPThread__end_data_singleton( VPThdSingleton **singletonAddr, VirtProcr *animPr );
217
218 void
219 VPThread__animate_short_fn_in_isolation( PtrToAtomicFn ptrToFnToExecInMaster,
220 void *data, VirtProcr *animPr );
221
222 void
223 VPThread__start_transaction( int32 transactionID, VirtProcr *animPr );
224
225 void
226 VPThread__end_transaction( int32 transactionID, VirtProcr *animPr );
227
228
229
230 //========================= Internal use only =============================
231 inline void
232 VPThread__Request_Handler( VirtProcr *requestingPr, void *_semEnv );
233
234 inline VirtProcr *
235 VPThread__schedule_virt_procr( void *_semEnv, int coreNum );
236
237 //=======================
238 inline void
239 VPThread__free_semantic_request( VPThdSemReq *semReq );
240
241 //=======================
242
243 void *
244 VPThread__malloc( size_t sizeToMalloc, VirtProcr *animPr );
245
246 void
247 VPThread__init();
248
249 void
250 VPThread__cleanup_after_shutdown();
251
252 void inline
253 resume_procr( VirtProcr *procr, VPThdSemEnv *semEnv );
254
255 #endif /* _VPThread_H */
256