src/ck-perf/trace-projector.C

   1 /***********Projector tracing file added by Sayantan ****************/
   2
   3 #include "charm++.h"
   4 #include "trace-projector.h"
   5 #include "trace-projections.h"
   6
   7 #define DEBUGF(x)           // CmiPrintf x
   8
   9 CkpvStaticDeclare(Trace*, _traceproj);
  10 class UsrEvent {
  11 public:
  12   int e;
  13   char *str;
  14   UsrEvent(int _e, char* _s): e(_e),str(_s) {}
  15 };
  16
  17 CkpvStaticDeclare(CkVec<UsrEvent *>, usrEventsProjector);
  18 #if ! CMK_TRACE_ENABLED
  19 static int warned=0;
  20 #define OPTIMIZED_VERSION       \
  21         if (!warned) { warned=1;        \
  22         CmiPrintf("\n\n!!!! Warning: traceUserEvent not available in optimized version!!!!\n\n\n"); }
  23 #else
  24 #define OPTIMIZED_VERSION /*empty*/
  25 #endif
  26
  27 /**
  28   For each TraceFoo module, _createTraceFoo() must be defined.
  29   This function is called in _createTraces() generated in moduleInit.C
  30 */
  31 void _createTraceprojector(char **argv)
  32 {
  33   DEBUGF(("%d createTraceProjector\n", CkMyPe()));
  34   CkpvInitialize(Trace*, _traceproj);
  35   CkpvInitialize(CkVec<UsrEvent *>, usrEventsProjector);
  36   CkpvAccess(_traceproj) = new  TraceProjector(argv);
  37   CkpvAccess(_traces)->addTrace(CkpvAccess(_traceproj));
  38 }
  39
  40 TraceProjector::TraceProjector(char **argv)
  41 {
  42
  43                 CpvInitialize(int, _traceCoreOn);
  44                 CpvAccess(_traceCoreOn)=1;
  45                 traceCoreOn = 1;
  46
  47 }
  48
  49 int TraceProjector::traceRegisterUserEvent(const char* evt, int e)
  50 {
  51 CkAssert(e==-1 || e>=0);
  52   CkAssert(evt != NULL);
  53   int event;
  54   int biggest = -1;
  55   for (int i=0; i<CkpvAccess(usrEventsProjector).length(); i++) {
  56     int cur = CkpvAccess(usrEventsProjector)[i]->e;
  57     if (cur == e)
  58       CmiAbort("UserEvent double registered!");
  59     if (cur > biggest) biggest = cur;
  60   }
  61   // if biggest is -1, it means no user events were previously registered
  62   // hence automatically assigned events will start from id of 0.
  63   if (e==-1) event = biggest+1; // automatically assign new event id
  64   else event = e;
  65   CkpvAccess(usrEventsProjector).push_back(new UsrEvent(event,(char *)evt));
  66   return event;
  67 }
  68
  69 void TraceProjector::traceClearEps(void)
  70 {
  71   // In trace-summary, this zeros out the EP bins, to eliminate noise
  72   // from startup.  Here, this isn't useful, since we can do that in
  73   // post-processing
  74 }
  75
  76
  77 extern "C" void writeSts(){
  78         FILE *stsfp;
  79         char *fname = new char[strlen(CkpvAccess(traceRoot))+strlen(".sts")+1];
  80         sprintf(fname, "%s.sts", CkpvAccess(traceRoot));
  81         do{
  82                 stsfp = fopen(fname, "w");
  83         } while (!stsfp && (errno == EINTR || errno == EMFILE));
  84         if(stsfp==0)
  85                 CmiAbort("Cannot open projections sts file for writing.\n");
  86         delete[] fname;
  87
  88          fprintf(stsfp, "VERSION %s\n", PROJECTION_VERSION);
  89          traceWriteSTS(stsfp,CkpvAccess(usrEventsProjector).length());
  90          int i;
  91          for(i=0;i<CkpvAccess(usrEventsProjector).length();i++)
  92               fprintf(stsfp, "EVENT %d %s\n", CkpvAccess(usrEventsProjector)[i]->e, CkpvAccess(usrEventsProjector)[i]->str);
  93          fprintf(stsfp, "END\n");
  94         fclose(stsfp);
  95
  96 }
  97
  98
  99 void TraceProjector::traceWriteSts(void)
 100 {
 101         if(CkMyPe()==0)
 102                 writeSts();
 103 }
 104
 105 void TraceProjector::traceClose(void)
 106 {
 107     if(CkMyPe()==0){
 108             writeSts();
 109     }
 110     CkpvAccess(_traceproj)->endComputation();
 111     closeTraceCore();
 112 }
 113
 114 void TraceProjector::traceBegin(void)
 115 {
 116 }
 117
 118 void TraceProjector::traceEnd(void)
 119 {
 120 }
 121
 122 void TraceProjector::userEvent(int e)
 123 {
 124         _LOG_E_USER_EVENT_CHARM(e);
 125 }
 126
 127 void TraceProjector::userBracketEvent(int e, double bt, double et)
 128 {
 129         _LOG_E_USER_EVENT_PAIR_CHARM(e,bt,et);
 130 }
 131
 132 void TraceProjector::creation(envelope *e, int ep,int num)
 133 {
 134         _LOG_E_CREATION_N(e, ep, num);
 135 }
 136
 137 void TraceProjector::beginExecute(envelope *e)
 138 {
 139         //_LOG_E_BEGIN_EXECUTE(e);
 140
 141         charm_beginExecute(e);
 142 }
 143
 144 void TraceProjector::beginExecute(CmiObjId  *tid)
 145 {
 146         // FIXME-- log this
 147
 148         _LOG_E_BEGIN_EXECUTE(0);
 149 }
 150
 151
 152 void TraceProjector::beginExecute(int event,int msgType,int ep,int srcPe,int mlen,CmiObjId *idx)
 153 {
 154         //CmiPrintf("TraceProjector:iData in beginExecuteDetailed %d %d \n",event,srcPe);
 155         _LOG_E_BEGIN_EXECUTE_DETAILED(event, msgType, ep, srcPe, mlen);
 156 }
 157
 158 void TraceProjector::endExecute(void)
 159 {
 160         _LOG_E_END_EXECUTE();
 161 }
 162
 163 void TraceProjector::messageRecv(char *env, int pe)
 164 {
 165         _LOG_E_MSG_RECV_CHARM(env, pe);
 166 }
 167
 168 void TraceProjector::beginIdle(double curWallTime)
 169 {
 170         _LOG_E_PROC_IDLE();
 171 }
 172
 173 void TraceProjector::endIdle(double curWallTime)
 174 {
 175         _LOG_E_PROC_BUSY();
 176 }
 177
 178 void TraceProjector::beginPack(void)
 179 {
 180         _LOG_E_BEGIN_PACK();
 181 }
 182
 183 void TraceProjector::endPack(void)
 184 {
 185         _LOG_E_END_PACK();
 186 }
 187
 188 void TraceProjector::beginUnpack(void)
 189 {
 190         _LOG_E_BEGIN_UNPACK();
 191 }
 192
 193 void TraceProjector::endUnpack(void)
 194 {
 195         _LOG_E_END_UNPACK();
 196 }
 197
 198 void TraceProjector::enqueue(envelope *env)
 199 {
 200         _LOG_E_ENQUEUE(env);
 201 }
 202
 203 void TraceProjector::dequeue(envelope *env)
 204 {
 205         _LOG_E_DEQUEUE(env);
 206 }
 207
 208 void TraceProjector::beginComputation(void)
 209 {
 210         _LOG_E_BEGIN_COMPUTATION();
 211 }
 212
 213 void TraceProjector::endComputation(void)
 214 {
 215         _LOG_E_END_COMPUTATION();
 216 }
 217