DataObjectHandleBase.h

Go to the documentation of this file.

#ifndef GAUDIHIVE_DATAOBJECTHANDLEBASE_H
#define GAUDIHIVE_DATAOBJECTHANDLEBASE_H

#include <mutex>

#include "GaudiKernel/DataHandle.h"
#include "GaudiKernel/SmartIF.h"
#include "GaudiKernel/IDataProviderSvc.h"
#include "GaudiKernel/IMessageSvc.h"
#include "GaudiKernel/IProperty.h"

//---------------------------------------------------------------------------

//---------------------------------------------------------------------------

class DataObjectHandleBase : public Gaudi::DataHandle {

public:

  DataObjectHandleBase(const DataObjID& k, Gaudi::DataHandle::Mode a,
                       IDataHandleHolder* owner );
  DataObjectHandleBase(const std::string& k, Gaudi::DataHandle::Mode a,
                       IDataHandleHolder* owner);

  virtual ~DataObjectHandleBase();
  DataObjectHandleBase(const DataObjectHandleBase&) = delete;
  DataObjectHandleBase(DataObjectHandleBase&&);
  DataObjectHandleBase& operator=(const DataObjectHandleBase&);

  template <class OWNER, class K,
            typename = typename std::enable_if<std::is_base_of<IProperty, OWNER>::value>::type>
  inline DataObjectHandleBase( OWNER* owner, Gaudi::DataHandle::Mode m,
                               std::string name, const K& key = {}, std::string doc = "" )
      : DataObjectHandleBase( key, m, owner )
  {
    auto p = owner->declareProperty( std::move(name), *this, std::move(doc) );
    p->template setOwnerType<OWNER>();
  }


  std::string toString() const;
  std::string pythonRepr() const override;
  void fromString(const std::string& s);

  friend std::ostream& operator<< (std::ostream& str, const DataObjectHandleBase& d);

  bool isOptional() const {return m_optional;}
  void setOptional(bool optional = true) { m_optional = optional; }

  bool initialized() const { return m_init; }
  bool wasRead() const { return m_wasRead; }
  bool wasWritten() const { return m_wasWritten; }

  bool isValid() const;

protected:
  void setRead(bool wasRead=true) {m_wasRead = wasRead;}
  void setWritten(bool wasWritten=true) {m_wasWritten = wasWritten;}

  bool init() override;

  DataObject* fetch() const;

protected:

  SmartIF<IDataProviderSvc> m_EDS;
  SmartIF<IMessageSvc> m_MS;

  bool  m_init = false;
  bool  m_optional = false;
  bool  m_wasRead = false;
  bool  m_wasWritten = false;

  mutable bool  m_searchDone = false; // TODO: optimize it so that it is std::any_of( objKey, ":" )

  mutable std::mutex m_searchMutex;

};

//---------------------------------------------------------------------------
//---------------------------------------------------------------------------


namespace Gaudi {
  namespace Parsers {
    StatusCode parse(DataObjectHandleBase&, const std::string&);
  }
  namespace Utils {
    GAUDI_API std::ostream& toStream(const DataObjectHandleBase& v, std::ostream& o);
  }
}

#endif