Changeset 2580 for XIOS3/trunk/src/client.cpp

Timestamp:

09/26/23 17:24:35 (10 months ago)

Author:

ymipsl

Message:

Tracking unfree MPI windows and communicators.

YM

File:

• XIOS3/trunk/src/client.cpp (modified) (6 diffs)

XIOS3/trunk/src/client.cpp

@@ -106 +106 @@
 
           MPI_Comm_split(globalComm, color, commRank, &clientComm) ;
+          CXios::getMpiGarbageCollector().registerCommunicator(clientComm) ;
         }
         else
@@ -115 +116 @@
       {
         MPI_Comm_dup(localComm,&clientComm) ;
+        CXios::getMpiGarbageCollector().registerCommunicator(clientComm) ;
         MPI_Comm_dup(localComm,&intraComm_) ;
+        CXios::getMpiGarbageCollector().registerCommunicator(intraComm_) ;
 
         if (CXios::usingServer)
@@ -175 +178 @@
       MPI_Comm_rank(CXios::getXiosComm(), &commRank) ;
       MPI_Comm_split(CXios::getXiosComm(),false,commRank, &clientsComm_) ;
+      CXios::getMpiGarbageCollector().registerCommunicator(clientsComm_) ;
       
       // is using server or not ?
@@ -277 +281 @@
         {  
           MPI_Intercomm_create(intraComm, 0, globalComm, serverRank, 3141, &interComm);
+          CXios::getMpiGarbageCollector().registerCommunicator(interComm) ;
           MPI_Comm_free(&intraComm) ;
           MPI_Intercomm_merge(interComm,high, &intraComm ) ;
@@ -341 +346 @@
       CXios::setXiosComm(xiosGlobalComm) ;
 
-      MPI_Comm commUnfree ;
-      MPI_Comm_dup(clientComm, &commUnfree ) ;
- 
     }
 
@@ -519 +521 @@
       finalizePoolRessource() ;
       CContext::removeAllContexts() ; // free memory for related context 
-
       CXios::getMpiGarbageCollector().release() ; // release unfree MPI ressources
+      MPI_Comm xiosComm=CXios::getXiosComm() ;
+      MPI_Comm_free(&xiosComm) ;
       CCommTrack::dumpComm() ;
       if (!is_MPI_Initialized)