Changeset 2229

Timestamp:

09/14/21 15:15:15 (3 years ago)

Author:

ymipsl

Message:

When checkEvent is set, add a new diagnoistic :
Check if every server receive the event.
YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/context_client.cpp (modified) (2 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/context_client.cpp

@@ -50 +50 @@
       computeLeader(clientRank, clientSize, serverSize, ranksServerLeader, ranksServerNotLeader);
 
-      if (flag) MPI_Intercomm_merge(interComm_,false,&interCommMerged) ;
+      if (flag) 
+      {
+        MPI_Intercomm_merge(interComm_,false, &interCommMerged) ;
+        int interCommMergedRank;
+        MPI_Comm_rank(interComm_, &interCommMergedRank);
+        MPI_Comm_rank(interCommMerged, &interCommMergedRank);
+        MPI_Comm_rank(intraComm, &interCommMergedRank);
+      }
       
       if (!isAttachedModeEnabled())
@@ -151 +158 @@
         {
            ERROR("void CContextClient::sendEvent(CEventClient& event)",
-               << "Event are not coherent between client.");
-        }
+               << "Event are not coherent between client for timeline = "<<timeLine);
+        }
+        
+        vector<int> servers(serverSize,0) ;
+        auto ranks=event.getRanks() ;
+        for(auto& rank : ranks) servers[rank]=1 ;
+        MPI_Allreduce(MPI_IN_PLACE, servers.data(), serverSize,MPI_INT,MPI_SUM,intraComm) ;
+        ostringstream osstr ;
+        for(int i=0;i<serverSize;i++)  if (servers[i]==0) osstr<<i<<" , " ;
+        if (!osstr.str().empty())
+        {
+          ERROR("void CContextClient::sendEvent(CEventClient& event)",
+                 <<" Some servers will not receive the message for timeline = "<<timeLine<<endl
+                 <<"Servers are : "<<osstr.str()) ;
+        }
+
+
       }