Changeset 595 for XIOS/trunk/src/node/file.cpp

Timestamp:

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

Author:

rlacroix

Message:

Allow using more servers than clients.

This will be useful later when implementing server to client communications.

File:

• XIOS/trunk/src/node/file.cpp (modified) (4 diffs)

XIOS/trunk/src/node/file.cpp

@@ -617 +617 @@
          msg<<this->getId() ;
          msg<<id ;
-         event.push(client->getServerLeader(),1,msg) ;
+         const std::list<int>& ranks = client->getRanksServerLeader();
+         for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank)
+           event.push(*itRank,1,msg);
          client->sendEvent(event) ;
        }
@@ -642 +644 @@
          msg<<this->getId() ;
          msg<<id ;
-         event.push(client->getServerLeader(),1,msg) ;
+         const std::list<int>& ranks = client->getRanksServerLeader();
+         for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank)
+           event.push(*itRank,1,msg);
          client->sendEvent(event) ;
        }
@@ -744 +748 @@
          msg<<this->getId() ;
          msg<<id ;
-         event.push(client->getServerLeader(),1,msg) ;
+         const std::list<int>& ranks = client->getRanksServerLeader();
+         for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank)
+           event.push(*itRank,1,msg);
          client->sendEvent(event) ;
        }
@@ -769 +775 @@
          msg<<this->getId() ;
          msg<<id ;
-         event.push(client->getServerLeader(),1,msg) ;
+         const std::list<int>& ranks = client->getRanksServerLeader();
+         for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank)
+           event.push(*itRank,1,msg);
          client->sendEvent(event) ;
        }