GridReportingModule.cxx

Go to the documentation of this file.

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

 
 
 
//
// includes
//
 
#include <EventLoop/GridReportingModule.h>
 
#include <EventLoop/ModuleData.h>
#include <algorithm>
#include <fstream>
 
//
// method implementations
//
 
namespace EL
{
  namespace Detail
  {
    StatusCode GridReportingModule ::
    onNewInputFile (ModuleData& data)
    {
      if (std::find (m_files.begin(), m_files.end(), data.m_inputFileUrl) == m_files.end())
        m_files.push_back (data.m_inputFileUrl);
      return StatusCode::SUCCESS;
    }
 
 
 
    StatusCode GridReportingModule ::
    onExecute (ModuleData& /*data*/)
    {
      ++m_eventsProcessed;
      return StatusCode::SUCCESS;
    }
 
 
 
    StatusCode GridReportingModule ::
    postFileClose (ModuleData& /*data*/)
    {
      // createJobSummary
      std::ofstream summaryfile("../AthSummary.txt");
      if (summaryfile.is_open()) {
        unsigned int nFiles = m_files.size();
        summaryfile << "Files read: " << nFiles << std::endl;
        for (auto& file : m_files)
          summaryfile << "  " << file << std::endl;
        summaryfile << "Events Read:    " << m_eventsProcessed << std::endl;
        summaryfile.close();
      }
      else {
        ANA_MSG_WARNING ("Failed to write summary file.");
      }
      return StatusCode::SUCCESS;
    }
 
 
 
    void GridReportingModule ::
    reportInputFailure (ModuleData& /*data*/)
    {
      ANA_MSG_FATAL ("encountered input error");
      exit (EC_BADINPUT);
    }
  }
}