Changeset 2589 for XIOS3/trunk/src/manager/server_context.cpp
- Timestamp:
- 10/06/23 11:32:05 (8 months ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS3/trunk/src/manager/server_context.cpp
r2588 r2589 23 23 int localRank, globalRank, commSize ; 24 24 25 MPI_Comm_dup(contextComm, &contextComm_) ;25 xios::MPI_Comm_dup(contextComm, &contextComm_) ; 26 26 CXios::getMpiGarbageCollector().registerCommunicator(contextComm_) ; 27 27 xiosComm_=CXios::getXiosComm() ; … … 104 104 { 105 105 MPI_Comm newInterCommClient, newInterCommServer ; 106 MPI_Comm_dup(contextComm_,&newInterCommClient) ;107 MPI_Comm_dup(contextComm_,&newInterCommServer) ;106 xios::MPI_Comm_dup(contextComm_,&newInterCommClient) ; 107 xios::MPI_Comm_dup(contextComm_,&newInterCommServer) ; 108 108 overlapedComm_[name_]=tuple<bool, MPI_Comm, MPI_Comm>(false, newInterCommClient, newInterCommServer) ; 109 109 MPI_Barrier(contextComm_) ; … … 129 129 if (nOverlap==0) 130 130 { 131 MPI_Intercomm_create(intraComm, 0, xiosComm_, contextLeader, 3141, &interCommClient) ;131 xios::MPI_Intercomm_create(intraComm, 0, xiosComm_, contextLeader, 3141, &interCommClient) ; 132 132 CXios::getMpiGarbageCollector().registerCommunicator(interCommClient) ; 133 MPI_Comm_dup(interCommClient, &interCommServer) ;133 xios::MPI_Comm_dup(interCommClient, &interCommServer) ; 134 134 CXios::getMpiGarbageCollector().registerCommunicator(interCommServer) ; 135 MPI_Comm_free(&newInterCommClient) ;136 MPI_Comm_free(&newInterCommServer) ;135 xios::MPI_Comm_free(&newInterCommClient) ; 136 xios::MPI_Comm_free(&newInterCommServer) ; 137 137 } 138 138 else … … 320 320 { 321 321 info(10)<<"CServerContext::createIntercomm : No overlap ==> context in server mode"<<endl ; 322 MPI_Intercomm_create(contextComm_, 0, xiosComm_, remoteLeader, 3141, &interCommServer) ;322 xios::MPI_Intercomm_create(contextComm_, 0, xiosComm_, remoteLeader, 3141, &interCommServer) ; 323 323 CXios::getMpiGarbageCollector().registerCommunicator(interCommServer) ; 324 MPI_Comm_dup(interCommServer,&interCommClient) ;324 xios::MPI_Comm_dup(interCommServer,&interCommClient) ; 325 325 CXios::getMpiGarbageCollector().registerCommunicator(interCommClient) ; 326 326 context_ -> createClientInterComm(interCommClient,interCommServer) ; … … 339 339 //delete winNotify_ ; 340 340 //winNotify_=nullptr ; 341 // MPI_Comm_free(&contextComm_) ;341 //xios::MPI_Comm_free(&contextComm_) ; 342 342 // don't forget intercomm -> later 343 343 }
Note: See TracChangeset
for help on using the changeset viewer.