Including _FAULT_CAUSAL_ in all related files.
authorEsteban Meneses <emenese2@illinois.edu>
Wed, 17 Mar 2010 15:54:24 +0000 (10:54 -0500)
committerEsteban Meneses <emenese2@illinois.edu>
Wed, 17 Mar 2010 15:54:24 +0000 (10:54 -0500)
24 files changed:
src/arch/net/charmrun/charmrun.c
src/arch/util/immediate.c
src/ck-core/charm++.h
src/ck-core/ck.C
src/ck-core/ckarray.C
src/ck-core/ckarray.h
src/ck-core/ckarrayreductionmgr.C
src/ck-core/ckcausalmlog.C
src/ck-core/ckcheckpoint.C
src/ck-core/ckcheckpoint.h
src/ck-core/cklocation.C
src/ck-core/cklocation.h
src/ck-core/ckreduction.C
src/ck-core/ckreduction.h
src/ck-core/envelope.h
src/ck-core/init.C
src/ck-ldb/BaseLB.h
src/ck-ldb/CentralLB.C
src/ck-ldb/CentralLB.h
src/ck-ldb/LBDBManager.h
src/conv-core/msgmgr.c
src/libs/ck-libs/ampi/ampi.C
src/libs/ck-libs/tcharm/tcharm.C
src/util/ckhashtable.h

index 8777ae7eb8ae13381b792037ac45562034fc41ed..014e70af2fb7e586fa7ffea903b9a4bec4eda662 100644 (file)
@@ -626,7 +626,7 @@ int   arg_help;             /* print help message */
 int   arg_ppn;         /* pes per node */
 int   arg_usehostname;
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 int     arg_read_pes=0;
 #endif
 
@@ -672,7 +672,7 @@ void arg_init(int argc, char **argv)
   pparam_flag(&arg_verbose,      0, "verbose",       "Print diagnostic messages");
   pparam_str(&arg_nodelist,      0, "nodelist",      "file containing list of nodes");
   pparam_str(&arg_nodegroup,"main", "nodegroup",     "which group of nodes to use");
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        pparam_int(&arg_read_pes, 0, "readpe",             "number of host names to read into the host table");
 #endif
 
@@ -932,7 +932,7 @@ int           nodetab_size;
 int          *nodetab_rank0_table;
 int           nodetab_rank0_size;
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 int                     loaded_max_pe;
 #endif
 
@@ -1038,7 +1038,7 @@ void nodetab_init_for_local()
   int tablesize, i, done=0;
   nodetab_host group;
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     if(arg_read_pes == 0){
         arg_read_pes = arg_requested_pes;
     }
@@ -1091,7 +1091,7 @@ void nodetab_init()
     exit(1);
   }
  
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        if(arg_read_pes == 0){
         arg_read_pes = arg_requested_pes;
     }
@@ -1111,7 +1111,7 @@ void nodetab_init()
   rightgroup = (strcmp(arg_nodegroup,"main")==0);
   
   while(fgets(input_line,sizeof(input_line)-1,f)!=0) {
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        if (nodetab_size == arg_read_pes) break;
 #else
     if (nodetab_size == arg_requested_pes) break;
@@ -1165,7 +1165,7 @@ fin:
       nodetab_table[i]->cpus = remain;
   }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        loaded_max_pe = arg_requested_pes-1;
 #endif
 
@@ -1617,7 +1617,7 @@ int req_handle_ending(ChMessage *msg,SOCKET fd)
   int i;
   req_ending++;
 
-#ifndef _FAULT_MLOG_    
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))    
        if (req_ending == nodetab_size)
 #else
        if(req_ending == arg_requested_pes)
@@ -1697,7 +1697,7 @@ void anounce_crash(int socket_index,int crashed_node);
 static int _last_crash = 0;                    /* last crashed pe number */
 static int _crash_socket_index = 0;            /* last restart socket */
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 static int numCrashes=0;  /*number of crashes*/
 static SOCKET last_crashed_fd=-1;
 #endif
@@ -1713,7 +1713,7 @@ int req_handle_crashack(ChMessage *msg,SOCKET fd)
     req_handle_initnodetab(NULL,req_clients[_crash_socket_index]);
     _last_crash = 0;
     count = 0;
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        last_crashed_fd=-1;
 #endif
   }
@@ -1732,7 +1732,7 @@ void error_in_req_serve_client(SOCKET fd){
                }
        }
        fflush(stdout);
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
        skt_close(fd);
 #endif
        crashed_pe = i;
@@ -1759,7 +1759,7 @@ void error_in_req_serve_client(SOCKET fd){
        }       
        socket_index = i;
        reconnect_crashed_client(socket_index,crashed_node);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        skt_close(fd);
 #endif
 }
@@ -1777,7 +1777,7 @@ int req_handler_dispatch(ChMessage *msg,SOCKET replyFd)
   /* grab request data */
   recv_status = ChMessageData_recv(replyFd,msg);
 #ifdef __FAULT__
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
  if(recv_status < 0){
         if(replyFd == last_crashed_fd){
             return REQ_OK;
@@ -3434,12 +3434,12 @@ void refill_nodetab_entry(int crashed_node){
        int pe =  nodetab_rank0_table[crashed_node];
        nodetab_host *h = nodetab_table[pe];
        *h = *(replacement_host(pe));
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 fprintf(stderr,"Charmrun>>> New pe %d is on host %s \n",pe,nodetab_name(pe));
 #endif
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 nodetab_host *replacement_host(int pe){
     int x=loaded_max_pe+1;
 
index 69f9d192ffd447204ca10dbc4ad424dbd5291a42..9bf027c18b2a294c6747806d21c87df287e79ffa 100644 (file)
@@ -71,7 +71,7 @@ SMP: This routine must be called holding immRecvLock
  */
 void CmiHandleImmediateMessage(void *msg) {
 /*  int handlerNo=CmiGetXHandler(msg); */
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CmiAssert(0);
 #endif
   int handlerNo=CmiImmediateHandler(msg);
index a61b647c923605f097741bec33c4da4d3b281c8b..e13c1e4fd2cf24230d765c4d36c4bcd61cdc99d0 100644 (file)
@@ -405,7 +405,7 @@ PUPmarshall(CkArrayID)
 #include "ckobjQ.h"
 
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 class ChareMlogData;
 #endif
 
@@ -424,7 +424,7 @@ class Chare {
 #ifndef CMK_CHARE_USE_PTR
     int chareIdx;                  // index in the chare obj table (chare_objs)
 #endif
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     ChareMlogData *mlogData;
 #endif
     Chare(CkMigrateMessage *m);
@@ -1116,7 +1116,7 @@ if(CpvAccess(networkProgressCount) >=  p)  \
 #endif
 
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 #include "ckmessagelogging.h"
 #endif
 #include "ckmemcheckpoint.h"
index e54fbf0fe16646d24396d7b66cc56d0684fee046..f03355c84bbc6c9b2487f6bc89936a8aa1c7a609 100644 (file)
@@ -67,7 +67,7 @@ Chare::Chare(void) {
      // for plain chare, objPtr is actually the index to chare obj table
   if (chareIdx >= 0) thishandle.objPtr=(void*)chareIdx;
 #endif
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
   mlogData = new ChareMlogData();
   mlogData->objID.type = TypeChare;
   mlogData->objID.data.chare.id = thishandle;
@@ -81,7 +81,7 @@ Chare::Chare(CkMigrateMessage* m) {
   thishandle.onPE=CkMyPe();
   thishandle.objPtr=this;
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         mlogData = NULL;
 #endif
 
@@ -132,7 +132,7 @@ void Chare::pup(PUP::er &p)
   p(chareIdx);
   if (chareIdx != -1) thishandle.objPtr=(void*)chareIdx;
 #endif
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        if(p.isUnpacking()){
                if(mlogData == NULL || !mlogData->teamRecoveryFlag)
                mlogData = new ChareMlogData();
@@ -175,7 +175,7 @@ void CkMessage::ckDebugPup(PUP::er &p,void *msg) {
 
 IrrGroup::IrrGroup(void) {
   thisgroup = CkpvAccess(_currentGroup);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         mlogData->objID.type = TypeGroup;
         mlogData->objID.data.group.id = thisgroup;
         mlogData->objID.data.group.onPE = CkMyPe();
@@ -509,7 +509,7 @@ extern "C" int CkGetArgc(void) {
 /******************** Basic support *****************/
 extern "C" void CkDeliverMessageFree(int epIdx,void *msg,void *obj)
 {
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CpvAccess(_currentObj) = (Chare *)obj;
 //      printf("[%d] CurrentObj set to %p\n",CkMyPe(),obj);
 #endif
@@ -535,7 +535,7 @@ extern "C" void CkDeliverMessageReadonly(int epIdx,const void *msg,void *obj)
   //fflush(stdout);
 
   void *deliverMsg;
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CpvAccess(_currentObj) = (Chare *)obj;
 #endif
   if (_entryTable[epIdx]->noKeep)
@@ -1100,7 +1100,7 @@ void _processHandler(void *converseMsg,CkCoreState *ck)
     if (!ck->watcher->processMessage(env,ck)) return;
   }
 //#endif
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         Chare *obj=NULL;
         CkObjID sender;
         MCount SN;
@@ -1201,7 +1201,7 @@ void _processHandler(void *converseMsg,CkCoreState *ck)
     default:
       CmiAbort("Fatal Charm++ Error> Unknown msg-type in _processHandler.\n");
   }
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         if(obj != NULL){
                 postProcessReceivedMessage(obj,sender,SN,entry);
         }
@@ -1327,7 +1327,7 @@ void _skipCldEnqueue(int pe,envelope *env, int infoFn)
 #endif
     CmiSetInfo(env,infoFn);
     if (pe==CLD_BROADCAST) {
-#ifdef _FAULT_MLOG_             
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))             
                         CmiSyncBroadcast(len, (char *)env);
 #else
                        CmiSyncBroadcastAndFree(len, (char *)env); 
@@ -1335,7 +1335,7 @@ void _skipCldEnqueue(int pe,envelope *env, int infoFn)
 
 }
     else if (pe==CLD_BROADCAST_ALL) { 
-#ifdef _FAULT_MLOG_             
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))             
                         CmiSyncBroadcastAll(len, (char *)env);
 #else
                         CmiSyncBroadcastAllAndFree(len, (char *)env);
@@ -1343,7 +1343,7 @@ void _skipCldEnqueue(int pe,envelope *env, int infoFn)
 
 }
     else{
-#ifdef _FAULT_MLOG_             
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))             
                         CmiSyncSend(pe, len, (char *)env);
 #else
                         CmiSyncSendAndFree(pe, len, (char *)env);
@@ -1409,14 +1409,14 @@ void _noCldNodeEnqueue(int node, envelope *env)
   CkPackMessage(&env);
   int len=env->getTotalsize();
   if (node==CLD_BROADCAST) { 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CmiSyncNodeBroadcast(len, (char *)env);
 #else
        CmiSyncNodeBroadcastAndFree(len, (char *)env); 
 #endif
 }
   else if (node==CLD_BROADCAST_ALL) { 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
                 CmiSyncNodeBroadcastAll(len, (char *)env);
 #else
                CmiSyncNodeBroadcastAllAndFree(len, (char *)env); 
@@ -1424,7 +1424,7 @@ void _noCldNodeEnqueue(int node, envelope *env)
 
 }
   else {
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CmiSyncNodeSend(node, len, (char *)env);
 #else
        CmiSyncNodeSendAndFree(node, len, (char *)env);
@@ -1590,7 +1590,7 @@ static inline void _sendMsgBranch(int eIdx, void *msg, CkGroupID gID,
 {
   int numPes;
   register envelope *env = _prepareMsgBranch(eIdx,msg,gID,ForBocMsg);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
   sendTicketGroupRequest(env,pe,_infoIdx);
 #else
   _TRACE_ONLY(numPes = (pe==CLD_BROADCAST_ALL?CkNumPes():1));
@@ -1738,7 +1738,7 @@ static inline void _sendMsgNodeBranch(int eIdx, void *msg, CkGroupID gID,
 {
   int numPes;
   register envelope *env = _prepareMsgBranch(eIdx,msg,gID,ForNodeBocMsg);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         sendTicketNodeGroupRequest(env,node,_infoIdx);
 #else
   _TRACE_ONLY(numPes = (node==CLD_BROADCAST_ALL?CkNumNodes():1));
@@ -1915,7 +1915,7 @@ extern "C"
 void CkArrayManagerDeliver(int pe,void *msg, int opts) {
   register envelope *env = UsrToEnv(msg);
   _prepareOutgoingArrayMsg(env,ForArrayEltMsg);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
    sendTicketArrayRequest(env,pe,_infoIdx);
 #else
   if (opts & CK_MSG_IMMEDIATE)
index 54df8cd7d76d9a7dc70ecd53ff119eb811f6a551..931de344f6fad9ea89127ab54a33178ea435aafb 100644 (file)
@@ -192,7 +192,7 @@ void ArrayElement::initBasics(void)
     CK_ARRAYLISTENER_LOOP(thisArray->listeners,
                          l->ckElementCreating(this));
   }
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         mlogData->objID.type = TypeArray;
         mlogData->objID.data.array.id = (CkGroupID)thisArrayID;
 #endif
@@ -313,7 +313,7 @@ void ArrayElement::CkAbort(const char *str) const
 }
 
 void ArrayElement::recvBroadcast(CkMessage *m){
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        CkArrayMessage *bcast = (CkArrayMessage *)m;
     envelope *env = UsrToEnv(m);
        int epIdx= env->piggyBcastIdx;
@@ -903,7 +903,7 @@ CmiBool CkArrayBroadcaster::deliver(CkArrayMessage *bcast,ArrayElement *el)
   DEBB((AA"Delivering broadcast %d to element %s\n"AB,elBcastNo,idx2str(el)));
   int epIdx=bcast->array_ep_bcast();
 
-#ifdef _FAULT_MLOG_     
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))     
         DEBUG(printf("[%d] elBcastNo %d bcastNo %d \n",CmiMyPe(),bcastNo));
         return true;
 #else
@@ -978,7 +978,7 @@ void CProxy_ArrayBase::ckBroadcast(CkArrayMessage *msg, int ep, int opts) const
          _TRACE_CREATION_DETAILED(UsrToEnv(msg), ep);
          int skipsched = opts & CK_MSG_EXPEDITED; 
          //int serializer=0;//1623802937%CkNumPes();
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
                 CProxy_CkArray ap(_aid);
                 ap[CpvAccess(serializer)].sendBroadcast(msg);
                 CkGroupID _id = _aid;
@@ -1021,7 +1021,7 @@ void CkArray::sendExpeditedBroadcast(CkMessage *msg)
        thisProxy.recvExpeditedBroadcast(msg);
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 int _tempBroadcastCount=0;
 
 void CkArray::broadcastHomeElements(void *data,CkLocRec *rec,CkArrayIndex *index){
@@ -1060,7 +1060,7 @@ void CkArray::recvBroadcast(CkMessage *m)
        CK_MAGICNUMBER_CHECK
        CkArrayMessage *msg=(CkArrayMessage *)m;
        broadcaster->incoming(msg);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         _tempBroadcastCount=0;
         locMgr->callForAllRecords(CkArray::staticBroadcastHomeElements,this,(void *)msg);
 #else
index 87c947c4ac772314200e4f9b4e943d44c65b6d41..63c112fba65905efe8e56400711c2aab538e54db 100644 (file)
@@ -607,7 +607,7 @@ class ArrayElementT : public ArrayElement
 {
 public:
   ArrayElementT(void): thisIndex(*(const T *)thisIndexMax.data()) {
-#ifdef _FAULT_MLOG_     
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))     
         mlogData->objID.data.array.idx.asMax()=thisIndexMax;
 #endif
 }
@@ -842,7 +842,7 @@ private:
   CkArrayBroadcaster *broadcaster; //Read-only copy of default broadcaster
 public:
   void flushStates() { CkReductionMgr::flushStates(); CK_ARRAYLISTENER_LOOP(listeners, l->flushState()); }
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        // the mlogft only support 1D arrays, then returning the number of elements in the first dimension
        virtual int numberReductionMessages(){CkAssert(CkMyPe() == 0);return numInitial.data()[0];}
        void broadcastHomeElements(void *data,CkLocRec *rec,CkArrayIndex *index);
index bdba53f87eeeb558286a395ae52d427ed931a10b..b93f1cfbe6df403a186bcb934ee4286abb7685d8 100644 (file)
@@ -187,7 +187,7 @@ void CkArrayReductionMgr::setAttachedGroup(CkGroupID groupID){
 
 
 void CkArrayReductionMgr::startNodeGroupReduction(int number,CkGroupID groupID){
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     Chare *oldObj =CpvAccess(_currentObj);
     CpvAccess(_currentObj) = this;
 #endif
@@ -199,7 +199,7 @@ void CkArrayReductionMgr::startNodeGroupReduction(int number,CkGroupID groupID){
        CkReductionNumberMsg *msg = new CkReductionNumberMsg(number);
        envelope::setSrcPe((char *)UsrToEnv(msg),CkMyNode());
        ((CkNodeReductionMgr *)this)->ReductionStarting(msg);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     CpvAccess(_currentObj) = oldObj;
 #endif
 }
index 1d91fc5ef4916ce635641087313220400c627b36..faf841eae8190ce26f71d903f43e59cca16b7a6e 100644 (file)
@@ -11,7 +11,7 @@
 #include <signal.h>
 #include "CentralLB.h"
 
-#ifdef _FAULT_MLOG_
+#ifdef _FAULT_CAUSAL_
 
 //#define DEBUG(x)  if(_restartFlag) {x;}
 #define DEBUG_MEM(x) //x
index 4988f3e155a14e8e03cbfaf286665496210ac01f..83ea1abdcdfeb2166f954fbf70084305d84d5bc7 100644 (file)
@@ -123,7 +123,7 @@ void CkCheckpointMgr::Checkpoint(const char *dirname, CkCallback& cb){
        FILE* fGroups = fopen(fileName,"wb");
        if(!fGroups) CkAbort("Failed to create checkpoint file for group table!");
        PUP::toDisk pGroups(fGroups);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     CkPupGroupData(pGroups,CmiTrue);
 #else
     CkPupGroupData(pGroups);
@@ -138,7 +138,7 @@ void CkCheckpointMgr::Checkpoint(const char *dirname, CkCallback& cb){
          if(!fNodeGroups) 
            CkAbort("Failed to create checkpoint file for nodegroup table!");
          PUP::toDisk pNodeGroups(fNodeGroups);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
       CkPupNodeGroupData(pNodeGroups,CmiTrue);
 #else
       CkPupNodeGroupData(pNodeGroups);
@@ -270,7 +270,7 @@ void CkPupChareData(PUP::er &p)
 }
 #endif
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 // handle GroupTable and data
 void CkPupGroupData(PUP::er &p, CmiBool create)
 {
@@ -542,7 +542,7 @@ void CkPupArrayElementsData(PUP::er &p, int notifyListeners)
        }
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 int  CkCountArrayElements(){
     int numGroups = CkpvAccess(_groupIDTable)->size();
     int i;
@@ -569,7 +569,7 @@ void CkPupProcessorData(PUP::er &p)
     CkPupChareData(p);
 
     // save groups 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     CkPupGroupData(p,CmiTrue);
 #else
     CkPupGroupData(p);
@@ -577,7 +577,7 @@ void CkPupProcessorData(PUP::er &p)
 
     // save nodegroups
     if(CkMyRank()==0) {
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CkPupNodeGroupData(p,CmiTrue); 
 #else
         CkPupNodeGroupData(p);
@@ -717,7 +717,7 @@ void CkRestartMain(const char* dirname, CkArgMsg *args){
        FILE* fGroups = fopen(filename,"rb");
        if(!fGroups) CkAbort("Failed to open checkpoint file for group table!");
        PUP::fromDisk pGroups(fGroups);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     CkPupGroupData(pGroups,CmiTrue);
 #else
     CkPupGroupData(pGroups);
@@ -734,7 +734,7 @@ void CkRestartMain(const char* dirname, CkArgMsg *args){
                FILE* fNodeGroups = fopen(filename,"rb");
                if(!fNodeGroups) CkAbort("Failed to open checkpoint file for nodegroup table!");
                PUP::fromDisk pNodeGroups(fNodeGroups);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CkPupNodeGroupData(pNodeGroups,CmiTrue);
 #else
         CkPupNodeGroupData(pNodeGroups);
index f8f8980a0d3c1a3fe9d8f3c68f3261ac0520ca6d..8532d7a842201c404be200dedb7cd6a7f0254178 100644 (file)
@@ -60,7 +60,7 @@ public:
 void CkPupROData(PUP::er &p);
 void CkPupMainChareData(PUP::er &p, CkArgMsg *args);
 void CkPupChareData(PUP::er &p);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void CkPupGroupData(PUP::er &p,CmiBool create=CmiTrue);
 void CkPupNodeGroupData(PUP::er &p,CmiBool create=CmiTrue);
 #else
@@ -74,7 +74,7 @@ void CkRemoveArrayElements();
 
 void CkStartCheckpoint(char* dirname,const CkCallback& cb);
 void CkRestartMain(const char* dirname, CkArgMsg *args);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 int  CkCountArrayElements();
 #endif
 
index 17180194ac96493419620b2f6c6f2520e3c2dd6c..8dfc3323ceb70b56f5973f90dd30e03c24740d1a 100644 (file)
@@ -957,7 +957,7 @@ void CkMigratable::AtSync(int waitForMigration)
 {
        if (!usesAtSync)
                CkAbort("You must set usesAtSync=CmiTrue in your array element constructor to use AtSync!\n");
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     mlogData->toResumeOrNot=1;
 #endif
        myRec->AsyncMigrate(!waitForMigration);
@@ -973,24 +973,24 @@ void CkMigratable::ReadyMigrate(CmiBool ready)
        myRec->ReadyMigrate(ready);
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     extern int globalResumeCount;
 #endif
 
 void CkMigratable::staticResumeFromSync(void* data)
 {
        CkMigratable *el=(CkMigratable *)data;
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     if(el->mlogData->toResumeOrNot ==0 || el->mlogData->resumeCount >= globalResumeCount){
         return;
     }
 #endif
        DEBL((AA"Element %s resuming from sync\n"AB,idx2str(el->thisIndexMax)));
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     CpvAccess(_currentObj) = el;
 #endif
        el->ResumeFromSync();
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     el->mlogData->resumeCount++;
 #endif
 }
@@ -1401,7 +1401,7 @@ void CkLocRec_local::setMigratable(int migratable)
        else
          the_lbdb->NonMigratable(ldHandle);
 }
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void CkLocRec_local::Migrated(){
     the_lbdb->Migrated(ldHandle, CmiTrue);
 }
@@ -1550,7 +1550,7 @@ public:
                if (opts & CK_MSG_KEEP)
                        msg = (CkArrayMessage *)CkCopyMsg((void **)&msg);
                buffer.enq(msg);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
                envelope *env = UsrToEnv(msg);
                env->sender = CpvAccess(_currentObj)->mlogData->objID;
 #endif
@@ -1564,7 +1564,7 @@ public:
                DEBS((AA" Delivering queued messages:\n"AB));
                CkArrayMessage *m;
                while (NULL!=(m=buffer.deq())) {
-#ifdef _FAULT_MLOG_         
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))         
                DEBUG(CmiPrintf("[%d] buffered message being sent\n",CmiMyPe()));
                envelope *env = UsrToEnv(m);
                Chare *oldObj = CpvAccess(_currentObj);
@@ -1573,7 +1573,7 @@ public:
 #endif
                DEBS((AA"Sending buffered message to %s\n"AB,idx2str(m->array_index())));
                myLocMgr->deliverViaQueue(m);
-#ifdef _FAULT_MLOG_         
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))         
                CpvAccess(_currentObj) = oldObj;
 #endif
                }
@@ -1675,7 +1675,7 @@ void CkLocMgr::flushAllRecs(void)
   CmiImmediateUnlock(hashImmLock);
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void CkLocMgr::callForAllRecords(CkLocFn fnPointer,CkArray *arr,void *data){
     void *objp;
     void *keyp;
@@ -1749,7 +1749,7 @@ void CkLocMgr::pup(PUP::er &p){
                // _lbdb is the fixed global groupID
                initLB(lbdbID);
 
-#ifdef _FAULT_MLOG_     
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))     
         int count;
         p | count;
         DEBUG(CmiPrintf("[%d] Unpacking Locmgr %d has %d home elements\n",CmiMyPe(),thisgroup.idx,count));
@@ -1778,7 +1778,7 @@ void CkLocMgr::pup(PUP::er &p){
  * indexes of local elements dont need to be packed
  * since they will be recreated later anyway
  */
-#ifdef _FAULT_MLOG_     
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))     
         int count=0,count1=0;
         void *objp;
         void *keyp;
@@ -1876,7 +1876,7 @@ void CkLocMgr::inform(const CkArrayIndex &idx,int nowOnPe)
                return; //Never insert a "remote" record pointing here
        CkLocRec *rec=elementNrec(idx);
        if (rec!=NULL && rec->type()==CkLocRec::local){
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CmiPrintf("[%d]WARNING!!! Element %d:%s is local but is being told it exists on %d\n",CkMyPe(),idx.dimension,idx2str(idx), nowOnPe);
 #endif
                return; //Never replace a local element's record!
@@ -1891,7 +1891,7 @@ void CkLocMgr::informHome(const CkArrayIndex &idx,int nowOnPe)
        if (home!=CkMyPe() && home!=nowOnPe) {
                //Let this element's home Pe know it lives here now
                DEBC((AA"  Telling %s's home %d that it lives on %d.\n"AB,idx2str(idx),home,nowOnPe));
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         informLocationHome(thisgroup,idx,home,CkMyPe());
 #else
                thisProxy[home].updateLocation(idx,nowOnPe);
@@ -1899,7 +1899,7 @@ void CkLocMgr::informHome(const CkArrayIndex &idx,int nowOnPe)
        }
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 CkLocRec_local *CkLocMgr::createLocal(const CkArrayIndex &idx,
         CmiBool forMigration, CmiBool ignoreArrival,
         CmiBool notifyHome,int dummy)
@@ -2060,7 +2060,7 @@ int CkLocMgr::deliver(CkMessage *m,CkDeliver_t type,int opts) {
        }else{
                DEBS((AA"deliver %s rec is null\n"AB,idx2str(idx)));
        }
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
 #if CMK_LBDB_ON
        if (type==CkDeliver_queue) {
                if (!(opts & CK_MSG_LB_NOTRACE) && the_lbdb->CollectingCommStats()) {
@@ -2292,7 +2292,7 @@ void CkLocMgr::iterate(CkLocIterator &dest) {
 
 
 /************************** LocMgr: MIGRATION *************************/
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void CkLocMgr::pupElementsFor(PUP::er &p,CkLocRec_local *rec,
         CkElementCreation_t type, CmiBool create, int dummy)
 {
@@ -2452,7 +2452,7 @@ void CkLocMgr::emigrate(CkLocRec_local *rec,int toPe)
                new (doubleSize, 0) CkArrayElementMigrateMessage;
        msg->idx=idx;
        msg->length=bufSize;
-#ifdef _FAULT_MLOG_ 
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_)) 
     msg->gid = ckGetGroupID();
 #endif
 #if CMK_LBDB_ON
@@ -2477,7 +2477,7 @@ void CkLocMgr::emigrate(CkLocRec_local *rec,int toPe)
 
        DEBM((AA"Migrated index size %s to %d \n"AB,idx2str(idx),toPe));        
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     sendMlogLocation(toPe,UsrToEnv(msg));
 #else
        //Send off message and delete old copy
@@ -2491,7 +2491,7 @@ void CkLocMgr::emigrate(CkLocRec_local *rec,int toPe)
        duringMigration=CmiFalse;
        //The element now lives on another processor-- tell ourselves and its home
        inform(idx,toPe);
-#ifndef _FAULT_MLOG_    
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))    
        informHome(idx,toPe);
 #endif
        CK_MAGICNUMBER_CHECK
@@ -2518,7 +2518,7 @@ void CkLocMgr::immigrate(CkArrayElementMigrateMessage *msg)
        }
 
        //Create a record for this element
-#ifndef _FAULT_MLOG_    
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))    
        CkLocRec_local *rec=createLocal(idx,CmiTrue,msg->ignoreArrival,CmiFalse /* home told on departure */ );
 #else
     CkLocRec_local *rec=createLocal(idx,CmiTrue,CmiTrue,CmiFalse /* home told on departure */ );
@@ -2592,7 +2592,7 @@ void CkLocMgr::restore(const CkArrayIndex &idx, PUP::er &p)
 
 
 /// Insert and unpack this array element from this checkpoint (e.g., from CkLocation::pup)
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void CkLocMgr::resume(const CkArrayIndex &idx, PUP::er &p, CmiBool create, int dummy)
 {
        CkLocRec_local *rec;
@@ -2686,7 +2686,7 @@ static const char *rec2str[]={
     "dead"//Deleted element (for debugging)
 };
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void CkLocMgr::setDuringMigration(CmiBool _duringMigration){
     duringMigration = _duringMigration;
 }
index 00e884c0ba995b6c2b85b4f845b81bbdbe7f1f88..6c30d43db31911ac7cd6b7240eee58ab15fe0e5e 100644 (file)
@@ -60,7 +60,7 @@ public:
        CkArrayIndexMax idx; // Array index that is migrating
        int ignoreArrival;   // if to inform LB of arrival
        int length;//Size in bytes of the packed data
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CkGroupID gid; //gid of location manager
 #endif
        CmiBool bounced;
@@ -222,7 +222,7 @@ public:
   int  isReadyMigrate()        { return readyMigrate; }
   CmiBool checkBufferedMigration();    // check and execute pending migration
   int   MigrateToPe();
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         void Migrated();
 #endif
   inline void setMeasure(CmiBool status) { enable_measure = status; }
@@ -505,7 +505,7 @@ public:
 };
 
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 typedef void (*CkLocFn)(CkArray *,void *,CkLocRec *,CkArrayIndex *);
 #endif
 
@@ -610,7 +610,7 @@ public:
        /// Return true if this array element lives on another processor
        bool isRemote(const CkArrayIndex &idx,int *onPe) const;
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        //mark the duringMigration variable .. used for parallel restart
        void setDuringMigration(CmiBool _duringMigration);
 #endif
@@ -621,7 +621,7 @@ public:
        /// Insert and unpack this array element from this checkpoint (e.g., from CkLocation::pup), skip listeners
        void restore(const CkArrayIndex &idx, PUP::er &p);
        /// Insert and unpack this array element from this checkpoint (e.g., from CkLocation::pup)
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        void resume(const CkArrayIndex &idx, PUP::er &p, CmiBool create, int dummy=0);
 #else
        void resume(const CkArrayIndex &idx, PUP::er &p, CmiBool notify=CmiTrue);
@@ -658,7 +658,7 @@ private:
 
        friend class CkLocation; //so it can call pupElementsFor
        friend class ArrayElement;
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        void pupElementsFor(PUP::er &p,CkLocRec_local *rec,
         CkElementCreation_t type, CmiBool create=CmiTrue, int dummy=0);
 #else
@@ -673,7 +673,7 @@ private:
        CmiBool deliverUnknown(CkArrayMessage *msg,CkDeliver_t type,int opts);
 
        /// Create a new local record at this array index.
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 CkLocRec_local *createLocal(const CkArrayIndex &idx,
         CmiBool forMigration, CmiBool ignoreArrival,
         CmiBool notifyHome,int dummy=0);
@@ -743,7 +743,7 @@ CkLocRec_local *createLocal(const CkArrayIndex &idx,
 #endif
        void initLB(CkGroupID lbdbID);
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 public:
        void callForAllRecords(CkLocFn,CkArray *,void *);
        int homeElementCount;
index 3f7f8b829bbeebcf31d7125c85e465ffa6d563f6..f90d7fcb45ff9a35dd1da7f4dd9e7ffb4f2ff9fd 100644 (file)
@@ -196,7 +196,7 @@ CkReductionMgr::CkReductionMgr()//Constructor
   gcount=lcount=0;
   nContrib=nRemote=0;
   maxStartRequest=0;
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     if(CkMyPe() != 0){
         perProcessorCounts = NULL;
     }else{
@@ -396,7 +396,7 @@ void CkReductionMgr::contribute(contributorInfo *ci,CkReductionMsg *m)
   m->sourceFlag=-1;//A single contribution
   m->gcount=0;
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     if(lcount == 0){
         m->sourceProcessorCount = 1;
     }else{
@@ -412,7 +412,7 @@ void CkReductionMgr::contribute(contributorInfo *ci,CkReductionMsg *m)
 #endif
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void CkReductionMgr::contributeViaMessage(CkReductionMsg *m){
     CmiAssert(CmiMyPe() == 0);
     DEBR(("[%d] contributeViaMessage fromPE %d\n",CmiMyPe(),m->fromPE));
@@ -459,7 +459,7 @@ void CkReductionMgr::ReductionStarting(CkReductionNumberMsg *m)
  }
  DEBR((AA" Group ReductionStarting called for redNo %d\n"AB,m->num));
  int srcPE = (UsrToEnv(m))->getSrcPe();
-#ifndef _FAULT_MLOG_ 
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_)) 
   if (isPresent(m->num) && !inProgress)
   {
     DEBR((AA"Starting reduction #%d at parent's request\n"AB,m->num));
@@ -551,7 +551,7 @@ void CkReductionMgr::startReduction(int number,int srcPE)
        return;
   }
 
-#ifdef _FAULT_MLOG_ 
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_)) 
   if(CmiMyPe() == 0 && redNo == 0){
             for(int j=0;j<CkNumPes();j++){
                 if(j != CkMyPe() && j != srcPE){
@@ -611,7 +611,7 @@ void CkReductionMgr::startReduction(int number,int srcPE)
          // kick-start your parent too ...
                        if(treeParent() != srcPE){
                                if(CmiNodeAlive(treeParent())||allowMessagesOnly !=-1){
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     CpvAccess(_currentObj) = oldObj;
 #endif
                                thisProxy[treeParent()].ReductionStarting(new CkReductionNumberMsg(i));
@@ -636,7 +636,7 @@ void CkReductionMgr::addContribution(CkReductionMsg *m)
 {
   if (isPast(m->redNo))
   {
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CmiAbort("this version should not have late migrations");
 #else
        //We've moved on-- forward late contribution straight to root
@@ -671,7 +671,7 @@ void CkReductionMgr::finishReduction(void)
        return;
   }
   //CkPrintf("[%d]finishReduction called for redNo %d with nContrib %d at %.6f\n",CkMyPe(),redNo, nContrib,CmiWallTimer());
-#ifndef _FAULT_MLOG_   
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))   
 
   if (nContrib<(lcount+adj(redNo).lcount)){
          DEBR((AA"Need more local messages %d %d\n"AB,nContrib,(lcount+adj(redNo).lcount)));
@@ -708,7 +708,7 @@ void CkReductionMgr::finishReduction(void)
   DEBR((AA"Reducing data... %d %d\n"AB,nContrib,(lcount+adj(redNo).lcount)));
   CkReductionMsg *result=reduceMessages();
   result->redNo=redNo;
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
 
 #if GROUP_LEVEL_REDUCTION
   if (hasParent())
@@ -783,7 +783,7 @@ void CkReductionMgr::finishReduction(void)
   redNo++;
   //Shift the count adjustment vector down one slot (to match new redNo)
   int i;
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
        if(CkMyPe()!=0){
 #else
     {
@@ -819,7 +819,7 @@ void CkReductionMgr::finishReduction(void)
   }
 #endif
 
-#ifndef _FAULT_MLOG_   
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))   
   if(maxStartRequest >= redNo){
          startReduction(redNo,CkMyPe());
          finishReduction();
@@ -1012,7 +1012,7 @@ void CkReductionMgr::pup(PUP::er &p)
   // we can not pup because inserting array elems will add the counters again
 //  p|lcount;
 //  p|gcount;
-#ifdef _FAULT_MLOG_ 
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_)) 
 //  p|lcount;
 //  //  p|gcount;
 //  //  printf("[%d] nodeProxy nodeGroup %d pupped in group %d \n",CkMyPe(),(nodeProxy.ckGetGroupID()).idx,thisgroup.idx);
@@ -1616,7 +1616,7 @@ CkReduction::reducerFn CkReduction::reducerTable[CkReduction::MAXREDUCERS]={
 /**nodegroup reduction manager . Most of it is similar to the guy above***/
 NodeGroup::NodeGroup(void) {
   __nodelock=CmiCreateLock();
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     mlogData->objID.type = TypeNodeGroup;
     mlogData->objID.data.group.onPE = CkMyNode();
 #endif
@@ -1726,7 +1726,7 @@ void CkNodeReductionMgr::ckSetReductionClient(CkCallback *cb)
 
 void CkNodeReductionMgr::contribute(contributorInfo *ci,CkReductionMsg *m)
 {
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     Chare *oldObj =CpvAccess(_currentObj);
     CpvAccess(_currentObj) = this;
 #endif
@@ -1740,7 +1740,7 @@ void CkNodeReductionMgr::contribute(contributorInfo *ci,CkReductionMsg *m)
 #endif
   addContribution(m);
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     CpvAccess(_currentObj) = oldObj;
 #endif
 }
@@ -1751,7 +1751,7 @@ void CkNodeReductionMgr::contributeWithCounter(contributorInfo *ci,CkReductionMs
 #if CMK_BLUEGENE_CHARM
   _TRACE_BG_TLINE_END(&m->log);
 #endif
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     Chare *oldObj =CpvAccess(_currentObj);
     CpvAccess(_currentObj) = this;
 #endif
@@ -1766,7 +1766,7 @@ void CkNodeReductionMgr::contributeWithCounter(contributorInfo *ci,CkReductionMs
   CkPrintf("[%d,%d] }}}contributewithCounter finished for %d at %0.6f\n",CkMyNode(),CkMyPe(),m->redNo,CmiWallTimer());
 #endif
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     CpvAccess(_currentObj) = oldObj;
 #endif
 }
@@ -2336,7 +2336,7 @@ void CkNodeReductionMgr::pup(PUP::er &p)
   p | blocked;
   p | maxModificationRedNo;
 
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
   int isnull = (storedCallback == NULL);
   p | isnull;
   if (!isnull) {
index be7678ca5e0ff877f7898505d05bbe228618afaa..f782334d37204028fd7a65d2ffb2522f817d3522 100644 (file)
@@ -75,7 +75,7 @@ public:
   CkReductionNumberMsg(int n) {num=n;}
 };
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 #define MAX_INT 5000000
 #endif
 
@@ -231,7 +231,7 @@ private:
 
 //Checkpointing utilities
 public:
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     int *perProcessorCounts;
     int processorCount;
     int totalCount;
@@ -310,7 +310,7 @@ private:
                >0 indicates this is a reduced contribution.
        */
        int nSources(void) {return sourceFlag<0?-sourceFlag:sourceFlag;}
-#ifdef _FAULT_MLOG_ 
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_)) 
     int sourceProcessorCount;
     int fromPE;
 #endif
index b81c419824a8d67e60986383309df4271a1e7700..44094ea9c73b2d65ea203c23a6656f1968db43cf 100644 (file)
@@ -89,7 +89,7 @@ typedef unsigned short UShort;
 typedef unsigned char  UChar;
 
 #include "charm.h" // for CkGroupID, and CkEnvelopeType
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 #include "ckobjid.h" //for the ckobjId
 #endif
 
@@ -180,7 +180,7 @@ public:
       UChar isPacked:1; ///< If true, message must be unpacked before use
       UChar isUsed:1;   ///< Marker bit to prevent message re-send.
     };
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     CkObjID sender;
     CkObjID recver;
     MCount SN;
@@ -202,7 +202,7 @@ private:
     UInt   totalsize;  ///< Byte count from envelope start to end of priobits
     
   public:
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     UInt piggyBcastIdx;
 #endif
     void pup(PUP::er &p);
@@ -258,7 +258,7 @@ private:
       env->pathHistory.reset();
 #endif
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
       env->sender.type = TypeInvalid;
       env->recver.type = TypeInvalid;
       env->SN = 0;
@@ -401,7 +401,7 @@ private:
     }
 public:
     MsgPool():SafePool<void*>(_alloc, CkFreeMsg, _reset) {}
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         void *get(void){
             return allocfn();
         }
index 3d0767cd492b2955c37a827822fa1318904033ec..bfc5a6d799d2f0c3723de028aadfc920b9011c2e 100644 (file)
@@ -187,7 +187,7 @@ typedef void (*CkFtFn)(const char *, CkArgMsg *);
 static CkFtFn  faultFunc = NULL;
 static char* _restartDir;
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 int teamSize=1;
 int chkptPeriod=1000;
 bool parallelRestart=false;
@@ -251,7 +251,7 @@ static inline void _parseCommandLineOpts(char **argv)
 # if CMK_MEM_CHECKPOINT
       faultFunc = CkMemRestart;
 # endif
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
       faultFunc = CkMlogRestart;
 #endif
       CmiPrintf("[%d] Restarting after crash \n",CmiMyPe());
@@ -284,7 +284,7 @@ static inline void _parseCommandLineOpts(char **argv)
        if(CmiGetArgStringDesc(argv,"+raiseevac", &_raiseEvacFile,"Generates processor evacuation on random processors")){
                _raiseEvac = 1;
        }
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        if(!CmiGetArgIntDesc(argv,"+teamSize",&teamSize,"Set the team size for message logging")){
         teamSize = 1;
     }
@@ -391,7 +391,7 @@ static inline void _sendStats(void)
   CmiSyncSendAndFree(0, env->getTotalsize(), (char *)env);
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 extern void _messageLoggingExit();
 #endif
 
@@ -447,7 +447,7 @@ static void _exitHandler(envelope *env)
       }        
       break;
     case ReqStatMsg:
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         _messageLoggingExit();
 #endif
       DEBUGF(("ReqStatMsg on %d\n", CkMyPe()));
@@ -1082,7 +1082,7 @@ void _initCharm(int unused_argc, char **argv)
     }
 #endif
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     _messageLoggingInit();
 #endif
 
@@ -1102,7 +1102,7 @@ void _initCharm(int unused_argc, char **argv)
 
        evacuate = 0;
        CcdCallOnCondition(CcdSIGUSR1,(CcdVoidFn)CkDecideEvacPe,0);
-#ifdef _FAULT_MLOG_ 
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_)) 
     CcdCallOnCondition(CcdSIGUSR2,(CcdVoidFn)CkMlogRestart,0);
 #endif
 
@@ -1152,7 +1152,7 @@ void _initCharm(int unused_argc, char **argv)
                        msg->argc = CmiGetArgc(argv);
                        msg->argv = argv;
                        _entryTable[_mainTable[i]->entryIdx]->call(msg, obj);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
             CpvAccess(_currentObj) = (Chare *)obj;
 #endif
                }
index e604de17d9c678afd253ee6ec9bfaada9e3396c7..78912c24b0527610df2a8dc3e4281b4f229ca114 100644 (file)
@@ -154,7 +154,7 @@ public:
   double * expectedLoad;       // expected load for future
 
 public:
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        int step;
        int lbDecisionCount;
 #endif
index 6e6ee4100047f3bfcffacf1a90dca797e62760bb..aad97b07d08a4645d3638f84090d3b5602bf1624 100644 (file)
@@ -32,7 +32,7 @@
 #define USE_LDB_SPANNING_TREE 1
 #endif
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 extern int _restartFlag;
 extern void getGlobalStep(CkGroupID );
 extern void initMlogLBStep(CkGroupID );
@@ -170,7 +170,7 @@ void CentralLB::AtSync()
 #if CMK_LBDB_ON
   DEBUGF(("[%d] CentralLB AtSync step %d!!!!!\n",CkMyPe(),step()));
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        CpvAccess(_currentObj)=this;
 #endif
 
@@ -197,7 +197,7 @@ void CentralLB::ProcessAtSync()
   }
 
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        initMlogLBStep(thisgroup);
 #endif
 
@@ -252,7 +252,7 @@ void CentralLB::BuildStatsMsg()
   CLBStatsMsg* msg = new CLBStatsMsg(osz, csz);
   _MEMCHECK(msg);
   msg->from_pe = CkMyPe();
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        msg->step = step();
 #endif
   //msg->serial = CrnRand();
@@ -321,13 +321,13 @@ void CentralLB::SendStats()
 #endif
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 extern int donotCountMigration;
 #endif
 
 void CentralLB::Migrated(LDObjHandle h, int waitBarrier)
 {
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     if(donotCountMigration){
         return ;
     }
@@ -443,7 +443,7 @@ void CentralLB::ReceiveStats(CkMarshalledCLBStatsMessage &msg)
     CmiAssert(m!=NULL);
     const int pe = m->from_pe;
     DEBUGF(("Stats msg received, %d %d %d %p step %d\n", pe,stats_msg_count,m->n_objs,m,step()));
-#ifdef _FAULT_MLOG_     
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))     
 /*      
  *  if(m->step < step()){
  *    //TODO: if a processor is redoing an old load balance step..
@@ -569,7 +569,7 @@ void CentralLB::LoadBalance()
 
   double strat_start_time = CkWallTimer();
   LBMigrateMsg* migrateMsg = Strategy(statsData, clients);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        migrateMsg->step = step();
 #endif
   if (_lb_args.debug()) {
@@ -603,7 +603,7 @@ void CentralLB::LoadBalance()
   }
 
   DEBUGF(("[%d]calling recv migration\n",CkMyPe()));
-#ifdef _FAULT_MLOG_ 
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_)) 
     lbDecisionCount++;
     migrateMsg->lbDecisionCount = lbDecisionCount;
 #endif
@@ -720,7 +720,7 @@ void CentralLB::removeNonMigratable(LDStats* stats, int count)
 }
 
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 extern int restarted;
 #endif
 
@@ -729,7 +729,7 @@ void CentralLB::ReceiveMigration(LBMigrateMsg *m)
 #if CMK_LBDB_ON
        int i;
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        int *dummyCounts;
 
        DEBUGF(("[%d] Starting ReceiveMigration WITH step %d m->step %d\n",CkMyPe(),step(),m->step));
@@ -752,7 +752,7 @@ void CentralLB::ReceiveMigration(LBMigrateMsg *m)
   }
   migrates_expected = 0;
   future_migrates_expected = 0;
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        int sending=0;
     int dummy=0;
        LBDB *_myLBDB = theLbdb->getLBDB();
@@ -767,7 +767,7 @@ void CentralLB::ReceiveMigration(LBMigrateMsg *m)
     if (move.from_pe == me && move.to_pe != me) {
       DEBUGF(("[%d] migrating object to %d\n",move.from_pe,move.to_pe));
       // migrate object, in case it is already gone, inform toPe
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
       if (theLbdb->Migrate(move.obj,move.to_pe) == 0) 
          thisProxy[move.to_pe].MissMigrate(!move.async_arrival);
 #else
@@ -796,7 +796,7 @@ void CentralLB::ReceiveMigration(LBMigrateMsg *m)
   DEBUGF(("[%d] in ReceiveMigration %d moves expected: %d future expected: %d\n",CkMyPe(),m->n_moves, migrates_expected, future_migrates_expected));
   // if (_lb_debug) CkPrintf("[%d] expecting %d objects migrating.\n", CkMyPe(), migrates_expected);
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        if(_restartFlag){
                sendDummyMigrationCounts(dummyCounts);
                _restartFlag  =0;
@@ -820,14 +820,14 @@ void CentralLB::ReceiveMigration(LBMigrateMsg *m)
   delete m;
 
 //     CkEvacuatedElement();
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 //  migrates_expected = 0;
 //  //  ResumeClients(1);
 #endif
 #endif
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void CentralLB::ReceiveDummyMigration(int globalDecisionCount){
     DEBUGF(("[%d] ReceiveDummyMigration called for step %d with globalDecisionCount %d\n",CkMyPe(),step(),globalDecisionCount));
     //TODO: this is gonna be important when a crash happens during checkpoint
@@ -850,13 +850,13 @@ void CentralLB::MigrationDone(int balancing)
        DEBUGF(("[%d] Incrementing Step %d \n",CkMyPe(),step()));
   // if sync resume, invoke a barrier
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     savedBalancing = balancing;
     startLoadBalancingMlog(&resumeCentralLbAfterChkpt,(void *)this);
 #endif
 
   LoadbalanceDone(balancing);        // callback
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
   // if sync resume invoke a barrier
   if (balancing && _lb_args.syncResume()) {
     CkCallback cb(CkIndex_CentralLB::ResumeClients((CkReductionMsg*)NULL), 
@@ -876,7 +876,7 @@ void CentralLB::MigrationDone(int balancing)
 #endif
 }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void CentralLB::endMigrationDone(int balancing){
     DEBUGF(("[%d] CentralLB::endMigrationDone step %d\n",CkMyPe(),step()));
 
@@ -896,7 +896,7 @@ void CentralLB::endMigrationDone(int balancing){
 }
 #endif
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 void resumeCentralLbAfterChkpt(void *_lb){
     CentralLB *lb= (CentralLB *)_lb;
     CpvAccess(_currentObj)=lb;
@@ -914,7 +914,7 @@ void CentralLB::ResumeClients(CkReductionMsg *msg)
 void CentralLB::ResumeClients(int balancing)
 {
 #if CMK_LBDB_ON
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     resumeCount++;
     globalResumeCount = resumeCount;
 #endif
@@ -923,7 +923,7 @@ void CentralLB::ResumeClients(int balancing)
     double end_lb_time = CkWallTimer();
   }
 
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
   if (balancing) ComlibNotifyMigrationDone();  
 #endif
 
@@ -1237,7 +1237,7 @@ void CentralLB::pup(PUP::er &p) {
   if (p.isUnpacking())  {
     initLB(CkLBOptions(seqno)); 
   }
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        p | lbDecisionCount;
     p | resumeCount;
 #endif
@@ -1277,7 +1277,7 @@ void CLBStatsMsg::pup(PUP::er &p) {
   p|total_walltime; p|total_cputime;
   p|idletime;
   p|bg_walltime;   p|bg_cputime;
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
   p | step;
 #endif
   p|n_objs;
index cf53fde8096d7bca18379b7c9da4163d627f0c07..0bf2edccfb4d8d2e93499d293ee4e3cdfb1ab4e1 100644 (file)
@@ -76,7 +76,7 @@ public:
   CkMarshalledCLBStatsMessage bufMsg;
   SpanningTree st;
   CentralLB(const CkLBOptions & opt):BaseLB(opt) { initLB(opt); 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         lbDecisionCount= resumeCount=0;
 #endif
 } 
@@ -104,7 +104,7 @@ public:
                                                // to be resumed via message
   void ResumeClients(CkReductionMsg *);
   void ReceiveMigration(LBMigrateMsg *);       // Receive migration data
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        void ReceiveDummyMigration(int _step);
 #endif
   void MissMigrate(int waitForBarrier);
@@ -253,14 +253,14 @@ private:
 
 public:
   int useMem();
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     int savedBalancing;
     void endMigrationDone(int balancing);
     int lbDecisionCount ,resumeCount;
 #endif
 };
 
-#ifdef _FAULT_MLOG_ 
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_)) 
     void resumeCentralLbAfterChkpt(void *lb);
 #endif
 
@@ -283,7 +283,7 @@ public:
 
   char * avail_vector;
   int next_lb;
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        int step;
 #endif
 
index 6533ca2d72db67d86ce3d39ccc47b5a4fb6537ff..b563908b566edc30e3ed5d9d8b4ccd129ed3db9c 100644 (file)
@@ -277,7 +277,7 @@ private:
   int            startLBFn_count;
 public:
   int useMem();
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     int validObjHandle(LDObjHandle h ){
             if(objCount == 0)
                 return 0;
index 2398923c691e8464e69cdd203709d1b2519358c8..6878f020fd9fa55302f516490d10f841e4c5f77e 100644 (file)
@@ -37,7 +37,7 @@ void CmmFree(t)
 CmmTable t;
 {
   if (t==NULL) return;
-#ifndef _FAULT_MLOG_    
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))    
   if (t->first!=NULL) CmiAbort("Cannot free a non-empty message table!");
 #endif
   CmiFree(t);
index 4928fb170366d2821192487ce7202cacccb10a19..b9a385ebea221894fd6f483e3443fdcd67b6ab9d 100644 (file)
@@ -1125,7 +1125,7 @@ ampi::ampi(CkArrayID parent_,const ampiCommStruct &s)
   
   seqEntries=parent->ckGetArraySize();
   oorder.init (seqEntries);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     if(thisIndex == 0){
 /*      CkAssert(CkMyPe() == 0);
  *              CkGroupID _myManagerGID = thisProxy.ckGetArrayID();     
@@ -1828,7 +1828,7 @@ ampi::send(int t, int sRank, const void* buf, int count, int type,  int rank, MP
    TRACE_BG_AMPI_BREAK(thread->getThread(), "AMPI_SEND", NULL, 0, 1);
 #endif
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
   MPI_Comm disComm = myComm.getComm();
   ampi *dis = getAmpiInstance(disComm);
   CpvAccess(_currentObj) = dis;
@@ -1947,7 +1947,7 @@ ampi::recv(int t, int s, void* buf, int count, int type, int comm, int *sts)
 
   resumeOnRecv=true;
   ampi *dis = getAmpiInstance(disComm);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 //  dis->yield();
 //  processRemoteMlogMessages();
 #endif
@@ -1963,7 +1963,7 @@ ampi::recv(int t, int s, void* buf, int count, int type, int comm, int *sts)
     dis = getAmpiInstance(disComm);
   }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
         CpvAccess(_currentObj) = dis;
         MSG_ORDER_DEBUG( printf("[%d] AMPI thread rescheduled  to Index %d buf %p src %d\n",CkMyPe(),dis->thisIndex,buf,s); )
 #endif
@@ -2070,7 +2070,7 @@ ampi::bcast(int root, void* buf, int count, int type,MPI_Comm destcomm)
     ciBcast.beginIteration();
     comlibProxy.generic(makeAmpiMsg(-1,MPI_BCAST_TAG,0, buf,count,type, MPI_BCAST_COMM));
 #else
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        CpvAccess(_currentObj) = this;
 #endif
     thisProxy.generic(makeAmpiMsg(-1,MPI_BCAST_TAG,0, buf,count,type, MPI_BCAST_COMM));
@@ -2286,7 +2286,7 @@ CDECL void AMPI_Migrate(void)
 #endif
   TCHARM_Migrate();
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     ampi *currentAmpi = getAmpiInstance(MPI_COMM_WORLD);
     CpvAccess(_currentObj) = currentAmpi;
 #endif
@@ -2525,7 +2525,7 @@ int AMPI_Send(void *msg, int count, MPI_Datatype type, int dest,
 #if AMPI_COUNTER
   getAmpiParent()->counters.send++;
 #endif
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 //  ptr->yield();
 //  //  processRemoteMlogMessages();
 #endif
@@ -2727,7 +2727,7 @@ int AMPI_Bcast(void *buf, int count, MPI_Datatype type, int root,
     PUParray(*(pptr->toPUPer), (char *)buf, (pptr->pupBytes));
   }
 #endif
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 //  ptr->yield();
 //  //  processRemoteMlogMessages();
 #endif
@@ -3383,13 +3383,13 @@ int AMPI_Waitall(int count, MPI_Request request[], MPI_Status sts[])
 #endif
     
 #if 1
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
             //for fault evacuation
       if(oldPe != CkMyPe()){
 #endif
                        reqs = getReqs();
                        reqvec  = vecIndex(count,request);
-#ifndef _FAULT_MLOG_
+#if (!defined(_FAULT_MLOG_) && !defined(_FAULT_CAUSAL_))
             }
 #endif
 #endif
index ec1aca04961456e9473b7840b84a23d66011cb85..8975487f1b220e8f1da7f03b428735d4eebd3df2 100644 (file)
@@ -214,7 +214,7 @@ void TCharm::pup(PUP::er &p) {
   //}
 
   checkPupMismatch(p,5134,"before TCHARM");
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
     if(!isStopped){
 //      resumeAfterMigration = true;
     }
@@ -372,7 +372,7 @@ void TCharm::migrateDelayed(int destPE) {
 }
 void TCharm::ckJustMigrated(void) {
        ArrayElement::ckJustMigrated();
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 //  resumeAfterMigration = true;
 #endif
        if (resumeAfterMigration) {
@@ -457,7 +457,7 @@ void TCharm::stop(void)
     we're resuming from migration!  (OSL 2003/9/23)
    */
   TCharm *dis=TCharm::get();
-#ifdef _FAULT_MLOG_ 
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_)) 
 /*  CpvAccess(_currentObj) = dis;
  *      printf("[%d] _currentObject set to TCharm index %d %p\n",CkMyPe(),dis->thisIndex,dis);*/
 #endif
@@ -474,7 +474,7 @@ void TCharm::start(void)
   DBG("thread resuming soon");
   //CkPrintf("TCharm[%d]::start()\n", thisIndex);
   //CmiPrintStackTrace(0);
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 //CthAwakenPrio(tid, CQS_QUEUEING_BFIFO, 1, &prio);
   CthAwaken(tid);
 #else
index e821b748f09d681e4970519273e67bf249631070..570b6f4c26bff55c46c6f49704d70853066054b0 100644 (file)
@@ -122,7 +122,7 @@ inline int CkHashCompare_int(const void *k1,const void *k2,size_t /*len*/)
 inline int CkHashCompare_pointer(const void *k1,const void *k2,size_t /*len*/)
        {return *(char **)k1 == *(char **)k2;}
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
 extern int countHashRefs;
 extern int countHashCollisions;
 #endif
@@ -382,7 +382,7 @@ public:
                };
        }
 
-#ifdef _FAULT_MLOG_
+#if (defined(_FAULT_MLOG_) || defined(_FAULT_CAUSAL_))
        OBJ *getPointer(const KEY &key) {
         countHashRefs++;
         int i=key.hash()%this->len;