Changeset 799 for XIOS/branchs/xios-1.0/src/node/context.cpp

Timestamp:

11/27/15 09:55:05 (8 years ago)

Author:

rlacroix

Message:

Add registry

File:

• XIOS/branchs/xios-1.0/src/node/context.cpp (modified) (7 diffs)

XIOS/branchs/xios-1.0/src/node/context.cpp

@@ -7 +7 @@
 #include "duration.hpp"
 
+#include "cxios.hpp"
 #include "context_client.hpp"
 #include "context_server.hpp"
@@ -268 +269 @@
      hasClient=true ;
      client = new CContextClient(this,intraComm, interComm) ;
+     registryIn=new CRegistry(intraComm);
+     registryIn->setPath(getId()) ;
+     if (client->clientRank==0) registryIn->fromFile("xios_registry.bin") ;
+     registryIn->bcastRegistry() ;
+
+     registryOut=new CRegistry(intraComm) ;
+     registryOut->setPath(getId()) ;
    } 
 
@@ -279 +287 @@
      hasServer=true ;
      server = new CContextServer(this,intraComm,interComm) ;
+     registryIn=new CRegistry(intraComm);
+     registryIn->setPath(getId()) ;
+     if (server->intraCommRank==0) registryIn->fromFile("xios_registry.bin") ;
+     registryIn->bcastRegistry() ;
+     registryOut=new CRegistry(intraComm) ;
+     registryOut->setPath(getId()) ;
    } 
 
@@ -290 +304 @@
       if (hasClient && !hasServer)
       {
+         if (hasClient) sendRegistry() ;
          client->finalize() ;
       }
@@ -295 +310 @@
       {
         closeAllFile() ;
+        registryOut->hierarchicalGatherRegistry() ;
+        if (server->intraCommRank==0) CXios::globalRegistry->mergeRegistry(*registryOut) ;
       }
    }
@@ -429 +446 @@
              return true ;
              break ;
+           case EVENT_ID_SEND_REGISTRY:
+            recvRegistry(event);
+            return true;
+           break;
            default :
              ERROR("bool CContext::dispatchEvent(CEventServer& event)",
@@ -564 +585 @@
     return (context);
   }
+
+  void CContext::recvRegistry(CEventServer& event)
+  {
+    CBufferIn* buffer=event.subEvents.begin()->buffer;
+    string id;
+    *buffer>>id;
+    get(id)->recvRegistry(*buffer);
+  }
+
+  void CContext::recvRegistry(CBufferIn& buffer)
+  {
+    if (server->intraCommRank==0)
+    {
+      CRegistry registry(server->intraComm) ;
+      registry.fromBuffer(buffer) ;
+      registryOut->mergeRegistry(registry) ;
+    }
+  }
+
+  void CContext::sendRegistry(void)
+  {
+    registryOut->hierarchicalGatherRegistry() ;
+
+    CEventClient event(CContext::GetType(), CContext::EVENT_ID_SEND_REGISTRY);
+    if (client->isServerLeader())
+    {
+       CMessage msg ;
+       msg<<this->getId();
+       if (client->clientRank==0) msg<<*registryOut ;
+       event.push(client->getServerLeader(),1,msg);
+       client->sendEvent(event);
+     }
+     else client->sendEvent(event);
+  }
 } // namespace xios