DataFactoryMng.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
//-----------------------------------------------------------------------------
/*---------------------------------------------------------------------------*/
/* DataFactoryMng.cc                                           (C) 2000-2021 */
/*                                                                           */
/* Data Factory Manager.                                                     */
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arcane/impl/DataFactoryMng.h"
 
#include "arcane/utils/PlatformUtils.h"
#include "arcane/utils/Deleter.h"
#include "arcane/utils/ITraceMng.h"
#include "arcane/utils/FatalErrorException.h"
 
#include "arcane/core/IApplication.h"
#include "arcane/core/IData.h"
#include "arcane/core/IDataStorageFactory.h"
#include "arcane/core/MathUtils.h"
 
#include "arcane/datatype/DataStorageTypeInfo.h"
#include "arcane/datatype/DataStorageBuildInfo.h"
 
#include "arcane/impl/SerializedData.h"
#include "arcane/impl/DataFactory.h"
#include "arcane/impl/DataOperation.h"
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
namespace Arcane
{
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
extern "C++" void
arcaneRegisterSimpleData(IDataFactoryMng* df);
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
DataFactoryMng::
DataFactoryMng(IApplication* app)
: TraceAccessor(app->traceMng())
, m_application(app)
, m_old_factory(new DataFactory(app))
{
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
DataFactoryMng::
~DataFactoryMng()
{
  delete m_old_factory;
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<IData> DataFactoryMng::
createSimpleDataRef(const String& storage_type, const DataStorageBuildInfo& build_info)
{
  auto x = m_factories.find(storage_type);
  if (x == m_factories.end())
    ARCANE_FATAL("Can not find data factory named={0}", storage_type);
  // Positions the values of \a build_info that are not yet
  // initialized.
  DataStorageBuildInfo b = build_info;
  if (!b.memoryAllocator())
    b.setMemoryAllocator(platform::getDefaultDataAllocator());
 
  return x->second->createSimpleDataRef(b);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
IDataOperation* DataFactoryMng::
createDataOperation(Parallel::eReduceType rt)
{
  return arcaneCreateDataOperation(rt);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<ISerializedData> DataFactoryMng::
createSerializedDataRef(eDataType data_type, Int64 memory_size,
                        Integer nb_dim, Int64 nb_element, Int64 nb_base_element,
                        bool is_multi_size, Int64ConstArrayView dimensions)
{
  return arcaneCreateSerializedDataRef(data_type, memory_size, nb_dim, nb_element,
                                       nb_base_element, is_multi_size, dimensions);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<ISerializedData> DataFactoryMng::
createEmptySerializedDataRef()
{
  return arcaneCreateEmptySerializedDataRef();
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
void DataFactoryMng::
build()
{
  arcaneRegisterSimpleData(this);
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
ITraceMng* DataFactoryMng::
traceMng() const
{
  return TraceAccessor::traceMng();
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
void DataFactoryMng::
registerDataStorageFactory(Ref<IDataStorageFactory> factory)
{
  DataStorageTypeInfo t = factory->storageTypeInfo();
  m_factories.insert(std::make_pair(t.fullName(), factory));
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Ref<IDataFactoryMng>
arcaneCreateDataFactoryMngRef(IApplication* app)
{
  Ref<IDataFactoryMng> df(Arccore::makeRef(new DataFactoryMng(app)));
  df->build();
  return df;
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
} // End namespace Arcane
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/