Changeset 2326 for XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.cpp
- Timestamp:
- 04/22/22 11:46:41 (2 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.cpp
r2310 r2326 115 115 CTimer::get("check pending request").suspend(); 116 116 CTimer::get("check event process").resume(); 117 if (enableEventsProcessing) processEvents();117 processEvents(enableEventsProcessing); 118 118 CTimer::get("check event process").suspend(); 119 119 return finished; … … 320 320 buffers[rank]->freeBuffer(count) ; 321 321 delete buffers[rank] ; 322 buffers[rank] = new CServerBuffer(windows_[rank], winAdress, 0, newSize) ;322 buffers[rank] = new CServerBuffer(windows_[rank], winAdress, 0, 2*newSize) ; 323 323 info(100)<<"Context id "<<context->getId()<<" : Receive ChangeBufferSize from client rank "<<rank 324 324 <<" newSize : "<<newSize<<" Address : "<<winAdress[0]<<" & "<<winAdress[1]<<endl ; … … 339 339 } 340 340 341 void CContextServer::processEvents( void)341 void CContextServer::processEvents(bool enableEventsProcessing) 342 342 { 343 343 map<size_t,CEventServer*>::iterator it; … … 363 363 else if (isAttachedModeEnabled() || eventScheduler_->queryEvent(currentTimeLine,hashId) ) 364 364 { 365 if (!enableEventsProcessing && isCollectiveEvent(*event)) return ; 365 366 366 367 if (!eventScheduled_) … … 498 499 bool CContextServer::isCollectiveEvent(CEventServer& event) 499 500 { 500 if (event. classId==CField::GetType()) return CField::isCollectiveEvent(event);501 if (event.type>1000) return false ; 501 502 else return true ; 502 503 }
Note: See TracChangeset
for help on using the changeset viewer.