DiskWriter.h

Go to the documentation of this file.

// $Id: DiskWriter.h,v 1.14 2011/06/20 09:07:22 mommsen Exp $

#ifndef EventFilter_StorageManager_DiskWriter_h
#define EventFilter_StorageManager_DiskWriter_h

#include "boost/date_time/posix_time/posix_time_types.hpp"
#include "boost/shared_ptr.hpp"

#include <stdint.h>
#include <vector>

#include "toolbox/lang/Class.h"
#include "toolbox/task/WaitingWorkLoop.h"
#include "xdaq/Application.h"

#include "EventFilter/StorageManager/interface/Configuration.h"
#include "EventFilter/StorageManager/interface/DbFileHandler.h"
#include "EventFilter/StorageManager/interface/ErrorStreamConfigurationInfo.h"
#include "EventFilter/StorageManager/interface/EventStreamConfigurationInfo.h"
#include "EventFilter/StorageManager/interface/SharedResources.h"
#include "EventFilter/StorageManager/interface/StreamsMonitorCollection.h"
#include "EventFilter/StorageManager/interface/Utils.h"


namespace stor {

  class I2OChain;
  class StreamHandler;

  class DiskWriter : public toolbox::lang::Class
  {
  public:


    DiskWriter(xdaq::Application*, SharedResourcesPtr sr);

    ~DiskWriter();


    bool writeAction(toolbox::task::WorkLoop*);

    void startWorkLoop(std::string workloopName);


  private:

    //Prevent copying of the DiskWriter
    DiskWriter(DiskWriter const&);
    DiskWriter& operator=(DiskWriter const&);


    void writeNextEvent();

    void writeEventToStreams(const I2OChain&);

    void checkStreamChangeRequest();

    void checkForFileTimeOuts(const bool doItNow = false);

    void closeTimedOutFiles(const utils::TimePoint_t);

    void configureEventStreams(EvtStrConfigListPtr);

    void configureErrorStreams(ErrStrConfigListPtr);

    void makeFaultyEventStream();

    void makeEventStream(EventStreamConfigurationInfo&);

    void makeErrorStream(ErrorStreamConfigurationInfo&);

    void destroyStreams();

    void processEndOfLumiSection(const I2OChain&);

    void reportRemainingLumiSections();

    void writeEndOfRunMarker();


    xdaq::Application* app_;
    SharedResourcesPtr sharedResources_;
    DiskWritingParams dwParams_;
    const DbFileHandlerPtr dbFileHandler_;

    unsigned int runNumber_;
    boost::posix_time::time_duration timeout_; // Timeout on stream queue
    utils::TimePoint_t lastFileTimeoutCheckTime_; // Last time we checked for time-out files

    typedef boost::shared_ptr<StreamHandler> StreamHandlerPtr;
    typedef std::vector<StreamHandlerPtr> StreamHandlers;
    StreamHandlers streamHandlers_;

    StreamsMonitorCollection::EndOfRunReportPtr endOfRunReport_;

    bool actionIsActive_;
    toolbox::task::WorkLoop* writingWL_;      

  };
  
} // namespace stor

#endif // EventFilter_StorageManager_DiskWriter_h