Commented out debugging code from inside the CharmMessageHolder class inside
authorLukasz Wesolowski <wesolwsk@illinois.edu>
Fri, 7 Oct 2011 18:47:48 +0000 (13:47 -0500)
committerLukasz Wesolowski <wesolwsk@illinois.edu>
Fri, 7 Oct 2011 18:47:48 +0000 (13:47 -0500)
Comlib. This code was not guarded by a flag and was greatly slowing Comlib
down. Also commented out all calls to the function from other parts of
the code.

src/ck-com/ComlibSectionInfo.C
src/ck-com/ComlibStrategy.h
src/ck-com/EachToManyMulticastStrategy.C
src/ck-com/EachToManyMulticastStrategy.h
src/conv-com/StreamingStrategy.C
src/conv-com/convcomlibmanager.C

index a03c9126ff86fbdcc79aee1719841f293a1d15ba..abdd8a30bc2faebd4a59924ec855c711ff918565 100644 (file)
@@ -30,7 +30,7 @@
 */
 ComlibMulticastMsg * ComlibSectionInfo::getNewMulticastMessage(CharmMessageHolder *cmsg, int needSort, int instanceID){
     
-  cmsg->checkme();
+  //  cmsg->checkme();
 
     if(cmsg->sec_id == NULL || cmsg->sec_id->_nElems == 0)
         return NULL;
@@ -190,7 +190,7 @@ void ComlibSectionInfo::unpack(envelope *cb_env,
 
 
 void ComlibSectionInfo::processOldSectionMessage(CharmMessageHolder *cmsg) {
-  cmsg->checkme();
+  //  cmsg->checkme();
 
     ComlibPrintf("Process Old Section Message \n");
 
index 227c791aaf9631e2f111fc2685a66b28aaf84b79..59ebb18aa4a524c326ab880244658104c03f8df9 100644 (file)
@@ -33,9 +33,9 @@ class CharmMessageHolder : public MessageHolder{
  public:
     /// An unused, and probably unnecessary array that was used to avoid a memory corruption that clobbers members in this class. The bug has likely been fixed.
 
-#define BUGTRAPSIZE 5000
+  //#define BUGTRAPSIZE 5000
 
-    int bug_trap[BUGTRAPSIZE];
+   //    int bug_trap[BUGTRAPSIZE];
 
     /// The section information for an enqueued multicast message
     CkSectionID *sec_id;
@@ -53,14 +53,17 @@ class CharmMessageHolder : public MessageHolder{
       type = t;
       sec_id = NULL;
       copy_of_sec_id = NULL;
+      /*
       for(int i=0;i<BUGTRAPSIZE;i++){
        bug_trap[i] = 0;
       }
       
       checkme();
+      */
     }
     
     /// Verfiy that the bug_trap array has not been corrupted. Noone should ever write to that array.
+    /*
     void checkme() {
        for(int i=0;i<BUGTRAPSIZE;i++){
          if(bug_trap[i] != 0){
@@ -69,19 +72,21 @@ class CharmMessageHolder : public MessageHolder{
          }
        }
     }
-
+    */
 
     CharmMessageHolder(CkMigrateMessage *m) : MessageHolder(m) {
+      /*
       for(int i=0;i<BUGTRAPSIZE;i++){
        bug_trap[i] = 0;
       }
       checkme();
+      */
     }
     
 
 
     ~CharmMessageHolder(){
-      checkme();
+      //      checkme();
     }
 
     inline char * getCharmMessage() {
@@ -92,7 +97,7 @@ class CharmMessageHolder : public MessageHolder{
     inline void saveCopyOf_sec_id(){
       //      ComlibPrintf("[%d] saveCopyOf_sec_id sec_id=%p NULL=%d\n", CkMyPe(), sec_id, NULL);
 
-      checkme();
+      //      checkme();
 
       if(sec_id!=NULL){
 
@@ -122,7 +127,7 @@ class CharmMessageHolder : public MessageHolder{
        //      ComlibPrintf("saving copy of sec_id into %p\n", copy_of_sec_id);
       }
 
-      checkme();
+      //      checkme();
 
     }
 
@@ -135,7 +140,7 @@ class CharmMessageHolder : public MessageHolder{
 /*     copy_of_sec_id = NULL; */
 /*       } */
 
-      checkme();
+//      checkme();
 
     }
 
index 822bd002ff83c7e046549299942b83f6aa2ee532..1d1b67a2ae36ca6e7e0c238c37f0574fe2f58e93 100644 (file)
@@ -96,7 +96,7 @@ EachToManyMulticastStrategy::~EachToManyMulticastStrategy() {
 
 void EachToManyMulticastStrategy::insertMessage(CharmMessageHolder *cmsg){
 
-  cmsg -> checkme();
+  //  cmsg -> checkme();
 
        ComlibPrintf("[%d] EachToManyMulticast: insertMessage\n", CkMyPe());
 
index ff30a8cffa63a2e0eac835db329944fec291df31..90895d20ac9e504ce678d17b0ad273d8378c1929 100644 (file)
@@ -53,7 +53,7 @@ class EachToManyMulticastStrategy : public RouterStrategy, public CharmStrategy
     ~EachToManyMulticastStrategy();
 
     void insertMessage(MessageHolder *msg) {
-      ((CharmMessageHolder*)msg) -> checkme();
+      //      ((CharmMessageHolder*)msg) -> checkme();
       insertMessage((CharmMessageHolder*)msg);
     }
 
index 001ea4d256e8fa8be2b9475e2039b484f1a83f56..b9e09d3c95b1071d4e9fec9e6cd6dd3a666fd84e 100644 (file)
@@ -78,7 +78,7 @@ void StreamingStrategy::insertMessage(MessageHolder *cmsg) {
     streamingMsgBuf[pe].enq(cmsg);
     streamingMsgCount[pe]++;
     bufSize[pe]+=size;
-    if (streamingMsgCount[pe] > bufferMax || bufSize[pe] > bufSizeMax) flushPE(pe);
+    if (streamingMsgCount[pe] >= bufferMax || bufSize[pe] >= bufSizeMax) flushPE(pe);
 }
 
 void StreamingStrategy::doneInserting() {
index 6f4682cd410e2800e2915054265e648195922879..86465b782b436d7158a0a0cd0334ac2a2b4bac4d 100644 (file)
@@ -285,7 +285,7 @@ void ConvComlibManager::enableStrategy(int i) {
   MessageHolder *mh;
   while ((mh=strategyTable[i].tmplist.deq()) != NULL) {
     CharmMessageHolder*cmh = (CharmMessageHolder*)mh;
-    cmh->checkme();
+    //    cmh->checkme();
     cmh->sec_id = cmh->copy_of_sec_id;
 
 #if DEBUG_MULTICAST