DQMFileSaverPB.h

Go to the documentation of this file.

#ifndef DQMSERVICES_COMPONENTS_DQMFILESAVERPB_H
#define DQMSERVICES_COMPONENTS_DQMFILESAVERPB_H
 
#include "FWCore/Framework/interface/global/EDAnalyzer.h"
#include "DQMServices/Core/interface/DQMStore.h"
 
#include <sys/time.h>
#include <string>
#include <mutex>
 
#include "DQMFileSaverBase.h"
 
namespace dqm {
 
  class DQMFileSaverPB : public DQMFileSaverBase {
  public:
    DQMFileSaverPB(const edm::ParameterSet& ps);
    ~DQMFileSaverPB() override;
 
    // used by the JsonWritingTimedPoolOutputModule,
    // fms will be nullptr in such case
    static boost::property_tree::ptree fillJson(int run,
                                                int lumi,
                                                const std::string& dataFilePathName,
                                                const std::string& transferDestinationStr,
                                                const std::string& mergeTypeStr,
                                                evf::FastMonitoringService* fms);
 
  protected:
    void initRun() const override;
    void saveLumi(const FileParameters& fp) const override;
    void saveRun(const FileParameters& fp) const override;
    void savePB(DQMStore* store, std::string const& filename, int run, int lumi) const;
 
    bool fakeFilterUnitMode_;
    std::string streamLabel_;
    std::string tag_;
    mutable std::string transferDestination_;
    mutable std::string mergeType_;
 
  public:
    static void fillDescriptions(edm::ConfigurationDescriptions& descriptions);
 
  private:
    int getMaxCompressedSize(int bufferSize) const;
    ulong compressME(const TBufferFile& buffer, int maxOutputSize, char* compression_output) const;
  };
 
}  // namespace dqm
 
#endif  // DQMSERVICES_COMPONENTS_DQMFILESAVERPB_H