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

annotate VSs.h @ 38:a951b38d2cfc

find changesets by author, revision, files, or words in the commit message
remove need for end_thread()
author Nina Engelhardt <nengel@mailbox.tu-berlin.de>
date Fri, 17 May 2013 17:49:49 +0200
parents c8d4f6d3c7d3
children 0715109abb08
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;
nengel@37 42 typedef void (*VSsTaskFnPtr ) ( void * );
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
nengel@38 320 void VSs__run_thread(TopLevelFnPtr fnPtr, void *initData);
nengel@38 321
seanhalle@0 322 void
nengel@37 323 VSs__end_thread();
seanhalle@0 324
seanhalle@0 325 //=======================
seanhalle@2 326
seanhalle@2 327 #define VSs__malloc( numBytes, callingSlave ) VMS_App__malloc( numBytes, callingSlave)
seanhalle@2 328
seanhalle@2 329 #define VSs__free(ptrToFree, callingSlave ) VMS_App__free( ptrToFree, callingSlave )
seanhalle@2 330
seanhalle@2 331
seanhalle@2 332 //=======================
seanhalle@4 333 void
nengel@37 334 VSs__submit_task( VSsTaskType *taskType, void *args);
seanhalle@2 335
nengel@20 336 int32 *
nengel@37 337 VSs__create_taskID_of_size( int32 numInts);
seanhalle@4 338
seanhalle@4 339 void
nengel@37 340 VSs__submit_task_with_ID( VSsTaskType *taskType, void *args, int32 *taskID);
seanhalle@0 341
nengel@38 342 void VSs__run_task(TopLevelFnPtr fnPtr, void *initData);
nengel@38 343
seanhalle@0 344 void
nengel@37 345 VSs__end_task();
seanhalle@0 346
seanhalle@4 347 //=========================
nengel@5 348 void
nengel@37 349 VSs__taskwait();
nengel@5 350
nengel@21 351 void
nengel@37 352 VSs__taskwait_on(void* ptr);
nengel@21 353
nengel@21 354 void
nengel@37 355 VSs__start_critical(int32 name);
nengel@21 356
nengel@21 357 void
nengel@37 358 VSs__end_critical(int32 name);
seanhalle@4 359
nengel@20 360 int32 *
nengel@37 361 VSs__give_self_taskID();
seanhalle@4 362
seanhalle@4 363 void
nengel@37 364 VSs__send_of_type_to( void *msg, const int32 type, int32 *receiverID);
seanhalle@4 365
seanhalle@4 366 void
nengel@37 367 VSs__send_from_to( void *msg, int32 *senderID, int32 *receiverID);
seanhalle@4 368
seanhalle@4 369 void *
nengel@37 370 VSs__receive_type_to( const int32 type, int32* receiverID );
seanhalle@4 371
seanhalle@4 372 void *
nengel@37 373 VSs__receive_from_to( int32 *senderID, int32 *receiverID );
seanhalle@0 374
seanhalle@0 375 //======================= Concurrency Stuff ======================
seanhalle@0 376 void
nengel@37 377 VSs__start_fn_singleton( int32 singletonID );
seanhalle@0 378
seanhalle@0 379 void
nengel@37 380 VSs__end_fn_singleton( int32 singletonID );
seanhalle@0 381
seanhalle@0 382 void
nengel@37 383 VSs__start_data_singleton( VSsSingleton **singeltonAddr );
seanhalle@0 384
seanhalle@0 385 void
nengel@37 386 VSs__end_data_singleton( VSsSingleton **singletonAddr );
seanhalle@0 387
seanhalle@0 388 void
seanhalle@2 389 VSs__animate_short_fn_in_isolation( PtrToAtomicFn ptrToFnToExecInMaster,
nengel@37 390 void *data );
seanhalle@0 391
seanhalle@0 392 void
nengel@37 393 VSs__start_transaction( int32 transactionID );
seanhalle@0 394
seanhalle@0 395 void
nengel@37 396 VSs__end_transaction( int32 transactionID );
seanhalle@0 397
seanhalle@0 398
seanhalle@0 399 //========================= Internal use only =============================
seanhalle@0 400 void
seanhalle@3 401 VSs__Request_Handler( SlaveVP *requestingSlv, void *_semEnv );
seanhalle@0 402
seanhalle@0 403 SlaveVP *
seanhalle@2 404 VSs__assign_slaveVP_to_slot( void *_semEnv, AnimSlot *slot );
seanhalle@0 405
seanhalle@0 406 SlaveVP*
nengel@38 407 VSs__create_slave_helper(TopLevelFnWrapper fnWrapper, TopLevelFnPtr fnPtr, void *initData,
seanhalle@2 408 VSsSemEnv *semEnv, int32 coreToAssignOnto );
seanhalle@0 409
seanhalle@7 410 VSsTaskStub *
seanhalle@8 411 create_thread_task_stub( void *initData );
seanhalle@7 412
seanhalle@7 413
seanhalle@7 414 SlaveVP *
seanhalle@7 415 VSs__create_slave_with( TopLevelFnPtr fnPtr, void *initData,
seanhalle@7 416 SlaveVP *creatingSlv );
seanhalle@7 417
seanhalle@7 418 SlaveVP *
seanhalle@7 419 VSs__create_slave_with_affinity( TopLevelFnPtr fnPtr, void *initData,
seanhalle@7 420 SlaveVP *creatingSlv, int32 coreToAssignOnto);
seanhalle@7 421
seanhalle@9 422 void
nengel@37 423 idle_fn(void* data);
seanhalle@7 424
nengel@20 425 void
nengel@20 426 resume_slaveVP(SlaveVP *slave, VSsSemEnv *semEnv);
nengel@20 427
seanhalle@0 428 //===================== Measurement of Lang Overheads =====================
seanhalle@3 429 #include "Measurement/VSs_Measurement.h"
seanhalle@0 430
seanhalle@0 431 //===========================================================================
nengel@37 432
nengel@37 433 /* Hide entry point trick */
nengel@37 434
nengel@37 435 typedef struct {
nengel@37 436 int argc;
nengel@37 437 char** argv;
nengel@37 438 } __main_args;
nengel@37 439
nengel@37 440 extern int __main_ret;
nengel@37 441
nengel@37 442 int __program_main(int argc, char** argv);
nengel@37 443
nengel@37 444 void __entry_point(void* _args);
nengel@37 445
nengel@37 446 int main(int argc, char** argv);
nengel@37 447
nengel@37 448
nengel@37 449 #define main __program_main
nengel@37 450
seanhalle@2 451 #endif /* _VSs_H */
seanhalle@0 452