Changeset 2528


Ignore:
Timestamp:
06/30/23 10:14:07 (11 months ago)
Author:
jderouillat
Message:

Fix intracommunicator probing for attached mode

Location:
XIOS3/trunk/src/transport
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • XIOS3/trunk/src/transport/legacy_context_client.cpp

    r2520 r2528  
    3434 
    3535      if (!isAttachedModeEnabled()) MPI_Intercomm_merge(interComm_,false, &interCommMerged_) ; 
     36      else interCommMerged_ = interComm_; // interComm_ is yet an intracommunicator in attached 
    3637       
    3738      MPI_Comm_split(intraComm_,clientRank,clientRank, &commSelf_) ; // for windows 
     
    226227      } 
    227228       
    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]); 
    229232      if (isGrowableBuffer_) buffer->setGrowableBuffer(1.2) ; 
    230233      else buffer->fixBuffer() ; 
  • XIOS3/trunk/src/transport/legacy_context_server.cpp

    r2520 r2528  
    4444 
    4545    if (!isAttachedModeEnabled()) MPI_Intercomm_merge(interComm_,true,&interCommMerged_) ; 
     46    else interCommMerged_ = interComm_; // interComm_ is yet an intracommunicator in attached 
    4647    MPI_Comm_split(intraComm_, intraCommRank, intraCommRank, &commSelf_) ; // for windows 
    4748     
Note: See TracChangeset for help on using the changeset viewer.