ItemConnectivityMng.h

// -*- 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
//-----------------------------------------------------------------------------
/*---------------------------------------------------------------------------*/
/* ItemConnectivityMng.h                                       (C) 2000-2023 */
/*                                                                           */
/* Connectivity Manager                                                      */
/*---------------------------------------------------------------------------*/
#ifndef ARCANE_CONNECTIVITYMANAGER_H
#define ARCANE_CONNECTIVITYMANAGER_H
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arcane/utils/ArcaneGlobal.h"
#include "arcane/utils/ITraceMng.h"
#include "arcane/utils/Array.h"
 
#include "arcane/core/IItemConnectivity.h"
#include "arcane/core/IItemConnectivityMng.h"
#include "arcane/core/IItemConnectivitySynchronizer.h"
#include "arcane/core/IIncrementalItemConnectivity.h"
#include "arcane/core/IItemFamily.h"
 
#include <map>
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
namespace Arcane
{
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
class IItemConnectivityGhostPolicy;
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
class FamilyState
{
 public:
 
  FamilyState()
  : m_state(-1)
  {}
  FamilyState(const FamilyState&) = default;
  virtual ~FamilyState() = default;
 
 public:

  Int32SharedArray m_added_items;
  Int32SharedArray m_removed_items;
  Int32UniqueArray m_current_added_items;
  Integer m_state;
  IntegerSharedArray m_state_first_added_item_index;
  IntegerSharedArray m_state_first_removed_item_index;
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
class ConnectivityStateData
{
 public:
 
  ConnectivityStateData()
  : m_last_family_state(-1)
  , m_last_added_item_index(-1)
  , m_last_removed_item_index(-1)
  {}
  ConnectivityStateData(const ConnectivityStateData&) = default;
  virtual ~ConnectivityStateData() = default;
 
 public:
 
  Integer m_last_family_state;
  Integer m_last_added_item_index;
  Integer m_last_removed_item_index;
};
 
class ConnectivityState
{
 public:
 
  ConnectivityState() {}
  ConnectivityState(const ConnectivityState&) = default;
  virtual ~ConnectivityState() = default;
 
 public:
 
  ConnectivityStateData m_state_with_source_family;
  ConnectivityStateData m_state_with_target_family;
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
class ARCANE_MESH_EXPORT ItemConnectivityMng
: public IItemConnectivityMng
{
 public:

  ItemConnectivityMng(ITraceMng* trace_mng)
  : m_trace_mng(trace_mng)
  {}

  ~ItemConnectivityMng() override
  {
    for (const auto& map_element : m_synchronizers) {
      if (map_element.second)
        delete map_element.second;
    }
  }
 
  // Save Connectivity
  void registerConnectivity(IItemConnectivity* connectivity) override
  {
    connectivity->sourceFamily()->addSourceConnectivity(connectivity);
    connectivity->targetFamily()->addTargetConnectivity(connectivity);
    // refactoring
    connectivity->sourceFamily()->setConnectivityMng(this);
    connectivity->targetFamily()->setConnectivityMng(this);
    _register(connectivity->name(), connectivity->sourceFamily()->fullName(), connectivity->targetFamily()->fullName());
  }
 
  void unregisterConnectivity(IItemConnectivity* connectivity) override
  {
    connectivity->sourceFamily()->removeSourceConnectivity(connectivity);
    connectivity->targetFamily()->removeTargetConnectivity(connectivity);
  }
 
  // Save Connectivity
  void registerConnectivity(IIncrementalItemConnectivity* connectivity) override
  {
    //connectivity->sourceFamily()->addSourceConnectivity(connectivity);
    //connectivity->targetFamily()->addTargetConnectivity(connectivity);
    // refactoring
    connectivity->sourceFamily()->setConnectivityMng(this);
    connectivity->targetFamily()->setConnectivityMng(this);
    _register(connectivity->name(), connectivity->sourceFamily()->fullName(), connectivity->targetFamily()->fullName());
  }
 
  void unregisterConnectivity([[maybe_unused]] IIncrementalItemConnectivity* connectivity) override
  {
    //connectivity->sourceFamily()->removeSourceConnectivity(connectivity);
    //connectivity->targetFamily()->removeTargetConnectivity(connectivity);
  }

  IItemConnectivitySynchronizer* createSynchronizer(IItemConnectivity* connectivity,
                                                    IItemConnectivityGhostPolicy* connectivity_ghost_policy) override;
  IItemConnectivitySynchronizer* getSynchronizer(IItemConnectivity* connectivity) override
  {
    // TODO handle failure
    return m_synchronizers[connectivity];
  }

  void setModifiedItems(IItemFamily* family, Int32ConstArrayView added_items, Int32ConstArrayView removed_items) override;

  void notifyLocalIdChanged(IItemFamily* family, Int32ConstArrayView old_to_new_ids, Integer nb_item) override;

  bool isUpToDate(IItemConnectivity* connectivity) override
  {
    return (isUpToDateWithSourceFamily(connectivity) && isUpToDateWithTargetFamily(connectivity));
  }
  bool isUpToDateWithSourceFamily(IItemConnectivity* connectivity) override
  {
    return (_lastUpdateSourceFamilyState(connectivity->name()) == _familyState(connectivity->sourceFamily()->fullName()));
  }
  bool isUpToDateWithTargetFamily(IItemConnectivity* connectivity) override
  {
    return (_lastUpdateTargetFamilyState(connectivity->name()) == _familyState(connectivity->targetFamily()->fullName()));
  }

  void setUpToDate(IItemConnectivity* connectivity) override;

  bool isUpToDate(IIncrementalItemConnectivity* connectivity) override
  {
    return (isUpToDateWithSourceFamily(connectivity) && isUpToDateWithTargetFamily(connectivity));
  }
  bool isUpToDateWithSourceFamily(IIncrementalItemConnectivity* connectivity) override
  {
    return (_lastUpdateSourceFamilyState(connectivity->name()) == _familyState(connectivity->sourceFamily()->fullName()));
  }
  bool isUpToDateWithTargetFamily(IIncrementalItemConnectivity* connectivity) override
  {
    return (_lastUpdateTargetFamilyState(connectivity->name()) == _familyState(connectivity->targetFamily()->fullName()));
  }

  void setUpToDate(IIncrementalItemConnectivity* connectivity) override;

  void getSourceFamilyModifiedItems(IItemConnectivity* connectivity, Int32ArrayView& added_items,
                                    Int32ArrayView& removed_items) override;
  void getTargetFamilyModifiedItems(IItemConnectivity* connectivity, Int32ArrayView& added_items,
                                    Int32ArrayView& removed_items) override;
 
  void getSourceFamilyModifiedItems(IIncrementalItemConnectivity* connectivity, Int32ArrayView& added_items,
                                    Int32ArrayView& removed_items) override;
  void getTargetFamilyModifiedItems(IIncrementalItemConnectivity* connectivity, Int32ArrayView& added_items,
                                    Int32ArrayView& removed_items) override;
 
 private:
 
  void _register(const String& connectivity_name, const String& from_family_name, const String& to_family_name);
  Integer _lastUpdateSourceFamilyState(const String& connectivity_name);
  Integer _lastUpdateTargetFamilyState(const String& connectivity_name);
  Integer _familyState(const String& family_name);
  ConnectivityState& _findConnectivity(const String& connectivity_name);
  FamilyState& _findFamily(const String& family_full_name);
  void _getModifiedItems(ConnectivityStateData& connectivity_state, FamilyState& family_state, Int32ArrayView& added_items, Int32ArrayView& removed_items);
  void _setUpToDate(ConnectivityStateData& connectivity_state, FamilyState& family_state);
 
  ITraceMng* m_trace_mng;
  std::map<IItemConnectivity*, IItemConnectivitySynchronizer*> m_synchronizers;
  typedef std::map<const String, FamilyState> FamilyStateMap;
  FamilyStateMap m_family_states;
  typedef std::map<const String, ConnectivityState> ConnectivityStateMap;
  ConnectivityStateMap m_connectivity_states;
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
} // End namespace Arcane
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#endif