Mercurial > cgi-bin > hgwebdir.cgi > VMS > VMS_Implementations > VSs_impls > VSs__MC_shared_impl

annotate VSs.h @ 36:94911329b067

find changesets by author, revision, files, or words in the commit message
fix access after free in reqHdlr
author Nina Engelhardt <nengel@mailbox.tu-berlin.de>
date Mon, 15 Apr 2013 16:41:31 +0200
parents b787a5234406
children c8d4f6d3c7d3
rev   line source
seanhalle@0 1 /*
seanhalle@0 2 * Copyright 2009 OpenSourceStewardshipFoundation.org
seanhalle@0 3 * Licensed under GNU General Public License version 2
seanhalle@0 4 *
seanhalle@0 5 * Author: seanhalle@yahoo.com
seanhalle@0 6 *
seanhalle@0 7 */
seanhalle@0 8
seanhalle@2 9 #ifndef _VSs_H
seanhalle@2 10 #define _VSs_H
seanhalle@0 11
seanhalle@0 12 #include "Queue_impl/PrivateQueue.h"
seanhalle@0 13 #include "Hash_impl/PrivateHash.h"
seanhalle@0 14 #include "VMS_impl/VMS.h"
seanhalle@3 15 #include "Measurement/dependency.h"
seanhalle@0 16
nengel@33 17 void free_pointer_entry(void* ptrEntry);
nengel@18 18 /* Switch for Nexus support
nengel@18 19 * Note: nexus incompatible with holistic recording (constraints not accessible)
nengel@18 20 * But counter recording still functional, can build constraintless display
nengel@18 21 * with wallclock time
nengel@18 22 */
nengel@20 23 //#define EXTERNAL_SCHEDULER
nengel@20 24 //#define SIMULATE_EXTERNAL_SCHEDULER
seanhalle@0 25
seanhalle@0 26 //===========================================================================
seanhalle@0 27 #define NUM_STRUCS_IN_SEM_ENV 1000
seanhalle@0 28
nengel@22 29 #define MAX_TASKS_NUM 256
nengel@22 30
seanhalle@0 31 //This is hardware dependent -- it's the number of cycles of scheduling
seanhalle@0 32 // overhead -- if a work unit is fewer than this, it is better being
seanhalle@0 33 // combined sequentially with other work
seanhalle@2 34 //This value depends on both VMS overhead and VSs's plugin. At some point
seanhalle@2 35 // it will be derived by perf-counter measurements during init of VSs
seanhalle@0 36 #define MIN_WORK_UNIT_CYCLES 20000
seanhalle@0 37
seanhalle@0 38 //===========================================================================
seanhalle@2 39 /*This header defines everything specific to the VSs semantic plug-in
seanhalle@0 40 */
seanhalle@2 41 typedef struct _VSsSemReq VSsSemReq;
seanhalle@3 42 typedef void (*VSsTaskFnPtr ) ( void *, SlaveVP *);
seanhalle@2 43 typedef void (*PtrToAtomicFn ) ( void * ); //executed atomically in master
seanhalle@0 44 //===========================================================================
seanhalle@0 45
seanhalle@4 46 #define NONCTLD 0
seanhalle@4 47 #define IN 1 /*Trick -- READER same as IN*/
seanhalle@4 48 #define OUT 2 /*Trick -- WRITER same as OUT and INOUT*/
seanhalle@4 49 #define INOUT 2 /*Trick -- WRITER same as OUT and INOUT*/
seanhalle@2 50
seanhalle@4 51 #define READER 1 /*Trick -- READER same as IN*/
seanhalle@4 52 #define WRITER 2 /*Trick -- WRITER same as OUT and INOUT*/
seanhalle@1 53
seanhalle@8 54 #define IS_A_THREAD NULL
seanhalle@8 55 #define IS_ENDED NULL
seanhalle@8 56 #define SEED_SLV NULL
seanhalle@8 57
seanhalle@1 58 typedef struct
seanhalle@1 59 {
seanhalle@1 60 VSsTaskFnPtr fn;
seanhalle@2 61 int32 numTotalArgs;//the number of inputs to function
seanhalle@2 62 int32 numCtldArgs;//how many of args have dependencies
seanhalle@2 63 int32 *argTypes; //says reader, writer, or non-ctld
seanhalle@2 64 int32 *argSizes; //for detecting overlap
seanhalle@2 65 int32 sizeOfArgs; //for memcpy of args struct
seanhalle@1 66 }
seanhalle@1 67 VSsTaskType;
seanhalle@1 68
seanhalle@1 69
seanhalle@2 70 typedef struct
seanhalle@2 71 {
seanhalle@3 72 bool32 hasEnabledNonFinishedWriter;
seanhalle@3 73 int32 numEnabledNonDoneReaders;
seanhalle@3 74 PrivQueueStruc *waitersQ;
nengel@16 75 #ifdef HOLISTIC__TURN_ON_OBSERVE_UCC
nengel@17 76 Unit lastWriter;
nengel@17 77 ListOfArrays* readersSinceLastWriter;
nengel@16 78 #endif
seanhalle@3 79 }
seanhalle@3 80 VSsPointerEntry;
seanhalle@3 81
nengel@33 82 typedef struct {
nengel@33 83 void **args; //ctld args must come first, as ptrs
nengel@33 84 VSsTaskType *taskType;
nengel@33 85 int32 *taskID;
nengel@33 86 int32 numBlockingProp;
nengel@33 87 SlaveVP *slaveAssignedTo; //only valid before end task (thread)
nengel@33 88 VSsPointerEntry **ptrEntries;
nengel@33 89 void* parentTaskStub;
nengel@33 90 int32 numLiveChildTasks;
nengel@33 91 int32 numLiveChildThreads;
nengel@33 92 bool32 isWaitingForChildTasksToEnd;
nengel@33 93 bool32 isWaitingForChildThreadsToEnd;
nengel@33 94 bool32 isEnded;
nengel@33 95 int *argsMask;
nengel@33 96 #ifdef HOLISTIC__TURN_ON_OBSERVE_UCC
nengel@33 97 Unit parentUnit;
nengel@33 98 Unit firstOfTask;
nengel@33 99 #endif
nengel@33 100 }
seanhalle@6 101 VSsTaskStub;
nengel@5 102
seanhalle@2 103
seanhalle@2 104 typedef struct
seanhalle@2 105 {
seanhalle@2 106 VSsTaskStub *taskStub;
seanhalle@2 107 int32 argNum;
seanhalle@2 108 int32 isReader;
nengel@21 109 bool32 isSuspended;
seanhalle@2 110 }
seanhalle@2 111 VSsTaskStubCarrier;
seanhalle@2 112
seanhalle@2 113
seanhalle@0 114 /*Semantic layer-specific data sent inside a request from lib called in app
seanhalle@0 115 * to request handler called in AnimationMaster
seanhalle@0 116 */
seanhalle@0 117
seanhalle@0 118 typedef struct
seanhalle@0 119 {
seanhalle@0 120 SlaveVP *VPCurrentlyExecuting;
seanhalle@0 121 PrivQueueStruc *waitingVPQ;
seanhalle@0 122 }
seanhalle@2 123 VSsTrans;
seanhalle@0 124
seanhalle@0 125 /*WARNING: assembly hard-codes position of endInstrAddr as first field
seanhalle@0 126 */
seanhalle@0 127 typedef struct
seanhalle@0 128 {
seanhalle@0 129 void *endInstrAddr;
seanhalle@0 130 int32 hasBeenStarted;
seanhalle@0 131 int32 hasFinished;
seanhalle@0 132 PrivQueueStruc *waitQ;
nengel@17 133 #ifdef HOLISTIC__TURN_ON_OBSERVE_UCC
nengel@17 134 Unit executingUnit;
nengel@17 135 #endif
seanhalle@0 136 }
seanhalle@2 137 VSsSingleton;
seanhalle@0 138
nengel@21 139 typedef struct
nengel@21 140 {
nengel@21 141 int32 isOccupied;
nengel@21 142 PrivQueueStruc *waitQ;
nengel@21 143 #ifdef HOLISTIC__TURN_ON_OBSERVE_UCC
nengel@21 144 Unit previous;
nengel@21 145 #endif
nengel@21 146 }
nengel@21 147 VSsCritical;
nengel@21 148
seanhalle@2 149 enum VSsReqType
seanhalle@0 150 {
seanhalle@2 151 submit_task = 1,
seanhalle@2 152 end_task,
seanhalle@2 153 create_slave,
seanhalle@2 154 create_slave_w_aff,
seanhalle@2 155 dissipate_slave,
seanhalle@2 156 //===============================
seanhalle@4 157 send_type_to,
seanhalle@4 158 receive_type_to,
seanhalle@4 159 send_from_to,
seanhalle@4 160 receive_from_to,
seanhalle@4 161 //===============================
nengel@5 162 taskwait,
nengel@21 163 taskwait_on,
nengel@21 164 critical_start,
nengel@21 165 critical_end,
seanhalle@0 166 malloc_req,
seanhalle@0 167 free_req,
seanhalle@0 168 singleton_fn_start,
seanhalle@0 169 singleton_fn_end,
seanhalle@0 170 singleton_data_start,
seanhalle@0 171 singleton_data_end,
seanhalle@0 172 atomic,
seanhalle@0 173 trans_start,
seanhalle@0 174 trans_end
seanhalle@0 175 };
seanhalle@0 176
seanhalle@2 177 struct _VSsSemReq
seanhalle@2 178 { enum VSsReqType reqType;
seanhalle@2 179 SlaveVP *callingSlv;
seanhalle@2 180 VSsTaskType *taskType;
seanhalle@2 181 void *args;
seanhalle@2 182 VSsTaskStub *taskStub;
seanhalle@2 183
seanhalle@4 184 SlaveVP *senderSlv;
seanhalle@4 185 SlaveVP *receiverSlv;
seanhalle@4 186 int32 *senderID;
seanhalle@4 187 int32 *receiverID;
seanhalle@4 188 int32 msgType;
seanhalle@4 189 void *msg;
seanhalle@4 190 VSsSemReq *nextReqInHashEntry;
seanhalle@4 191 int32 *taskID;
seanhalle@4 192
seanhalle@2 193 TopLevelFnPtr fnPtr;
seanhalle@0 194 void *initData;
seanhalle@0 195 int32 coreToAssignOnto;
seanhalle@0 196
seanhalle@0 197 int32 sizeToMalloc;
seanhalle@0 198 void *ptrToFree;
seanhalle@0 199
seanhalle@0 200 int32 singletonID;
seanhalle@2 201 VSsSingleton **singletonPtrAddr;
seanhalle@0 202
seanhalle@0 203 PtrToAtomicFn fnToExecInMaster;
seanhalle@0 204 void *dataForFn;
seanhalle@0 205
seanhalle@0 206 int32 transID;
nengel@21 207 int32 criticalID;
seanhalle@0 208 }
seanhalle@2 209 /* VSsSemReq */;
seanhalle@0 210
seanhalle@0 211
seanhalle@0 212 typedef struct
seanhalle@0 213 {
seanhalle@9 214 PrivQueueStruc *slavesReadyToResumeQ; //Shared (slaves not pinned)
seanhalle@9 215 PrivQueueStruc *freeExtraTaskSlvQ; //Shared
seanhalle@9 216 PrivQueueStruc *taskReadyQ; //Shared (tasks not pinned)
seanhalle@10 217 SlaveVP *slotTaskSlvs[NUM_CORES][NUM_ANIM_SLOTS];
seanhalle@2 218 HashTable *argPtrHashTbl;
seanhalle@4 219 HashTable *commHashTbl;
seanhalle@8 220 int32 numLiveExtraTaskSlvs;
seanhalle@8 221 int32 numLiveThreadSlvs;
seanhalle@3 222 int32 nextCoreToGetNewSlv;
seanhalle@0 223 int32 primitiveStartTime;
seanhalle@0 224
seanhalle@0 225 //fix limit on num with dynArray
seanhalle@2 226 VSsSingleton fnSingletons[NUM_STRUCS_IN_SEM_ENV];
seanhalle@2 227 VSsTrans transactionStrucs[NUM_STRUCS_IN_SEM_ENV];
nengel@21 228 VSsCritical criticalSection[NUM_STRUCS_IN_SEM_ENV];
seanhalle@3 229
seanhalle@3 230 bool32 *coreIsDone;
seanhalle@3 231 int32 numCoresDone;
seanhalle@0 232
nengel@22 233 int numInFlightTasks;
nengel@22 234 PrivQueueStruc *deferredSubmitsQ;
nengel@22 235 int numDeferred;
nengel@22 236
seanhalle@0 237 #ifdef HOLISTIC__TURN_ON_OBSERVE_UCC
seanhalle@0 238 ListOfArrays* unitList;
seanhalle@0 239 ListOfArrays* ctlDependenciesList;
seanhalle@0 240 ListOfArrays* commDependenciesList;
nengel@16 241 ListOfArrays* dataDependenciesList;
nengel@17 242 ListOfArrays* warDependenciesList;
seanhalle@0 243 NtoN** ntonGroups;
seanhalle@0 244 PrivDynArrayInfo* ntonGroupsInfo;
seanhalle@0 245 ListOfArrays* dynDependenciesList;
nengel@16 246 ListOfArrays* singletonDependenciesList;
seanhalle@0 247 Unit last_in_slot[NUM_CORES * NUM_ANIM_SLOTS];
seanhalle@0 248 ListOfArrays* hwArcs;
seanhalle@0 249 #endif
seanhalle@0 250
seanhalle@0 251 #ifdef HOLISTIC__TURN_ON_PERF_COUNTERS
seanhalle@0 252 ListOfArrays* counterList[NUM_CORES];
seanhalle@0 253 #endif
nengel@22 254 #ifdef IDLE_SLAVES
seanhalle@3 255 SlaveVP* idleSlv[NUM_CORES][NUM_ANIM_SLOTS];
nengel@22 256 #endif
nengel@33 257 //int shutdownInitiated;
seanhalle@0 258 }
seanhalle@2 259 VSsSemEnv;
seanhalle@0 260
seanhalle@0 261
seanhalle@0 262 typedef struct _TransListElem TransListElem;
seanhalle@0 263 struct _TransListElem
seanhalle@0 264 {
seanhalle@0 265 int32 transID;
seanhalle@0 266 TransListElem *nextTrans;
seanhalle@0 267 };
seanhalle@0 268 //TransListElem
seanhalle@0 269
seanhalle@8 270 enum VSsSlvType
seanhalle@10 271 { ExtraTaskSlv = 1,
seanhalle@10 272 SlotTaskSlv,
seanhalle@10 273 ThreadSlv
seanhalle@8 274 };
nengel@5 275
seanhalle@0 276 typedef struct
seanhalle@0 277 {
seanhalle@14 278 int32 highestTransEntered;
seanhalle@14 279 TransListElem *lastTransEntered;
seanhalle@14 280 bool32 needsTaskAssigned;
seanhalle@14 281 VSsTaskStub *taskStub;
seanhalle@14 282 enum VSsSlvType slaveType;
seanhalle@0 283 }
seanhalle@2 284 VSsSemData;
seanhalle@0 285
seanhalle@0 286 //===========================================================================
seanhalle@0 287
seanhalle@0 288 void
seanhalle@2 289 VSs__create_seed_slave_and_do_work( TopLevelFnPtr fn, void *initData );
seanhalle@0 290
seanhalle@0 291 int32
seanhalle@2 292 VSs__giveMinWorkUnitCycles( float32 percentOverhead );
seanhalle@0 293
seanhalle@0 294 void
seanhalle@2 295 VSs__start_primitive();
seanhalle@0 296
seanhalle@0 297 int32
seanhalle@2 298 VSs__end_primitive_and_give_cycles();
seanhalle@0 299
seanhalle@0 300 int32
seanhalle@2 301 VSs__giveIdealNumWorkUnits();
seanhalle@0 302
seanhalle@0 303 int32
seanhalle@2 304 VSs__give_number_of_cores_to_schedule_onto();
seanhalle@0 305
seanhalle@0 306 //=======================
seanhalle@0 307
seanhalle@0 308 void
seanhalle@2 309 VSs__init();
seanhalle@0 310
seanhalle@0 311 void
seanhalle@2 312 VSs__cleanup_after_shutdown();
seanhalle@0 313
seanhalle@0 314 //=======================
seanhalle@0 315
seanhalle@4 316 SlaveVP *
seanhalle@7 317 VSs__create_thread( TopLevelFnPtr fnPtr, void *initData,
seanhalle@7 318 SlaveVP *creatingThd );
seanhalle@0 319
seanhalle@0 320 void
seanhalle@7 321 VSs__end_thread( SlaveVP *thdToEnd );
seanhalle@0 322
seanhalle@0 323 //=======================
seanhalle@2 324
seanhalle@2 325 #define VSs__malloc( numBytes, callingSlave ) VMS_App__malloc( numBytes, callingSlave)
seanhalle@2 326
seanhalle@2 327 #define VSs__free(ptrToFree, callingSlave ) VMS_App__free( ptrToFree, callingSlave )
seanhalle@2 328
seanhalle@2 329
seanhalle@2 330 //=======================
seanhalle@4 331 void
seanhalle@3 332 VSs__submit_task( VSsTaskType *taskType, void *args, SlaveVP *animSlv);
seanhalle@2 333
nengel@20 334 int32 *
seanhalle@4 335 VSs__create_taskID_of_size( int32 numInts, SlaveVP *animSlv );
seanhalle@4 336
seanhalle@4 337 void
seanhalle@4 338 VSs__submit_task_with_ID( VSsTaskType *taskType, void *args, int32 *taskID,
seanhalle@4 339 SlaveVP *animSlv);
seanhalle@0 340
seanhalle@0 341 void
seanhalle@2 342 VSs__end_task( SlaveVP *animSlv );
seanhalle@0 343
seanhalle@4 344 //=========================
nengel@5 345 void
nengel@5 346 VSs__taskwait(SlaveVP *animSlv);
nengel@5 347
nengel@21 348 void
nengel@21 349 VSs__taskwait_on(SlaveVP *animSlv,void* ptr);
nengel@21 350
nengel@21 351 void
nengel@21 352 VSs__start_critical(SlaveVP *animSlv,int32 name);
nengel@21 353
nengel@21 354 void
nengel@21 355 VSs__end_critical(SlaveVP *animSlv,int32 name);
seanhalle@4 356
nengel@20 357 int32 *
seanhalle@4 358 VSs__give_self_taskID( SlaveVP *animSlv );
seanhalle@4 359
seanhalle@4 360 void
seanhalle@4 361 VSs__send_of_type_to( void *msg, const int32 type, int32 *receiverID,
seanhalle@4 362 SlaveVP *senderSlv );
seanhalle@4 363
seanhalle@4 364 void
seanhalle@4 365 VSs__send_from_to( void *msg, int32 *senderID, int32 *receiverID, SlaveVP *senderSlv );
seanhalle@4 366
seanhalle@4 367 void *
seanhalle@4 368 VSs__receive_type_to( const int32 type, int32* receiverID, SlaveVP *receiverSlv );
seanhalle@4 369
seanhalle@4 370 void *
seanhalle@4 371 VSs__receive_from_to( int32 *senderID, int32 *receiverID, SlaveVP *receiverSlv );
seanhalle@0 372
seanhalle@0 373 //======================= Concurrency Stuff ======================
seanhalle@0 374 void
seanhalle@2 375 VSs__start_fn_singleton( int32 singletonID, SlaveVP *animSlv );
seanhalle@0 376
seanhalle@0 377 void
seanhalle@2 378 VSs__end_fn_singleton( int32 singletonID, SlaveVP *animSlv );
seanhalle@0 379
seanhalle@0 380 void
seanhalle@2 381 VSs__start_data_singleton( VSsSingleton **singeltonAddr, SlaveVP *animSlv );
seanhalle@0 382
seanhalle@0 383 void
seanhalle@2 384 VSs__end_data_singleton( VSsSingleton **singletonAddr, SlaveVP *animSlv );
seanhalle@0 385
seanhalle@0 386 void
seanhalle@2 387 VSs__animate_short_fn_in_isolation( PtrToAtomicFn ptrToFnToExecInMaster,
seanhalle@0 388 void *data, SlaveVP *animSlv );
seanhalle@0 389
seanhalle@0 390 void
seanhalle@2 391 VSs__start_transaction( int32 transactionID, SlaveVP *animSlv );
seanhalle@0 392
seanhalle@0 393 void
seanhalle@2 394 VSs__end_transaction( int32 transactionID, SlaveVP *animSlv );
seanhalle@0 395
seanhalle@0 396
seanhalle@0 397 //========================= Internal use only =============================
seanhalle@0 398 void
seanhalle@3 399 VSs__Request_Handler( SlaveVP *requestingSlv, void *_semEnv );
seanhalle@0 400
seanhalle@0 401 SlaveVP *
seanhalle@2 402 VSs__assign_slaveVP_to_slot( void *_semEnv, AnimSlot *slot );
seanhalle@0 403
seanhalle@0 404 SlaveVP*
seanhalle@2 405 VSs__create_slave_helper( TopLevelFnPtr fnPtr, void *initData,
seanhalle@2 406 VSsSemEnv *semEnv, int32 coreToAssignOnto );
seanhalle@0 407
seanhalle@7 408 VSsTaskStub *
seanhalle@8 409 create_thread_task_stub( void *initData );
seanhalle@7 410
seanhalle@7 411
seanhalle@7 412 SlaveVP *
seanhalle@7 413 VSs__create_slave_with( TopLevelFnPtr fnPtr, void *initData,
seanhalle@7 414 SlaveVP *creatingSlv );
seanhalle@7 415
seanhalle@7 416 SlaveVP *
seanhalle@7 417 VSs__create_slave_with_affinity( TopLevelFnPtr fnPtr, void *initData,
seanhalle@7 418 SlaveVP *creatingSlv, int32 coreToAssignOnto);
seanhalle@7 419
seanhalle@9 420 void
seanhalle@9 421 idle_fn(void* data, SlaveVP *animatingSlv);
seanhalle@7 422
nengel@20 423 void
nengel@20 424 resume_slaveVP(SlaveVP *slave, VSsSemEnv *semEnv);
nengel@20 425
seanhalle@0 426 //===================== Measurement of Lang Overheads =====================
seanhalle@3 427 #include "Measurement/VSs_Measurement.h"
seanhalle@0 428
seanhalle@0 429 //===========================================================================
seanhalle@2 430 #endif /* _VSs_H */
seanhalle@0 431