CaloUnpackPRDF.cc

Go to the documentation of this file. Or view the newest version in sPHENIX GitHub for file CaloUnpackPRDF.cc

#include "CaloUnpackPRDF.h"

#include "PROTOTYPE4_FEM.h"
#include "RawTower_Prototype4.h"

#include <calobase/RawTower.h>  // for RawTower
#include <calobase/RawTowerContainer.h>
#include <calobase/RawTowerDefs.h>  // for HCALIN, HCALOUT, CEMC

#include <fun4all/Fun4AllReturnCodes.h>
#include <fun4all/SubsysReco.h>  // for SubsysReco

#include <phool/PHCompositeNode.h>
#include <phool/PHIODataNode.h>    // for PHIODataNode
#include <phool/PHNodeIterator.h>  // for PHNodeIterator
#include <phool/PHObject.h>        // for PHObject
#include <phool/getClass.h>
#include <phool/phool.h>

#include <Event/Event.h>
#include <Event/EventTypes.h>
#include <Event/packet.h>

#include <cassert>
#include <cmath>  // for NAN
#include <iostream>
#include <map>      // for _Rb_tree_const_iterator
#include <utility>  // for pair

using namespace std;

//____________________________________
CaloUnpackPRDF::CaloUnpackPRDF()
  : SubsysReco("CaloUnpackPRDF")
  ,
  /*Event**/ _event(nullptr)
  ,
  /*Packet_hbd_fpgashort**/ _packet(nullptr)
  ,
  /*int*/ _nevents(0)
  ,
  /*PHCompositeNode **/ dst_node(nullptr)
  ,
  /*PHCompositeNode **/ data_node(nullptr)
  ,
  /*RawTowerContainer**/ hcalin_towers_lg(nullptr)
  ,
  /*RawTowerContainer**/ hcalout_towers_lg(nullptr)
  ,
  /*RawTowerContainer**/ hcalin_towers_hg(nullptr)
  ,
  /*RawTowerContainer**/ hcalout_towers_hg(nullptr)
  ,
  /*RawTowerContainer**/ emcal_towers(nullptr)
{
}

//_____________________________________
int CaloUnpackPRDF::InitRun(PHCompositeNode *topNode)
{
  CreateNodeTree(topNode);
  return Fun4AllReturnCodes::EVENT_OK;
}

//____________________________________
int CaloUnpackPRDF::process_event(PHCompositeNode *topNode)
{
  _nevents++;
  _event = findNode::getClass<Event>(topNode, "PRDF");
  if (_event == 0)
  {
    cout << "CaloUnpackPRDF::Process_Event - Event not found" << endl;
    return -1;
  }

  if (Verbosity())
  {
    cout << PHWHERE << "Process event entered" << std::endl;
  }

  if (Verbosity())
    _event->identify();

  _packet = _event->getPacket(PROTOTYPE4_FEM::PACKET_ID);

  if (!_packet)
  {
    // They could be special events at the beginning or end of run
    if (_event->getEvtType() == DATAEVENT)
    {
      cout << "CaloUnpackPRDF::Process_Event - Packet not found" << endl;
      _event->identify();
    }
    return Fun4AllReturnCodes::DISCARDEVENT;
  }
  RawTower_Prototype4 *tower_lg = nullptr;
  RawTower_Prototype4 *tower_hg = nullptr;

  // HCALIN
  assert(hcalin_towers_lg);
  //  assert(hcalin_towers_hg);
  for (int ibinz = 0; ibinz < PROTOTYPE4_FEM::NCH_IHCAL_ROWS; ibinz++)
  {
    for (int ibinphi = 0; ibinphi < PROTOTYPE4_FEM::NCH_IHCAL_COLUMNS;
         ibinphi++)
    {
      tower_lg = dynamic_cast<RawTower_Prototype4 *>(
          hcalin_towers_lg->getTower(ibinz, ibinphi));
      if (!tower_lg)
      {
        tower_lg = new RawTower_Prototype4();
        tower_lg->set_energy(NAN);
        hcalin_towers_lg->AddTower(ibinz, ibinphi, tower_lg);
      }
      //      tower_hg =
      //          dynamic_cast<RawTower_Prototype4
      //          *>(hcalin_towers_hg->getTower(
      //              ibinz, ibinphi));
      //      if (!tower_hg)
      //      {
      //        tower_hg = new RawTower_Prototype4();
      //        tower_hg->set_energy(NAN);
      //        hcalin_towers_hg->AddTower(ibinz, ibinphi, tower_hg);
      //      }

      int ich = PROTOTYPE4_FEM::GetChannelNumber("HCALIN", ibinz, ibinphi);
      tower_lg->set_HBD_channel_number(ich);
      //      tower_hg->set_HBD_channel_number(ich);
      for (int isamp = 0; isamp < PROTOTYPE4_FEM::NSAMPLES; isamp++)
      {
        //        tower_hg->set_signal_samples(isamp, _packet->iValue(isamp,
        //        ich) & PROTOTYPE4_FEM::ADC_DATA_MASK);
        tower_lg->set_signal_samples(isamp, _packet->iValue(isamp, ich) &
                                                PROTOTYPE4_FEM::ADC_DATA_MASK);
      }
    }
  }

  // HCALOUT
  assert(hcalout_towers_lg);
  assert(hcalout_towers_hg);
  for (int ibinz = 0; ibinz < PROTOTYPE4_FEM::NCH_OHCAL_ROWS; ibinz++)
  {
    for (int ibinphi = 0; ibinphi < PROTOTYPE4_FEM::NCH_OHCAL_COLUMNS;
         ibinphi++)
    {
      tower_lg = dynamic_cast<RawTower_Prototype4 *>(
          hcalout_towers_lg->getTower(ibinz, ibinphi));
      if (!tower_lg)
      {
        tower_lg = new RawTower_Prototype4();
        tower_lg->set_energy(NAN);
        hcalout_towers_lg->AddTower(ibinz, ibinphi, tower_lg);
      }
      tower_hg = dynamic_cast<RawTower_Prototype4 *>(
          hcalout_towers_hg->getTower(ibinz, ibinphi));
      if (!tower_hg)
      {
        tower_hg = new RawTower_Prototype4();
        tower_hg->set_energy(NAN);
        hcalout_towers_hg->AddTower(ibinz, ibinphi, tower_hg);
      }
      int ich = PROTOTYPE4_FEM::GetChannelNumber("HCALOUT", ibinz, ibinphi);
      tower_lg->set_HBD_channel_number(ich);
      tower_hg->set_HBD_channel_number(ich);
      for (int isamp = 0; isamp < PROTOTYPE4_FEM::NSAMPLES; isamp++)
      {
        tower_lg->set_signal_samples(isamp, _packet->iValue(isamp, ich) &
                                                PROTOTYPE4_FEM::ADC_DATA_MASK);
        tower_hg->set_signal_samples(isamp, _packet->iValue(isamp, ich + 1) &
                                                PROTOTYPE4_FEM::ADC_DATA_MASK);
      }
    }
  }

  // EMCAL
  RawTower_Prototype4 *tower = nullptr;
  assert(emcal_towers);
  for (int ibinz = 0; ibinz < PROTOTYPE4_FEM::NCH_EMCAL_ROWS; ibinz++)
  {
    for (int ibinphi = 0; ibinphi < PROTOTYPE4_FEM::NCH_EMCAL_COLUMNS;
         ibinphi++)
    {
      tower = dynamic_cast<RawTower_Prototype4 *>(
          emcal_towers->getTower(ibinz, ibinphi));
      if (!tower)
      {
        tower = new RawTower_Prototype4();
        tower->set_energy(NAN);
        emcal_towers->AddTower(ibinz, ibinphi, tower);
      }

      int ich = PROTOTYPE4_FEM::GetChannelNumber("EMCAL", ibinz, ibinphi);
      tower->set_HBD_channel_number(ich);
      for (int isamp = 0; isamp < PROTOTYPE4_FEM::NSAMPLES; isamp++)
      {
        tower->set_signal_samples(isamp, _packet->iValue(isamp, ich) &
                                             PROTOTYPE4_FEM::ADC_DATA_MASK);
      }
    }
  }

  if (Verbosity())
  {
    cout << "HCALIN Towers: " << endl;
    hcalin_towers_hg->identify();
    RawTowerContainer::ConstRange begin_end = hcalin_towers_lg->getTowers();
    RawTowerContainer::ConstIterator iter;
    for (iter = begin_end.first; iter != begin_end.second; ++iter)
    {
      RawTower_Prototype4 *tower =
          dynamic_cast<RawTower_Prototype4 *>(iter->second);
      tower->identify();
      cout << "Signal Samples: [" << endl;
      for (int isamp = 0; isamp < PROTOTYPE4_FEM::NSAMPLES; isamp++)
      {
        cout << tower->get_signal_samples(isamp) << ", ";
      }
      cout << " ]" << endl;
    }
  }
  delete _packet;
  return Fun4AllReturnCodes::EVENT_OK;
}

//_______________________________________
void CaloUnpackPRDF::CreateNodeTree(PHCompositeNode *topNode)
{
  PHNodeIterator nodeItr(topNode);
  // DST node
  dst_node = static_cast<PHCompositeNode *>(
      nodeItr.findFirst("PHCompositeNode", "DST"));
  if (!dst_node)
  {
    cout << "PHComposite node created: DST" << endl;
    dst_node = new PHCompositeNode("DST");
    topNode->addNode(dst_node);
  }

  // DATA nodes
  data_node = static_cast<PHCompositeNode *>(
      nodeItr.findFirst("PHCompositeNode", "RAW_DATA"));
  if (!data_node)
  {
    if (Verbosity())
      cout << "PHComposite node created: RAW_DATA" << endl;
    data_node = new PHCompositeNode("RAW_DATA");
    dst_node->addNode(data_node);
  }

  // HCAL Towers
  hcalin_towers_lg = new RawTowerContainer(RawTowerDefs::HCALIN);
  PHIODataNode<PHObject> *tower_node = new PHIODataNode<PHObject>(
      hcalin_towers_lg, "TOWER_RAW_LG_HCALIN", "PHObject");
  data_node->addNode(tower_node);
  hcalin_towers_hg = new RawTowerContainer(RawTowerDefs::HCALIN);
  tower_node = new PHIODataNode<PHObject>(hcalin_towers_hg,
                                          "TOWER_RAW_HG_HCALIN", "PHObject");
  data_node->addNode(tower_node);

  hcalout_towers_lg = new RawTowerContainer(RawTowerDefs::HCALOUT);
  tower_node = new PHIODataNode<PHObject>(hcalout_towers_lg,
                                          "TOWER_RAW_LG_HCALOUT", "PHObject");
  data_node->addNode(tower_node);
  hcalout_towers_hg = new RawTowerContainer(RawTowerDefs::HCALOUT);
  tower_node = new PHIODataNode<PHObject>(hcalout_towers_hg,
                                          "TOWER_RAW_HG_HCALOUT", "PHObject");
  data_node->addNode(tower_node);

  // EMCAL towers
  emcal_towers = new RawTowerContainer(RawTowerDefs::CEMC);
  PHIODataNode<PHObject> *emcal_towerNode =
      new PHIODataNode<PHObject>(emcal_towers, "TOWER_RAW_CEMC", "PHObject");
  data_node->addNode(emcal_towerNode);
}