Changeset 597 for XIOS/trunk/src/context_server.cpp

Timestamp:

05/26/15 16:13:47 (9 years ago)

Author:

rlacroix

Message:

Add basic infrastructure for servers to clients communication.

File:

• XIOS/trunk/src/context_server.cpp (modified) (5 diffs)

XIOS/trunk/src/context_server.cpp

@@ -52 +52 @@
   }
 
+  bool CContextServer::hasFinished(void)
+  {
+    return finished;
+  }
+
   bool CContextServer::eventLoop(void)
   {
@@ -79 +84 @@
         {
           it=buffers.find(rank);
-          if (it==buffers.end())
+          if (it==buffers.end()) // Receive the buffer size and allocate the buffer
           {
             StdSize buffSize = 0;
@@ -169 +174 @@
       if (event->isFull())
       {
-        if (!scheduled && !CXios::isServer)
+        if (!scheduled && CServer::eventScheduler) // Skip event scheduling for attached mode and reception on client side
         {
           CServer::eventScheduler->registerEvent(currentTimeLine,hashId);
           scheduled=true;
         }
-        else if (CXios::isServer || CServer::eventScheduler->queryEvent(currentTimeLine,hashId) )
+        else if (!CServer::eventScheduler || CServer::eventScheduler->queryEvent(currentTimeLine,hashId) )
         {
          CTimer::get("Process events").resume();
@@ -207 +212 @@
     if (event.classId==CContext::GetType() && event.type==CContext::EVENT_ID_CONTEXT_FINALIZE)
     {
+      finished=true;
       info(20)<<"Server Side context <"<<context->getId()<<"> finalized"<<endl;
       std::map<int, StdSize>::const_iterator itbMap = mapBufferSize_.begin(),
@@ -218 +224 @@
       }
       context->finalize();
-      finished=true;
       report(0)<< " Memory report : Context <"<<context->getId()<<"> : server side : total memory used for buffer "<<totalBuf<<" bytes"<<endl;
     }