Line Code
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132
/*
 *  See header file for a description of this class.
 *
 *  $Date: 2009/09/16 11:00:18 $
 *  $Revision: 1.3.14.1 $
 *  \author Paolo Ronchese INFN Padova
 *
 */

//-----------------------
// This Class' Header --
//-----------------------
#include "CondTools/DT/interface/DTStatusFlagHandler.h"

//-------------------------------
// Collaborating Class Headers --
//-------------------------------
#include "CondFormats/DTObjects/interface/DTStatusFlag.h"

//---------------
// C++ Headers --
//---------------
#include <iostream>
#include <fstream>

//-------------------
// Initializations --
//-------------------

//----------------
// Constructors --
//----------------
DTStatusFlagHandler::DTStatusFlagHandler(const edm::ParameterSet& ps)
    : dataTag(ps.getParameter<std::string>("tag")),
      fileName(ps.getParameter<std::string>("file")),
      runNumber(ps.getParameter<unsigned int>("run")) {}

//--------------
// Destructor --
//--------------
DTStatusFlagHandler::~DTStatusFlagHandler() {}

//--------------
// Operations --
//--------------
void DTStatusFlagHandler::getNewObjects() {
  //to access the information on the tag inside the offline database:
  cond::TagInfo_t const& ti = tagInfo();
  cond::Time_t last = ti.lastInterval.since;

  //to access the information on last successful log entry for this tag:
  //  cond::LogDBEntry const & lde = logDBEntry();

  //to access the lastest payload (Ref is a smart pointer)
  //  Ref payload = lastPayload();

  /*
  int irun = event.id().run();
  int ievt = event.id().event();
  std::cout << "================ "
            << irun << " " << ievt << std::endl;

  std::map<std::string, popcon::PayloadIOV> mp = getOfflineInfo();
  std::map<std::string, popcon::PayloadIOV>::iterator iter = mp.begin();
  std::map<std::string, popcon::PayloadIOV>::iterator iend = mp.end();
  std::cout << "list of all tags: " << std::endl;
  while ( iter != iend ) {
    std::cout << "Tag: "                       << iter->first
              << " , last object valid since " << iter->second.last_since
              << " to "                        << iter->second.last_till
              << std::endl;
    iter++;
  }

  std::cout << "look for tag " << dataTag << std::endl;
  std::map<std::string, popcon::PayloadIOV>::iterator itag =
    mp.find( dataTag );
*/
  if (runNumber <= last) {
    std::cout << "More recent data already present - skipped" << std::endl;
    return;
  }

  DTStatusFlag* stFlag = new DTStatusFlag(dataTag);

  int status = 0;
  std::ifstream ifile(fileName.c_str());
  int whe;
  int sta;
  int sec;
  int qua;
  int lay;
  int cel;
  int noiseFlag;
  int feMask;
  int tdcMask;
  int trigMask;
  int deadFlag;
  int nohvFlag;
  while (ifile >> whe >> sta >> sec >> qua >> lay >> cel >> noiseFlag >> feMask >> tdcMask >> trigMask >> deadFlag >>
         nohvFlag) {
    status = stFlag->set(whe,
                         sta,
                         sec,
                         qua,
                         lay,
                         cel,
                         noiseFlag != 0,
                         feMask != 0,
                         tdcMask != 0,
                         trigMask != 0,
                         deadFlag != 0,
                         nohvFlag != 0);
    std::cout << whe << " " << sta << " " << sec << " " << qua << " " << lay << " " << cel << " " << noiseFlag << " "
              << feMask << " " << tdcMask << " " << trigMask << " " << deadFlag << " " << nohvFlag << "  -> ";
    std::cout << "insert status: " << status << std::endl;
  }

  /*
  unsigned int runf = irun;
  unsigned int runl = 0xffffffff;
  popcon::IOVPair iop = { runf, runl };
  std::cout << "APPEND NEW OBJECT: "
            << runf << " " << runl << " " << stFlag << std::endl;
  m_to_transfer->push_back( std::make_pair( stFlag, iop ) );
*/

  //for each payload provide IOV information (say in this case we use since)
  m_to_transfer.emplace_back(stFlag, runNumber);
}

std::string DTStatusFlagHandler::id() const { return dataTag; }