Changeset 1638 for XIOS/trunk/src/node/context.cpp
- Timestamp:
- 01/22/19 16:15:03 (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/trunk/src/node/context.cpp
r1622 r1638 265 265 266 266 //! Initialize client side 267 void CContext::initClient( MPI_Comm intraComm,MPI_Comm interComm, CContext* cxtServer /*= 0*/)267 void CContext::initClient(ep_lib::MPI_Comm intraComm, ep_lib::MPI_Comm interComm, CContext* cxtServer /*= 0*/) 268 268 TRY 269 269 { 270 270 271 271 hasClient = true; 272 MPI_Comm intraCommServer, interCommServer;272 ep_lib::MPI_Comm intraCommServer, interCommServer; 273 273 274 274 … … 284 284 else 285 285 { 286 MPI_Comm_dup(intraComm, &intraCommServer);286 ep_lib::MPI_Comm_dup(intraComm, &intraCommServer); 287 287 comms.push_back(intraCommServer); 288 MPI_Comm_dup(interComm, &interCommServer);288 ep_lib::MPI_Comm_dup(interComm, &interCommServer); 289 289 comms.push_back(interCommServer); 290 290 } … … 309 309 { 310 310 clientPrimServer.push_back(new CContextClient(this, intraComm, interComm)); 311 MPI_Comm_dup(intraComm, &intraCommServer);311 ep_lib::MPI_Comm_dup(intraComm, &intraCommServer); 312 312 comms.push_back(intraCommServer); 313 MPI_Comm_dup(interComm, &interCommServer);313 ep_lib::MPI_Comm_dup(interComm, &interCommServer); 314 314 comms.push_back(interCommServer); 315 315 serverPrimServer.push_back(new CContextServer(this, intraCommServer, interCommServer)); … … 383 383 CATCH_DUMP_ATTR 384 384 385 void CContext::initServer( MPI_Comm intraComm,MPI_Comm interComm, CContext* cxtClient /*= 0*/)385 void CContext::initServer(ep_lib::MPI_Comm intraComm, ep_lib::MPI_Comm interComm, CContext* cxtClient /*= 0*/) 386 386 TRY 387 387 { … … 402 402 registryOut->setPath(contextRegistryId) ; 403 403 404 MPI_Comm intraCommClient, interCommClient;404 ep_lib::MPI_Comm intraCommClient, interCommClient; 405 405 if (cxtClient) // Attached mode 406 406 { … … 410 410 else 411 411 { 412 MPI_Comm_dup(intraComm, &intraCommClient);412 ep_lib::MPI_Comm_dup(intraComm, &intraCommClient); 413 413 comms.push_back(intraCommClient); 414 MPI_Comm_dup(interComm, &interCommClient);414 ep_lib::MPI_Comm_dup(interComm, &interCommClient); 415 415 comms.push_back(interCommClient); 416 416 } … … 502 502 503 503 //! Free internally allocated communicators 504 for (std::list< MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it)505 MPI_Comm_free(&(*it));504 for (std::list<ep_lib::MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it) 505 ep_lib::MPI_Comm_free(&(*it)); 506 506 comms.clear(); 507 507 … … 544 544 545 545 //! Free internally allocated communicators 546 for (std::list< MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it)547 MPI_Comm_free(&(*it));546 for (std::list<ep_lib::MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it) 547 ep_lib::MPI_Comm_free(&(*it)); 548 548 comms.clear(); 549 549 … … 560 560 TRY 561 561 { 562 for (std::list< MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it)563 MPI_Comm_free(&(*it));562 for (std::list<ep_lib::MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it) 563 ep_lib::MPI_Comm_free(&(*it)); 564 564 comms.clear(); 565 565 }
Note: See TracChangeset
for help on using the changeset viewer.