Changeset 597 for XIOS/trunk/src/node/context.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/node/context.cpp (modified) (4 diffs)

XIOS/trunk/src/node/context.cpp

@@ -23 +23 @@
    CContext::CContext(void)
       : CObjectTemplate<CContext>(), CContextAttributes()
-      , calendar(),hasClient(false),hasServer(false), isPostProcessed(false), dataSize_(), idServer_()
+      , calendar(), hasClient(false), hasServer(false), isPostProcessed(false), finalized(false)
+      , dataSize_(), idServer_(), client(0), server(0)
    { /* Ne rien faire de plus */ }
 
    CContext::CContext(const StdString & id)
       : CObjectTemplate<CContext>(id), CContextAttributes()
-      , calendar(),hasClient(false),hasServer(false), isPostProcessed(false), dataSize_(), idServer_()
+      , calendar(), hasClient(false), hasServer(false), isPostProcessed(false), finalized(false)
+      , dataSize_(), idServer_(), client(0), server(0)
    { /* Ne rien faire de plus */ }
 
    CContext::~CContext(void)
    {
-     if (hasClient) delete client;
-     if (hasServer) delete server;
+     delete client;
+     delete server;
    }
 
@@ -231 +233 @@
 
    //! Initialize client side
-   void CContext::initClient(MPI_Comm intraComm, MPI_Comm interComm, CContext* cxtServer)
+   void CContext::initClient(MPI_Comm intraComm, MPI_Comm interComm, CContext* cxtServer /*= 0*/)
    {
      hasClient=true;
      client = new CContextClient(this,intraComm, interComm, cxtServer);
+     MPI_Comm intraCommServer, interCommServer;
+     if (cxtServer) // Attached mode
+     {
+       intraCommServer = intraComm;
+       interCommServer = interComm;
+     }
+     else
+     {
+       MPI_Comm_dup(intraComm, &intraCommServer);
+       MPI_Comm_dup(interComm, &interCommServer);
+     }
+     server = new CContextServer(this,intraCommServer,interCommServer);
    }
 
@@ -277 +291 @@
 
    //! Initialize server
-   void CContext::initServer(MPI_Comm intraComm,MPI_Comm interComm)
+   void CContext::initServer(MPI_Comm intraComm,MPI_Comm interComm, CContext* cxtClient /*= 0*/)
    {
      hasServer=true;
      server = new CContextServer(this,intraComm,interComm);
+     MPI_Comm intraCommClient, interCommClient;
+     if (cxtClient) // Attached mode
+     {
+       intraCommClient = intraComm;
+       interCommClient = interComm;
+     }
+     else
+     {
+       MPI_Comm_dup(intraComm, &intraCommClient);
+       MPI_Comm_dup(interComm, &interCommClient);
+     }
+     client = new CContextClient(this,intraCommClient,interCommClient, cxtClient);
+     // Do something clever instead
+     std::map<int, StdSize> bufferSize;
+     for (int r = 0; r < client->serverSize; r++)
+       bufferSize[r] = 10 * sizeof(size_t) * 1024;
+     client->setBufferSize(bufferSize);
    }
 
@@ -289 +320 @@
    }
 
+   //! Try to send the buffers and receive possible answers
+   bool CContext::checkBuffersAndListen(void)
+   {
+     client->checkBuffers();
+     return server->eventLoop();
+   }
+
    //! Terminate a context
    void CContext::finalize(void)
    {
-      if (hasClient && !hasServer)
-      {
-         client->finalize();
-      }
-      if (hasServer)
-      {
-        closeAllFile();
+      if (!finalized)
+      {
+        finalized = true;
+
+        client->finalize();
+        while (!server->hasFinished())
+        {
+          server->eventLoop();
+        }
+
+        if (hasServer)
+        {
+          closeAllFile();
+        }
       }
    }