Changeset 1766
- Timestamp:
- 11/06/19 11:43:37 (5 years ago)
- 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 530 530 CATCH_DUMP_ATTR 531 531 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 570 533 571 534 bool CContext::eventLoop(bool enableEventsProcessing) -
XIOS/dev/dev_ym/XIOS_SERVICES/src/node/context.hpp
r1765 r1766 94 94 void initClient(MPI_Comm intraComm, int serviceType); 95 95 96 void initServer(MPI_Comm intraComm, MPI_Comm interComm, CContext* cxtClient = 0);97 96 void initServer(MPI_Comm intraComm, int serviceType ); 98 97 void createClientInterComm(MPI_Comm interCommClient, MPI_Comm interCommServer) ;
Note: See TracChangeset
for help on using the changeset viewer.