DybArchiveOutput.h

Go to the documentation of this file.

#ifndef DYBARCHIVEOUTPUT_H
#define DYBARCHIVEOUTPUT_H

#include "DybKernel/IDybStorageSvc.h"
#include "Event/RegistrationSequence.h"
#include "DataUtilities/DybArchiveList.h"

#include "GaudiKernel/IDataManagerSvc.h"
#include "GaudiAlg/GaudiAlgorithm.h"
#include "GaudiKernel/IIncidentSvc.h"

#include <string>

class IDataManagerSvc;

class DybArchiveOutput: public GaudiAlgorithm {
public:
    DybArchiveOutput (const std::string& name, ISvcLocator* pSvcLocator);

    StatusCode initialize();
    StatusCode execute();
    StatusCode finalize();
    StatusCode stop();

private:
    // Property: WindowSeconds: time window (in seconds) to apply to
    // the AES by default.
    double m_window;

    // Property SaveOutput: if false do not write output
    bool m_saveFlag;

    // Property: RegSeqLocation: location of the RegistrationSequence stream.
    std::string m_regSeqLocation;

    // Property: ArchiveSvc: name of the Archive Event Service.
    std::string m_aesName;
    IDataProviderSvc*  m_aes;

    // Property: DybStorageSvc: name of a IDybStorageSvc.
    std::string m_dybStorageSvcName;
    IDybStorageSvc* m_store;

    IIncidentSvc* m_incsvc;

    DayaBay::RegistrationSequence* condemned();
    StatusCode erase(const DataObject* object, const std::string& path);
    StatusCode store(DayaBay::RegistrationSequence* rs);
    StatusCode trim(DayaBay::RegistrationSequence* rs);
    StatusCode process(DayaBay::RegistrationSequence* rs);
    StatusCode sweep_up();

    typedef std::map<std::string,DybArchiveList*> AESListMap_t;
    AESListMap_t m_aesListMap;
    DybArchiveList* aes_list(const std::string& location);
    DybArchiveList::iterator find_in_archive(DybArchiveList* aeslist, const DataObject* object);

};
#endif  // DYBARCHIVEOUTPUT_H