ParallelMngUtilsFactoryBase.cc

// -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
//-----------------------------------------------------------------------------
// Copyright 2000-2026 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
// See the top-level COPYRIGHT file for details.
// SPDX-License-Identifier: Apache-2.0
//-----------------------------------------------------------------------------
/*---------------------------------------------------------------------------*/
/* ParallelMngUtilsFactoryBase.cc                              (C) 2000-2025 */
/*                                                                           */
/* Base class of a factory for utility functions of IParallelMng.            */
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arcane/impl/internal/ParallelMngUtilsFactoryBase.h"
 
#include "arcane/utils/Real2.h"
#include "arcane/utils/Real3.h"
#include "arcane/utils/Real2x2.h"
#include "arcane/utils/Real3x3.h"
 
#include "arcane/impl/GetVariablesValuesParallelOperation.h"
#include "arcane/impl/TransferValuesParallelOperation.h"
#include "arcane/impl/ParallelExchanger.h"
#include "arcane/impl/ParallelTopology.h"
#include "arcane/impl/internal/VariableSynchronizer.h"
 
#include "arcane/core/DataTypeDispatchingDataVisitor.h"
#include "arcane/core/IItemFamily.h"
#include "arcane/core/internal/SerializeMessage.h"
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
namespace Arcane
{
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<IGetVariablesValuesParallelOperation> ParallelMngUtilsFactoryBase::
createGetVariablesValuesOperation(IParallelMng* pm)
{
  return makeRef<IGetVariablesValuesParallelOperation>(new GetVariablesValuesParallelOperation(pm));
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<ITransferValuesParallelOperation> ParallelMngUtilsFactoryBase::
createTransferValuesOperation(IParallelMng* pm)
{
  return makeRef<ITransferValuesParallelOperation>(new TransferValuesParallelOperation(pm));
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<IParallelExchanger> ParallelMngUtilsFactoryBase::
createExchanger(IParallelMng* pm)
{
  return createParallelExchangerImpl(makeRef(pm));
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<IParallelTopology> ParallelMngUtilsFactoryBase::
createTopology(IParallelMng* pm)
{
  ParallelTopology* t = new ParallelTopology(pm);
  t->initialize();
  return makeRef<IParallelTopology>(t);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<IVariableSynchronizer> ParallelMngUtilsFactoryBase::
createSynchronizer(IParallelMng* pm, IItemFamily* family)
{
  auto* x = new VariableSynchronizer(pm, family->allItems(), {});
  return makeRef<IVariableSynchronizer>(x);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<IVariableSynchronizer> ParallelMngUtilsFactoryBase::
createSynchronizer(IParallelMng* pm, const ItemGroup& group)
{
  auto* x = new VariableSynchronizer(pm, group, {});
  return makeRef<IVariableSynchronizer>(x);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<ISerializeMessage> ParallelMngUtilsFactoryBase::
createSendSerializeMessage(IParallelMng* pm, Int32 rank)
{
  Int32 my_rank = pm->commRank();
  auto x = new SerializeMessage(my_rank, rank, ISerializeMessage::MT_Send);
  return makeRef<ISerializeMessage>(x);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<ISerializeMessage> ParallelMngUtilsFactoryBase::
createReceiveSerializeMessage(IParallelMng* pm, Int32 rank)
{
  Int32 my_rank = pm->commRank();
  auto x = new SerializeMessage(my_rank, rank, ISerializeMessage::MT_Recv);
  return makeRef<ISerializeMessage>(x);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
} // End namespace Arcane
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/