TimeoutPoolOutputModule.h

Go to the documentation of this file.

#ifndef IOPool_Output_TimeoutPoolOutputModule_h
#define IOPool_Output_TimeoutPoolOutputModule_h
 
//
// Class TimeoutPoolOutputModule. Output module to POOL file with file
// closure based on timeout. First file has only one event, second
// file is closed after 15 seconds if at least one event was processed.
// Then timeout is increased to 30 seconds and 60 seconds. After that
// all other files are closed with timeout of 60 seconds.
//
// Created by Dmytro.Kovalskyi@cern.ch
//
 
#include "IOPool/Output/interface/PoolOutputModule.h"
 
namespace edm {
  class ConfigurationDescriptions;
  class ModuleCallingContext;
  class ParameterSet;
 
  class TimeoutPoolOutputModule : public PoolOutputModule {
  public:
    explicit TimeoutPoolOutputModule(ParameterSet const& ps);
    ~TimeoutPoolOutputModule() override{};
    TimeoutPoolOutputModule(TimeoutPoolOutputModule const&) = delete;             // Disallow copying and moving
    TimeoutPoolOutputModule& operator=(TimeoutPoolOutputModule const&) = delete;  // Disallow copying and moving
 
    static void fillDescriptions(ConfigurationDescriptions& descriptions);
 
  protected:
    bool shouldWeCloseFile() const override;
    void write(EventForOutput const& e) override;
 
  private:
    mutable time_t m_lastEvent;
    mutable unsigned int eventsWrittenInCurrentFile;
    mutable int m_timeout;
  };
}  // namespace edm
 
#endif