Changeset 1194 for XIOS/dev/dev_olga/src/context_client.cpp

Timestamp:

07/04/17 14:28:50 (7 years ago)

Author:

oabramkina

Message:

Two server levels: simplifying context finalization.
Send of context finalization is blocking now on all server types.

File:

• XIOS/dev/dev_olga/src/context_client.cpp (modified) (2 diffs)

XIOS/dev/dev_olga/src/context_client.cpp

@@ -248 +248 @@
      if (!mapBufferSize_.count(rank))
      {
-       error(0) << "WARNING: Unexpected request for buffer to communicate with server " << rank << std::endl;
+//       error(0) << "WARNING: Unexpected request for buffer to communicate with server " << rank << std::endl;
        mapBufferSize_[rank] = CXios::minBufferSize;
      }
@@ -423 +423 @@
   }
 
-  /*!
-  * Finalize context client and do some reports. Function is non-blocking.
-  */
- void CContextClient::postFinalize(void)
- {
-   map<int,CClientBuffer*>::iterator itBuff;
-   bool stop = false;
-
-   CTimer::get("Blocking time").resume();
-   while (hasTemporarilyBufferedEvent())
-   {
-     checkBuffers();
-     sendTemporarilyBufferedEvent();
-   }
-   CTimer::get("Blocking time").suspend();
-
-   CEventClient event(CContext::GetType(), CContext::EVENT_ID_CONTEXT_POST_FINALIZE);
-   if (isServerLeader())
-   {
-     CMessage msg;
-     const std::list<int>& ranks = getRanksServerLeader();
-     for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank)
-       event.push(*itRank, 1, msg);
-     sendEvent(event);
-   }
-   else sendEvent(event);
-
-   CTimer::get("Blocking time").resume();
-//   while (!stop)
-   {
-     checkBuffers();
-     if (hasTemporarilyBufferedEvent())
-       sendTemporarilyBufferedEvent();
-     stop = true;
-//     for (itBuff = buffers.begin(); itBuff != buffers.end(); itBuff++) stop &= !itBuff->second->hasPendingRequest();
-   }
-   CTimer::get("Blocking time").suspend();
-
- }
 
   /*!