HiveEventRegistryEntry.h

Go to the documentation of this file.

#ifndef GAUDIHIVE_HIVEEVENTREGISTRYENTRY_H
#define GAUDIHIVE_HIVEEVENTREGISTRYENTRY_H

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

// Framework include files
#include "GaudiKernel/DataSvc.h"
#include "GaudiKernel/Kernel.h"
#include "GaudiKernel/RegistryEntry.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