Changeset 2628 for XIOS3/trunk/src/manager/services.cpp

Timestamp:

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

Author:

jderouillat

Message:

New timers integration/reporting

File:

• XIOS3/trunk/src/manager/services.cpp (modified) (7 diffs)

XIOS3/trunk/src/manager/services.cpp

@@ -10 +10 @@
 namespace xios
 {
+  extern CLogType logTimers ;
+
   CService::CService(MPI_Comm serviceComm, shared_ptr<CEventScheduler> eventScheduler, const std::string& poolId, const std::string& serviceId, const int& partitionId, 
                      int type, int nbPartitions) 
@@ -115 +117 @@
   {
     //checkCreateContextNotification() ;
-    CTimer::get("CService::eventLoop").resume();
+    if (info.isActive(logTimers)) CTimer::get("CService::eventLoop").resume();
     int flag ;
     MPI_Iprobe(MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &flag, MPI_STATUS_IGNORE);
@@ -140 +142 @@
     }
   
-    CTimer::get("CService::eventLoop").suspend();
+    if (info.isActive(logTimers)) CTimer::get("CService::eventLoop").suspend();
     if (contexts_.empty() && finalizeSignal_) return true ;
     else return false ;
@@ -147 +149 @@
   void CService::threadEventLoop(void)
   {
+    if (info.isActive(logTimers)) CTimer::get("CService::eventLoop").resume();
     info(100)<<"Launch Thread for  CService::threadEventLoop, service id = "<<name_<<endl ;
     CThreadManager::threadInitialize() ; 
@@ -152 +155 @@
     do
     {
-      CTimer::get("CService::eventLoop").resume();
       int flag ;
       MPI_Iprobe(MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &flag, MPI_STATUS_IGNORE);
@@ -177 +179 @@
       }
 
-      CTimer::get("CService::eventLoop").suspend();
       if (contexts_.empty() && finalizeSignal_) finished_=true ;
       if (!finished_) CThreadManager::yield() ;
@@ -184 +185 @@
     CThreadManager::threadFinalize() ;
     info(100)<<"Close thread for  CService::threadEventLoop, service id = "<<name_<<endl ;
+    if (info.isActive(logTimers)) CTimer::get("CService::eventLoop").suspend();
   }