Changeset 2399 for XIOS3/trunk/src/transport/one_sided_client_buffer.cpp

Timestamp:

09/09/22 17:23:16 (22 months ago)

Author:

ymipsl

Message:

-Fix performance issue in one_sided protocol

• better timer instrumentation of the protocol

YM

File:

• XIOS3/trunk/src/transport/one_sided_client_buffer.cpp (modified) (3 diffs)

XIOS3/trunk/src/transport/one_sided_client_buffer.cpp

@@ -43 +43 @@
     CXios::getMpiGarbageCollector().registerWindow(winControl_) ;
 
-    
-
-    CTimer::get("create Windows").suspend() ;
-
     MPI_Barrier(winComm_) ;
     MPI_Win_attach(winControl_, control_, controlSize_*sizeof(MPI_Aint)) ;
     MPI_Barrier(winComm_) ;
+    CTimer::get("create Windows").suspend() ;
+ 
  //   MPI_Win_lock(MPI_LOCK_EXCLUSIVE, 0, 0, winControl_) ;
  //   MPI_Win_unlock(0,winControl_) ;
@@ -217 +215 @@
     {
       request = requests_.front() ;
+      if (info.isActive(logProtocol)) CTimer::get("sendTimelineEvent : MPI_Test").resume() ;
       MPI_Test(&request.mpiRequest, &flag, MPI_STATUS_IGNORE) ;
+      if (info.isActive(logProtocol)) CTimer::get("sendTimelineEvent : MPI_Test").suspend() ;
       if (flag==true)
       {
@@ -260 +260 @@
       }
     }
+    if (info.isActive(logProtocol)) CTimer::get("sendTimelineEvent : MPI_Isend").resume() ;
     MPI_Isend(request.buffer->start(),request.buffer->count(), MPI_CHAR, serverRank_, 20, interComm_, &request.mpiRequest ) ;
+    if (info.isActive(logProtocol)) CTimer::get("sendTimelineEvent : MPI_Isend").suspend() ;
     info(logProtocol)<<outStr.str()<<endl ;
     requests_.push_back(request) ;