EveWorkflowHelper.h

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
 
 
#ifndef ALICE_O2_EVENTVISUALISATION_WORKFLOW_EVEWORKFLOWHELPER_H
#define ALICE_O2_EVENTVISUALISATION_WORKFLOW_EVEWORKFLOWHELPER_H
 
#include "ReconstructionDataFormats/GlobalTrackID.h"
#include "ReconstructionDataFormats/TrackFwd.h"
#include "Framework/DataProcessingHeader.h"
#include "DataFormatsTRD/TrackTRD.h"
#include "DataFormatsGlobalTracking/RecoContainer.h"
#include "DataFormatsITSMFT/ClustersPerLayer.h"
#include "EveWorkflow/EveConfiguration.h"
#include "EventVisualisationDataConverter/VisualisationEvent.h"
#include "MFTBase/GeometryTGeo.h"
#include "MIDBase/GeometryParameters.h"
#include "MCHTracking/TrackParam.h"
#include "ITSBase/GeometryTGeo.h"
#include "TPCFastTransform.h"
#include "TPCReconstruction/TPCFastTransformHelperO2.h"
#include "DataFormatsTPC/VDriftCorrFact.h"
#include "Framework/AnalysisDataModel.h"
#include "DetectorsVertexing/PVertexerParams.h"
 
namespace o2::itsmft
{
class TopologyDictionary;
}
 
namespace o2::mft
{
class GeometryTGeo;
}
 
namespace o2::its
{
class GeometryTGeo;
}
 
namespace o2::phos
{
class Geometry;
}
 
namespace o2::emcal
{
class Geometry;
class CellRecalibrator;
} // namespace o2::emcal
 
namespace o2::event_visualisation
{
using GID = o2::dataformats::GlobalTrackID;
using PNT = std::array<float, 3>;
 
struct TracksSet {
  std::vector<GID> trackGID;
  std::vector<float> trackTime;
};
 
class EveWorkflowHelper
{
  struct PropagationRange {
    float minR;
    float maxR;
    float minZ;
    float maxZ;
  };
 
  static constexpr EveWorkflowHelper::PropagationRange prITS = {1.f, 40.f, -74.f, 74.f};
  static constexpr EveWorkflowHelper::PropagationRange prTPC = {85.f, 240.f, -260.f, 260.f};
  static constexpr EveWorkflowHelper::PropagationRange prTRD = {-1.f, 372.f, -375.f, 375.f};
  static constexpr EveWorkflowHelper::PropagationRange prTOF = {-1.f, 405.f, -375.f, 375.f};
 
  static const std::unordered_map<GID::Source, PropagationRange> propagationRanges;
 
  std::unique_ptr<gpu::TPCFastTransform> mTPCFastTransform;
 
  static constexpr int TIME_OFFSET = 23000; // max TF time
  static constexpr int MAXBCDiffErrCount = 5;
 
  static constexpr std::array<const double, 4> mftZPositions = {-40., -45., -65., -85.};
 
  static constexpr std::array<const double, 20> mchZPositions = {
    -526.1599731445312,
    -526.1599731445312,
    -545.239990234375,
    -545.239990234375,
    -676.4,
    -676.4,
    -695.4,
    -695.4,
    -959.75,
    -975.25,
    -990.75,
    -1006.25,
    -1259.75,
    -1284.25,
    -1299.75,
    -1315.25,
    -1398.85,
    -1414.35,
    -1429.85,
    -1445.35};
 
  static constexpr std::array<const double, 4> midZPositions = o2::mid::geoparams::DefaultChamberZ;
 
 public:
  using AODBarrelTracks = soa::Join<aod::Tracks, aod::TracksExtra>;
  using AODBarrelTrack = AODBarrelTracks::iterator;
 
  using AODForwardTracks = aod::FwdTracks;
  using AODForwardTrack = AODForwardTracks::iterator;
 
  using AODMFTTracks = aod::MFTTracks;
  using AODMFTTrack = AODMFTTracks::iterator;
  using Bracket = o2::math_utils::Bracketf_t;
 
  EveWorkflowHelper();
  static std::vector<PNT> getTrackPoints(const o2::track::TrackPar& trc, float minR, float maxR, float maxStep, float minZ = -25000, float maxZ = 25000);
  void setTPCVDrift(const o2::tpc::VDriftCorrFact* v);
  void selectTracks(const CalibObjectsConst* calib, GID::mask_t maskCl, GID::mask_t maskTrk, GID::mask_t maskMatch);
  void selectTowers();
  void setITSROFs();
  void addTrackToEvent(const o2::track::TrackPar& tr, GID gid, float trackTime, float dz, GID::Source source = GID::NSources, float maxStep = 4.f);
  void draw(std::size_t primaryVertexIdx, bool sortTracks);
  void drawTPC(GID gid, float trackTime, float dz = 0.f);
  void drawITS(GID gid, float trackTime);
  void drawMFT(GID gid, float trackTime);
  void drawMCH(GID gid, float trackTime);
  void drawMID(GID gid, float trackTime);
  void drawMFTMCH(GID gid, float trackTime);
  void drawITSTPC(GID gid, float trackTime, GID::Source source = GID::ITSTPC);
  void drawITSTPCTOF(GID gid, float trackTime, GID::Source source = GID::ITSTPCTOF);
  void drawITSTPCTRD(GID gid, float trackTime, GID::Source source = GID::ITSTPCTRD);
  void drawITSTPCTRDTOF(GID gid, float trackTime);
  void drawTPCTRDTOF(GID gid, float trackTime);
  void drawMFTMCHMID(GID gid, float trackTime);
  void drawTPCTRD(GID gid, float trackTime, GID::Source source = GID::TPCTRD);
  void drawTPCTOF(GID gid, float trackTime);
  void drawMCHMID(GID gid, float trackTime);
  void drawPHS(GID gid);
  void drawEMC(GID gid);
  void drawHMP(GID gid);
 
  void drawAODBarrel(AODBarrelTrack const& track, float trackTime);
  void drawAODMFT(AODMFTTrack const& track, float trackTime);
  void drawAODFwd(AODForwardTrack const& track, float trackTime);
 
  void drawMFTTrack(GID gid, o2::track::TrackParFwd track, float trackTime);
  void drawForwardTrack(GID gid, mch::TrackParam track, float startZ, float endZ, float trackTime);
  void drawITSClusters(GID gid);
  void drawTPCClusters(GID gid, float trackTimeTB = -2.e9); // if trackTimeTB<-1.e9, then use tpcTrack.getTime0()
  void drawMFTClusters(GID gid);
  void drawMCHClusters(GID gid);
  void drawMIDClusters(GID gid);
  void drawTRDClusters(const o2::trd::TrackTRD& trc);
  void drawTOFClusters(GID gid);
  void drawPoint(const float xyz[]) { mEvent.addCluster(xyz); }
  void drawGlobalPoint(const TVector3& xyx, GID gid, float time) { mEvent.addGlobalCluster(xyx, gid, time); }
  void prepareITSClusters(const o2::itsmft::TopologyDictionary* dict); // fills mITSClustersArray
  void prepareMFTClusters(const o2::itsmft::TopologyDictionary* dict); // fills mMFTClustersArray
  void clear() { mEvent.clear(); }
 
  GID::Source detectorMapToGIDSource(uint8_t dm);
  o2::mch::TrackParam forwardTrackToMCHTrack(const o2::track::TrackParFwd& track);
  float findLastMIDClusterPosition(const o2::mid::Track& track);
  float findLastMCHClusterPosition(const o2::mch::TrackMCH& track);
  double bcDiffToTFTimeMUS(const o2::InteractionRecord& ir);
  bool isInsideITSROF(const Bracket& br);
  bool isInsideTimeBracket(const Bracket& br);
  bool isInsideITSROF(float t);
  bool isInsideTimeBracket(float t);
 
  void save(const std::string& jsonPath, const std::string& ext, int numberOfFiles, const std::string& receiverHostname, int receiverPort, int receiverTimeout, bool useOnlyFiles, bool useOnlySockets);
 
  bool mUseTimeBracket = false;
  bool mUseEtaBracketTPC = false;
  Bracket mTimeBracket{};
  Bracket mEtaBracketTPC;
  const o2::globaltracking::RecoContainer* mRecoCont = nullptr;
  const o2::globaltracking::RecoContainer* getRecoContainer() const { return mRecoCont; }
  void setRecoContainer(const o2::globaltracking::RecoContainer* rc) { mRecoCont = rc; }
  void setEMCALCellRecalibrator(o2::emcal::CellRecalibrator* calibrator) { mEMCALCalib = calibrator; }
  TracksSet mTrackSet;
  o2::event_visualisation::VisualisationEvent mEvent;
  std::unordered_map<GID, std::size_t> mTotalDataTypes;
  std::unordered_set<GID> mTotalAcceptedDataTypes;
  std::unordered_map<std::size_t, std::vector<GID>> mPrimaryVertexTrackGIDs;
  std::unordered_map<std::size_t, std::vector<GID>> mPrimaryVertexTriggerGIDs;
  std::unordered_map<GID, unsigned int> mGIDTrackTime;
  std::vector<Bracket> mItsROFBrackets;
  o2::itsmft::ClustersPerLayer<o2::BaseCluster<float>> mITSClustersArray; // addressed by the composed (layer,index) ID
  std::vector<o2::BaseCluster<float>> mMFTClustersArray;
  o2::mft::GeometryTGeo* mMFTGeom;
  o2::its::GeometryTGeo* mITSGeom;
  o2::phos::Geometry* mPHOSGeom;
  o2::emcal::Geometry* mEMCALGeom;
  o2::emcal::CellRecalibrator* mEMCALCalib = nullptr;
  const o2::tpc::VDriftCorrFact* mTPCVDrift = nullptr;
  float mMUS2TPCTimeBins = 5.0098627f;
  float mTPCTimeBins2MUS = 0.199606f;
  float mITSROFrameLengthMUS = 0; 
  float mMFTROFrameLengthMUS = 0; 
  float mTPCBin2MUS = 0;
  static int BCDiffErrCount;
  const o2::vertexing::PVertexerParams* mPVParams = nullptr;
};
} // namespace o2::event_visualisation
 
#endif // ALICE_O2_EVENTVISUALISATION_WORKFLOW_EVEWORKFLOWHELPER_H