Changeset 987 for XIOS/dev/dev_olga/src/node/domain.cpp

Timestamp:

11/10/16 13:29:57 (8 years ago)

Author:

mhnguyen

Message:

First working version.
There are more things to do with it

File:

• XIOS/dev/dev_olga/src/node/domain.cpp (modified) (4 diffs)

XIOS/dev/dev_olga/src/node/domain.cpp

@@ -1395 +1395 @@
   {
     CContext* context = CContext::getCurrent();
-    CContextClient* client = context->client;
-    int nbServer = client->serverSize;
+     // Use correct context client to send message
+     CContextClient* contextClientTmp = (0 != context->clientPrimServer) ? context->clientPrimServer 
+                                                                         : context->client;
+
+    // CContextClient* client = context->client;
+    int nbServer = contextClientTmp->serverSize;
 
     CServerDistributionDescription serverDescription(nGlobDomain_, nbServer);
@@ -1406 +1410 @@
 
     CEventClient event(getType(),EVENT_ID_SERVER_ATTRIBUT);
-    if (client->isServerLeader())
+    if (contextClientTmp->isServerLeader())
     {
       std::list<CMessage> msgs;
 
-      const std::list<int>& ranks = client->getRanksServerLeader();
+      const std::list<int>& ranks = contextClientTmp->getRanksServerLeader();
       for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank)
       {
@@ -1430 +1434 @@
         event.push(*itRank,1,msg);
       }
-      client->sendEvent(event);
-    }
-    else client->sendEvent(event);
+      contextClientTmp->sendEvent(event);
+    }
+    else contextClientTmp->sendEvent(event);
   }
 
@@ -1852 +1856 @@
     *buffer>>domainId ;
     get(domainId)->recvServerAttribut(*buffer) ;
+    
+    CContext* context = CContext::getCurrent();
+    if (context->hasClient && context->hasServer)
+    {
+      get(domainId)->sendServerAttribut();
+    }
+
   }