GhostLayerFromConnectivityComputer.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
//-----------------------------------------------------------------------------
/*------------------------------------------------------------------------------*/
/* ReplicatedGhostDoFBuilder.cc                                   (C) 2000-2017 */
/*                                                                              */
/* Implementation of a ghost creation policy for connectivity                   */
/*------------------------------------------------------------------------------*/
/*------------------------------------------------------------------------------*/
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arcane/mesh/GhostLayerFromConnectivityComputer.h"
#include "arcane/core/IItemFamily.h"
#include "arcane/core/IParallelMng.h"
#include "arcane/core/IVariableSynchronizer.h"
 
#include <algorithm>
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Arcane::GhostLayerFromConnectivityComputer::
GhostLayerFromConnectivityComputer(IItemConnectivity* item_to_dofs)
: m_connectivity(item_to_dofs)
, m_trace_mng(m_connectivity->sourceFamily()->traceMng())
{
  _computeSharedItems();
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
void Arcane::GhostLayerFromConnectivityComputer::
_computeSharedItems()
{
  m_shared_items.clear();
  m_shared_items_connected_items.clear();
  // Policy: the shared items of the To family are those connected to the shared items of the from family
  // Note here that the shared items array contains items from the To family
  Arcane::IItemFamily* item_family = m_connectivity->sourceFamily();
  Arcane::IVariableSynchronizer* synchronizer = item_family->allItemsSynchronizer();
  Arcane::Int32ConstArrayView ranks = synchronizer->communicatingRanks();
  m_shared_items.resize(synchronizer->parallelMng()->commSize());
  m_shared_items_connected_items.resize(synchronizer->parallelMng()->commSize());
 
  for (Arcane::Integer i = 0; i < ranks.size(); ++i) {
    Arcane::ItemVectorView from_family_shared_items_view = item_family->view(synchronizer->sharedItems(i));
    Arcane::ConnectivityItemVector con_items(m_connectivity);
    Arcane::Int32Array& shared_items = m_shared_items[ranks[i]];
    Arcane::Int32Array& shared_items_connected_items = m_shared_items_connected_items[ranks[i]];
 
    ENUMERATE_ITEM (from_family_item, from_family_shared_items_view) {
      ENUMERATE_ITEM (to_family_item, con_items.connectedItems(from_family_item)) {
        shared_items.add(to_family_item.localId());
        shared_items_connected_items.add(from_family_item.localId());
      }
    }
  }
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
void Arcane::GhostLayerFromConnectivityComputer::
updateConnectivity(Int32ConstArrayView ghost_items, Int64ConstArrayView ghost_items_connected_items)
{
  // Very simple case : ghost_items are connected to the items to witch they where connected in their owner
  // => ghost_items_connected items are present as ghost item in the current sub-domain
  Arcane::Int32SharedArray ghost_items_connected_items_lids(ghost_items_connected_items.size());
  bool do_fatal = true;
  m_connectivity->sourceFamily()->itemsUniqueIdToLocalId(ghost_items_connected_items_lids, ghost_items_connected_items, do_fatal);
  m_connectivity->updateConnectivity(ghost_items_connected_items_lids, ghost_items);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Arcane::Int32ConstArrayView
Arcane::GhostLayerFromConnectivityComputer::
communicatingRanks()
{
  return m_connectivity->sourceFamily()->allItemsSynchronizer()->communicatingRanks();
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Arcane::Int32ConstArrayView
Arcane::GhostLayerFromConnectivityComputer::
sharedItems(const Integer rank, const String& family_name)
{
  ARCANE_ASSERT((family_name == m_connectivity->targetFamily()->name()),
                (String::format("Error : asking shared item for the family {0} that is not the ToFamily ({1}) of the connectivity", family_name, m_connectivity->targetFamily()->name()).localstr()))
  _computeSharedItems();
  return m_shared_items[rank];
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Arcane::Int32ConstArrayView
Arcane::GhostLayerFromConnectivityComputer::
sharedItemsConnectedItems(const Integer rank, const String& family_name)
{
  ARCANE_ASSERT((family_name == m_connectivity->sourceFamily()->name()),
                (String::format("Error : asking shared item connected items for the family {0} that is not the FromFamily ({1}) of the connectivity", family_name, m_connectivity->sourceFamily()->name()).localstr()))
  return m_shared_items_connected_items[rank];
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/