Changeset 2628 for XIOS3/trunk/src/client.cpp

Timestamp:

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

Author:

jderouillat

Message:

New timers integration/reporting

File:

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

XIOS3/trunk/src/client.cpp

@@ -36 +36 @@
     StdOFStream CClient::m_errorStream;
     CPoolRessource* CClient::poolRessource_=nullptr ;
+    extern CLogType logTimers ;
 
     MPI_Comm& CClient::getInterComm(void)   { return (interComm_); }
@@ -543 +544 @@
       report(0)<< " Memory report : Minimum buffer size required : " << CClientBuffer::maxRequestSize << " bytes" << endl ;
       report(0)<< " Memory report : increasing it by a factor will increase performance, depending of the volume of data wrote in file at each time step of the file"<<endl ;
-      report(100)<<CTimer::getAllCumulatedTime()<<endl ;
+
+      if (info.isActive(logProfile))
+      {
+        printProfile();
+      }
+        
+      if (info.isActive(logTimers)) report(0)<<"\n"<<CTimer::getAllCumulatedTime()<<endl ;
       if (CXios::reportMemory)
       {
@@ -552 +559 @@
       xios::releaseStaticAllocation() ;
 
+    }
+
+    void CClient::printProfile()
+    {
+      list< pair<string,int> > timer_name;
+      timer_name.push_back({"XIOS init",0});
+      timer_name.push_back({"XIOS init context",0});
+      timer_name.push_back({"XIOS close definition",0});
+      timer_name.push_back({"XIOS solve inheritance",0});
+      timer_name.push_back({"XIOS update calendar",0});
+      timer_name.push_back({"Check late data (read)",1});
+      timer_name.push_back({"XIOS recv field",0});
+      timer_name.push_back({"XIOS send field",0});
+      timer_name.push_back({"Context event loop",1});
+      timer_name.push_back({"Model to client",1});
+      timer_name.push_back({"Client workflow",1});
+      timer_name.push_back({"Applying filters",2});
+      timer_name.push_back({"Transformation transfers",3});
+      timer_name.push_back({"Transformation MPI",4});
+      timer_name.push_back({"Temporal filters",3});
+      timer_name.push_back({"Scatter event",3});
+      timer_name.push_back({"Field : send data",4});
+      timer_name.push_back({"Blocking time",0});
+      timer_name.push_back({"XIOS context finalize",0});
+      timer_name.push_back({"XIOS finalize",0});
+      
+      report(0)<< endl;
+      double total_time = CTimer::get("XIOS").getCumulatedTime();
+      for(auto it_timer_name = timer_name.begin(); it_timer_name != timer_name.end(); it_timer_name++)
+      {
+        double timer_time = CTimer::get(it_timer_name->first).getCumulatedTime();
+        if ( timer_time / total_time > 0.001 )
+        {
+          ostringstream printed_line;
+          printed_line << setprecision(3) << std::fixed;
+          for(int itab=0;itab<it_timer_name->second;itab++)
+              printed_line << "  ";
+          printed_line << it_timer_name->first << " : " << timer_time <<endl;
+          string string_line = printed_line.str();
+          report(0)<< string_line;
+        }
+      }
     }