DiskOutputXRD.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2019 CERN for the benefit of the ATLAS collaboration
*/

 
 
//
// includes
//
 
#include <SampleHandler/DiskOutputXRD.h>
 
#include <sstream>
#include <RootCoreUtils/Assert.h>
#include <SampleHandler/DiskWriterXRD.h>
 
//
// method implementations
//
 
ClassImp (SH::DiskOutputXRD)
 
namespace SH
{
  void DiskOutputXRD :: 
  testInvariant () const
  {
    RCU_INVARIANT (m_prefix.find ("root://") == 0);
  }
 
 
 
  DiskOutputXRD :: 
  DiskOutputXRD ()
    : m_prefix ("root://ThisIsANonExistantPath")
  {
    RCU_NEW_INVARIANT (this);
  }
 
 
 
  DiskOutputXRD :: 
  DiskOutputXRD (const std::string& val_prefix)
    : m_prefix (val_prefix)
  {
    RCU_REQUIRE (val_prefix.find ("root://") == 0);
 
    RCU_NEW_INVARIANT (this);
  }
 
 
 
  std::unique_ptr<DiskWriter> DiskOutputXRD ::
  doMakeWriter (const std::string& sampleName,
                const std::string& segmentName,
        const std::string& suffix) const
  {
    RCU_READ_INVARIANT (this);
    return std::make_unique<DiskWriterXRD>
      (targetURL (sampleName, segmentName, suffix));
  }
 
 
 
  std::string DiskOutputXRD ::
  getTargetURL (const std::string& sampleName,
                const std::string& segmentName,
                const std::string& suffix) const
  {
    RCU_READ_INVARIANT (this);
    std::ostringstream file;
    file << m_prefix;
    if (m_prefix.back() != '-')
      file << "/";
    file << sampleName;
    if (!segmentName.empty())
      file << "-" << segmentName;
    file << suffix;
    return file.str();
  }
}