registry.hpp

Aller à la documentation de ce fichier.

#ifndef __XIOS_REGISTRY_HPP__
#define __XIOS_REGISTRY_HPP__

#include "base_type.hpp"
#include "type.hpp"
#include "mpi.hpp"
#include "message.hpp"

// Those two headers can be replaced by the C++11 equivalent in the future
#include <boost/utility/enable_if.hpp>
#include <boost/type_traits.hpp>

namespace xios
{
  class CRegistry : virtual public CBaseType
  {
    public:

      CRegistry(const MPI_Comm& comm=MPI_COMM_WORLD) : communicator(comm) {}

      CRegistry(const CRegistry& reg) ;


      void setKey(const std::string& key, const CBaseType& value) { this->setKey_(key,value); }

      template<typename T> typename boost::enable_if_c<!boost::is_convertible<T&, CBaseType&>::value>::type
      setKey(const std::string& key, const T& value) { this->setKey_(key,CType<T>(value)); }


      void getKey(const std::string& key, CBaseType& value) { this->getKey_(key,value); }

      template<typename T> typename boost::enable_if_c<!boost::is_convertible<T&, CBaseType&>::value>::type
      getKey(const std::string& key, T& value) { CType_ref<T> valRef(value); this->getKey_(key,valRef); }


      bool foundKey(const std::string& key) const ;

      bool toBuffer(CBufferOut& buffer) const ;

      bool fromBuffer(CBufferIn& buffer) ;

      void toFile(const string& filename) ;

      void fromFile(const string& filename) ;

      void mergeRegistry(const CRegistry& inRegistry) ;

      void bcastRegistry(void) ;

      void gatherRegistry(void) ;

      void hierarchicalGatherRegistry(void) ;

       ~CRegistry() { reset() ; }

      void fromString(const string& str) ;

      string toString(void) const ;

      CRegistry* clone(void) const { return new CRegistry(*this); }

      size_t size(void) const ;

      bool isEmpty(void) const { return registry.empty(); }

      void reset(void) ;

      void setPath(const string& str) { path=str+"::" ; }

    private:

      void setKey_(const std::string& key, const CBaseType& value) ;

      void getKey_(const std::string& key, CBaseType& value) ;

      void gatherRegistry(const MPI_Comm& comm) ;

      void hierarchicalGatherRegistry(const MPI_Comm& comm) ;


      std::string path ;

      std::map<std::string,std::pair<size_t,char*> > registry ;

      MPI_Comm communicator ;
  } ;

  inline CMessage& operator<<(CMessage& msg, CRegistry& registry)
  {
      msg.push(registry) ;
      return msg ;
  }

  inline CMessage& operator<<(CMessage& msg, const CRegistry& registry)
  {
      msg.push(registry) ;
      return msg ;
  }

}

#endif