Ignore:
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:
1 edited

Legend:

Unmodified
Added
Removed

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

    r957 r987  
    826826   void CFile::sendAddField(const string& id) 
    827827   { 
    828     CContext* context = CContext::getCurrent(); 
    829  
    830     if (! context->hasServer ) 
    831     { 
    832        CContextClient* client = context->client; 
    833  
    834        CEventClient event(this->getType(),EVENT_ID_ADD_FIELD); 
    835        if (client->isServerLeader()) 
    836        { 
    837          CMessage msg; 
    838          msg << this->getId(); 
    839          msg << id; 
    840          const std::list<int>& ranks = client->getRanksServerLeader(); 
    841          for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
    842            event.push(*itRank,1,msg); 
    843          client->sendEvent(event); 
    844        } 
    845        else client->sendEvent(event); 
    846     } 
     828      sendAddItem(id, EVENT_ID_ADD_FIELD); 
     829    // CContext* context = CContext::getCurrent(); 
     830 
     831    // if (! context->hasServer ) 
     832    // { 
     833    //    CContextClient* client = context->client; 
     834 
     835    //    CEventClient event(this->getType(),EVENT_ID_ADD_FIELD); 
     836    //    if (client->isServerLeader()) 
     837    //    { 
     838    //      CMessage msg; 
     839    //      msg << this->getId(); 
     840    //      msg << id; 
     841    //      const std::list<int>& ranks = client->getRanksServerLeader(); 
     842    //      for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
     843    //        event.push(*itRank,1,msg); 
     844    //      client->sendEvent(event); 
     845    //    } 
     846    //    else client->sendEvent(event); 
     847    // } 
    847848 
    848849   } 
    … …  
    854855   void CFile::sendAddFieldGroup(const string& id) 
    855856   { 
    856     CContext* context = CContext::getCurrent(); 
    857     if (! context->hasServer ) 
    858     { 
    859        CContextClient* client = context->client; 
    860  
    861        CEventClient event(this->getType(),EVENT_ID_ADD_FIELD_GROUP); 
    862        if (client->isServerLeader()) 
    863        { 
    864          CMessage msg; 
    865          msg << this->getId(); 
    866          msg << id; 
    867          const std::list<int>& ranks = client->getRanksServerLeader(); 
    868          for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
    869            event.push(*itRank,1,msg); 
    870          client->sendEvent(event); 
    871        } 
    872        else client->sendEvent(event); 
    873     } 
     857      sendAddItem(id, (int)EVENT_ID_ADD_FIELD_GROUP); 
     858    // CContext* context = CContext::getCurrent(); 
     859    // if (! context->hasServer ) 
     860    // { 
     861    //    CContextClient* client = context->client; 
     862 
     863    //    CEventClient event(this->getType(),EVENT_ID_ADD_FIELD_GROUP); 
     864    //    if (client->isServerLeader()) 
     865    //    { 
     866    //      CMessage msg; 
     867    //      msg << this->getId(); 
     868    //      msg << id; 
     869    //      const std::list<int>& ranks = client->getRanksServerLeader(); 
     870    //      for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
     871    //        event.push(*itRank,1,msg); 
     872    //      client->sendEvent(event); 
     873    //    } 
     874    //    else client->sendEvent(event); 
     875    // } 
    874876 
    875877   } 
    … …  
    950952   void CFile::sendAddVariable(const string& id) 
    951953   { 
    952     CContext* context = CContext::getCurrent(); 
    953  
    954     if (! context->hasServer ) 
    955     { 
    956        CContextClient* client = context->client; 
    957  
    958        CEventClient event(this->getType(),EVENT_ID_ADD_VARIABLE); 
    959        if (client->isServerLeader()) 
    960        { 
    961          CMessage msg; 
    962          msg << this->getId(); 
    963          msg << id; 
    964          const std::list<int>& ranks = client->getRanksServerLeader(); 
    965          for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
    966            event.push(*itRank,1,msg); 
    967          client->sendEvent(event); 
    968        } 
    969        else client->sendEvent(event); 
    970     } 
     954      sendAddItem(id, (int)EVENT_ID_ADD_VARIABLE); 
     955    // CContext* context = CContext::getCurrent(); 
     956 
     957    // if (! context->hasServer ) 
     958    // { 
     959    //    CContextClient* client = context->client; 
     960 
     961    //    CEventClient event(this->getType(),EVENT_ID_ADD_VARIABLE); 
     962    //    if (client->isServerLeader()) 
     963    //    { 
     964    //      CMessage msg; 
     965    //      msg << this->getId(); 
     966    //      msg << id; 
     967    //      const std::list<int>& ranks = client->getRanksServerLeader(); 
     968    //      for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
     969    //        event.push(*itRank,1,msg); 
     970    //      client->sendEvent(event); 
     971    //    } 
     972    //    else client->sendEvent(event); 
     973    // } 
    971974 
    972975   } 
    … …  
    978981   void CFile::sendAddVariableGroup(const string& id) 
    979982   { 
    980     CContext* context = CContext::getCurrent(); 
    981     if (! context->hasServer ) 
    982     { 
    983        CContextClient* client = context->client; 
    984  
    985        CEventClient event(this->getType(),EVENT_ID_ADD_VARIABLE_GROUP); 
    986        if (client->isServerLeader()) 
    987        { 
    988          CMessage msg; 
    989          msg << this->getId(); 
    990          msg << id; 
    991          const std::list<int>& ranks = client->getRanksServerLeader(); 
    992          for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
    993            event.push(*itRank,1,msg); 
    994          client->sendEvent(event); 
    995        } 
    996        else client->sendEvent(event); 
    997     } 
     983      sendAddItem(id, (int)EVENT_ID_ADD_VARIABLE_GROUP); 
     984    // CContext* context = CContext::getCurrent(); 
     985    // if (! context->hasServer ) 
     986    // { 
     987    //    CContextClient* client = context->client; 
     988 
     989    //    CEventClient event(this->getType(),EVENT_ID_ADD_VARIABLE_GROUP); 
     990    //    if (client->isServerLeader()) 
     991    //    { 
     992    //      CMessage msg; 
     993    //      msg << this->getId(); 
     994    //      msg << id; 
     995    //      const std::list<int>& ranks = client->getRanksServerLeader(); 
     996    //      for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
     997    //        event.push(*itRank,1,msg); 
     998    //      client->sendEvent(event); 
     999    //    } 
     1000    //    else client->sendEvent(event); 
     1001    // } 
    9981002 
    9991003   } 
Note: See TracChangeset for help on using the changeset viewer.