Removed old MPI_Checkpoint/Restart. Yet to put in the new version.
authorChao Huang <chuang10@uiuc.edu>
Fri, 21 Mar 2003 05:39:36 +0000 (05:39 +0000)
committerChao Huang <chuang10@uiuc.edu>
Fri, 21 Mar 2003 05:39:36 +0000 (05:39 +0000)
src/libs/ck-libs/ampi/ampi.C
src/libs/ck-libs/ampi/ampi.ci
src/libs/ck-libs/ampi/ampiimpl.h

index 70d6babeceb4862d94e735ef48eea239647e9bd9..b148186e7102b3435033998761e8c53ee9e18b7f 100644 (file)
@@ -389,7 +389,7 @@ ampiParent::ampiParent(MPI_Comm worldNo_,CProxy_TCharm threads_)
   myDDT=&myDDTsto;
   prepareCtv();
 }
-ampiParent::ampiParent(CkMigrateMessage *msg) {
+ampiParent::ampiParent(CkMigrateMessage *msg):ArrayElement1D(msg) {
   thread=NULL;
   worldPtr=NULL;
   myDDT=&myDDTsto;
@@ -449,18 +449,6 @@ TCharm *ampiParent::registerAmpi(ampi *ptr,ampiCommStruct s,bool forMigration)
   return thread;
 }
 
-void ampiParent::checkpoint(int len, char dname[]){
-//  char str[256];
-//  sprintf(str, "%s/%d.cpt",dname, thisIndex);
-//  CkCheckpoint(str);
-}
-
-void ampiParent::restart(int len, char dname[]){
-//  char str[256];
-//  sprintf(str, "%s/%d.cpt",dname, thisIndex);
-//  ckRestart(str);
-//CkPrintf("[%d]ampiParent::restart this=%p\n",thisIndex,this);
-}
 
 //----------------------- ampi -------------------------
 ampi::ampi()
@@ -497,6 +485,7 @@ ampi::ampi(CkArrayID parent_,const ampiCommStruct &s)
 }
 
 ampi::ampi(CkMigrateMessage *msg)
+         : ArrayElement1D(msg)
 {
   parent=NULL;
   thread=NULL;
@@ -547,52 +536,6 @@ ampi::~ampi()
   CmmFree(msgs);
 }
 
-//------------------- maintainance -----------------
-void ampi::stopthread(){
-  thread->stop();
-}
-
-void ampi::checkpoint(int len, char dname[])
-{
-/*
-  char str[256];
-  sprintf(str, "%s/%d.cpt",dname,thisIndex);
-  ckCheckpoint(str);
-*/
-}
-
-void ampi::checkpointthread(int len, char dname[]){
-/*
-  char str[256];
-  sprintf(str, "%s/thread%d.cpt", dname, thisIndex);
-  thread->ckCheckpoint(str);
-  thread->resume();
-*/
-}
-
-void ampi::restart(int len, char dname[]){
-/*
-  char str[256];
-  sprintf(str, "%s/%d.cpt",dname,thisIndex);
-  ckRestart(str);
-//CkPrintf("[%d]ampi::restart this=%p\n",thisIndex,this);
-*/
-}
-
-void ampi::restartthread(int len, char dname[]){
-/*
-//CkPrintf("[%d]ampi::restartthread\n",thisIndex);
-  char str[256];
-  sprintf(str, "%s/thread%d.cpt", dname, thisIndex);
-//CkPrintf("[%d] me: %p\n", thisIndex, CthSelf());
-  thread->clear();
-  thread->ckRestart(str);
-  thread->start();
-//CkPrintf("[%d]ampi::restartthread end\n",thisIndex);
-*/
-}
-
-
 //------------------------ Communicator Splitting ---------------------
 class ampiSplitKey {
 public:
@@ -2152,49 +2095,15 @@ int MPI_Comm_create(MPI_Comm comm, MPI_Group group, MPI_Comm* newcomm)
 CDECL
 void MPI_Restart(char *dname)
 {
-  int len;
-  char str[256];
   AMPIAPI("MPI_Restart");
-  MPI_Barrier(MPI_COMM_WORLD);
-  mkdir(dname,0777);
-
-  ampiParent *parentptr = getAmpiParent();
-  sprintf(str, "%s/ampiParent", dname);
-  len = strlen(str)+1;
-  parentptr->restart(len,str);
-
-  ampi *ampiptr = getAmpiInstance(MPI_COMM_WORLD);
-  sprintf(str, "%s/ampi%d", dname, ampiptr->getComm());
-  len = strlen(str)+1;
-  ampiptr->restart(len,str); //getProxy()[ampiptr->thisIndex].
-//CkPrintf("before me: %p\n", CthSelf());
-  ampiptr->getProxy()[ampiptr->thisIndex].restartthread(len,str);
-  ampiptr->stopthread();
+  CkPrintf("MPI_Restart not implemented\n");
 }
 
 CDECL
 void MPI_Checkpoint(char *dname)
 {
-  int len;
-  char str[256];
   AMPIAPI("MPI_Checkpoint");
-  MPI_Barrier(MPI_COMM_WORLD);
-  mkdir(dname,0777);
-
-  ampiParent *parentptr = getAmpiParent();
-  sprintf(str, "%s/ampiParent", dname);
-  mkdir(str, 0777);
-  len = strlen(str);
-  parentptr->checkpoint(len,str);
-
-  ampi *ampiptr = getAmpiInstance(MPI_COMM_WORLD);
-  sprintf(str, "%s/ampi%d", dname, ampiptr->getComm());
-  mkdir(str, 0777);
-  len = strlen(str)+1;
-  ampiptr->checkpoint(len,str);
-
-  ampiptr->getProxy()[ampiptr->thisIndex].checkpointthread(len,str);
-  ampiptr->stopthread();
+  CkPrintf("MPI_Checkpoint not implemented\n");
 }
 
 CDECL
index e6ebfb040b57f840a83e2bed279950644ae67c2c..64047dd644db5aaac1f0e2ef71f03dd1500d5c9b 100644 (file)
@@ -7,8 +7,6 @@ module ampi {
 
   array[1D] ampiParent {
     entry ampiParent(int universeNo,CProxy_TCharm threads_);
-    entry void checkpoint(int len, char dname[len]);
-    entry void restart(int len, char dname[len]);
   };
   array[1D] ampi {
     entry ampi();
@@ -17,9 +15,5 @@ module ampi {
     entry void reduceResult(CkReductionMsg *m);
     entry void splitPhase1(CkReductionMsg *msg);
     entry void commCreatePhase1(CkReductionMsg *msg);
-    entry void checkpoint(int len, char dname[len]);
-    entry void restart(int len, char dname[len]);
-    entry void checkpointthread(int len, char dname[len]);
-    entry void restartthread(int len, char dname[len]);
   };
 };
index ba43950a94993c2251e75ea612d2fb41c3fccc94..1689c64d0d8e0ffe67d900a1087aff74e3be0311 100644 (file)
@@ -506,9 +506,6 @@ public:
       return (MPI_Group)(s.getComm());
     }
 
-    void checkpoint(int len, char dname[]);
-    void restart(int len, char dname[]);
-
     CkDDT myDDTsto;
     CkDDT *myDDT;
     ampiPersRequests pers;
@@ -568,12 +565,6 @@ class ampi : public ArrayElement1D {
     void split(int color,int key,MPI_Comm *dest);
     void commCreate(const groupStruct vec,MPI_Comm *newcomm);
 
-    void stopthread();
-    void checkpoint(int len, char dname[]);
-    void restart(int len, char dname[]);
-    void checkpointthread(int len, char dname[]);
-    void restartthread(int len, char dname[]);
-
     inline int getRank(void) const {return myRank;}
     inline int getSize(void) const {return myComm.getSize();}
     inline MPI_Comm getComm(void) const {return myComm.getComm();}