HiveEventRegistryEntry.h

Go to the documentation of this file.

#ifndef GAUDIHIVE_HIVEEVENTREGISTRYENTRY_H
#define GAUDIHIVE_HIVEEVENTREGISTRYENTRY_H

// STL include files
#include <vector>
#include <string>

// Framework include files
#include "GaudiKernel/Kernel.h"
#include "GaudiKernel/RegistryEntry.h"
#include "GaudiKernel/DataSvc.h"

// tbb include files
#include "tbb/concurrent_queue.h"
#include "tbb/concurrent_vector.h"

// Forward declarations
//class DataSvc;
class DataObject;
class IDataProviderSvc;
class IOpaqueAddress;
class IDataStoreAgent;

namespace Hive   {

  class HiveRegistryEntry;

  class GAUDI_API HiveEventRegistryEntry : public DataSvcHelpers::RegistryEntry  {
  public:
    friend class ::DataSvc;
  private:
    tbb::concurrent_queue<std::string> m_publishedData;
  private:
    void  assemblePath(std::string& buffer)  const;
    HiveRegistryEntry* i_add(const std::string&);
  public:
    HiveEventRegistryEntry(const std::string& path, DataSvcHelpers::RegistryEntry* parent = 0);
    virtual ~HiveEventRegistryEntry();
    virtual long add(const std::string& name,
                     DataObject* pObject,
                     bool is_soft = false);
    virtual long add(const std::string& name,
                     IOpaqueAddress* pAddress,
                     bool is_soft = false);
    virtual long add(IRegistry* obj);
    virtual tbb::concurrent_queue<std::string>& new_products() {
      return m_publishedData;
    }
  };

} // namespace Hive
#endif  // GAUDIHIVE_HIVEEVENTREGISTRYENTRY_H