ByteStreamOutputStreamCopyTool.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef BYTESTREAMCNVSVC_BYTESTREAMOUTPUTSTREAMCOPYTOOL_H
#define BYTESTREAMCNVSVC_BYTESTREAMOUTPUTSTREAMCOPYTOOL_H
 
// Gaudi
#include "AthenaKernel/IAthenaOutputStreamTool.h"
#include "GaudiKernel/ServiceHandle.h"
#include "AthenaBaseComps/AthAlgTool.h"
 
// ByteStream
#include "ByteStreamCnvSvcBase/IByteStreamInputSvc.h"
#include "ByteStreamCnvSvcBase/IByteStreamOutputSvc.h"
 
#include <string>
#include <vector>

 
class ByteStreamOutputStreamCopyTool : public extends<AthAlgTool, IAthenaOutputStreamTool> {
 
public:
   using base_class::base_class;

   virtual StatusCode initialize() override;

   virtual StatusCode connectOutput(const std::string& outputName = "") override;

   virtual StatusCode commitOutput(bool doCommit = false) override;

   virtual StatusCode finalizeOutput() override;

   virtual StatusCode connectServices(const std::string& dataStore,
        const std::string& cnvSvc,
        bool extendProvenenceRecord = false) override;

   virtual StatusCode streamObjects(const TypeKeyPairs& typeKeys, const std::string& outputName = "") override;

   virtual StatusCode streamObjects(const DataObjectVec& dataObjects, const std::string& outputName = "") override;

   virtual StatusCode getInputItemList(SG::IFolder* m_p2BWrittenFromTool) override;
 
private:
   ServiceHandle<IByteStreamOutputSvc> m_outputSvc{this, "ByteStreamOutputSvc", "ByteStreamEventStorageOutputSvc"};

   ServiceHandle<IByteStreamInputSvc> m_inputSvc{this, "ByteStreamInputSvc", "ByteStreamEventStorageInputSvc"};
};
 
#endif // BYTESTREAMCNVSVC_BYTESTREAMOUTPUTSTREAMCOPYTOOL_H