Mercurial > cgi-bin > hgwebdir.cgi > VMS > VMS_Implementations > VMS_impls > VMS__MC_shared_impl

comparison VMS.h @ 69:11bfe9d136ed

find changesets by author, revision, files, or words in the commit message
removed warnings
author Merten Sach <msach@mailbox.tu-berlin.de>
date Wed, 11 May 2011 16:13:24 +0200
parents 9c3107044f86
children f9b60012fd74 5ff1631c26ed
comparison
equal deleted inserted replaced
36:3dbb551a7aa7 37:ffb803f3f0ad
15 #include "Histogram/Histogram.h" 15 #include "Histogram/Histogram.h"
16 #include "DynArray/DynArray.h" 16 #include "DynArray/DynArray.h"
17 #include "Hash_impl/PrivateHash.h" 17 #include "Hash_impl/PrivateHash.h"
18 #include "vmalloc.h" 18 #include "vmalloc.h"
19 19
20 //#include <stdio.h>
20 #include <pthread.h> 21 #include <pthread.h>
21 #include <sys/time.h> 22 #include <sys/time.h>
22 23
23 24
24 //=============================== Debug =================================== 25 //=============================== Debug ===================================
48 #define DEBUG1( bool, msg, param) \ 49 #define DEBUG1( bool, msg, param) \
49 // if(bool){printf(msg, param); fflush(stdin);} 50 // if(bool){printf(msg, param); fflush(stdin);}
50 #define DEBUG2( bool, msg, p1, p2) \ 51 #define DEBUG2( bool, msg, p1, p2) \
51 // if(bool) {printf(msg, p1, p2); fflush(stdin);} 52 // if(bool) {printf(msg, p1, p2); fflush(stdin);}
52 53
53 #define ERROR(msg) printf(msg); fflush(stdin); 54 #define ERROR(msg) printf(msg); //fflush(stdin);
54 #define ERROR1(msg, param) printf(msg, param); fflush(stdin); 55 #define ERROR1(msg, param) printf(msg, param); fflush(stdin);
55 #define ERROR2(msg, p1, p2) printf(msg, p1, p2); fflush(stdin); 56 #define ERROR2(msg, p1, p2) printf(msg, p1, p2); fflush(stdin);
56 57
57 //=========================== STATS ======================= 58 //=========================== STATS =======================
58 59
74 75
75 76
76 //========================= Hardware related Constants ===================== 77 //========================= Hardware related Constants =====================
77 //This value is the number of hardware threads in the shared memory 78 //This value is the number of hardware threads in the shared memory
78 // machine 79 // machine
79 #define NUM_CORES 4 80 #define NUM_CORES 8
80 81
81 // tradeoff amortizing master fixed overhead vs imbalance potential 82 // tradeoff amortizing master fixed overhead vs imbalance potential
82 // when work-stealing, can make bigger, at risk of losing cache affinity 83 // when work-stealing, can make bigger, at risk of losing cache affinity
83 #define NUM_SCHED_SLOTS 5 84 #define NUM_SCHED_SLOTS 5
84 85
399 _VMSMasterEnv->measHists[idx] = \ 400 _VMSMasterEnv->measHists[idx] = \
400 makeFixedBinHist( numBins, startVal, binWidth, name ); 401 makeFixedBinHist( numBins, startVal, binWidth, name );
401 402
402 403
403 #define MEAS__SUB_CREATE /*turn on/off subtraction of create from plugin*/ 404 #define MEAS__SUB_CREATE /*turn on/off subtraction of create from plugin*/
405
406 //VPThread
404 #define createHistIdx 1 407 #define createHistIdx 1
405 #define mutexLockHistIdx 2 408 #define mutexLockHistIdx 2
406 #define mutexUnlockHistIdx 3 409 #define mutexUnlockHistIdx 3
407 #define condWaitHistIdx 4 410 #define condWaitHistIdx 4
408 #define condSignalHistIdx 5 411 #define condSignalHistIdx 5
409 412
413 //VCilk
414 #define spawnHistIdx 1
415 #define syncHistIdx 2
416
417 //SSR
418 #define SendFromToHistIdx 1
419 #define SendOfTypeHistIdx 2
420 #define ReceiveFromToHistIdx 3
421 #define ReceiveOfTypeHistIdx 4
422
410 423
411 #define MakeTheMeasHists \ 424 #define MakeTheMeasHists \
412 _VMSMasterEnv->measHistsInfo = \ 425 _VMSMasterEnv->measHistsInfo = \
413 makePrivDynArrayOfSize( &(_VMSMasterEnv->measHists), 200);\ 426 makePrivDynArrayOfSize( (void***)&(_VMSMasterEnv->measHists), 200);\
414 makeAMeasHist( createHistIdx, "Create", 50, 0, 200 ) \ 427 makeAMeasHist( spawnHistIdx, "Spawn", 50, 0, 200 ) \
415 makeAMeasHist( mutexLockHistIdx, "mutex lock", 50, 0, 100 ) \ 428 makeAMeasHist( syncHistIdx, "Sync", 50, 0, 200 )
416 makeAMeasHist( mutexUnlockHistIdx, "mutex unlock", 50, 0, 100 ) \ 429
417 makeAMeasHist( condWaitHistIdx, "cond wait", 50, 0, 100 ) \ 430 // makeAMeasHist( createHistIdx, "Create", 50, 0, 100 ) \
418 makeAMeasHist( condSignalHistIdx, "cond signal", 50, 0, 100 ) 431 // makeAMeasHist( mutexLockHistIdx, "mutex lock", 50, 0, 100 ) \
432 // makeAMeasHist( mutexUnlockHistIdx, "mutex unlock", 50, 0, 100 ) \
433 // makeAMeasHist( condWaitHistIdx, "cond wait", 50, 0, 100 ) \
434 // makeAMeasHist( condSignalHistIdx, "cond signal", 50, 0, 100 )
435
436 // makeAMeasHist( SendFromToHistIdx, "SendFromTo", 50, 0, 100 ) \
437 // makeAMeasHist( SendOfTypeHistIdx, "SendOfType", 50, 0, 100 ) \
438 // makeAMeasHist( ReceiveFromToHistIdx,"ReceiveFromTo", 50, 0, 100 ) \
439 // makeAMeasHist( ReceiveOfTypeHistIdx,"ReceiveOfType", 50, 0, 100 )
440
441
442 //===========================================================================
443 //VPThread
444
419 445
420 #define Meas_startCreate \ 446 #define Meas_startCreate \
421 int32 startStamp, endStamp; \ 447 int32 startStamp, endStamp; \
422 saveLowTimeStampCountInto( startStamp ); \ 448 saveLowTimeStampCountInto( startStamp ); \
423 449
460 #define Meas_endCondSignal \ 486 #define Meas_endCondSignal \
461 saveLowTimeStampCountInto( endStamp ); \ 487 saveLowTimeStampCountInto( endStamp ); \
462 addIntervalToHist( startStamp, endStamp, \ 488 addIntervalToHist( startStamp, endStamp, \
463 _VMSMasterEnv->measHists[ condSignalHistIdx ] ); 489 _VMSMasterEnv->measHists[ condSignalHistIdx ] );
464 490
491 //===========================================================================
492 // VCilk
493 #define Meas_startSpawn \
494 int32 startStamp, endStamp; \
495 saveLowTimeStampCountInto( startStamp ); \
496
497 #define Meas_endSpawn \
498 saveLowTimeStampCountInto( endStamp ); \
499 addIntervalToHist( startStamp, endStamp, \
500 _VMSMasterEnv->measHists[ spawnHistIdx ] );
501
502 #define Meas_startSync \
503 int32 startStamp, endStamp; \
504 saveLowTimeStampCountInto( startStamp ); \
505
506 #define Meas_endSync \
507 saveLowTimeStampCountInto( endStamp ); \
508 addIntervalToHist( startStamp, endStamp, \
509 _VMSMasterEnv->measHists[ syncHistIdx ] );
510
511 //===========================================================================
512 // SSR
513 #define Meas_startSendFromTo \
514 int32 startStamp, endStamp; \
515 saveLowTimeStampCountInto( startStamp ); \
516
517 #define Meas_endSendFromTo \
518 saveLowTimeStampCountInto( endStamp ); \
519 addIntervalToHist( startStamp, endStamp, \
520 _VMSMasterEnv->measHists[ SendFromToHistIdx ] );
521
522 #define Meas_startSendOfType \
523 int32 startStamp, endStamp; \
524 saveLowTimeStampCountInto( startStamp ); \
525
526 #define Meas_endSendOfType \
527 saveLowTimeStampCountInto( endStamp ); \
528 addIntervalToHist( startStamp, endStamp, \
529 _VMSMasterEnv->measHists[ SendOfTypeHistIdx ] );
530
531 #define Meas_startReceiveFromTo \
532 int32 startStamp, endStamp; \
533 saveLowTimeStampCountInto( startStamp ); \
534
535 #define Meas_endReceiveFromTo \
536 saveLowTimeStampCountInto( endStamp ); \
537 addIntervalToHist( startStamp, endStamp, \
538 _VMSMasterEnv->measHists[ ReceiveFromToHistIdx ] );
539
540 #define Meas_startReceiveOfType \
541 int32 startStamp, endStamp; \
542 saveLowTimeStampCountInto( startStamp ); \
543
544 #define Meas_endReceiveOfType \
545 saveLowTimeStampCountInto( endStamp ); \
546 addIntervalToHist( startStamp, endStamp, \
547 _VMSMasterEnv->measHists[ReceiveOfTypeHistIdx ] );
465 548
466 //===== 549 //=====
467 550
468 #include "SwitchAnimators.h" 551 #include "SwitchAnimators.h"
469 #include "probes.h" 552 #include "probes.h"