Changeset 1766


Ignore:
Timestamp:
11/06/19 11:43:37 (5 years ago)
Author:
ymipsl
Message:

more cleaning...
YM

Location:
XIOS/dev/dev_ym/XIOS_SERVICES/src/node
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • XIOS/dev/dev_ym/XIOS_SERVICES/src/node/context.cpp

    r1765 r1766  
    530530  CATCH_DUMP_ATTR 
    531531 
    532   
    533    void CContext::initServer(MPI_Comm intraComm, MPI_Comm interComm, CContext* cxtClient /*= 0*/) 
    534    TRY 
    535    { 
    536      hasServer=true; 
    537      server = new CContextServer(this,intraComm,interComm); 
    538  
    539 /* for registry take the id of client context */ 
    540 /* for servers, supress the _server_ from id  */ 
    541      string contextRegistryId=getId() ; 
    542      size_t pos=contextRegistryId.find("_server_") ; 
    543      if (pos!=std::string::npos)  contextRegistryId=contextRegistryId.substr(0,pos) ; 
    544         
    545      registryIn=new CRegistry(intraComm); 
    546      registryIn->setPath(contextRegistryId) ; 
    547      if (server->intraCommRank==0) registryIn->fromFile("xios_registry.bin") ; 
    548      registryIn->bcastRegistry() ; 
    549      registryOut=new CRegistry(intraComm) ; 
    550      registryOut->setPath(contextRegistryId) ; 
    551  
    552      MPI_Comm intraCommClient, interCommClient; 
    553      if (cxtClient) // Attached mode 
    554      { 
    555        intraCommClient = intraComm; 
    556        interCommClient = interComm; 
    557      } 
    558      else 
    559      { 
    560        MPI_Comm_dup(intraComm, &intraCommClient); 
    561        comms.push_back(intraCommClient); 
    562        MPI_Comm_dup(interComm, &interCommClient); 
    563        comms.push_back(interCommClient); 
    564      } 
    565      client = new CContextClient(this,intraCommClient,interCommClient, cxtClient); 
    566    } 
    567    CATCH_DUMP_ATTR 
    568  
    569   
     532    
    570533 
    571534  bool CContext::eventLoop(bool enableEventsProcessing) 
  • XIOS/dev/dev_ym/XIOS_SERVICES/src/node/context.hpp

    r1765 r1766  
    9494         void initClient(MPI_Comm intraComm, int serviceType); 
    9595          
    96          void initServer(MPI_Comm intraComm, MPI_Comm interComm, CContext* cxtClient = 0); 
    9796         void initServer(MPI_Comm intraComm, int serviceType ); 
    9897         void createClientInterComm(MPI_Comm interCommClient, MPI_Comm interCommServer)  ; 
Note: See TracChangeset for help on using the changeset viewer.