Changeset 2310 for XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.cpp

Timestamp:

03/15/22 14:56:16 (2 years ago)

Author:

ymipsl

Message:

Implement small garbage collector for unfreed MPI windows and communicator.

YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.cpp (modified) (1 diff)

XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.cpp

@@ -162 +162 @@
         MPI_Intercomm_create(commSelf_, 0, interCommMerged_, rank, 0 , &interComm) ;
         MPI_Intercomm_merge(interComm, true, &winComm_[rank]) ;
+        CXios::getMpiGarbageCollector().registerCommunicator(winComm_[rank]) ;
+        MPI_Comm_free(&interComm) ;
         windows_[rank].resize(2) ;
         MPI_Win_create_dynamic(MPI_INFO_NULL, winComm_[rank], &windows_[rank][0]);
+        CXios::getMpiGarbageCollector().registerWindow(windows_[rank][0]) ;
         MPI_Win_create_dynamic(MPI_INFO_NULL, winComm_[rank], &windows_[rank][1]);
+        CXios::getMpiGarbageCollector().registerWindow(windows_[rank][1]) ;
         CTimer::get("create Windows").suspend() ;
         MPI_Barrier(winComm_[rank]) ;