[arcane,impl] Ajoute possibilité de vérifier la cohérence des synchronisations.

Author: grospelliergilles

arcane/src/arcane/impl/VariableSynchronizer.cc

@@ -18,6 +18,7 @@
 #include "arcane/utils/FatalErrorException.h"
 #include "arcane/utils/ITraceMng.h"
 #include "arcane/utils/IMemoryRessourceMng.h"
+#include "arcane/utils/ValueConvert.h"
 #include "arcane/utils/internal/MemoryBuffer.h"
 
 #include "arcane/core/VariableSynchronizerEventArgs.h"
@@ -224,6 +225,10 @@ VariableSynchronizer(IParallelMng* pm, const ItemGroup& group,
       m_trace_sync = true;
   }
 
+  // Indique si on vérifie la cohérence des variables synchronisées
+  if (auto v = Convert::Type<Int32>::tryParseFromEnvironment("ARCANE_CHECK_SYNCHRONIZE_COHERENCE",true))
+    m_is_check_coherence = (v.value()!=0);
+
   m_default_message = _buildMessage();
   m_partial_message = makeRef<SyncMessage>(_buildMessage(m_partial_sync_info));
 }
@@ -424,6 +429,8 @@ _synchronize(IVariable* var, SyncMessage* message)
   message->initialize(var);
 
   IParallelMng* pm = m_parallel_mng;
+  if (m_is_check_coherence)
+    MessagePassing::namedBarrier(pm,var->name());
   debug(Trace::High) << " Proc " << pm->commRank() << " Sync variable " << var->fullName();
   if (m_trace_sync) {
     info() << " Synchronize variable " << var->fullName()

arcane/src/arcane/impl/internal/VariableSynchronizer.h

@@ -76,11 +76,11 @@ class ARCANE_IMPL_EXPORT VariableSynchronizer
   void synchronize(IVariable* var) override;
 
   void synchronize(IVariable* var, Int32ConstArrayView local_ids) override;
-  
+
   void synchronize(VariableCollection vars) override;
 
   void synchronize(VariableCollection vars, Int32ConstArrayView local_ids) override;
-  
+
   Int32ConstArrayView communicatingRanks() override;
 
   Int32ConstArrayView sharedItems(Int32 index) override;
@@ -116,7 +116,8 @@ class ARCANE_IMPL_EXPORT VariableSynchronizer
   Ref<DataSynchronizeInfo> m_partial_sync_info;
   Ref<SyncMessage> m_partial_message;
   UniqueArray<Int32> m_partial_local_ids;
-  
+  bool m_is_check_coherence = false;
+
  private:
 
   void _synchronize(IVariable* var, SyncMessage* message);