Changeset 2628 for XIOS3/trunk/src/transport/one_sided_context_server.cpp
- Timestamp:
- 04/03/24 10:33:55 (7 weeks ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS3/trunk/src/transport/one_sided_context_server.cpp
r2595 r2628 30 30 { 31 31 using namespace std ; 32 extern CLogType logTimers ; 33 extern CLogType logProfile ; 32 34 33 35 COneSidedContextServer::COneSidedContextServer(CContext* parent,MPI_Comm intraComm_,MPI_Comm interComm_) … … 71 73 bool COneSidedContextServer::eventLoop(bool enableEventsProcessing /*= true*/) 72 74 { 73 CTimer::get("listen request").resume();75 if (info.isActive(logTimers)) CTimer::get("listen request").resume(); 74 76 listen(); 75 CTimer::get("listen request").suspend();76 77 CTimer::get("listen pending request").resume();77 if (info.isActive(logTimers)) CTimer::get("listen request").suspend(); 78 79 if (info.isActive(logTimers)) CTimer::get("listen pending request").resume(); 78 80 listenPendingRequest() ; 79 CTimer::get("listen pending request").suspend();80 81 CTimer::get("check server Buffers").resume();81 if (info.isActive(logTimers)) CTimer::get("listen pending request").suspend(); 82 83 if (info.isActive(logTimers)) CTimer::get("check server Buffers").resume(); 82 84 checkBuffers() ; 83 CTimer::get("check server Buffers").suspend();84 85 CTimer::get("check event process").resume();85 if (info.isActive(logTimers)) CTimer::get("check server Buffers").suspend(); 86 87 if (info.isActive(logTimers)) CTimer::get("check event process").resume(); 86 88 processEvents(enableEventsProcessing); 87 CTimer::get("check event process").suspend();89 if (info.isActive(logTimers)) CTimer::get("check event process").suspend(); 88 90 return finished; 89 91 … … 265 267 if (event.classId==CContext::GetType() && event.type==CContext::EVENT_ID_CONTEXT_FINALIZE) 266 268 { 269 if (info.isActive(logProfile)) CTimer::get("Context finalize").resume(); 267 270 finished=true; 268 271 info(20)<<" COneSidedContextServer: Receive context <"<<context->getId()<<"> finalize."<<endl; 269 272 notifyClientsFinalize() ; 270 CTimer::get("receiving requests").suspend();273 if (info.isActive(logTimers)) CTimer::get("receiving requests").suspend(); 271 274 context->finalize(); 272 275 … … 281 284 } 282 285 report(0)<< " Memory report : Context <"<<ctxId<<"> : server side : total memory used for buffer "<<totalBuf<<" bytes"<<endl; 286 if (info.isActive(logProfile)) CTimer::get("Context finalize").suspend(); 283 287 } 284 288 else if (event.classId==CContext::GetType()) CContext::dispatchEvent(event);
Note: See TracChangeset
for help on using the changeset viewer.