DQMTopLevelFolder.h

Go to the documentation of this file.

// $Id: DQMTopLevelFolder.h,v 1.4 2011/04/04 12:03:30 mommsen Exp $

#ifndef EventFilter_StorageManager_DQMTopLevelFolder_h
#define EventFilter_StorageManager_DQMTopLevelFolder_h

#include <vector>

#include "boost/shared_ptr.hpp"

#include "DataFormats/Provenance/interface/Timestamp.h"

#include "EventFilter/StorageManager/interface/AlarmHandler.h"
#include "EventFilter/StorageManager/interface/Configuration.h"
#include "EventFilter/StorageManager/interface/DQMFolder.h"
#include "EventFilter/StorageManager/interface/DQMKey.h"
#include "EventFilter/StorageManager/interface/I2OChain.h"
#include "EventFilter/StorageManager/interface/QueueID.h"

#include "IOPool/Streamer/interface/DQMEventMessage.h"


namespace stor {

  class DQMEventMonitorCollection;


  class DQMTopLevelFolder
  {

  public:

    class Record
    {
    private:

      struct Entry
      {
        std::vector<unsigned char> buffer;
        QueueIDs dqmConsumers;
      };

    public:
      
      Record() :
      entry_(new Entry) {};

      inline void clear()
      { entry_->buffer.clear(); entry_->dqmConsumers.clear(); }

      inline void* getBuffer(size_t size) const
      { entry_->buffer.resize(size); return &(entry_->buffer[0]); }

      inline void tagForEventConsumers(const QueueIDs& ids)
      { entry_->dqmConsumers = ids; }
      
      inline QueueIDs getEventConsumerTags() const
       { return entry_->dqmConsumers; }

      inline DQMEventMsgView getDQMEventMsgView() const
      { return DQMEventMsgView(&entry_->buffer[0]); }

      inline bool empty() const
      { return ( entry_->buffer.empty() ); }

      inline size_t memoryUsed() const
      { return entry_->buffer.size() + entry_->dqmConsumers.size()*sizeof(QueueID); }

      inline unsigned long totalDataSize() const
      { return entry_->buffer.size(); }


    private:

      // We use here a shared_ptr to avoid copying the whole
      // buffer each time the event record is handed on
      boost::shared_ptr<Entry> entry_;
      
    };
    
    
  public:

    DQMTopLevelFolder
    (
      const DQMKey&,
      const QueueIDs&,
      const DQMProcessingParams&,
      DQMEventMonitorCollection&,
      const unsigned int expectedUpdates,
      AlarmHandlerPtr
    );

    ~DQMTopLevelFolder();

    void addDQMEvent(const DQMEventMsgView&);

    void addDQMEvent(const I2OChain& dqmEvent);

    bool isReady(const utils::TimePoint_t& now) const;

    bool getRecord(Record&);


  private:

    void addEvent(std::auto_ptr<DQMEvent::TObjectTable>);
    size_t populateTable(DQMEvent::TObjectTable&) const;

    const DQMKey dqmKey_;
    const QueueIDs dqmConsumers_;
    const DQMProcessingParams dqmParams_;
    DQMEventMonitorCollection& dqmEventMonColl_;
    const unsigned int expectedUpdates_;
    AlarmHandlerPtr alarmHandler_;

    unsigned int nUpdates_;
    unsigned int mergeCount_;
    utils::TimePoint_t lastUpdate_;
    std::string releaseTag_;
    uint32_t updateNumber_;
    edm::Timestamp timeStamp_;

    typedef boost::shared_ptr<DQMFolder> DQMFolderPtr;
    typedef std::map<std::string, DQMFolderPtr> DQMFoldersMap;
    DQMFoldersMap dqmFolders_;
    
    static unsigned int sentEvents_;    
  };

  typedef boost::shared_ptr<DQMTopLevelFolder> DQMTopLevelFolderPtr;

} // namespace stor

#endif // EventFilter_StorageManager_DQMTopLevelFolder_h