I2OChain.h

Go to the documentation of this file.

// $Id: I2OChain.h,v 1.16 2012/04/20 10:48:18 mommsen Exp $

#ifndef EventFilter_StorageManager_I2OChain_h
#define EventFilter_StorageManager_I2OChain_h

#include <vector>

#include "boost/shared_ptr.hpp"
#include "toolbox/mem/Reference.h"

#include "EventFilter/StorageManager/interface/FragKey.h"
#include "EventFilter/StorageManager/interface/QueueID.h"
#include "EventFilter/StorageManager/interface/StreamID.h"
#include "EventFilter/StorageManager/interface/Utils.h"

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

namespace stor {

  class DQMKey;


  // We need only declare ChainData here; it is defined in I2OChain.cc.
  namespace detail
  {
    class ChainData;
  }

  class I2OChain
  {
  public:


    I2OChain();

    explicit I2OChain(toolbox::mem::Reference* pRef);

    I2OChain(I2OChain const& other);

    ~I2OChain();

    I2OChain& operator=(I2OChain const& rhs);

    void swap(I2OChain& other);

    bool empty() const;

    bool complete() const;

    bool faulty() const;

    unsigned int faultyBits() const;

    void addToChain(I2OChain& newpart);

    //void markComplete();

    void markFaulty();

    unsigned long* getBufferData() const;


    void release();

    utils::TimePoint_t creationTime() const;

    utils::TimePoint_t lastFragmentTime() const;

    utils::TimePoint_t staleWindowStartTime() const;

    void addToStaleWindowStartTime(const utils::Duration_t);

    void resetStaleWindowStartTime();

    void tagForStream(StreamID);

    void tagForEventConsumer(QueueID);

    void tagForDQMEventConsumer(QueueID);

    bool isTaggedForAnyStream() const;

    bool isTaggedForAnyEventConsumer() const;

    bool isTaggedForAnyDQMEventConsumer() const;

    std::vector<StreamID> getStreamTags() const;

    QueueIDs getEventConsumerTags() const;

    QueueIDs getDQMEventConsumerTags() const;

    unsigned int droppedEventsCount() const;

    void setDroppedEventsCount(unsigned int);

    unsigned int messageCode() const;

    unsigned short i2oMessageCode() const;

    unsigned int rbBufferId() const;

    unsigned int hltLocalId() const;

    unsigned int hltInstance() const;

    unsigned int hltTid() const;

    std::string hltURL() const;

    std::string hltClassName() const;

    unsigned int fuProcessId() const;

    unsigned int fuGuid() const;

    FragKey fragmentKey() const;


    size_t memoryUsed() const;

    unsigned int fragmentCount() const;

    unsigned long totalDataSize() const;

    unsigned long dataSize(int fragmentIndex) const;

    unsigned char* dataLocation(int fragmentIndex) const;

    unsigned int getFragmentID(int fragmentIndex) const;

    unsigned long headerSize() const;

    unsigned char* headerLocation() const;

    unsigned int copyFragmentsIntoBuffer(std::vector<unsigned char>& buff) const;

    std::string outputModuleLabel() const;

    uint32_t outputModuleId() const;

    uint32_t nExpectedEPs() const;

    std::string topFolderName() const;

    DQMKey dqmKey() const;

    void hltTriggerNames(Strings& nameList) const;

    void hltTriggerSelections(Strings& nameList) const;

    void l1TriggerNames(Strings& nameList) const;

    uint32_t hltTriggerCount() const;

    void hltTriggerBits(std::vector<unsigned char>& bitList) const;

    uint32_t runNumber() const;

    uint32_t lumiSection() const;

    uint32_t eventNumber() const;

    uint32_t adler32Checksum() const;

    void assertRunNumber(uint32_t runNumber);

    bool isEndOfLumiSectionMessage() const;

  private:

    boost::shared_ptr<detail::ChainData> data_;
  };
  
} // namespace stor

#endif // EventFilter_StorageManager_I2OChain_h