Changeset 2628 for XIOS3/trunk/src/transport/legacy_context_server.cpp

Timestamp:

04/03/24 10:33:55 (6 weeks ago)

Author:

jderouillat

Message:

New timers integration/reporting

File:

• XIOS3/trunk/src/transport/legacy_context_server.cpp (modified) (9 diffs)

XIOS3/trunk/src/transport/legacy_context_server.cpp

@@ -30 +30 @@
 {
   using namespace std ;
+  extern CLogType logTimers ;
+  extern CLogType logProfile ;
 
   CLegacyContextServer::CLegacyContextServer(CContext* parent,MPI_Comm intraComm_,MPI_Comm interComm_) 
@@ -70 +72 @@
   bool CLegacyContextServer::eventLoop(bool enableEventsProcessing /*= true*/)
   {
-    CTimer::get("listen request").resume();
+    if (info.isActive(logProfile)) CTimer::get("Recv event loop (legacy)").resume();
+    if (info.isActive(logTimers)) CTimer::get("listen request").resume();
     listen();
-    CTimer::get("listen request").suspend();
-    CTimer::get("check pending request").resume();
+    if (info.isActive(logTimers)) CTimer::get("listen request").suspend();
+    if (info.isActive(logTimers)) CTimer::get("check pending request").resume();
     checkPendingRequest();
     checkPendingProbe() ;
-    CTimer::get("check pending request").suspend();
-    CTimer::get("check event process").resume();
+    if (info.isActive(logTimers)) CTimer::get("check pending request").suspend();
+    if (info.isActive(logTimers)) CTimer::get("check event process").resume();
     processEvents(enableEventsProcessing);
-    CTimer::get("check event process").suspend();
+    if (info.isActive(logTimers)) CTimer::get("check event process").suspend();
+    if (info.isActive(logProfile)) CTimer::get("Recv event loop (legacy)").suspend();
     return finished;
   }
@@ -121 +125 @@
       int dummy ;
       MPI_Send(&dummy, 0, MPI_INT, rank, 21,interCommMerged_) ;
-      CTimer::get("create Windows").resume() ;
+      if (info.isActive(logTimers)) CTimer::get("create Windows").resume() ;
       MPI_Comm interComm ;
       int tag = 0 ;
@@ -138 +142 @@
       windows_[rank][0] -> setWinBufferAddress(winBufferAddress[0],0) ;
       windows_[rank][1] -> setWinBufferAddress(winBufferAddress[1],0) ;
-      CTimer::get("create Windows").suspend() ;
+      if (info.isActive(logTimers)) CTimer::get("create Windows").suspend() ;
       CXios::getMpiGarbageCollector().registerCommunicator(winComm_[rank]) ;
       MPI_Barrier(winComm_[rank]) ;
@@ -200 +204 @@
     MPI_Status status;
    
-    if (!pendingRequest.empty()) CTimer::get("receiving requests").resume();
-    else CTimer::get("receiving requests").suspend();
+    if (!pendingRequest.empty()) if (info.isActive(logTimers)) CTimer::get("receiving requests").resume();
+    else if (info.isActive(logTimers)) CTimer::get("receiving requests").suspend();
 
     for(it=pendingRequest.begin();it!=pendingRequest.end();it++)
@@ -227 +231 @@
   void CLegacyContextServer::getBufferFromClient(size_t timeLine)
   {
-    CTimer::get("CLegacyContextServer::getBufferFromClient").resume() ;
+    if (info.isActive(logTimers)) CTimer::get("CLegacyContextServer::getBufferFromClient").resume() ;
 
     int rank ;
@@ -244 +248 @@
       }
     }
-    CTimer::get("CLegacyContextServer::getBufferFromClient").suspend() ;
+    if (info.isActive(logTimers)) CTimer::get("CLegacyContextServer::getBufferFromClient").suspend() ;
   }
          
@@ -423 +427 @@
     if (event.classId==CContext::GetType() && event.type==CContext::EVENT_ID_CONTEXT_FINALIZE)
     {
+      if (info.isActive(logProfile)) CTimer::get("Context finalize").resume();
       finished=true;
       info(20)<<" CLegacyContextServer: Receive context <"<<context->getId()<<"> finalize."<<endl;
       notifyClientsFinalize() ;
-      CTimer::get("receiving requests").suspend();
+      if (info.isActive(logTimers)) CTimer::get("receiving requests").suspend();
       context->finalize();
       
@@ -439 +444 @@
       }
       report(0)<< " Memory report : Context <"<<ctxId<<"> : server side : total memory used for buffer "<<totalBuf<<" bytes"<<endl;
+      if (info.isActive(logProfile)) CTimer::get("Context finalize").suspend();
     }
     else if (event.classId==CContext::GetType()) CContext::dispatchEvent(event);