StreamerOutputModuleCommon.h

Go to the documentation of this file.

#ifndef IOPool_Streamer_StreamerOutputModuleCommon_h
#define IOPool_Streamer_StreamerOutputModuleCommon_h
 
#include "IOPool/Streamer/interface/MsgTools.h"
#include "FWCore/Common/interface/TriggerNames.h"
#include "IOPool/Streamer/interface/StreamSerializer.h"
#include "DataFormats/Common/interface/Handle.h"
#include "DataFormats/Streamer/interface/StreamedProducts.h"
#include <memory>
#include <vector>
 
class InitMsgBuilder;
class EventMsgBuilder;
namespace edm {
  class ParameterSet;
  class ParameterSetDescription;
  class EventForOutput;
  class ThinnedAssociationsHelper;
  class TriggerResults;
 
  class StreamerOutputModuleCommon {
  public:
    explicit StreamerOutputModuleCommon(ParameterSet const& ps, SelectedProducts const* selections);
    ~StreamerOutputModuleCommon();
    static void fillDescription(ParameterSetDescription& desc);
 
    std::unique_ptr<InitMsgBuilder> serializeRegistry(SerializeDataBuffer& sbuf,
                                                      BranchIDLists const& branchLists,
                                                      ThinnedAssociationsHelper const& helper,
                                                      std::string const& processName,
                                                      std::string const& moduleLabel,
                                                      ParameterSetID const& toplevel,
                                                      SendJobHeader::ParameterSetMap const* psetMap);
 
    std::unique_ptr<EventMsgBuilder> serializeEvent(SerializeDataBuffer& sbuf,
                                                    EventForOutput const& e,
                                                    Handle<TriggerResults> const& triggerResults,
                                                    ParameterSetID const& selectorCfg);
 
    SerializeDataBuffer* getSerializerBuffer();
 
  protected:
    std::unique_ptr<SerializeDataBuffer> serializerBuffer_;
 
  private:
    void setHltMask(EventForOutput const& e,
                    Handle<TriggerResults> const& triggerResults,
                    std::vector<unsigned char>& hltbits) const;
 
    StreamSerializer serializer_;
 
    int maxEventSize_;
    bool useCompression_;
    std::string compressionAlgoStr_;
    int compressionLevel_;
 
    StreamerCompressionAlgo compressionAlgo_;
 
    // test luminosity sections
    int lumiSectionInterval_;
    double timeInSecSinceUTC;
 
    unsigned int hltsize_;
    char host_name_[255];
 
    Strings hltTriggerSelections_;
    uint32 outputModuleId_;
 
  };  //end-of-class-def
 
}  // namespace edm
 
#endif