Ignore:
Timestamp:
01/22/21 12:00:29 (3 years ago)
Author:
yushan
Message:

Graph intermedia commit to a tmp branch

File:
1 edited

Legend:

Unmodified
Added
Removed
  • XIOS/dev/dev_trunk_graph/src/node/variable.cpp

    r1158 r2019  
    9494   * 
    9595   */ 
    96    void CVariable::sendValue() 
    97    { 
    98      CContext* context=CContext::getCurrent() ; 
    99  
    100      if (context->hasClient) 
    101      { 
    102        // Use correct context client to send message 
    103        // int nbSrvPools = (context->hasServer) ? context->clientPrimServer.size() : 1; 
    104       int nbSrvPools = (context->hasServer) ? (context->hasClient ? context->clientPrimServer.size() : 0) : 1; 
    105        for (int i = 0; i < nbSrvPools; ++i) 
    106        { 
    107 //       CContextClient* contextClientTmp = (0 != context->clientPrimServer) ? context->clientPrimServer 
    108          CContextClient* contextClientTmp = (context->hasServer) ? context->clientPrimServer[i] 
    109                                                                              : context->client; 
    110  
    111          CEventClient event(this->getType(),EVENT_ID_VARIABLE_VALUE) ; 
    112          if (contextClientTmp->isServerLeader()) 
    113          { 
    114            CMessage msg ; 
    115            msg<<this->getId() ; 
    116            msg<<content ; 
    117            const std::list<int>& ranks = contextClientTmp->getRanksServerLeader(); 
    118            for (std::list<int>::const_iterator itRank = ranks.begin(), itRankEnd = ranks.end(); itRank != itRankEnd; ++itRank) 
    119              event.push(*itRank,1,msg); 
    120            contextClientTmp->sendEvent(event) ; 
    121          } 
    122          else contextClientTmp->sendEvent(event) ; 
    123       } 
    124      } 
    125    } 
    126  
    127    void CVariable::sendValue(CContextClient* client, bool clientPrim /*= false*/) 
     96 
     97   void CVariable::sendValue(CContextClient* client) 
    12898   { 
    12999     CEventClient event(this->getType(),EVENT_ID_VARIABLE_VALUE) ; 
Note: See TracChangeset for help on using the changeset viewer.