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

annotate VSs.h @ 40:df464a215387

find changesets by author, revision, files, or words in the commit message
add implementations of (some) nanos api functions
author Nina Engelhardt <nengel@mailbox.tu-berlin.de>
date Mon, 03 Jun 2013 18:49:19 +0200
parents a951b38d2cfc
children 37bb39da5ff1
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;
nengel@39 61 int32 numDeps;//how many of args have dependencies
nengel@39 62 int32 *depsTypes; //says reader, writer, or non-ctld
nengel@39 63 size_t *depsSizes; //for detecting overlap
seanhalle@2 64 int32 sizeOfArgs; //for memcpy of args struct
seanhalle@1 65 }
seanhalle@1 66 VSsTaskType;
seanhalle@1 67
seanhalle@1 68
seanhalle@2 69 typedef struct
seanhalle@2 70 {
seanhalle@3 71 bool32 hasEnabledNonFinishedWriter;
seanhalle@3 72 int32 numEnabledNonDoneReaders;
seanhalle@3 73 PrivQueueStruc *waitersQ;
nengel@16 74 #ifdef HOLISTIC__TURN_ON_OBSERVE_UCC
nengel@17 75 Unit lastWriter;
nengel@17 76 ListOfArrays* readersSinceLastWriter;
nengel@16 77 #endif
seanhalle@3 78 }
seanhalle@3 79 VSsPointerEntry;
seanhalle@3 80
nengel@33 81 typedef struct {
nengel@39 82 void **args; //for calling only, can contain values
nengel@39 83 void** depsAddrs; //pointers only
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@39 95 int *depsMask;
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;
nengel@39 182 void *deps;
seanhalle@2 183 VSsTaskStub *taskStub;
seanhalle@2 184
seanhalle@4 185 SlaveVP *senderSlv;
seanhalle@4 186 SlaveVP *receiverSlv;
seanhalle@4 187 int32 *senderID;
seanhalle@4 188 int32 *receiverID;
seanhalle@4 189 int32 msgType;
seanhalle@4 190 void *msg;
seanhalle@4 191 VSsSemReq *nextReqInHashEntry;
seanhalle@4 192 int32 *taskID;
seanhalle@4 193
seanhalle@2 194 TopLevelFnPtr fnPtr;
seanhalle@0 195 void *initData;
seanhalle@0 196 int32 coreToAssignOnto;
seanhalle@0 197
seanhalle@0 198 int32 sizeToMalloc;
seanhalle@0 199 void *ptrToFree;
seanhalle@0 200
seanhalle@0 201 int32 singletonID;
seanhalle@2 202 VSsSingleton **singletonPtrAddr;
seanhalle@0 203
seanhalle@0 204 PtrToAtomicFn fnToExecInMaster;
seanhalle@0 205 void *dataForFn;
seanhalle@0 206
seanhalle@0 207 int32 transID;
nengel@39 208 void* criticalID;
seanhalle@0 209 }
seanhalle@2 210 /* VSsSemReq */;
seanhalle@0 211
seanhalle@0 212
seanhalle@0 213 typedef struct
seanhalle@0 214 {
seanhalle@9 215 PrivQueueStruc *slavesReadyToResumeQ; //Shared (slaves not pinned)
seanhalle@9 216 PrivQueueStruc *freeExtraTaskSlvQ; //Shared
seanhalle@9 217 PrivQueueStruc *taskReadyQ; //Shared (tasks not pinned)
seanhalle@10 218 SlaveVP *slotTaskSlvs[NUM_CORES][NUM_ANIM_SLOTS];
seanhalle@2 219 HashTable *argPtrHashTbl;
seanhalle@4 220 HashTable *commHashTbl;
nengel@39 221 HashTable *criticalHashTbl;
seanhalle@8 222 int32 numLiveExtraTaskSlvs;
seanhalle@8 223 int32 numLiveThreadSlvs;
seanhalle@3 224 int32 nextCoreToGetNewSlv;
seanhalle@0 225 int32 primitiveStartTime;
seanhalle@0 226
seanhalle@0 227 //fix limit on num with dynArray
seanhalle@2 228 VSsSingleton fnSingletons[NUM_STRUCS_IN_SEM_ENV];
seanhalle@2 229 VSsTrans transactionStrucs[NUM_STRUCS_IN_SEM_ENV];
nengel@39 230
seanhalle@3 231
seanhalle@3 232 bool32 *coreIsDone;
seanhalle@3 233 int32 numCoresDone;
seanhalle@0 234
nengel@22 235 int numInFlightTasks;
nengel@22 236 PrivQueueStruc *deferredSubmitsQ;
nengel@22 237 int numDeferred;
nengel@22 238
seanhalle@0 239 #ifdef HOLISTIC__TURN_ON_OBSERVE_UCC
seanhalle@0 240 ListOfArrays* unitList;
seanhalle@0 241 ListOfArrays* ctlDependenciesList;
seanhalle@0 242 ListOfArrays* commDependenciesList;
nengel@16 243 ListOfArrays* dataDependenciesList;
nengel@17 244 ListOfArrays* warDependenciesList;
seanhalle@0 245 NtoN** ntonGroups;
seanhalle@0 246 PrivDynArrayInfo* ntonGroupsInfo;
seanhalle@0 247 ListOfArrays* dynDependenciesList;
nengel@16 248 ListOfArrays* singletonDependenciesList;
seanhalle@0 249 Unit last_in_slot[NUM_CORES * NUM_ANIM_SLOTS];
seanhalle@0 250 ListOfArrays* hwArcs;
seanhalle@0 251 #endif
seanhalle@0 252
seanhalle@0 253 #ifdef HOLISTIC__TURN_ON_PERF_COUNTERS
seanhalle@0 254 ListOfArrays* counterList[NUM_CORES];
seanhalle@0 255 #endif
nengel@22 256 #ifdef IDLE_SLAVES
seanhalle@3 257 SlaveVP* idleSlv[NUM_CORES][NUM_ANIM_SLOTS];
nengel@22 258 #endif
nengel@33 259 //int shutdownInitiated;
seanhalle@0 260 }
seanhalle@2 261 VSsSemEnv;
seanhalle@0 262
seanhalle@0 263
seanhalle@0 264 typedef struct _TransListElem TransListElem;
seanhalle@0 265 struct _TransListElem
seanhalle@0 266 {
seanhalle@0 267 int32 transID;
seanhalle@0 268 TransListElem *nextTrans;
seanhalle@0 269 };
seanhalle@0 270 //TransListElem
seanhalle@0 271
seanhalle@8 272 enum VSsSlvType
seanhalle@10 273 { ExtraTaskSlv = 1,
seanhalle@10 274 SlotTaskSlv,
seanhalle@10 275 ThreadSlv
seanhalle@8 276 };
nengel@5 277
seanhalle@0 278 typedef struct
seanhalle@0 279 {
seanhalle@14 280 int32 highestTransEntered;
seanhalle@14 281 TransListElem *lastTransEntered;
seanhalle@14 282 bool32 needsTaskAssigned;
seanhalle@14 283 VSsTaskStub *taskStub;
seanhalle@14 284 enum VSsSlvType slaveType;
seanhalle@0 285 }
seanhalle@2 286 VSsSemData;
seanhalle@0 287
seanhalle@0 288 //===========================================================================
seanhalle@0 289
seanhalle@0 290 void
seanhalle@2 291 VSs__create_seed_slave_and_do_work( TopLevelFnPtr fn, void *initData );
seanhalle@0 292
seanhalle@0 293 int32
seanhalle@2 294 VSs__giveMinWorkUnitCycles( float32 percentOverhead );
seanhalle@0 295
seanhalle@0 296 void
seanhalle@2 297 VSs__start_primitive();
seanhalle@0 298
seanhalle@0 299 int32
seanhalle@2 300 VSs__end_primitive_and_give_cycles();
seanhalle@0 301
seanhalle@0 302 int32
seanhalle@2 303 VSs__giveIdealNumWorkUnits();
seanhalle@0 304
seanhalle@0 305 int32
seanhalle@2 306 VSs__give_number_of_cores_to_schedule_onto();
seanhalle@0 307
seanhalle@0 308 //=======================
seanhalle@0 309
seanhalle@0 310 void
seanhalle@2 311 VSs__init();
seanhalle@0 312
seanhalle@0 313 void
seanhalle@2 314 VSs__cleanup_after_shutdown();
seanhalle@0 315
seanhalle@0 316 //=======================
seanhalle@0 317
seanhalle@4 318 SlaveVP *
seanhalle@7 319 VSs__create_thread( TopLevelFnPtr fnPtr, void *initData,
seanhalle@7 320 SlaveVP *creatingThd );
seanhalle@0 321
nengel@38 322 void VSs__run_thread(TopLevelFnPtr fnPtr, void *initData);
nengel@38 323
seanhalle@0 324 void
nengel@37 325 VSs__end_thread();
seanhalle@0 326
seanhalle@0 327 //=======================
seanhalle@2 328
seanhalle@2 329 #define VSs__malloc( numBytes, callingSlave ) VMS_App__malloc( numBytes, callingSlave)
seanhalle@2 330
seanhalle@2 331 #define VSs__free(ptrToFree, callingSlave ) VMS_App__free( ptrToFree, callingSlave )
seanhalle@2 332
seanhalle@2 333
seanhalle@2 334 //=======================
seanhalle@4 335 void
nengel@39 336 VSs__submit_task( VSsTaskType *taskType, void *args, void* deps);
seanhalle@2 337
nengel@20 338 int32 *
nengel@37 339 VSs__create_taskID_of_size( int32 numInts);
seanhalle@4 340
seanhalle@4 341 void
nengel@39 342 VSs__submit_task_with_ID( VSsTaskType *taskType, void *args, void* deps, int32 *taskID);
seanhalle@0 343
nengel@38 344 void VSs__run_task(TopLevelFnPtr fnPtr, void *initData);
nengel@38 345
seanhalle@0 346 void
nengel@37 347 VSs__end_task();
seanhalle@0 348
seanhalle@4 349 //=========================
nengel@5 350 void
nengel@37 351 VSs__taskwait();
nengel@5 352
nengel@21 353 void
nengel@37 354 VSs__taskwait_on(void* ptr);
nengel@21 355
nengel@21 356 void
nengel@39 357 VSs__start_critical(void* name);
nengel@21 358
nengel@21 359 void
nengel@39 360 VSs__end_critical(void* name);
seanhalle@4 361
nengel@20 362 int32 *
nengel@37 363 VSs__give_self_taskID();
seanhalle@4 364
seanhalle@4 365 void
nengel@37 366 VSs__send_of_type_to( void *msg, const int32 type, int32 *receiverID);
seanhalle@4 367
seanhalle@4 368 void
nengel@37 369 VSs__send_from_to( void *msg, int32 *senderID, int32 *receiverID);
seanhalle@4 370
seanhalle@4 371 void *
nengel@37 372 VSs__receive_type_to( const int32 type, int32* receiverID );
seanhalle@4 373
seanhalle@4 374 void *
nengel@37 375 VSs__receive_from_to( int32 *senderID, int32 *receiverID );
seanhalle@0 376
seanhalle@0 377 //======================= Concurrency Stuff ======================
seanhalle@0 378 void
nengel@37 379 VSs__start_fn_singleton( int32 singletonID );
seanhalle@0 380
seanhalle@0 381 void
nengel@37 382 VSs__end_fn_singleton( int32 singletonID );
seanhalle@0 383
seanhalle@0 384 void
nengel@37 385 VSs__start_data_singleton( VSsSingleton **singeltonAddr );
seanhalle@0 386
seanhalle@0 387 void
nengel@37 388 VSs__end_data_singleton( VSsSingleton **singletonAddr );
seanhalle@0 389
seanhalle@0 390 void
seanhalle@2 391 VSs__animate_short_fn_in_isolation( PtrToAtomicFn ptrToFnToExecInMaster,
nengel@37 392 void *data );
seanhalle@0 393
seanhalle@0 394 void
nengel@37 395 VSs__start_transaction( int32 transactionID );
seanhalle@0 396
seanhalle@0 397 void
nengel@37 398 VSs__end_transaction( int32 transactionID );
seanhalle@0 399
seanhalle@0 400
seanhalle@0 401 //========================= Internal use only =============================
seanhalle@0 402 void
seanhalle@3 403 VSs__Request_Handler( SlaveVP *requestingSlv, void *_semEnv );
seanhalle@0 404
seanhalle@0 405 SlaveVP *
seanhalle@2 406 VSs__assign_slaveVP_to_slot( void *_semEnv, AnimSlot *slot );
seanhalle@0 407
seanhalle@0 408 SlaveVP*
nengel@38 409 VSs__create_slave_helper(TopLevelFnWrapper fnWrapper, TopLevelFnPtr fnPtr, void *initData,
seanhalle@2 410 VSsSemEnv *semEnv, int32 coreToAssignOnto );
seanhalle@0 411
seanhalle@7 412 VSsTaskStub *
seanhalle@8 413 create_thread_task_stub( void *initData );
seanhalle@7 414
seanhalle@7 415
seanhalle@7 416 SlaveVP *
seanhalle@7 417 VSs__create_slave_with( TopLevelFnPtr fnPtr, void *initData,
seanhalle@7 418 SlaveVP *creatingSlv );
seanhalle@7 419
seanhalle@7 420 SlaveVP *
seanhalle@7 421 VSs__create_slave_with_affinity( TopLevelFnPtr fnPtr, void *initData,
seanhalle@7 422 SlaveVP *creatingSlv, int32 coreToAssignOnto);
seanhalle@7 423
seanhalle@9 424 void
nengel@37 425 idle_fn(void* data);
seanhalle@7 426
nengel@20 427 void
nengel@20 428 resume_slaveVP(SlaveVP *slave, VSsSemEnv *semEnv);
nengel@20 429
seanhalle@0 430 //===================== Measurement of Lang Overheads =====================
seanhalle@3 431 #include "Measurement/VSs_Measurement.h"
seanhalle@0 432
seanhalle@0 433 //===========================================================================
nengel@37 434
nengel@37 435 /* Hide entry point trick */
nengel@37 436
nengel@37 437 typedef struct {
nengel@37 438 int argc;
nengel@37 439 char** argv;
nengel@37 440 } __main_args;
nengel@37 441
nengel@37 442 extern int __main_ret;
nengel@37 443
nengel@37 444 int __program_main(int argc, char** argv);
nengel@37 445
nengel@37 446 void __entry_point(void* _args);
nengel@37 447
nengel@37 448 int main(int argc, char** argv);
nengel@37 449
nengel@37 450
nengel@37 451 #define main __program_main
nengel@37 452
seanhalle@2 453 #endif /* _VSs_H */
seanhalle@0 454