ByteStreamMultipleOutputStreamCopyTool.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef  OVERLAYBYTESTREAMUTILS_BYTESTREAMMULTIPLEOUTPUTSTREAMCOPYTOOL_H
# define OVERLAYBYTESTREAMUTILS_BYTESTREAMMULTIPLEOUTPUTSTREAMCOPYTOOL_H
 
//<<<<<< INCLUDES                                                       >>>>>>
 
// Gaudi
#include "AthenaKernel/IAthenaOutputStreamTool.h"
#include "GaudiKernel/ServiceHandle.h"
#include "AthenaBaseComps/AthAlgTool.h"
 
#include <string>
#include <vector>
 
// ByteStream
 
#include "ByteStreamCnvSvc/ByteStreamInputSvc.h"
#include "ByteStreamCnvSvc/ByteStreamOutputSvc.h"
 
#include "CxxUtils/checker_macros.h"
ATLAS_NO_CHECK_FILE_THREAD_SAFETY;  // this code is obsolete/unused (certainly in production)
 
//<<<<<< CLASS DECLARATIONS                                             >>>>>>
 
 
class ByteStreamMultipleOutputStreamCopyTool  :  public AthAlgTool, virtual public IAthenaOutputStreamTool
{
 
public:
 
  ByteStreamMultipleOutputStreamCopyTool(const std::string& type,
                                         const std::string& name,
                                         const IInterface* parent);
  virtual ~ByteStreamMultipleOutputStreamCopyTool();
 
  virtual StatusCode initialize();
  virtual StatusCode finalize();
 
 
  virtual StatusCode connectOutput(const std::string& outputName = "")  ;
 
  virtual StatusCode commitOutput(bool doCommit = false) ;
 
  virtual StatusCode finalizeOutput();
 
  virtual StatusCode connectServices(const std::string& dataStore,
                                     const std::string& cnvSvc,
                                     bool extendProvenenceRecord = false)  ;
 
  virtual StatusCode streamObjects(const TypeKeyPairs& typeKeys, const std::string& outputName = "") ;
 
 
  virtual StatusCode streamObjects (const DataObjectVec& dataObjects, const std::string& outputName = "") ;
 
 
  virtual StatusCode fillObjectRefs(const DataObjectVec& dataObjects) ;
 
  virtual StatusCode getInputItemList(SG::IFolder* m_p2BWrittenFromTool) ;
 
private:
 
  // Handle for BS input Svc
  ServiceHandle<ByteStreamInputSvc> m_inputSvc;
  
  // Whether to use lbn map or not
  bool m_uselbnmap;
  std::string m_lbn_map_file;
  std::string m_trigfile;
  void initlbnmap();
 
  // Handle for BS output Svc
  std::vector< ServiceHandle<ByteStreamOutputSvc> > m_outputSvc;
  int m_NoutputSvc;
 
  int m_skipevents;
 
};
 
 
#endif // OVERLAYBYTESTREAMUTILS_BYTESTREAMMULTIPLEOUTPUTSTREAMCOPYTOOL_H