Ignore:
Timestamp:
11/10/16 13:29:57 (7 years ago)
Author:
mhnguyen
Message:

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

File:
1 edited

Legend:

Unmodified
Added
Removed

  • XIOS/dev/dev_olga/src/node/grid.cpp

    r983 r987  
    15141514   void CGrid::sendAddDomain(const string& id) 
    15151515   { 
    1516     CContext* context=CContext::getCurrent(); 
    1517  
    1518     if (! context->hasServer ) 
    1519     { 
    1520        CContextClient* client=context->client; 
    1521  
    1522        CEventClient event(this->getType(),EVENT_ID_ADD_DOMAIN); 
    1523        if (client->isServerLeader()) 
    1524        { 
    1525          CMessage msg; 
    1526          msg<<this->getId(); 
    1527          msg<<id; 
    1528          const std::list<int>& ranks = client->getRanksServerLeader(); 
    1529          for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
    1530            event.push(*itRank,1,msg); 
    1531          client->sendEvent(event); 
    1532        } 
    1533        else client->sendEvent(event); 
    1534     } 
     1516      sendAddItem(id, (int)EVENT_ID_ADD_DOMAIN); 
     1517    // CContext* context=CContext::getCurrent(); 
     1518 
     1519    // if (! context->hasServer ) 
     1520    // { 
     1521    //    CContextClient* client=context->client; 
     1522 
     1523    //    CEventClient event(this->getType(),EVENT_ID_ADD_DOMAIN); 
     1524    //    if (client->isServerLeader()) 
     1525    //    { 
     1526    //      CMessage msg; 
     1527    //      msg<<this->getId(); 
     1528    //      msg<<id; 
     1529    //      const std::list<int>& ranks = client->getRanksServerLeader(); 
     1530    //      for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
     1531    //        event.push(*itRank,1,msg); 
     1532    //      client->sendEvent(event); 
     1533    //    } 
     1534    //    else client->sendEvent(event); 
     1535    // } 
    15351536   } 
    15361537 
    … …  
    15411542   void CGrid::sendAddAxis(const string& id) 
    15421543   { 
    1543     CContext* context=CContext::getCurrent(); 
    1544  
    1545     if (! context->hasServer ) 
    1546     { 
    1547        CContextClient* client=context->client; 
    1548  
    1549        CEventClient event(this->getType(),EVENT_ID_ADD_AXIS); 
    1550        if (client->isServerLeader()) 
    1551        { 
    1552          CMessage msg; 
    1553          msg<<this->getId(); 
    1554          msg<<id; 
    1555          const std::list<int>& ranks = client->getRanksServerLeader(); 
    1556          for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
    1557            event.push(*itRank,1,msg); 
    1558          client->sendEvent(event); 
    1559        } 
    1560        else client->sendEvent(event); 
    1561     } 
     1544      sendAddItem(id, (int)EVENT_ID_ADD_AXIS); 
     1545    // CContext* context=CContext::getCurrent(); 
     1546 
     1547    // if (! context->hasServer ) 
     1548    // { 
     1549    //    CContextClient* client=context->client; 
     1550 
     1551    //    CEventClient event(this->getType(),EVENT_ID_ADD_AXIS); 
     1552    //    if (client->isServerLeader()) 
     1553    //    { 
     1554    //      CMessage msg; 
     1555    //      msg<<this->getId(); 
     1556    //      msg<<id; 
     1557    //      const std::list<int>& ranks = client->getRanksServerLeader(); 
     1558    //      for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
     1559    //        event.push(*itRank,1,msg); 
     1560    //      client->sendEvent(event); 
     1561    //    } 
     1562    //    else client->sendEvent(event); 
     1563    // } 
    15621564   } 
    15631565 
    … …  
    15681570   void CGrid::sendAddScalar(const string& id) 
    15691571   { 
    1570     CContext* context=CContext::getCurrent(); 
    1571  
    1572     if (! context->hasServer ) 
    1573     { 
    1574        CContextClient* client=context->client; 
    1575  
    1576        CEventClient event(this->getType(),EVENT_ID_ADD_SCALAR); 
    1577        if (client->isServerLeader()) 
    1578        { 
    1579          CMessage msg; 
    1580          msg<<this->getId(); 
    1581          msg<<id; 
    1582          const std::list<int>& ranks = client->getRanksServerLeader(); 
    1583          for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
    1584            event.push(*itRank,1,msg); 
    1585          client->sendEvent(event); 
    1586        } 
    1587        else client->sendEvent(event); 
    1588     } 
     1572      sendAddItem(id, (int)EVENT_ID_ADD_SCALAR); 
     1573    // CContext* context=CContext::getCurrent(); 
     1574 
     1575    // if (! context->hasServer ) 
     1576    // { 
     1577    //    CContextClient* client=context->client; 
     1578 
     1579    //    CEventClient event(this->getType(),EVENT_ID_ADD_SCALAR); 
     1580    //    if (client->isServerLeader()) 
     1581    //    { 
     1582    //      CMessage msg; 
     1583    //      msg<<this->getId(); 
     1584    //      msg<<id; 
     1585    //      const std::list<int>& ranks = client->getRanksServerLeader(); 
     1586    //      for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
     1587    //        event.push(*itRank,1,msg); 
     1588    //      client->sendEvent(event); 
     1589    //    } 
     1590    //    else client->sendEvent(event); 
     1591    // } 
    15891592   } 
    15901593 
Note: See TracChangeset for help on using the changeset viewer.