DataHandleTestTool.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2023 CERN for the benefit of the ATLAS collaboration
*/
 
 
 
 
//
// includes
//
 
#include "CxxUtils/checker_macros.h"
ATLAS_NO_CHECK_FILE_THREAD_SAFETY;
 
#include <AsgExampleTools/DataHandleTestTool.h>
 
#include <AsgDataHandles/ReadHandle.h>
#include <AsgDataHandles/ReadDecorHandle.h>
#include <AsgDataHandles/WriteDecorHandle.h>
#include <AsgDataHandles/WriteHandle.h>
#include <AsgTesting/UnitTest.h>
#include <gtest/gtest.h>
#include <map>
 
#ifndef SIMULATIONBASE
#include <xAODMuon/MuonAuxContainer.h>
#endif
 
//
// method implementations
//
 
namespace asg
{
  DataHandleTestTool ::
  DataHandleTestTool (const std::string& val_name)
    : AsgTool (val_name)
  {
    declareProperty ("readFailure", m_readFailure, "whether to expect a read failure");
    declareProperty ("readDecorFailure", m_readDecorFailure, "whether to expect a read decoration failure");
    declareProperty ("readArray", m_readArray, "whether to read from the array");
    declareProperty ("doWriteName", m_doWriteName, "if we should write, the name we expect to write to");
    declareProperty ("doWriteDecorName", m_doWriteDecorName, "if we should write a decoration, the name we expect to write to");
    declareProperty ("doWriteDecorNameExisting", m_doWriteDecorNameExisting, "if we should try to overwrite an existing decoration, the name we expect to write to");
  }
 
 
 
  DataHandleTestTool ::
  ~DataHandleTestTool ()
  {
  }
 
 
 
  StatusCode DataHandleTestTool ::
  initialize ()
  {
#ifndef SIMULATIONBASE
    ANA_CHECK (m_readKey.initialize ());
    ANA_CHECK (m_readKeyEmpty.initialize (!m_readKeyEmpty.empty ()));
    ANA_CHECK (m_readDecorKey.initialize ());
    ANA_CHECK (m_readDecorKeyEmpty.initialize (!m_readDecorKeyEmpty.empty ()));
    ANA_CHECK (m_writeKey.initialize (!m_writeKey.empty()));
    ANA_CHECK (m_readKeyArray.initialize());
    ANA_CHECK (m_writeDecorKey.initialize (!m_writeDecorKey.empty ()));
    ANA_CHECK (m_writeDecorKeyExisting.initialize (!m_writeDecorKeyExisting.empty ()));
#endif
    return StatusCode::SUCCESS;
  }
 
 
 
  void DataHandleTestTool ::
  runTest ATLAS_NOT_THREAD_SAFE ()
  {
#ifndef SIMULATIONBASE
    const xAOD::MuonContainer *muonsStore {nullptr};
    ASSERT_SUCCESS (evtStore()->retrieve (muonsStore, "Muons"));
    ASSERT_NE (0u, muonsStore->size());
    const xAOD::Muon *testMuon = (*muonsStore)[0];
 
    auto readHandle = makeHandle (m_readKey);
    if (m_readFailure == true)
    {
      EXPECT_FALSE (readHandle.isPresent());
      EXPECT_EQ (nullptr, readHandle.get());
      EXPECT_FALSE (readHandle.isValid());
    } else
    {
      EXPECT_TRUE (readHandle.isPresent());
      EXPECT_EQ (muonsStore, readHandle.get());
      EXPECT_TRUE (readHandle.isValid());
    }
 
    SG::ReadDecorHandle<xAOD::MuonContainer,float> readDecorHandle (m_readDecorKey);
    if (m_readDecorFailure == true)
    {
      EXPECT_TRUE(readDecorHandle.isPresent());
      EXPECT_FALSE(readDecorHandle.isAvailable());
      EXPECT_ANY_THROW (readDecorHandle (*testMuon));
    } else
    {
      EXPECT_TRUE(readDecorHandle.isPresent());
      EXPECT_TRUE(readDecorHandle.isAvailable());
      SG::AuxElement::ConstAccessor<float> acc ("pt");
      EXPECT_EQ (acc (*testMuon), readDecorHandle (*testMuon));
    }
 
    if (m_readArray)
    {
      EXPECT_EQ (1u, m_readKeyArray.size());
      auto handles = m_readKeyArray.makeHandles();
      EXPECT_EQ (muonsStore, handles[0].get());
    } else
    {
      EXPECT_EQ (0u, m_readKeyArray.size());
    }
 
    if (!m_doWriteName.empty())
    {
      auto writeHandle = makeHandle (m_writeKey);
      auto newMuons = std::make_unique<xAOD::MuonContainer>();
      auto newAux = std::make_unique<xAOD::MuonAuxContainer>();
      xAOD::MuonContainer *recordMuons {newMuons.get()};
      xAOD::MuonAuxContainer *recordAux {newAux.get()};
      EXPECT_SUCCESS (writeHandle.record (std::move (newMuons), std::move (newAux)));
      const xAOD::MuonContainer *retrieveMuons {nullptr};
      EXPECT_SUCCESS (evtStore()->retrieve (retrieveMuons, m_doWriteName));
      EXPECT_EQ (recordMuons, retrieveMuons);
      xAOD::MuonAuxContainer *retrieveAux {nullptr};
      EXPECT_SUCCESS (evtStore()->retrieve (retrieveAux, m_doWriteName + "Aux."));
      EXPECT_EQ (recordAux, retrieveAux);
    }
 
    if (!m_doWriteDecorName.empty())
    {
      auto writeDecorHandle = SG::makeHandle<unsigned> (m_writeDecorKey);
      EXPECT_TRUE(writeDecorHandle.isPresent());
      EXPECT_FALSE(writeDecorHandle.isAvailable());
      writeDecorHandle (*(*muonsStore)[0]) = 42u;
      SG::AuxElement::ConstAccessor<unsigned> acc (m_doWriteDecorName);
      EXPECT_EQ (42u, acc (*(*muonsStore)[0]));
    }
 
    if (!m_doWriteDecorNameExisting.empty())
    {
      auto writeDecorHandleExisting = SG::makeHandle<float> (m_writeDecorKeyExisting);
      EXPECT_TRUE(writeDecorHandleExisting.isPresent());
      EXPECT_TRUE(writeDecorHandleExisting.isAvailable());
    }
#endif
  }
}