Changeset 1554 for XIOS/dev/dev_ym/XIOS_ONE_SIDED/src/context_server.cpp

Timestamp:

06/28/18 18:03:28 (6 years ago)

Author:

ymipsl

Message:

• Remove temporary buffered event
• Some cleaning

YM

File:

• XIOS/dev/dev_ym/XIOS_ONE_SIDED/src/context_server.cpp (modified) (4 diffs)

XIOS/dev/dev_ym/XIOS_ONE_SIDED/src/context_server.cpp

@@ -84 +84 @@
   bool CContextServer::eventLoop(bool enableEventsProcessing /*= true*/)
   {
-//    info(100)<<"CContextServer::eventLoop : listen"<<endl ;
     listen();
-//    info(100)<<"CContextServer::eventLoop : checkPendingRequest"<<endl ;
     checkPendingRequest();
-//    info(100)<<"CContextServer::eventLoop : process events"<<endl ;
     if (enableEventsProcessing)  processEvents();
-//    info(100)<<"CContextServer::eventLoop : finished "<<finished<<endl ;
     return finished;
   }
@@ -150 +146 @@
          MPI_Intercomm_create(commSelf, 0, interCommMerged, rank, 0, &OneSidedInterComm );
          MPI_Intercomm_merge(OneSidedInterComm,true,&oneSidedComm);
-         info(100)<<"DEBUG: before creating windows (server)"<<endl ;
          buffers[rank]->createWindows(oneSidedComm) ;
-         info(100)<<"DEBUG: before creating windows (server)"<<endl ;
        }
        lastTimeLine[rank]=0 ;
@@ -223 +217 @@
           if (buffers[rank]->getBufferFromClient(timeLine, buffer, count))
           {
-            info(100)<<"get buffer from client : timeLine "<<timeLine<<endl ;
             processRequest(rank, buffer, count);
             break ;
@@ -249 +242 @@
       CBufferIn newBuffer(startBuffer,buffer.remain());
       newBuffer>>size>>timeLine;
-      info(100)<<"new event :   timeLine : "<<timeLine<<"  size : "<<size<<endl ;
       it=events.find(timeLine);
       if (it==events.end()) it=events.insert(pair<int,CEventServer*>(timeLine,new CEventServer)).first;