PpmByteStreamV1Tool.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2020 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef TRIGT1CALOBYTESTREAM_PPMBYTESTREAMV1TOOL_H
#define TRIGT1CALOBYTESTREAM_PPMBYTESTREAMV1TOOL_H
 
#include <stdint.h>
 
#include <map>
#include <string>
#include <vector>
#include <atomic>
#include <mutex>
 
#include "L1CaloSrcIdMap.h"
#include "PpmSubBlockV1.h"
#include "AthenaBaseComps/AthAlgTool.h"
#include "ByteStreamCnvSvcBase/IROBDataProviderSvc.h"
#include "ByteStreamData/RawEvent.h"
#include "TrigT1CaloUtils/TriggerTowerKey.h"
#include "AthContainers/DataVector.h"
#include "AthenaKernel/SlotSpecificObj.h"
#include "eformat/SourceIdentifier.h"
#include "GaudiKernel/ServiceHandle.h"
#include "GaudiKernel/ToolHandle.h"
#include "CxxUtils/checker_macros.h"
 
class IInterface;
class InterfaceID;
class StatusCode;
class SegMemSvc;
 
template <class T> class FullEventAssembler;
 
namespace LVL1 {
  class IL1CaloMappingTool;
  class TriggerTower;
  class TriggerTowerKey;
}
 
namespace LVL1BS {
 
class L1CaloErrorByteStreamTool;
class L1CaloSrcIdMap;
class PpmSubBlockV1;

 
class PpmByteStreamV1Tool : public AthAlgTool {
 
 public:
   PpmByteStreamV1Tool(const std::string& type, const std::string& name,
                     const IInterface* parent);
   virtual ~PpmByteStreamV1Tool();

   static const InterfaceID& interfaceID();
 
   virtual StatusCode initialize() override;
   virtual StatusCode finalize() override;

   StatusCode convert(const std::string& sgKey,
                      const IROBDataProviderSvc::VROBFRAG& robFrags,
                      DataVector<LVL1::TriggerTower>* ttCollection) const;

   StatusCode convert(const DataVector<LVL1::TriggerTower>* ttCollection,
                      RawEventWrite* re) const;

   const std::vector<uint32_t>& sourceIDs(const std::string& sgKey) const;
 
 private:
 
   typedef DataVector<LVL1::TriggerTower>                TriggerTowerCollection;
   typedef std::vector<LVL1::TriggerTower*>              TriggerTowerVector;
   typedef std::map<unsigned int, int>                   TriggerTowerMap;
   typedef std::map<unsigned int, const LVL1::TriggerTower*>
                                                         TriggerTowerMapConst;
   typedef std::vector<uint32_t>                         ChannelBitVector;
   typedef IROBDataProviderSvc::VROBFRAG::const_iterator ROBIterator;
   typedef OFFLINE_FRAGMENTS_NAMESPACE::PointerType      ROBPointer;
   typedef OFFLINE_FRAGMENTS_NAMESPACE::PointerType      RODPointer;

   void addCompStats(const std::vector<uint32_t>& stats) const;
   void printCompStats() const;

   const LVL1::TriggerTower* findLayerTriggerTower(double eta, double phi,
                                                   int layer,
                                                   const TriggerTowerMapConst& ttEmMap,
                                                   const TriggerTowerMapConst& ttHadMap,
                                                   LVL1::TriggerTowerKey& towerKey) const;
   void setupTTMaps(const TriggerTowerCollection* ttCollection,
                    TriggerTowerMapConst& ttEmMap,
                    TriggerTowerMapConst& ttHadMap,
                    LVL1::TriggerTowerKey& towerKey) const;

   bool slinkSlices(int crate, int module, int modulesPerSlink,
        int& slicesLut, int& slicesFadc, int& trigLut, int& trigFadc,
        const TriggerTowerMapConst& ttEmMap,
        const TriggerTowerMapConst& ttHadMap,
        LVL1::TriggerTowerKey& towerKey) const;
 
   std::vector<uint32_t>
   makeSourceIDs (bool spareChannels, bool muonChannels) const;

   void printVec(const std::vector<int>& vec) const;
 
   struct SlotData
   {
     std::mutex m_mutex;
     TriggerTowerVector m_ttData;
     TriggerTowerVector m_ttSpare;
     TriggerTowerVector m_ttMuon;
     std::vector<int> m_ttPos;
     ChannelBitVector m_chanLayer;
     ChannelBitVector m_dataChan;
     ChannelBitVector m_spareChan;
     ChannelBitVector m_muonChan;
     ChannelBitVector m_dataMod;
     ChannelBitVector m_spareMod;
     ChannelBitVector m_muonMod;
     ChannelBitVector m_foundChan;
     DataVector<PpmSubBlockV1> m_ppmBlocks;
     PpmSubBlockV1 m_errorBlock;
     LVL1::TriggerTowerKey m_towerKey;
   };
   mutable SG::SlotSpecificObj<SlotData> m_slotData ATLAS_THREAD_SAFE;
 

   ToolHandle<LVL1::IL1CaloMappingTool> m_ppmMaps;
   ToolHandle<LVL1BS::L1CaloErrorByteStreamTool> m_errorTool;
   ServiceHandle<SegMemSvc> m_sms;

   const int m_version;
   int m_dataFormat;
   const int m_compVers;
   int m_printCompStats;
   int m_slinks;
   int m_dfltSlicesLut;
   int m_dfltSlicesFadc;
   int m_forceSlicesLut;
   int m_forceSlicesFadc;
   int m_crateMin;
   int m_crateMax;
   int m_pedestal;
   int m_fadcBaseline;
   int m_fadcThreshold;
   int m_zeroSuppress;
   std::vector<uint32_t> m_sourceIDsProp;
   const eformat::SubDetector m_subDetector;
   const L1CaloSrcIdMap m_srcIdMap;
   static constexpr unsigned int MAXFORMATS = 10;
   std::atomic<uint32_t> m_compStats[MAXFORMATS];
 
   static const int s_crates   = 8;
   static const int s_modules  = 16;
   static const int s_channels = 64;
   static const int s_dataSize = 3584;
 
};
 
} // end namespace
 
#endif