Changeset 2528
- Timestamp:
- 06/30/23 10:14:07 (11 months ago)
- Location:
- XIOS3/trunk/src/transport
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS3/trunk/src/transport/legacy_context_client.cpp
r2520 r2528 34 34 35 35 if (!isAttachedModeEnabled()) MPI_Intercomm_merge(interComm_,false, &interCommMerged_) ; 36 else interCommMerged_ = interComm_; // interComm_ is yet an intracommunicator in attached 36 37 37 38 MPI_Comm_split(intraComm_,clientRank,clientRank, &commSelf_) ; // for windows … … 226 227 } 227 228 228 CClientBuffer* buffer = buffers[rank] = new CClientBuffer(interCommMerged_, clientSize+rank, mapBufferSize_[rank], maxEventSizes[rank]); 229 int considerServers = 1; 230 if (isAttachedModeEnabled()) considerServers = 0; 231 CClientBuffer* buffer = buffers[rank] = new CClientBuffer(interCommMerged_, considerServers*clientSize+rank, mapBufferSize_[rank], maxEventSizes[rank]); 229 232 if (isGrowableBuffer_) buffer->setGrowableBuffer(1.2) ; 230 233 else buffer->fixBuffer() ; -
XIOS3/trunk/src/transport/legacy_context_server.cpp
r2520 r2528 44 44 45 45 if (!isAttachedModeEnabled()) MPI_Intercomm_merge(interComm_,true,&interCommMerged_) ; 46 else interCommMerged_ = interComm_; // interComm_ is yet an intracommunicator in attached 46 47 MPI_Comm_split(intraComm_, intraCommRank, intraCommRank, &commSelf_) ; // for windows 47 48
Note: See TracChangeset
for help on using the changeset viewer.