Changeset 2592

Timestamp:

10/10/23 14:33:07 (7 months ago)

Author:

jderouillat

Message:

Free communicators in legacy and one_sided transport layer

Location:

XIOS3/trunk/src/transport

Files:

• legacy_context_client.cpp (modified) (1 diff)
• legacy_context_server.cpp (modified) (2 diffs)
• one_sided_context_client.cpp (modified) (1 diff)
• one_sided_context_server.cpp (modified) (2 diffs)

XIOS3/trunk/src/transport/legacy_context_client.cpp

@@ -32 +32 @@
       pureOneSided=CXios::getin<bool>("pure_one_sided",false); // pure one sided communication (for test)
       xios::MPI_Intercomm_merge(interComm_,false, &interCommMerged_) ;
+      CXios::getMpiGarbageCollector().registerCommunicator(interCommMerged_) ;
       xios::MPI_Comm_split(intraComm_,clientRank,clientRank, &commSelf_) ; // for windows
+      CXios::getMpiGarbageCollector().registerCommunicator(commSelf_) ;
       eventScheduler_ = parent->getEventScheduler() ;  
       timeLine = 1;

XIOS3/trunk/src/transport/legacy_context_server.cpp

@@ -37 +37 @@
  
     xios::MPI_Comm_dup(intraComm, &processEventBarrier_) ;
- 
+    CXios::getMpiGarbageCollector().registerCommunicator(processEventBarrier_) ;
 
     currentTimeLine=1;
@@ -44 +44 @@
 
     xios::MPI_Intercomm_merge(interComm_,true,&interCommMerged_) ;
+    CXios::getMpiGarbageCollector().registerCommunicator(interCommMerged_) ;
     xios::MPI_Comm_split(intraComm_, intraCommRank, intraCommRank, &commSelf_) ; // for windows
-    
+    CXios::getMpiGarbageCollector().registerCommunicator(commSelf_) ;
+  
     itLastTimeLine=lastTimeLine.begin() ;
 

XIOS3/trunk/src/transport/one_sided_context_client.cpp

@@ -32 +32 @@
 
       xios::MPI_Intercomm_merge(interComm_,false, &interCommMerged_) ;
+      CXios::getMpiGarbageCollector().registerCommunicator(interCommMerged_) ;
       
       xios::MPI_Comm_split(intraComm_,clientRank,clientRank, &commSelf_) ; // for windows
+      CXios::getMpiGarbageCollector().registerCommunicator(commSelf_) ;
       eventScheduler_ = parent->getEventScheduler() ;  
       timeLine = 1;

XIOS3/trunk/src/transport/one_sided_context_server.cpp

@@ -37 +37 @@
    
     xios::MPI_Comm_dup(intraComm, &processEventBarrier_) ;
- 
+    CXios::getMpiGarbageCollector().registerCommunicator(processEventBarrier_) ;
+    
     currentTimeLine=1;
     scheduled=false;
@@ -43 +44 @@
 
     xios::MPI_Intercomm_merge(interComm_,true,&interCommMerged_) ;
+    CXios::getMpiGarbageCollector().registerCommunicator(interCommMerged_) ;
     xios::MPI_Comm_split(intraComm_, intraCommRank, intraCommRank, &commSelf_) ; // for windows
-    
+    CXios::getMpiGarbageCollector().registerCommunicator(commSelf_) ;
+
     itLastTimeLine=lastTimeLine.begin() ;