Removing CCS tracing code from trace-summary. The working, good version is in trace...
authorIsaac Dooley <idooley2@illinois.edu>
Thu, 18 Jun 2009 20:28:17 +0000 (20:28 +0000)
committerIsaac Dooley <idooley2@illinois.edu>
Thu, 18 Jun 2009 20:28:17 +0000 (20:28 +0000)
src/ck-perf/trace-summary.C
src/ck-perf/trace-summary.ci
src/ck-perf/trace-summary.h
src/ck-perf/trace-summaryBOC.h

index f6b0209d597e24d6c7e1af220538f939f030825f..78b018f3aee955c41488f6aedc03d3fc6e12a298 100644 (file)
@@ -21,7 +21,7 @@
 #define INVALIDEP     -2
 #define TRACEON_EP     -3
 
-// 5 minutes of run before it'll fill up:
+// 1 minutes of run before it'll fill up:
 #define DefaultBinCount      (1000*60*1) 
 
 CkpvStaticDeclare(TraceSummary*, _trace);
@@ -152,38 +152,6 @@ public:
 };
 
 
-/** Define the types used in the gathering of sum detail statistics for use with CCS */
-#define numBins_T int
-#define numProcs_T int
-#define entriesInBin_T short
-#define ep_T short
-#define utilization_T unsigned char
-#define other_EP 10000
-
-
-// Predeclarations of the functions at the bottom of this file
-compressedBuffer compressAvailableNewSumDetail(int max=10000);
-void mergeCompressedBin(compressedBuffer *srcBufferArray, int numSrcBuf, int *numProcsRepresentedInMessage, int totalProcsAcrossAllMessages, compressedBuffer &destBuffer);
-compressedBuffer compressNRecentSumDetail(int desiredBinsToSend);
-void printSumDetailInfo(int desiredBinsToSend);
-CkReductionMsg *sumDetailCompressedReduction(int nMsg,CkReductionMsg **msgs);
-void printCompressedBuf(compressedBuffer b);
-compressedBuffer fakeCompressedMessage();
-compressedBuffer emptyCompressedBuffer();
-void sanityCheckCompressedBuf(compressedBuffer b);
-bool isCompressedBufferSane(compressedBuffer b);
-double averageUtilizationInBuffer(compressedBuffer b);
-
-
-
-/// A reduction type for merging compressed sum detail data
-CkReduction::reducerType sumDetailCompressedReducer;
-/// An initnode registration function for the reducer
-void registerIdleTimeReduction(void) {
-  CkAssert(sizeof(short) == 2);
-  sumDetailCompressedReducer=CkReduction::addReducer(sumDetailCompressedReduction);
-}
-
 
 
 // Global Readonly
@@ -949,8 +917,6 @@ void TraceSummaryBOC::initCCS() {
                         CkCallback(CkIndex_TraceSummaryBOC::ccsRequestSummaryDouble(NULL), sumProxy[0]));
       CcsRegisterHandler("CkPerfSummaryCcsClientCB uchar", 
                         CkCallback(CkIndex_TraceSummaryBOC::ccsRequestSummaryUnsignedChar(NULL), sumProxy[0])); 
-      CcsRegisterHandler("CkPerfSumDetail compressed", 
-                        CkCallback(CkIndex_TraceSummaryBOC::ccsRequestSumDetailCompressed(NULL), sumProxy[0])); 
 
       CkPrintf("[%d] Setting up periodic startCollectData callback\n", CkMyPe());
       CcdCallOnConditionKeep(CcdPERIODIC_1second, startCollectData,
@@ -1034,58 +1000,6 @@ void TraceSummaryBOC::ccsRequestSummaryUnsignedChar(CkCcsRequestMsg *m) {
 }
 
 
-/**
-
-Send back to the client compressed sum-detail style measurements about the 
-utilization for each active PE combined across all PEs.
-
-The data format sent by this handler is a bunch of records(one for each bin) of the following format:
-   #samples (EP,utilization)* 
-
-One example record for two EPS that executed during the sample period. 
-EP 3 used 150/200 of the time while EP 122 executed for 20/200 of the time. 
-All of these would be packed as bytes into the message:
-2 3 150 122 20
-
- */
-void TraceSummaryBOC::ccsRequestSumDetailCompressed(CkCcsRequestMsg *m) {
-  CkPrintf("CCS request for compressed sum detail. (found %d stored in deque)\n",  storedSumDetailResults.size() );
-  CkAssert(sumDetail);
-  int datalength;
-
-#if 0
-
-  compressedBuffer fakeMessage = fakeCompressedMessage();
-  CcsSendDelayedReply(m->reply, fakeMessage.datalength(), fakeMessage.buffer() );
-  fakeMessage.freeBuf();
-
-#else
-
-  if (storedSumDetailResults.size()  == 0) {
-    compressedBuffer b = emptyCompressedBuffer();
-    CcsSendDelayedReply(m->reply, b.datalength(), b.buffer()); 
-    b.freeBuf();
-  } else {
-    CkReductionMsg * msg = storedSumDetailResults.front();
-    storedSumDetailResults.pop_front();
-
-    
-    void *sendBuffer = (void *)msg->getData();
-    datalength = msg->getSize();
-    CcsSendDelayedReply(m->reply, datalength, sendBuffer);
-    
-    delete msg;
-  }
-    
-  
-#endif
-
-  CkPrintf("CCS response of %d bytes sent.\n", datalength);
-  delete m;
-}
-
-
-
 
 void startCollectData(void *data, double currT) {
   CkAssert(CkMyPe() == 0);
@@ -1105,14 +1019,9 @@ void startCollectData(void *data, double currT) {
   //   if it proves to be a problem.
   CProxy_TraceSummaryBOC sumProxy(traceSummaryGID);
 
-//   sumProxy.collectSummaryData(startTime, 
-//                    collectionGranularity,
-//                    numBlocksToGet*indicesPerBlock);
-
-  sumProxy.collectSumDetailData(startTime, 
+   sumProxy.collectSummaryData(startTime, 
                       collectionGranularity,
-                      1000);
-
+                      numBlocksToGet*indicesPerBlock);
   // assume success
   sumObj->lastRequestedIndexBlock += numBlocksToGet; 
 }
@@ -1155,45 +1064,6 @@ void TraceSummaryBOC::summaryDataCollected(CkReductionMsg *msg) {
 }
 
 
-void TraceSummaryBOC::collectSumDetailData(double startTime, double binSize, int numBins) {
-  
-  
-  printSumDetailInfo(numBins);
-  compressedBuffer b = compressNRecentSumDetail(numBins);
-  //  CkPrintf("[%d] contributing buffer created by compressNRecentSumDetail: \n", CkMyPe());
-  //  printCompressedBuf(b);
-  
-  
-  
-#if 0
-  b = fakeCompressedMessage();
-#endif
-  
-  //  CkPrintf("[%d] contributing %d bytes worth of SumDetail data\n", CkMyPe(), b.datalength());
-  
-  //  CProxy_TraceSummaryBOC sumProxy(traceSummaryGID);
-  CkCallback cb(CkIndex_TraceSummaryBOC::sumDetailDataCollected(NULL), thisProxy[0]);
-  contribute(b.datalength(), b.buffer(), sumDetailCompressedReducer, cb);
-  
-  b.freeBuf();
-}
-
-
-void TraceSummaryBOC::sumDetailDataCollected(CkReductionMsg *msg) {
-  CkAssert(CkMyPe() == 0);
-  CkPrintf("[%d] Reduction of SumDetail completed. Result stored in storedSumDetailResults deque(sizes=%d)\n", CkMyPe(), storedSumDetailResults.size() );
-  fflush(stdout);
-
-  //  printCompressedBuf(msg->getData());
-  //  CkPrintf("Sanity Checking buffer before putting in storedSumDetailResults\n");
-  compressedBuffer b(msg->getData());
-  //  CkPrintf("---------------------------------------- putting CCS reply in queue (average utilization= %lf)\n", averageUtilizationInBuffer(b));
-  if(isCompressedBufferSane(b)){
-    storedSumDetailResults.push_back(msg); 
-  }
-}
-
-
 
 
 void TraceSummaryBOC::startSumOnly()
@@ -1325,455 +1195,6 @@ void initTraceSummaryBOC()
 
 
 
-
-////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-
-
-  
-/// Compress a buffer by merging all entries in a bin that are less than the threshold into a single "other" category
-  compressedBuffer moveTinyEntriesToOther(compressedBuffer src, double threshold){
-    //    CkPrintf("[%d] moveTinyEntriesToOther\n", CkMyPe());
-    
-    // reset the src buffer to the beginning
-    src.pos = 0;
-
-    compressedBuffer dest(100000); 
-    
-    int numBins = src.pop<numBins_T>();
-    int numProcs = src.pop<numProcs_T>();
-    
-    dest.push<numBins_T>(numBins);
-    dest.push<numProcs_T>(numProcs);
-    
-    
-    for(int i=0;i<numBins;i++){
-      double utilizationInOther = 0.0;
-      
-      entriesInBin_T numEntriesInSrcBin = src.pop<entriesInBin_T>();
-      int numEntriesInDestBinOffset = dest.push<entriesInBin_T>(0);
-      
-      CkAssert(numEntriesInSrcBin < 200);
-
-      for(int j=0;j<numEntriesInSrcBin;j++){
-       ep_T ep = src.pop<ep_T>();
-       double v = src.pop<utilization_T>();
-       
-       if(v < threshold * 250.0){
-         // do not copy bin into destination
-         utilizationInOther += v / 250.0;
-       } else {
-         // copy bin into destination
-         dest.increment<entriesInBin_T>(numEntriesInDestBinOffset);
-         dest.push<ep_T>(ep);
-         dest.push<utilization_T>(v);
-       }
-
-      }
-      
-      // if other category has stuff in it, add it to the destination buffer
-      if(utilizationInOther > 0.0){
-       dest.increment<entriesInBin_T>(numEntriesInDestBinOffset);
-       dest.push<ep_T>(other_EP);
-       if(utilizationInOther > 1.0)
-         utilizationInOther = 1.0;
-       dest.push<utilization_T>(utilizationInOther*250.0);
-      }
-      
-    }
-   
-    return dest;
-  }
-  
-    
-
-
-
-
-
-/// A reducer for merging compressed sum detail data
-CkReductionMsg *sumDetailCompressedReduction(int nMsg,CkReductionMsg **msgs){
-  // CkPrintf("[%d] sumDetailCompressedReduction(nMsgs=%d)\n", CkMyPe(), nMsg);
-  
-  compressedBuffer *incomingMsgs = new compressedBuffer[nMsg];
-  int *numProcsRepresentedInMessage = new int[nMsg];
-  
-  int numBins = 0;
-  int totalsize = 0;
-  int totalProcsAcrossAllMessages = 0;
-  
-  for (int i=0;i<nMsg;i++) {
-    incomingMsgs[i].init(msgs[i]->getData());
-    
-    //  CkPrintf("[%d] Incoming reduction message %d has average utilization %lf\n", CkMyPe(),  i, averageUtilizationInBuffer(incomingMsgs[i])); 
-    //   CkPrintf("Is buffer %d sane? %s\n", i, isCompressedBufferSane(incomingMsgs[i]) ? "yes": "no" );
-
-
-    totalsize += msgs[i]->getSize();
-    //  CkPrintf("BEGIN MERGE MESSAGE=========================================================\n");
-    //   printCompressedBuf(incomingMsgs[i]);
-    
-    // Read first value from message. 
-    // Make sure all messages have the same number of bins
-    if(i==0)
-      numBins = incomingMsgs[i].pop<numBins_T>();
-    else 
-      CkAssert( numBins ==  incomingMsgs[i].pop<numBins_T>() );
-    
-    // Read second value from message. 
-    numProcsRepresentedInMessage[i] = incomingMsgs[i].pop<numProcs_T>();
-    totalProcsAcrossAllMessages += numProcsRepresentedInMessage[i];
-    //    CkPrintf("Number of procs in message[%d] is %d\n", i,  (int)numProcsRepresentedInMessage[i]);
-  }
-  
-  compressedBuffer dest(totalsize + 100); 
-  
-  // build a compressed representation of each merged bin
-  dest.push<numBins_T>(numBins);
-  dest.push<numProcs_T>(totalProcsAcrossAllMessages);
-  
-  for(int i=0; i<numBins; i++){
-    mergeCompressedBin(incomingMsgs, nMsg, numProcsRepresentedInMessage, totalProcsAcrossAllMessages, dest);
-  }
-  
-  // CkPrintf("END MERGE RESULT=========================================================\n");
-  // printCompressedBuf(dest);
-
-
-  //CkPrintf("[%d] Merged buffer has average utilization %lf \n", CkMyPe(), averageUtilizationInBuffer(dest));
-
-  //CkPrintf("Is resulting merged buffer sane? %s\n", isCompressedBufferSane(dest) ? "yes": "no" );  
-  
-  compressedBuffer dest2 = moveTinyEntriesToOther(dest, 0.15);
-  
-  //  CkPrintf("Is resulting merged Filtered buffer sane? %s\n", isCompressedBufferSane(dest2) ? "yes": "no" ); 
-
-  //  CkPrintf("[%d] Outgoing reduction (filtered) message has average utilization %lf \n", CkMyPe(), averageUtilizationInBuffer(dest2));
-
-  
-  CkReductionMsg *m = CkReductionMsg::buildNew(dest2.datalength(),dest2.buffer());   
-  dest.freeBuf();
-  delete[] incomingMsgs;
-  return m;
-}
-
-
-
-
-
-
-
-/// Create fake sum detail data in the compressed format (for debugging)
- compressedBuffer fakeCompressedMessage(){
-   CkPrintf("[%d] fakeCompressedMessage\n", CkMyPe());
-   
-   compressedBuffer fakeBuf(10000);
-   
-   int numBins = 55;
-   int totalsize = 0;
-   int numProcs = 1000;
-
-   // build a compressed representation of each merged bin
-   fakeBuf.push<numBins_T>(numBins);
-   fakeBuf.push<numProcs_T>(numProcs);
-   for(int i=0; i<numBins; i++){
-     int numRecords = 3;
-     fakeBuf.push<entriesInBin_T>(numRecords);
-     for(int j=0;j<numRecords;j++){
-       fakeBuf.push<ep_T>(j*10+2);
-       fakeBuf.push<utilization_T>(120.00);
-     }  
-   }
-   
-   //CkPrintf("Fake Compressed Message:=========================================================\n");
-   //   printCompressedBuf(fakeBuf);
-
-   CkAssert(isCompressedBufferSane(fakeBuf));
-
-   return fakeBuf;
- }
-
-
- /// Create an empty message
- compressedBuffer emptyCompressedBuffer(){
-   compressedBuffer result(sizeof(numBins_T));
-   result.push<numBins_T>(0);
-   return result;
- }
-
-
-
-
-/// Create a compressed buffer of the sum detail samples that occured since the previous call to this function (default max of 10000 bins).
-compressedBuffer compressAvailableNewSumDetail(int max){
-  const SumLogPool * p = CkpvAccess(_trace)->pool();
-  const int numBinsAvailable = p->getNumEntries();
-  int binsToSend = numBinsAvailable - CkpvAccess(previouslySentBins);
-  if(binsToSend > max)
-    binsToSend = max;
-
-  return compressNRecentSumDetail(binsToSend);
-}
-
-
-
-
-
-/** print out the compressed buffer starting from its begining*/
-void printCompressedBuf(compressedBuffer b){
-  // b should be passed in by value, and hence we can modify it
-  b.pos = 0;
-  int numEntries = b.pop<numBins_T>();
-  CkPrintf("Buffer contains %d records\n", numEntries);
-  int numProcs = b.pop<numProcs_T>();
-  CkPrintf("Buffer represents an average over %d PEs\n", numProcs);
-
-  for(int i=0;i<numEntries;i++){
-    entriesInBin_T recordLength = b.pop<entriesInBin_T>();
-    if(recordLength > 0){
-      CkPrintf("    Record %d is of length %d : ", i, recordLength);
-      
-      for(int j=0;j<recordLength;j++){
-       ep_T ep = b.pop<ep_T>();
-       utilization_T v = b.pop<utilization_T>();
-       CkPrintf("(%d,%f) ", ep, v);
-      }
-    
-      CkPrintf("\n");
-    }
-  }
-}
-
-
-
- bool isCompressedBufferSane(compressedBuffer b){
-   // b should be passed in by value, and hence we can modify it  
-   b.pos = 0;  
-   numBins_T numBins = b.pop<numBins_T>();  
-   numProcs_T numProcs = b.pop<numProcs_T>();  
-   
-   if(numBins > 2000){
-     ckout << "WARNING: numBins=" << numBins << endl;
-     return false;
-   }
-   
-   for(int i=0;i<numBins;i++){  
-     entriesInBin_T recordLength = b.pop<entriesInBin_T>();  
-     if(recordLength > 200){
-       ckout << "WARNING: recordLength=" << recordLength << endl;
-       return false;
-     }
-     
-     if(recordLength > 0){  
-       
-       for(int j=0;j<recordLength;j++){  
-         ep_T ep = b.pop<ep_T>();  
-         utilization_T v = b.pop<utilization_T>();  
-         //      CkPrintf("(%d,%f) ", ep, v);  
-        if(((ep>800 || ep <0 ) && ep != other_EP) || v < 0.0 || v > 251.0){
-          ckout << "WARNING: ep=" << ep << " v=" << v << endl;
-          return false;
-        }
-       }  
-       
-     }  
-   }  
-   
-   return true;
- }
-
-
-
- double averageUtilizationInBuffer(compressedBuffer b){
-   // b should be passed in by value, and hence we can modify it  
-   b.pos = 0;  
-   numBins_T numBins = b.pop<numBins_T>();  
-   numProcs_T numProcs = b.pop<numProcs_T>();  
-   
-   //   CkPrintf("[%d] averageUtilizationInBuffer numProcs=%d   (grep reduction message)\n", CkMyPe(), numProcs);
-   
-   double totalUtilization = 0.0;
-   
-   for(int i=0;i<numBins;i++) {  
-     entriesInBin_T entriesInBin = b.pop<entriesInBin_T>();     
-     for(int j=0;j<entriesInBin;j++){  
-       ep_T ep = b.pop<ep_T>();  
-       totalUtilization +=  b.pop<utilization_T>();  
-     }
-   }
-   
-   return totalUtilization / numBins / 2.5;
- }
-
- void sanityCheckCompressedBuf(compressedBuffer b){  
-   CkAssert(isCompressedBufferSane(b)); 
- }  
-
-
- /// Print out some information about the sum detail statistics.
- void printSumDetailInfo(int desiredBinsToSend){
-   //   CkPrintf("printSumDetailInfo(desiredBinsToSend=%d)\n", desiredBinsToSend);
-
-   int _numEntries=_entryTable.size();
-   SumLogPool * p = CkpvAccess(_trace)->pool();
-   int numBinsAvailable = p->getNumEntries();
-
-   int binsToSend = desiredBinsToSend;
-   if(binsToSend > numBinsAvailable)
-     binsToSend = numBinsAvailable;
-
-   int startBin = numBinsAvailable - binsToSend;
-  
-   //CkPrintf("printSumDetailInfo() binsToSend=%d\n", binsToSend);
-
-   if (binsToSend < 1) {
-     //CkPrintf("printSumDetailInfo() No Bins\n");
-   } else {
-     double u = 0.0;
-
-     for(int i=0; i<binsToSend; i++) {
-       for(int e=0; e<_numEntries; e++) {
-        u += p->getUtilization(i+startBin,e);
-       }
-     }
-    
-     double uu = u / binsToSend;
-     
-     // CkPrintf("printSumDetailInfo()                         uu = %lf\n", uu);
-            
-   }
-   
- }
-
-
- /// Create a compressed buffer of the n most recent sum detail samples
- compressedBuffer compressNRecentSumDetail(int desiredBinsToSend){
-   //   CkPrintf("compressNRecentSumDetail(desiredBinsToSend=%d)\n", desiredBinsToSend);
-
-   int _numEntries=_entryTable.size();
-   SumLogPool * p = CkpvAccess(_trace)->pool();
-   int numBinsAvailable = p->getNumEntries();
-
-   int binsToSend = desiredBinsToSend;
-   if(binsToSend > numBinsAvailable)
-     binsToSend = numBinsAvailable;
-
-   int startBin = numBinsAvailable - binsToSend;
-  
-   //   CkPrintf("compressNRecentSumDetail binsToSend=%d\n", binsToSend);
-
-   if (binsToSend < 1) {
-     return emptyCompressedBuffer();
-   } else {
-     compressedBuffer b(8*(2+_numEntries) * (2+binsToSend)+100);
-
-     b.push<numBins_T>(binsToSend);
-     b.push<numProcs_T>(1); // number of processors along reduction subtree. I am just one processor.
-
-     for(int i=0; i<binsToSend; i++) {
-       // Create a record for bin i
-       //  CkPrintf("Adding record for bin %d\n", i);
-       int numEntriesInRecordOffset = b.push<entriesInBin_T>(0); // The number of entries in this record
-       
-       for(int e=0; e<_numEntries; e++) {
-        double scaledUtilization = p->getUtilization(i+startBin,e) * 2.5; // use range of 0 to 250 for the utilization, so it can fit in an unsigned char
-        if(scaledUtilization > 250.0)
-          scaledUtilization = 250.0;
-        
-        if(scaledUtilization > 0.0) {
-          //      CkPrintf("Adding non-zero entry (%d,%lf) to bin %d\n", e, scaledUtilization, i);
-          b.push<ep_T>(e);
-          b.push<utilization_T>(scaledUtilization);
-          b.increment<entriesInBin_T>(numEntriesInRecordOffset);
-        } else{
-          
-        }
-       }
-     }
-
-
-     //     CkPrintf("[%d] compressNRecentSumDetail resulting buffer: averageUtilizationInBuffer()=%lf\n", CkMyPe(), averageUtilizationInBuffer(b));
-     
-     CkpvAccess(previouslySentBins) += binsToSend;    
-     return b;
-   }
-   
- }
-
-
-
-/** Merge the compressed entries from the first bin in each of the srcBuf buffers.
-     
-*/
- void mergeCompressedBin(compressedBuffer *srcBufferArray, int numSrcBuf, int *numProcsRepresentedInMessage, int totalProcsAcrossAllMessages, compressedBuffer &destBuf){
-  // put a counter at the beginning of destBuf
-  int numEntriesInDestRecordOffset = destBuf.push<entriesInBin_T>(0);
-  
-  //  CkPrintf("BEGIN MERGE------------------------------------------------------------------\n");
-  
-  // Read off the number of bins in each buffer
-  int *remainingEntriesToRead = new int[numSrcBuf];
-  for(int i=0;i<numSrcBuf;i++){
-    remainingEntriesToRead[i] = srcBufferArray[i].pop<entriesInBin_T>();
-  }
-
-  int count = 0;
-  // Count remaining entries to process
-  for(int i=0;i<numSrcBuf;i++){
-    count += remainingEntriesToRead[i];
-  }
-  
-  while (count>0) {
-    // find first EP from all buffers (these are sorted by EP already)
-    int minEp = 10000;
-    for(int i=0;i<numSrcBuf;i++){
-      if(remainingEntriesToRead[i]>0){
-       int ep = srcBufferArray[i].peek<ep_T>();
-       if(ep < minEp){
-         minEp = ep;
-       }
-      }
-    }
-    
-    //   CkPrintf("[%d] mergeCompressedBin minEp found was %d   totalProcsAcrossAllMessages=%d\n", CkMyPe(), minEp, (int)totalProcsAcrossAllMessages);
-    
-    destBuf.increment<entriesInBin_T>(numEntriesInDestRecordOffset);
-
-    // Merge contributions from all buffers that list the EP
-    double v = 0.0;
-    for(int i=0;i<numSrcBuf;i++){
-      if(remainingEntriesToRead[i]>0){
-       int ep = srcBufferArray[i].peek<ep_T>(); 
-       if(ep == minEp){
-         srcBufferArray[i].pop<ep_T>();  // pop ep
-         double util = srcBufferArray[i].pop<utilization_T>();
-         v += util * numProcsRepresentedInMessage[i];
-         remainingEntriesToRead[i]--;
-         count --;
-       }
-      }
-    }
-
-    // create a new entry in the output for this EP.
-    destBuf.push<ep_T>(minEp);
-    destBuf.push<utilization_T>(v / (double)totalProcsAcrossAllMessages);
-
-  }
-
-
-  delete [] remainingEntriesToRead;
-  // CkPrintf("[%d] End of mergeCompressedBin:\n", CkMyPe() );
-  // CkPrintf("END MERGE ------------------------------------------------------------------\n");
- }
-
-
-
-
-
-
 #include "TraceSummary.def.h"
 
 
index 443f8a47c3558ca9db280b1f22804f2b2af041be..dc90df3c9deb2a940a4d8429ab5447d79aaf83a6 100644 (file)
@@ -9,7 +9,6 @@ module TraceSummary {
   };
 
   initnode void initTraceSummaryBOC();
-  initnode void registerIdleTimeReduction();
 
   group [migratable] TraceSummaryBOC {
     entry TraceSummaryBOC(void);
@@ -22,14 +21,10 @@ module TraceSummary {
     // The ccs handlers:
     entry void ccsRequestSummaryDouble(CkCcsRequestMsg *m);
     entry void ccsRequestSummaryUnsignedChar(CkCcsRequestMsg *m);
-    entry void ccsRequestSumDetailCompressed(CkCcsRequestMsg *m);
 
     entry void collectSummaryData(double startTime, double binSize, int numBins);
     entry void summaryDataCollected(CkReductionMsg *);
 
-    entry void collectSumDetailData(double startTime, double binSize, int numBins);
-    entry void sumDetailDataCollected(CkReductionMsg *);
-
   };
 
 };
index 1f169a7097a7db550977c5717f8b0a8d3741a9cd..7372587b6db05d55b56161d9a3c797dbf45ec5b0 100644 (file)
@@ -210,7 +210,6 @@ class SumLogPool {
     void startPhase(int phase) { phaseTab.startPhase(phase); }
     BinEntry *bins() { return pool; }
     int getNumEntries() const { return numBins; }
-    void updateSummaryDetail(int epIdx, double startTime, double endTime);
 
     // accessors to normal summary data
     inline double getTime(unsigned int interval) {
@@ -240,6 +239,9 @@ class SumLogPool {
     inline int getUtilization(int interval, int ep);
 
 
+    void updateSummaryDetail(int epIdx, double startTime, double endTime);
+
+
 };
 
 /// class for recording trace summary events 
index c5fe94e81429da31ede876d4c8627dc4b067b619..fa6eb1690e1aa0fcba0e8074c9dd5fbc68506453 100644 (file)
@@ -37,8 +37,6 @@ public:
   int nBufferedBins;
   CkVec<double> *ccsBufferedData;
   int nextBinIndexCcs;
-  std::deque<CkReductionMsg *> storedSumDetailResults;
-
 
 public:
   TraceSummaryBOC(void): count(0), bins(NULL), nBins(0), 
@@ -52,14 +50,9 @@ public:
   void initCCS();
   void ccsRequestSummaryDouble(CkCcsRequestMsg *m);
   void ccsRequestSummaryUnsignedChar(CkCcsRequestMsg *m);
-  void ccsRequestSumDetailUnsignedChar(CkCcsRequestMsg *m);
-  void ccsRequestSumDetailCompressed(CkCcsRequestMsg *m);
-  void ccsRequestSumDetailCompressedPE0(CkCcsRequestMsg *m);
 
   void collectSummaryData(double startTime, double binSize, int numBins);
   void summaryDataCollected(CkReductionMsg *);
-  void collectSumDetailData(double startTime, double binSize, int numBins);
-  void sumDetailDataCollected(CkReductionMsg *);
 
 private:
   void write();